Commit 035f6baf authored by duanruiming's avatar duanruiming

[update] 优化代码7,优化程序中告警异常

parent c1a64e06
...@@ -47,7 +47,7 @@ public class RealTimeDataWebSocket { ...@@ -47,7 +47,7 @@ public class RealTimeDataWebSocket {
public void onOpen(Session session, @PathParam("crossId") String crossId) { public void onOpen(Session session, @PathParam("crossId") String crossId) {
this.session = session; this.session = session;
this.crossId = crossId; this.crossId = crossId;
// TODO evenWarnWebSocketMap中的key为crossId 如果多个用户使用同一个crossId登录 一个用户退出代表所有公用该接口的用户都退出了,需要将key改为sessionid // TODO evenWarnWebSocketMap中的key为crossId 如果多个用户使用同一个crossId登录 一个用户退出代表所有公用该接口的用户都退出了,需要将key改为sessionId
if (evenWarnWebSocketMap.containsKey(crossId)) { if (evenWarnWebSocketMap.containsKey(crossId)) {
evenWarnWebSocketMap.remove(crossId); evenWarnWebSocketMap.remove(crossId);
evenWarnWebSocketMap.put(crossId, this); evenWarnWebSocketMap.put(crossId, this);
...@@ -94,8 +94,8 @@ public class RealTimeDataWebSocket { ...@@ -94,8 +94,8 @@ public class RealTimeDataWebSocket {
//解析发送的报文 //解析发送的报文
JSONObject jsonObject = JSON.parseObject(message); JSONObject jsonObject = JSON.parseObject(message);
//追加发送人(防止串改) //追加发送人(防止串改)
jsonObject.put("fromcrossId", this.crossId); jsonObject.put("fromCrossId", this.crossId);
String toCrossId = jsonObject.getString("tocrossId"); String toCrossId = jsonObject.getString("toCrossId");
// 传送给对应toCrossId用户的websocket // 传送给对应toCrossId用户的websocket
if (StringUtils.isNotBlank(toCrossId) && evenWarnWebSocketMap.containsKey(toCrossId)) { if (StringUtils.isNotBlank(toCrossId) && evenWarnWebSocketMap.containsKey(toCrossId)) {
evenWarnWebSocketMap.get(toCrossId).sendMessage(jsonObject.toJSONString()); evenWarnWebSocketMap.get(toCrossId).sendMessage(jsonObject.toJSONString());
......
...@@ -13,6 +13,7 @@ import javax.websocket.*; ...@@ -13,6 +13,7 @@ import javax.websocket.*;
@ClientEndpoint @ClientEndpoint
@Component @Component
@Slf4j @Slf4j
@SuppressWarnings("unused")
public class WebSocketClientHandler { public class WebSocketClientHandler {
@OnOpen @OnOpen
public void onOpen(Session session) { public void onOpen(Session session) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment