Java如何获取美股实时盘口数据

在量化交易和实时行情展示中，获取美股盘口数据（Level 2 Order Book）是一项基础能力。本文将介绍如何使用 WebSocket 接口 实时获取苹果（AAPL）股票的盘口数据，数据源来自 Infoway，支持免费申请 API Key。

虽然示例代码为 Python 实现，但本文的重点是讲解接口结构和步骤，Java 开发者可轻松照搬逻辑实现。

步骤一：申请API Key

首先，在 Infoway 官网注册账号，申请一个免费的 API Key。该 Key 将用于身份验证，所有 WebSocket 请求都必须携带。

步骤二：构建 WebSocket 请求连接

WebSocket地址：

wss://data.infoway.io/ws?business=stock&apikey=yourApiKey
# 申请API Key: www.infoway.io

请将其中的 yourApiKey 替换为你申请到的有效 Key。

Java中推荐使用 java-websocket 或 okhttp-ws 库建立 WebSocket 连接。

步骤三：发送订阅消息

连接成功后，需立即发送订阅请求，格式如下：

{
  "code": 10002,
  "trace": "随机字符串",
  "data": {
    "codes": "AAPL"
  }
}

code = 10002 表示订阅盘口数据。
trace 可使用 UUID 等随机字符串，便于追踪请求。
codes 为股票代码，可同时订阅多个代码（如 AAPL,MSFT,TSLA）。

步骤四：设置心跳机制（Ping）

Infoway 要求客户端每 30 秒发送一次心跳包以保持连接：

{
  "code": 10010,
  "trace": "与订阅一致的追踪ID"
}

在 Java 中你可使用定时器（如 ScheduledExecutorService）每隔30秒发送一次 Ping 消息。

步骤五：接收并解析盘口数据

WebSocket 接口将持续返回如下格式的 Level 2 数据：

{
  "a": [  // Ask 卖盘
    ["150.00", "150.10", "150.20", "150.30", "150.40"],
    ["10.0000", "5.0000", "3.0000", "1.0000", "2.0000"]
  ],
  "b": [  // Bid 买盘
    ["149.90", "149.80", "149.70", "149.60", "149.50"],
    ["8.0000", "4.0000", "2.5000", "1.5000", "3.0000"]
  ],
  "s": "AAPL",           // 股票代码
  "t": 1747553102161     // 时间戳（毫秒）
}

解释：

"a"：五档卖盘价格和对应数量

"b"：五档买盘价格和对应数量

"s"：股票代码

"t"：数据时间戳

在 Java 中可将消息字符串转换为 JSONObject，再通过 JSONArray 解析出价格与数量列表。

开发者需关注的技术细节

1. 断线重连机制不可省略

WebSocket 在网络波动、服务端维护时可能断开连接。建议实现自动重连逻辑（如指数退避 + 最大重试次数），并在重连后重新发送订阅请求与心跳包，确保数据流不中断。

2. 数据处理需解耦，避免阻塞 WebSocket 主线程

接收到的盘口数据量大、频率高，务必将数据解析与业务逻辑处理放入异步队列或独立线程池中，以防堵塞 WebSocket 消息接收主线程，导致延迟或丢包。

3. 时间戳字段 t 建议用于数据对齐与去重

同一时间戳可能对应多条推送数据（如多只股票），应基于时间戳与股票代码做精确匹配与聚合，避免重复处理。对于需要回放的系统，也可按 t 进行时间线还原。

4. 合约代码与交易所规范保持一致

Infoway 使用标准证券代码（如 AAPL），但不同供应商可能略有差异。开发者在接入多源行情时，应构建一套内部的股票代码映射系统，确保代码统一性。

5. 流控与速率限制

虽然接口是实时推送，但在高频订阅场景下应考虑接口的频率上限，建议查阅 Infoway 官方文档 获取精确的订阅限制、消息包大小限制、速率限制等，以免触发封禁。

5. 安全与异常处理

请对 websocket.recv() 返回的数据做容错处理，例如判断字段是否缺失、格式是否正确，避免单一异常导致客户端崩溃。