src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java | ●●●●● 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; } // 订阅事件流,将事件编译和处理放到单独的线程中执行