|
|
@ -126,6 +126,7 @@ public class MessageWebSocket {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
MessageWebSocket websocket = webSocketMap.get(userLoginSid);
|
|
|
|
MessageWebSocket websocket = webSocketMap.get(userLoginSid);
|
|
|
|
if (websocket != null && websocket.session.isOpen()) {
|
|
|
|
if (websocket != null && websocket.session.isOpen()) {
|
|
|
|
|
|
|
|
synchronized (websocket.session) {
|
|
|
|
if (message.equals("heartBit")) {
|
|
|
|
if (message.equals("heartBit")) {
|
|
|
|
websocket.session.getBasicRemote().sendText(message + "=" + sendCount);
|
|
|
|
websocket.session.getBasicRemote().sendText(message + "=" + sendCount);
|
|
|
|
sendCount++;
|
|
|
|
sendCount++;
|
|
|
@ -133,6 +134,7 @@ public class MessageWebSocket {
|
|
|
|
websocket.session.getBasicRemote().sendText(message);
|
|
|
|
websocket.session.getBasicRemote().sendText(message);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
} catch (IOException e) {
|
|
|
|
} catch (IOException e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
e.printStackTrace();
|
|
|
|
}
|
|
|
|
}
|
|
|
|