|
@@ -79,6 +79,10 @@ public class WebsocketEndPoint extends TextWebSocketHandler {
|
|
|
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
|
|
|
String msg = message.getPayload().toString();
|
|
|
String projectId = this.getProjectId(session);
|
|
|
+ WebSocketSession sessionk = userMap.get(projectId);
|
|
|
+ if(sessionk == null || !session.isOpen()){
|
|
|
+ userMap.put(projectId, session);
|
|
|
+ }
|
|
|
System.err.println("该" + projectId + "用户发送的消息是:" + msg);
|
|
|
message = new TextMessage("服务端已经接收到消息,msg=" + msg);
|
|
|
session.sendMessage(message);
|