后台修改

xiaoyong931011

2023-03-24 a6595316ae375294e41cc502701814a2c7f7b994

后台修改

 src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java

@@ -168,20 +168,6 @@

            EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress());
            Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter);
            while (!webSocketClient.getReadyState().equals(ReadyState.OPEN)) {
                log.info("连接中···请稍后");
                int retries = 3;
                while (retries-- > 0) {
                    try {
                        Thread.sleep(1000);
                        wssContractEventListener2(startBlock, event, type);
                        return;
                    } catch (Exception ex) {
                        log.error("币安监听异常", ex);
                    }
                }
                return;
            }
            // 判断websocket是否连接成功
            if (!webSocketClient.isOpen()) {
                log.error("WebSocket连接失败");