Administrator
2026-06-15 44cfb32985e7ec9ba01c49de346e8d9f8e66758a
src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
@@ -232,6 +232,7 @@
                    isConnected.set(false);
                }
            };
            webSocketClient.setConnectionLostTimeout(0);
            webSocketClient.connect();
        } catch (URISyntaxException e) {
            log.error("[WS] URI格式错误", e);
@@ -257,6 +258,12 @@
            }
            if ("subscribe".equals(event)) {
                log.info("[WS] {} 订阅成功: {}", channel, response.getJSONObject("result"));
                for (GateChannelHandler handler : channelHandlers) {
                    if (channel.equals(handler.getChannelName())) {
                        handler.setSubscribed(true);
                        break;
                    }
                }
                return;
            }
            if ("unsubscribe".equals(event)) {
@@ -281,6 +288,17 @@
        }
    }
    /**
     * 检查所有已注册的频道是否都已收到订阅成功确认。
     */
    public boolean areAllSubscribed() {
        if (channelHandlers.isEmpty()) return false;
        for (GateChannelHandler h : channelHandlers) {
            if (!h.isSubscribed()) return false;
        }
        return true;
    }
    // ---- heartbeat ----
    /**