spring4 websocket聊天室 Handler方式

package com.exception.core.web.handler; import com.fasterxml.jackson.databind.util.BeanUtil; import com.fasterxml.jackson.databind.util.JSONPObject; import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.handler.TextWebSocketHandler; import sun.org.mozilla.javascript.internal.json.JsonParser; import java.util.HashMap; import java.util.Hashtable; import java.util.Map; public class RoomHandler extends TextWebSocketHandler { private Map<String, WebSocketSession> userMap = new Hashtable<>(); @Override public void afterConnectionEstablished(WebSocketSession session) throws Exception { userMap.put(session.getId(), session); super.afterConnectionEstablished(session); } @Override public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception { super.handleTransportError(session, exception); } @Override public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception { userMap.remove(session); super.afterConnectionClosed(session, status); } @Override protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { for (WebSocketSession webSocketSession : userMap.values()) { if (webSocketSession.isOpen()) { webSocketSession.sendMessage(message); } } super.handleTextMessage(session, message); } }