diff --git a/huaheng-wms-core/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java b/huaheng-wms-core/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java index 96091e6..0c69910 100644 --- a/huaheng-wms-core/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java +++ b/huaheng-wms-core/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java @@ -6,6 +6,7 @@ import java.util.concurrent.CopyOnWriteArraySet; import javax.annotation.Resource; import javax.websocket.OnClose; +import javax.websocket.OnError; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; @@ -44,6 +45,7 @@ public class WebSocket { * 缓存 webSocket连接到单机服务class中(整体方案支持集群) */ private static CopyOnWriteArraySet<WebSocket> webSockets = new CopyOnWriteArraySet<>(); + private static Map<String, Session> sessionPool = new HashMap<String, Session>(); @OnOpen @@ -69,6 +71,20 @@ public class WebSocket { } /** + * 配置错误信息处理 + * @param session + * @param t + */ + @OnError + public void onError(Session session, Throwable t) { + // 什么都不想打印都去掉就好了 + log.error("【websocket消息】出现未知错误,errorMessage:{} ", t.getMessage()); + // 打印错误信息,如果你不想打印错误信息,去掉就好了 + // 这里打印的也是 java.io.EOFException: null +// t.printStackTrace(); + } + + /** * 服务端推送消息 * @param userId * @param message