如何实现币安Websocket自动重连以无中断获取K线数据？

我刚好处理过类似的币安Websocket重连需求，结合你在用的Java SDK，给你一套实用的解决方案——既能主动规避24小时自动断开的问题，也能兜底处理意外断连的情况：

核心思路：主动提前重连 + 外部状态存储 #

币安的Websocket连接确实会在24小时左右自动断开，与其被动等待断开后再补救，不如提前23小时主动触发重连，从根源上避免中断。同时要注意：把数据处理需要保留的状态（比如最后处理的K线时间、计算的中间结果等）放在回调逻辑外部，确保重连后能无缝衔接。

具体代码实现步骤 #

首先把WebSocket客户端的引用改成类成员变量，方便后续替换；再把连接逻辑抽成单独的方法，重连时直接复用即可：

1. 定义类成员变量和定时任务池

private BinanceApiWebSocketClient webSocketClient;
// 用单线程定时任务池处理重连，避免多线程冲突
private final ScheduledExecutorService reconnectScheduler = Executors.newSingleThreadScheduledExecutor();

2. 封装连接/重连方法

private void setupCandlestickStream(String cryptoPair, CandlestickInterval interval) {
    // 先关闭旧连接（如果存在），防止资源泄漏
    if (webSocketClient != null) {
        webSocketClient.close();
    }

    // 创建新客户端实例并订阅K线流
    BinanceApiClientFactory clientFactory = BinanceApiClientFactory.newInstance(
        appConfig.getApiKey(),
        appConfig.getApiSecret(),
        appConfig.isUseTestNet(),
        appConfig.isUseTestNet()
    );
    webSocketClient = clientFactory.newWebSocketClient();

    webSocketClient.onCandlestickEvent(
        cryptoPair.toLowerCase(), 
        interval, 
        new BinanceApiCallback<CandlestickEvent>() {
            @Override
            public void onResponse(final CandlestickEvent evt) {
                // 你的K线数据处理逻辑写在这里
                // 重点：把需要保留的状态（比如最后处理的K线时间戳）存在类成员变量里，别放在回调内部
                // 示例：lastProcessedTimestamp = evt.getCloseTime();
            }

            @Override
            public void onFailure(Throwable cause) {
                // 处理意外断连（比如网络波动），触发即时重连
                System.err.println("Websocket意外断开，启动重连：" + cause.getMessage());
                // 加短延迟避免频繁请求被限流
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                setupCandlestickStream(cryptoPair, interval);
            }
        }
    );
}

3. 初始化连接并启动定时重连任务

// 程序启动时先建立初始连接
setupCandlestickStream("BTCUSDT", getCandlestickInterval());

// 启动定时任务：23小时后第一次重连，之后每隔23小时重复执行
reconnectScheduler.scheduleAtFixedRate(
    () -> setupCandlestickStream("BTCUSDT", getCandlestickInterval()),
    23, 
    23, 
    TimeUnit.HOURS
);

关键注意事项 #

• 状态持久化：所有需要延续的处理状态（比如最后处理的K线、累计指标等）一定要放在回调外部，比如类成员变量、数据库或Redis，重连后新回调能直接复用这些状态，不会丢失上下文。
• 资源清理：每次重连前必须关闭旧的WebSocket客户端，避免创建过多无效连接导致内存泄漏。
• 异常兜底：不要只依赖定时重连，onFailure回调的兜底逻辑能处理网络波动等意外情况，加短延迟重连还能避免被币安限流。
• 线程池管理：程序退出时记得调用reconnectScheduler.shutdown()关闭定时任务池，避免线程残留。

备注：内容来源于stack exchange，提问作者czetsuya