springWebsocket的简单例子

package com.gxuwz.websocket.handler; import java.io.IOException; import java.util.ArrayList; import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.WebSocketMessage; import org.springframework.web.socket.WebSocketSession; public class SystemWebSocketHandler implements WebSocketHandler { private static final ArrayList<WebSocketSession> users = new ArrayList<WebSocketSession>();; public void afterConnectionEstablished(WebSocketSession session) throws Exception { users.add(session); System.err.println("新增的请求IP："+session.getRemoteAddress()); System.err.println("当前人数"+users.size()); } public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception { sendMessageToUsers(message); } public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception { if(session.isOpen()){ session.close(); } users.remove(session); } public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception { System.err.println(session.getId()+"离开了哦"); users.remove(session); } public boolean supportsPartialMessages() { return false; } public void sendMessageToUsers(WebSocketMessage<?> message) { for (WebSocketSession user : users) { try { if (user.isOpen()) { user.sendMessage(message); } } catch (IOException e) { e.printStackTrace(); } } } }