Przeglądaj źródła

新增webSocket客户端

anderx 2 lat temu
rodzic
commit
eb400c02de

+ 0 - 5
src/main/java/com/goafanti/common/bean/WebSocketClientBean.java

@@ -1,17 +1,12 @@
 package com.goafanti.common.bean;
 
 import com.goafanti.common.utils.LoggerUtils;
-import com.goafanti.common.webSocket.MsgWebSocketClient;
-import com.goafanti.common.webSocket.WebClientEnum;
 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.drafts.Draft_6455;
 import org.java_websocket.enums.ReadyState;
 import org.java_websocket.handshake.ServerHandshake;
-import org.springframework.context.annotation.Bean;
 
 import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.URL;
 
 public class WebSocketClientBean {
 

+ 4 - 0
src/main/java/com/goafanti/core/websocket/SystemWebSocketHandler.java

@@ -4,6 +4,8 @@ import java.io.IOException;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
+import com.goafanti.common.webSocket.MsgWebSocketClient;
+import org.java_websocket.client.WebSocketClient;
 import org.springframework.web.socket.CloseStatus;
 import org.springframework.web.socket.TextMessage;
 import org.springframework.web.socket.WebSocketHandler;
@@ -27,7 +29,9 @@ public class SystemWebSocketHandler implements WebSocketHandler {
 
 	@Override
 	public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
+//		收到消息
 		LoggerUtils.debug(getClass(), message.getPayload().toString());
+
 	}
 
 	@Override