| | |
|---|
| | | } else { |
|---|
| | | webSocketServers.add(this); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | log.info("有新用户加入，username={}, 当前在线人数为：{}", username, sessionMap.get(username).size()); |
|---|
| | | |
|---|
| | | // JSONObject result = new JSONObject(); |
|---|
| | |
|---|
| | | 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()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | * 后台收到客户端发送过来的消息 |
|---|
| | | * onMessage 是一个消息的中转站 |
|---|
| | | * 接受 浏览器端 socket.send 发送过来的 json数据 |
|---|
| | | * |
|---|
| | | * |
|---|
| | | * @param message 客户端发送过来的消息 |
|---|
| | | */ |
|---|
| | | @OnMessage |
|---|
| | |
|---|
| | | public void clearMessages() { |
|---|
| | | messages.clear(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
