wms / wms4_shandongtaikai · Commits

Commit c16aca8c4330875d8dd1500ec37bc8770f1962f6

Authored by 谭毅彬
1 parent 80aa81b9

websocket消息错误简化 

Signed-off-by: TanYibin <5491541@qq.com>
Inline Side-by-side
Showing 1 changed file with 16 additions and 0 deletions
huaheng-wms-core/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java
  View file @c16aca8
... ... @@ -6,6 +6,7 @@ import java.util.concurrent.CopyOnWriteArraySet;
6 6  
7 7 import javax.annotation.Resource;
8 8 import javax.websocket.OnClose;
  9 +import javax.websocket.OnError;
9 10 import javax.websocket.OnMessage;
10 11 import javax.websocket.OnOpen;
11 12 import javax.websocket.Session;
... ... @@ -44,6 +45,7 @@ public class WebSocket {
44 45 * 缓存 webSocket连接到单机服务class中（整体方案支持集群）
45 46 */
46 47 private static CopyOnWriteArraySet<WebSocket> webSockets = new CopyOnWriteArraySet<>();
  48 +
47 49 private static Map<String, Session> sessionPool = new HashMap<String, Session>();
48 50  
49 51 @OnOpen
... ... @@ -69,6 +71,20 @@ public class WebSocket {
69 71 }
70 72  
71 73 /**
  74 + * 配置错误信息处理
  75 + * @param session
  76 + * @param t
  77 + */
  78 + @OnError
  79 + public void onError(Session session, Throwable t) {
  80 + // 什么都不想打印都去掉就好了
  81 + log.error("【websocket消息】出现未知错误，errorMessage:{} ", t.getMessage());
  82 + // 打印错误信息，如果你不想打印错误信息，去掉就好了
  83 + // 这里打印的也是 java.io.EOFException: null
  84 +// t.printStackTrace();
  85 + }
  86 +
  87 + /**
72 88 * 服务端推送消息
73 89 * @param userId
74 90 * @param message
... ...