Browse Source

解决报警websocket初次连接卡死的问题

menglu 3 years ago
parent
commit
e6a5a5d938

+ 1 - 1
ibms-data-sdk/pom.xml

@@ -2,7 +2,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.persagy</groupId>
 	<artifactId>ibms-data-sdk</artifactId>
-	<version>0.1.2</version>
+	<version>0.1.3</version>
 
 	<repositories>
 		<repository>

+ 6 - 8
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/websocket/AlarmWebSocketClient.java

@@ -7,7 +7,6 @@ import org.java_websocket.handshake.ServerHandshake;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
-import com.persagy.ibms.core.util.ComputeUtil;
 import com.persagy.ibms.core.util.LogUtil;
 import com.persagy.ibms.data.sdk.util.RWDAlarmUtil;
 import com.persagy.ibms.data.sdk.util.RepositoryContainer;
@@ -29,8 +28,9 @@ public class AlarmWebSocketClient extends WebSocketClient {
 	@Override
 	public void onOpen(ServerHandshake arg0) {
 		log.warn("onOpen: " + serverUri.toString());
-		try {
-			ComputeUtil.fixedThreadPool.execute(() -> {
+		Runnable runnable = new Runnable() {
+			@Override
+			public void run() {
 				try {
 					log.warn("onOpen refresh begin");
 					int alarm_size = RWDAlarmUtil.refresh();
@@ -38,11 +38,9 @@ public class AlarmWebSocketClient extends WebSocketClient {
 				} catch (Exception e) {
 					e.printStackTrace();
 				}
-			});
-		} catch (Exception e) {
-			log.error("onOpen refresh error");
-			log.error(e.getMessage(), e);
-		}
+			}
+		};
+		runnable.run();
 	}
 
 	@Override