YiWuProject.git

File was renamed from UnLoadGlassModule/src/main/java/com/mes/tools/WebSocketServer.java
			@@ -1,4 +1,4 @@
			package com.mes.tools;
			package com.mes.common;

			import cn.hutool.json.JSONObject;
			import cn.hutool.json.JSONUtil;
			@@ -19,8 +19,6 @@
			@Component("webSocketServer")
			public class WebSocketServer {

			// @Autowired
			// HomeMapper homeMapper;

			public static ConfigurableApplicationContext applicationContext;

			@@ -59,7 +57,7 @@
			} else {
			webSocketServers.add(this);
			}


			log.info("有新用户加入，username={}, 当前在线人数为：{}", username, sessionMap.get(username).size());

			// JSONObject result = new JSONObject();
			@@ -81,19 +79,19 @@
			public void onClose(Session session, @PathParam("username") String username) {
			List<WebSocketServer> webSocketServers = sessionMap.get(username);
			ArrayList<WebSocketServer> arrayListwebserver = new ArrayList<WebSocketServer>();
			if (webSocketServers.size()>1) {
			if (webSocketServers.size() > 1) {
			for (WebSocketServer webSocketServer : webSocketServers) {
			if(webSocketServer!=this){
			if (webSocketServer != this) {
			arrayListwebserver.add(webSocketServer);
			}
			}
			sessionMap.put(username, arrayListwebserver);
			log.info("移除username={}一名用户session, {}的当前在线人数为：{}", username, username, sessionMap.get(username).size());
			}else{
			} else {
			sessionMap.remove(username);
			log.info("移除username={}一名用户session, {}连接关闭, 当前连接数为：{}", username, username, sessionMap.size());
			}


			}

			/**
			@@ -101,7 +99,7 @@
			* 后台收到客户端发送过来的消息
			* onMessage 是一个消息的中转站
			* 接受浏览器端 socket.send 发送过来的 json数据
			*
			*
			* @param message 客户端发送过来的消息
			*/
			@OnMessage
			@@ -157,8 +155,6 @@
			public void clearMessages() {
			messages.clear();
			}




			}