使用WebSocket对接马来西亚、印度等国家股票实时数据API

news/2025/4/1 19:12:35/文章来源:https://www.cnblogs.com/paostock/p/18801040

使用WebSocket与心跳机制实现StockTV全球金融市场实时数据推送（无限次调用）

引言

StockTV API提供了覆盖全球股票、外汇、期货及加密货币的实时行情数据，其中WebSocket协议作为核心实时推送技术，结合心跳机制保障连接稳定性，支持无限次接口调用。本文将通过代码实战，解析如何通过WebSocket实现毫秒级实时数据订阅。

一、WebSocket协议的优势

与传统HTTP轮询相比，WebSocket具有以下特点：

全双工通信：服务端可主动推送数据，无需客户端频繁请求
低延迟：建立TCP长连接，减少握手开销
高效性：适合高频数据场景（如行情推送）
心跳保活：通过定时心跳包维持连接状态

二、StockTV WebSocket接口解析

1. 连接地址

wss://ws-api.stocktv.top/connect?key=您的API密钥

2. 心跳机制实现

作用：防止NAT超时断开、检测连接状态
频率：建议每30秒发送一次心跳包

实现逻辑：

// 前端心跳示例
setInterval(() => {if (websocket.readyState === WebSocket.OPEN) {websocket.send(JSON.stringify({ "action": "ping" }));}
}, 30000);

3. 实时数据字段说明

字段	类型	说明
`last_numeric`	String	最新成交价
`bid`	String	当前买一价
`ask`	String	当前卖一价
`high`/`low`	String	当日最高/低价
`pcp`	String	涨跌幅（需拼接%）
`timestamp`	String	数据时间戳（Unix秒级）

三、实战代码示例

1. 前端WebSocket连接

<button onclick="connectWS()">连接行情</button>
<div id="ticker-data"></div><script>
const API_KEY = "YOUR_API_KEY"; function connectWS() {const ws = new WebSocket(`wss://ws-api.stocktv.top/connect?key=${API_KEY}`);ws.onopen = () => {console.log("WebSocket连接成功");// 订阅股票ID（示例：7310）ws.send(JSON.stringify({ action: "subscribe", pid: 7310 }));};ws.onmessage = (event) => {const data = JSON.parse(event.data);document.getElementById("ticker-data").innerHTML = `最新价：${data.last_numeric} 涨跌幅：${data.pcp}%`;};// 心跳保活setInterval(() => {if (ws.readyState === WebSocket.OPEN) {ws.send(JSON.stringify({ action: "ping" }));}}, 30000);
}
</script>

2. C#服务端实现

using WebSocketSharp;public class StockTvClient 
{private WebSocket _ws;private Timer _heartbeatTimer;public void Connect(string apiKey) {_ws = new WebSocket($"wss://ws-api.stocktv.top/connect?key={apiKey}");_ws.OnOpen += (sender, e) => {Console.WriteLine("连接已建立");// 订阅期货ID（示例：XAG）_ws.Send(JsonConvert.SerializeObject(new {action = "subscribe",symbol = "XAG"}));StartHeartbeat();};_ws.OnMessage += (sender, e) => {dynamic data = JsonConvert.DeserializeObject(e.Data);Console.WriteLine($"[{DateTime.Now}] 价格更新: {data.last_numeric}");};_ws.Connect();}private void StartHeartbeat() {_heartbeatTimer = new Timer(state => {if (_ws.ReadyState == WebSocketState.Open) {_ws.Send(JsonConvert.SerializeObject(new { action = "ping" }));}}, null, TimeSpan.Zero, TimeSpan.FromSeconds(30));}
}