在量化交易系统或行情订阅程序中，WebSocket 是实现实时行情获取的关键通道。但在实际部署中，我们经常会遇到一个头痛的问题：WebSocket连接在运行一段时间后断开了，而我们的策略还以为数据一直在更新，直到发生实际交易损失。
本文将以外汇行情 WebSocket 接口为例，详细还原一次断连排查过程，并提供一个健壮的重连机制实现方案，帮助你构建高可用的实时行情接入组件。
初始接入代码示例（外汇行情）
根据infoway API的官方示例中，我们通过如下代码订阅了 BTCUSDT 的实时行情（注意：虽然标的是 crypto，Infoway 支持的外汇行情与加密币行情结构一致，实际只需修改订阅品种即可）：
private static final String WS_URL = "wss://data.infoway.io/ws?business=forex&apikey=yourApikey";// 申请免费token: https://infoway.io// 对接文档：docs.infoway.ioJSONObject jsonObject = new JSONObject();jsonObject.put("code", 10000);jsonObject.put("trace", UUID.randomUUID().toString());JSONObject data = new JSONObject();data.put("codes", "EURUSD"); // 示例：订阅 EUR/USD 外汇对jsonObject.put("data", data);session.getBasicRemote().sendText(jsonObject.toJSONString());这是典型的基于 @ClientEndpoint 的 WebSocket 接入方式。但在运行过程中，我们观察到 30 分钟左右后，控制台停止打印行情，连接虽然没有报错，但实际上已经断开了。
问题表现
没有报错或异常（@OnError未触发）；@OnClose 也未打印；行情打印停止，ping 发送不报错但无回应；监控发现 WebSocket 实际已经被远端关闭（心跳丢失）。原因分析
此类问题在接入 WebSocket 时较为常见，可能由以下原因之一引起：
客户端网络瞬断；长时间未发送心跳或心跳机制失效；远端服务端定期断开空闲连接；Session 对象未能正确检测“半连接”状态（即 TCP 已断但对象仍可调用）；Java WebSocket API 没有内建自动重连机制。重连机制设计思路
为了解决这个问题，我们需要构建一个健壮的“自动重连机制”，核心包括：
监听连接状态：@OnClose 和 @OnError 都要触发重连；每次连接失败要有退避策略（避免死循环尝试）；在主线程或守护线程中保持连接活跃监测；支持手动关闭与恢复机制，防止重复连接。改造后的关键代码（支持自动重连）
package org.example.ws;import com.alibaba.fastjson2.JSONObject;import jakarta.websocket.*;import java.io.IOException;import java.net.URI;import java.util.UUID;import java.util.concurrent.*;// 申请免费token: https://infoway.io// 对接文档：docs.infoway.iopublic class ReconnectableWSClient {private static Session session;private static final String WS_URL = "wss://data.infoway.io/ws?business=forex&apikey=yourApikey";private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);private static final int RECONNECT_DELAY = 5; // secondsprivate static volatile boolean userClose = false;public static void main(String[] args) {connectWithRetry();scheduler.scheduleAtFixedRate(ReconnectableWSClient::ping, 30, 30, TimeUnit.SECONDS);}private static void connectWithRetry() {scheduler.execute(() -> {while (true) {try {WebSocketContainer container = ContainerProvider.getWebSocketContainer();session = container.connectToServer(MyClientEndpoint.class, URI.create(WS_URL));subscribeForex("EURUSD");break;} catch (Exception e) {System.err.println("连接失败，" + RECONNECT_DELAY + "秒后重试...");try {TimeUnit.SECONDS.sleep(RECONNECT_DELAY);} catch (InterruptedException ignored) {}}}});}private static void subscribeForex(String symbol) throws IOException {JSONObject jsonObject = new JSONObject();jsonObject.put("code", 10000);jsonObject.put("trace", UUID.randomUUID().toString());JSONObject data = new JSONObject();data.put("codes", symbol);jsonObject.put("data", data);session.getBasicRemote().sendText(jsonObject.toJSONString());}private static void ping() {if (session != null && session.isOpen()) {try {JSONObject jsonObject = new JSONObject();jsonObject.put("code", 10010);jsonObject.put("trace", UUID.randomUUID().toString());session.getBasicRemote().sendText(jsonObject.toJSONString());} catch (IOException e) {System.err.println("Ping发送失败，尝试重连...");reconnect();}}}private static void reconnect() {if (userClose) return;try {if (session != null && session.isOpen()) {session.close();}} catch (IOException ignored) {}connectWithRetry();}@ClientEndpointpublic static class MyClientEndpoint {@OnOpenpublic void onOpen(Session session) {System.out.println("连接已建立：" + session.getId());}@OnMessagepublic void onMessage(String message) {System.out.println("收到数据：" + message);}@OnClosepublic void onClose(Session session, CloseReason reason) {System.err.println("连接关闭，原因：" + reason);reconnect();}@OnErrorpublic void onError(Session session, Throwable throwable) {System.err.println("发生错误：" + throwable.getMessage());reconnect();}}}经验总结
WebSocket 是实时行情系统的核心通道，必须做到可用性高、断线可恢复；Java 的 WebSocket API 原生不支持重连，需要手动封装；合理使用线程池和状态控制，可以避免连接雪崩或资源泄露；实际部署中建议使用独立监控线程检测长时间无数据/心跳响应，进一步增强稳定性。