package com.casic.missiles.common; import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import javax.websocket.OnClose; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.CopyOnWriteArraySet; /** * 此注解相当于设置访问URL */ @Component @ServerEndpoint("/websocket/{userId}") @Slf4j public class WebSocket { private Session session; private static CopyOnWriteArraySet<WebSocket> webSockets = new CopyOnWriteArraySet<>(); private static Map<String, Session> sessionPool = new HashMap<String, Session>(); @OnOpen public void onOpen(Session session, @PathParam(value = "userId") String userId) { this.session = session; webSockets.add(this); sessionPool.put(userId, session); log.info(userId + "【websocket消息】有新的连接,总数为:" + webSockets.size()); } @OnClose public void onClose() { webSockets.remove(this); log.info("【websocket消息】连接断开,总数为:" + webSockets.size()); } @OnMessage public void onMessage(String message) { log.info("【websocket消息】收到客户端消息:" + message); } // 此为广播消息 public void sendAllMessage(String message) { for (WebSocket webSocket : webSockets) { // System.out.println("【websocket消息】广播消息:"+message); try { synchronized (webSocket.session) { webSocket.session.getBasicRemote().sendText(message); // webSocket.session.getAsyncRemote().sendText(message); } } catch (Exception e) { e.printStackTrace(); } } } /** * 发送列表消息 * * @param userIds 用户集合 * @param message 消息体 */ public void sendListMessage(List<String> userIds, String message) { log.info("【websocket消息】列表消息:" + message); for (String userId : userIds) { Session session = sessionPool.get(userId); if (session != null) { try { session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } } /** * 单点消息 * * @param userId 用户信息 * @param message 消息体 */ public void sendOneMessage(String userId, String message) { log.info("【websocket消息】单点消息:" + message); Session session = sessionPool.get(userId); if (session != null) { try { // session.getAsyncRemote().sendObject(JSON.parseObject(message)); session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } /** * 单点消息 * * @param userId 用户信息 * @param obj 消息体 */ public void sendOneObjMessage(String userId, Object obj) { log.info("【websocket消息】单点消息:" + obj); Session session = sessionPool.get(userId); if (session != null) { try { session.getAsyncRemote().sendObject(obj); } catch (Exception e) { e.printStackTrace(); } } } }