fix(okx): 防止应用关闭时执行WebSocket连接回调

Administrator

2025-12-09 3c693fa3cc1798e51ef434bcdcff7d5925b3e987

 src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java

@@ -130,8 +130,13 @@
                @Override
                public void onOpen(ServerHandshake handshake) {
                    log.info("OKX account-order WebSocket连接成功");
                    resetHeartbeatTimer();
                    websocketLogin();
                    // 检查应用是否正在关闭
                    if (!sharedExecutor.isShutdown()) {
                        resetHeartbeatTimer();
                        websocketLogin();
                    } else {
                        log.warn("应用正在关闭，忽略WebSocket连接成功回调");
                    }
                }

                @Override
@@ -318,7 +323,8 @@
    private void resetHeartbeatTimer() {
        cancelPongTimeout();

        if (heartbeatExecutor != null) {
        // 检查线程池状态，避免在关闭过程中提交任务
        if (heartbeatExecutor != null && !heartbeatExecutor.isShutdown()) {
            pongTimeoutFuture = heartbeatExecutor.schedule(this::checkHeartbeatTimeout,
                    HEARTBEAT_TIMEOUT, TimeUnit.SECONDS);
        }