package com.skua.modules.websocket; import com.alibaba.fastjson.JSONObject; import com.skua.modules.system.enums.SysUserLoginStateEnums; 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; @Component @Slf4j @ServerEndpoint("/websocket/{userId}") //此注解相当于设置访问URL 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) { try { this.session = session; webSockets.add(this); sessionPool.put(userId, session); log.info("【websocket消息】有新的连接,总数为:"+webSockets.size()); } catch (Exception e) { } } @OnClose public void onClose() { try { webSockets.remove(this); log.info("【websocket消息】连接断开,总数为:"+webSockets.size()); } catch (Exception e) { } } @OnMessage public void onMessage(String message) { //log.info("【websocket消息】收到客户端消息:"+message); JSONObject obj = new JSONObject(); obj.put("cmd", "heartcheck");//业务类型 obj.put("msgTxt", "心跳响应");//消息内容 session.getAsyncRemote().sendText(obj.toJSONString()); } // 此为广播消息 public void sendAllMessage(String message) { log.info("【websocket消息】广播消息:"+message); for(WebSocket webSocket : webSockets) { try { if(webSocket.session.isOpen()) { webSocket.session.getAsyncRemote().sendText(message); } } catch (Exception e) { e.printStackTrace(); } } } // 此为单点消息(多人) public void sendAllMessageByDepartIds(List<String> userIds,String message) { for(String userId:userIds) { Session session = sessionPool.get(userId); if (session != null&&session.isOpen()) { try { log.info("【websocket消息】 单点消息:"+message); session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } } // 此为单点消息 public void sendOneMessage(String userId, String message) { Session session = sessionPool.get(userId); if (session != null&&session.isOpen()) { try { log.info("【websocket消息】 单点消息:"+message); session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } // 此为单点消息(多人) public void sendMoreMessage(String[] userIds, String message) { for(String userId:userIds) { Session session = sessionPool.get(userId); if (session != null&&session.isOpen()) { try { log.info("【websocket消息】 单点消息:"+message); session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } } /** * 获取用户状态(在线?离线) * @param userId * @return */ public SysUserLoginStateEnums getLoginState(String userId){ return sessionPool.containsKey(userId) && sessionPool.get(userId).isOpen()? SysUserLoginStateEnums.ON_LINE : SysUserLoginStateEnums.OFF_LINE; } }