新加坡实时行情 WebSocket 落地方案（SGX）

发布日期：2026-03-21

适用市场：新加坡（SG）

重点交易所：SGX

如果你要把新加坡行情接进现有系统，建议先把链路跑通，再把稳定性和监控补齐。

你可以把本文当成接入 checklist：先联调，再压测，最后上线。

本文视角

方案页重点是架构落地，关注实时流与历史接口的协同，以及失败时的兜底路径。

业务应用场景

SGX 实时订阅 + 告警触发
SGX:D05 历史 K 线回测与策略验证
多市场聚合网关与统一数据服务
新加坡行情面板和榜单展示

架构建议（稳定优先）

建议用“WebSocket + REST 历史接口”的双通道架构：

WebSocket：承载实时推送，适合盘口、最新价、告警触发
REST 历史接口：负责初始化与补数，适合回测与审计追溯
统一鉴权：REST 与 WebSocket 都用同一个市场 Key（REST 用请求头 X-API-Key，WebSocket 用连接参数 key），一个市场一个 Key

这套组合的价值在于：

实时体验、稳定性、可维护性三者平衡，不会只追求“能跑通”。

集成检查清单

确认 market 与 symbol 格式一致
实时链路加心跳、重连与消息去重
历史接口按分页/批次拉取，避免过载
落库字段统一精度和时区
上线前做回放测试与告警演练

实战提示

如果你要做前后端协作，建议把 SGX 响应字段先沉淀成统一 DTO，再分发给前端和策略服务。

快速接入（最小可用）

REST（历史 K 线）

GET https://api.zafeed.com/v1/klines?market=SG&symbol=SGX:D05&interval=1m&limit=200
X-API-Key: YOUR_SG_KEY

WebSocket（实时行情）

wss://api.zafeed.com/v1/stream?key=YOUR_SG_KEY

{"op":"subscribe","market":"SG","symbols":["SGX:D05"]}

参数与字段建议（工程实战版）

核心请求参数：

market：市场代码（示例：SG）
symbol：完整标的代码（示例：SGX:D05）
interval：K 线周期（如 1m/5m/15m/1h/1d）
limit：返回条数（默认 200，最多 1000）

落库时建议统一字段：

symbol、venue、time（Unix 毫秒）
open/high/low/close、volume
实时流可补 price/change/changePct 等快照字段

多语言请求示例

cURL（联调首选）

curl "https://api.zafeed.com/v1/klines?market=SG&symbol=SGX:D05&interval=1m&limit=200" \
  -H "X-API-Key: YOUR_SG_KEY"

JavaScript（Node.js 服务端）

const url = "https://api.zafeed.com/v1/klines?market=SG&symbol=SGX:D05&interval=1m&limit=200";
const resp = await fetch(url, {
  headers: {
    "X-API-Key": "YOUR_SG_KEY"
  }
});
const data = await resp.json();
console.log(data);

Python（数据任务）

import requests

url = "https://api.zafeed.com/v1/klines?market=SG&symbol=SGX:D05&interval=1m&limit=200"
headers = {"X-API-Key": "YOUR_SG_KEY"}
res = requests.get(url, headers=headers, timeout=20)
print(res.status_code, res.json())

Go（后端服务）

req, _ := http.NewRequest("GET", "https://api.zafeed.com/v1/klines?market=SG&symbol=SGX:D05&interval=1m&limit=200", nil)
req.Header.Set("X-API-Key", "YOUR_SG_KEY")
resp, _ := http.DefaultClient.Do(req)

WebSocket（实时订阅）

const ws = new WebSocket("wss://api.zafeed.com/v1/stream?key=YOUR_SG_KEY");
ws.onopen = () => ws.send(JSON.stringify({
  op: "subscribe",
  market: "SG",
  symbols: ["SGX:D05"]
}));

参数建议

market：SG
symbol：SGX:D05
venue：SGX

错误排查（高频问题）

1. 返回 401

Key 缺失、无效、已轮换或已过期：在会员中心确认 Key 状态，复制最新的 Key 替换（注意不要带空格）。

2. 返回 market/symbol 不匹配

先确认 market=SG 与 symbol=SGX:D05 属于同一市场体系。

3. WebSocket 连接后很快断开

检查是否缺少心跳，或同一个 Key 重复连接（每个市场 Key 默认 1 个 WebSocket 连接），或网络侧代理超时。

4. 数据延迟感知明显

将实时展示与落库解耦：前端先显示增量，后端异步补齐校验。

性能与稳定性建议

使用连接池与重试退避，避免瞬时失败放大
对历史接口做分页和限流，不要一次性拉全量
对实时推送做去重（按 symbol + time）
关键链路加监控：错误率、延迟、断线重连次数

常见问题（FAQ）

1) 什么时候优先使用 WebSocket？

需要实时刷新行情、盘口或推送告警时，优先使用 WebSocket。

2) 什么时候使用历史 K 线接口？

回测、指标计算、数据补齐等离线或准实时任务优先使用历史 K 线接口。

3) 市场 Key 放在哪里？

REST 在请求头 X-API-Key 中携带该市场的 Key，WebSocket 在连接地址参数 key 中携带；Key 只能用于所属市场，market 必须与 Key 一致，否则返回 403。Key 不要写进网页前端代码，建议由后端服务调用。

4) 这套接口适合做什么产品？

适合行情终端、量化信号系统、策略回测平台、交易风控与通知系统。

容易踩坑的细节

忽略 symbol 命名规范，导致跨服务对接失败
只关注“能收到数据”，没做幂等与去重
接口异常没有分级，问题定位速度慢

运维建议（上线后）

监控关键指标：错误率、P95 延迟、断线重连次数
保留响应样本用于故障复盘
在会员中心轮换 Key 后，同步更新服务配置

最后建议

如果你希望我把新加坡市场接入流程再拆成“开发任务清单”，可以直接按本文结构继续扩展。

新加坡 实时行情 WebSocket 落地方案（SGX）