xiaoyong931011
2023-03-24 210ad49fa529f6d339080ea9c9995f9572269f7b
后台修改
1 files modified
10 ■■■■■ changed files
src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java 10 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java
@@ -179,6 +179,16 @@
            // 判断websocket是否连接成功
            if (!webSocketClient.isOpen()) {
                log.error("WebSocket连接失败");
                int retries = 3;
                while (retries-- > 0) {
                    try {
                        Thread.sleep(1000);
                        wssContractEventListener2(startBlock, event, type);
                        return;
                    } catch (Exception ex) {
                        log.error("币安监听异常", ex);
                    }
                }
                return;
            }
            // 订阅事件流,将事件编译和处理放到单独的线程中执行