package com.ruoyi.utils.websocket.service; import com.alibaba.fastjson2.JSONObject; import com.ruoyi.app.position.service.impl.AppPositionPushService; import com.ruoyi.call.dto.CallMessage; import com.ruoyi.utils.websocket.util.WebSocketUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import javax.websocket.*; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS; /** * @ClassName ChatServerEndpoint * @Description: websocket操作类 * @Author 刘苏义 * @Date 2023/1/27 7:42 * @Version 1.0 */ @Component @Slf4j(topic = "websocket") @ServerEndpoint("/websocket/{userId}") public class ChatServerEndpoint { @OnOpen public void openSession(@PathParam("userId") String userId, Session session) { WebSocketUtils.ONLINE_USER_SESSIONS.put(userId, session); String message = "用户[" + userId + "] 成功连接!"; log.info("用户登录:" + message); WebSocketUtils.sendMessage(session, message); } @OnMessage public void onMessage(@PathParam("userId") String userId, String message) { log.info("收到消息:" + message); // Session session = WebSocketUtils.ONLINE_USER_SESSIONS.get(userId); // WebSocketUtils.sendMessage(session, message); Map messageMap = JSONObject.parseObject(message, Map.class); if (((String) messageMap.get("type")).equals("callMessage")) { String msg = (String) messageMap.get("message"); CallMessage callMessage = JSONObject.parseObject(msg, CallMessage.class); if (callMessage != null && callMessage.getType().equals(0)) { String regex = "^" + Pattern.quote(callMessage.getTargetId()) + "_\\d+$"; Pattern pattern = Pattern.compile(regex); ONLINE_USER_SESSIONS.entrySet().stream() .filter(entry -> { Matcher matcher = pattern.matcher(entry.getKey()); return matcher.matches(); }) .map(Map.Entry::getValue) .forEach(session -> WebSocketUtils.sendMessage(session, message)); } } // 根据用户新的频率重新调整定时任务 AppPositionPushService.messageHandler(userId, message); } @OnClose public void onClose(@PathParam("userId") String userId, Session session) { //当前的Session 移除 WebSocketUtils.ONLINE_USER_SESSIONS.remove(userId); //并且通知其他人当前用户已经离开聊天室了 String message = "用户[" + userId + "] 断开连接!"; //sendMessage(session,message); log.info("消息:" + message); try { session.close(); AppPositionPushService.stopHandler(userId); } catch (IOException e) { log.error("onClose error", e); } } @OnError public void onError(Session session, Throwable throwable) { try { session.close(); } catch (IOException e) { log.error("onError excepiton", e); } log.info("Throwable msg " + throwable.getMessage()); } }