refactor(okxApi): 分离公有和私有频道连接状态管理

Administrator

5 days ago 672f2cf6d8d87dffb5713067b3545e74f544cca7

 src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java

@@ -131,8 +131,11 @@
    /** 私有频道连接状态 */
    private final AtomicBoolean isPrivateConnected = new AtomicBoolean(false);

    /** 连接中标记，防重入 */
    private final AtomicBoolean isConnecting = new AtomicBoolean(false);
    /** 公开频道连接中标记，防重入 */
    private final AtomicBoolean isPublicConnecting = new AtomicBoolean(false);

    /** 私有频道连接中标记，防重入 */
    private final AtomicBoolean isPrivateConnecting = new AtomicBoolean(false);

    /** 初始化标记，防重复 init */
    private final AtomicBoolean isInitialized = new AtomicBoolean(false);
@@ -302,7 +305,8 @@
        String wsUrl = isPrivate ? config.getWsPrivateUrl() : config.getWsPublicUrl();
        String label = isPrivate ? "私有" : "公开";

        if (isConnecting.get() || !isConnecting.compareAndSet(false, true)) {
        AtomicBoolean connectingFlag = isPrivate ? isPrivateConnecting : isPublicConnecting;
        if (connectingFlag.get() || !connectingFlag.compareAndSet(false, true)) {
            log.info("[OKX-WS] 连接进行中，跳过重复{} WS请求", label);
            return;
        }
@@ -315,7 +319,7 @@
                @Override
                public void onOpen(ServerHandshake handshake) {
                    log.info("[OKX-WS] {} WS连接成功", label);
                    isConnecting.set(false);
                    connectingFlag.set(false);

                    if (isPrivate) {
                        isPrivateConnected.set(true);
@@ -351,7 +355,7 @@
                    } else {
                        isPublicConnected.set(false);
                    }
                    isConnecting.set(false);
                    connectingFlag.set(false);
                    cancelPongTimeout();

                    if (sharedExecutor != null && !sharedExecutor.isShutdown() && !sharedExecutor.isTerminated()) {
@@ -372,6 +376,7 @@
                @Override
                public void onError(Exception ex) {
                    log.error("[OKX-WS] {} WS发生错误", label, ex);
                    connectingFlag.set(false);
                    if (isPrivate) {
                        isPrivateConnected.set(false);
                    } else {
@@ -389,7 +394,7 @@
            }
        } catch (URISyntaxException e) {
            log.error("[OKX-WS] URI格式错误: {}", wsUrl, e);
            isConnecting.set(false);
            connectingFlag.set(false);
        }
    }