renkang/xj-platform
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新疆aed迁移

Browse Source
This commit is contained in:
wanghao
2025-11-27 17:36:05 +08:00
parent fe0e075220
commit f09b695903
1 changed files with 63 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files
health-emergency/health-emergency-biz/src/main/java/com/renkang/emergency/aed/manage/WebSocketClientManagerNew.java
+63 -63
View File
@@ -28,11 +28,11 @@ import java.util.concurrent.atomic.AtomicReference;
@Slf4j @Slf4j
public class WebSocketClientManagerNew { public class WebSocketClientManagerNew {
@Value("${websocket.url}") // @Value("${websocket.url}")
private String url; // private String url;
@Value("${websocket.username}") // @Value("${websocket.username}")
private String username; // private String username;
@Autowired @Autowired
private AedEquipmentMangerMapper aedEquipmentMangerMapper; private AedEquipmentMangerMapper aedEquipmentMangerMapper;
@@ -45,68 +45,68 @@ public class WebSocketClientManagerNew {
// connect(); // connect();
} }
private void connect() { // private void connect() {
try { // try {
log.info("aed websocket 开始建立连接..."); // log.info("aed websocket 开始建立连接...");
WebSocketContainer container = ContainerProvider.getWebSocketContainer(); // WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String fullUrl = url + URLEncoder.encode(username, "UTF-8"); // String fullUrl = url + URLEncoder.encode(username, "UTF-8");
// 创建被注解的端点实例 // // 创建被注解的端点实例
MyEndpoint endpoint = new MyEndpoint(); // MyEndpoint endpoint = new MyEndpoint();
// 建立连接 // // 建立连接
container.connectToServer(endpoint, new URI(fullUrl)); // container.connectToServer(endpoint, new URI(fullUrl));
isReconnecting = true; // isReconnecting = true;
log.info("aed websocket 连接成功..."); // log.info("aed websocket 连接成功...");
} catch (Exception e) { // } catch (Exception e) {
log.error("aed websocket 连接失败...", e); // log.error("aed websocket 连接失败...", e);
scheduleReconnect(); // scheduleReconnect();
} // }
} // }
// @ClientEndpoint // @ClientEndpoint
private class MyEndpoint extends Endpoint { // private class MyEndpoint extends Endpoint {
@Override // @Override
public void onOpen(Session session, EndpointConfig config) { // public void onOpen(Session session, EndpointConfig config) {
sessionRef.set(session); // sessionRef.set(session);
try { // try {
session.addMessageHandler(new MessageHandler.Whole<String>() { // session.addMessageHandler(new MessageHandler.Whole<String>() {
@Override // @Override
public void onMessage(String message) { // public void onMessage(String message) {
handleMessage(message); // handleMessage(message);
} // }
}); // });
} catch (Exception ignore) { // } catch (Exception ignore) {
log.error("Failed to add message handler"); // log.error("Failed to add message handler");
} // }
} // }
//
// @Override
// public void onClose(Session session, CloseReason closeReason) {
// log.info("Connection closed: {}", closeReason);
// scheduleReconnect();
// }
//
// @Override
// public void onError(Session session, Throwable thr) {
// log.error("WebSocket error", thr);
// scheduleReconnect();
// }
// }
@Override // private void scheduleReconnect() {
public void onClose(Session session, CloseReason closeReason) { // if (isReconnecting) {
log.info("Connection closed: {}", closeReason); // return;
scheduleReconnect(); // }
} // isReconnecting = true;
// scheduler.schedule(() -> {
@Override // try {
public void onError(Session session, Throwable thr) { // connect();
log.error("WebSocket error", thr); // } catch (Exception e) {
scheduleReconnect(); // log.error("aed webSocket 连接失败...", e);
} // } finally {
} // isReconnecting = false;
// }
private void scheduleReconnect() { // }, 20, TimeUnit.SECONDS);
if (isReconnecting) { // }
return;
}
isReconnecting = true;
scheduler.schedule(() -> {
try {
connect();
} catch (Exception e) {
log.error("aed webSocket 连接失败...", e);
} finally {
isReconnecting = false;
}
}, 20, TimeUnit.SECONDS);
}
private void handleMessage(String message) { private void handleMessage(String message) {
if (StrUtil.isBlank(message)) { if (StrUtil.isBlank(message)) {