前段时间在做一个美股实时盯盘的小工具，需要同时监控十来只股票的分时变化。一开始我用REST接口每隔两秒拉一次，盘中一波动，数据就明显滞后，界面数字跳得不够“跟手”。更烦的是，有时候请求发多了直接被限流，页面直接空白几秒。后来切到WebSocket，又遇到连接断断续续的问题。折腾一圈下来发现，美股数据源的选择，核心就卡在两个点上：延迟能不能压得住，连接稳不稳。

延迟跟稳定性的常见差异点

我对比了几种不同API，发现差异主要来自这几个地方：

• 接口协议不同：REST是请求-响应，每次都要建连、传头、等返回，天生有延迟。WebSocket是长连接，数据主动推过来，延迟能压到几十毫秒。

• 服务器节点位置：访问美国的数据源，如果节点不在北美，跨太平洋的延迟可能直接到200ms以上。有CDN或边缘节点的会好很多。

• 数据更新频率：有的API只提供秒级聚合，有的提供逐笔tick。逐笔的实时性最强，但数据量也大，对连接稳定性要求更高。

• 心跳与超时策略：服务端如果几秒没收到心跳就踢掉连接，客户端必须配合好。不同API的心跳要求差别挺大。

这些问题单独看不复杂，但叠在一起，选错数据源或者客户端没写好，体验就很糟糕。

延迟敏感的几种处理思路

我自己的项目里，对延迟要求最高的是盘口异动提醒——价格变化超过某个阈值就要弹窗。用REST轮询根本来不及，必须上WebSocket。

以 AllTick API 为例，下面是一个订阅美股逐笔成交的代码示例：

python

import websocket

import json

def on_message ( ws , message ):

    data = json . loads ( message )

     # 只拿最关键的字段，减少解析开销

     print ( f" { data [ 'symbol' ]} 价格: { data [ 'price' ]} 时间: { data [ 'time' ]} " )

def on_open ( ws ):

     # 订阅苹果和微软的实时tick

    req = {

         "cmd" : "subscribe" ,

         "symbols" : [ "AAPL" , "MSFT" ]

     }

    ws . send ( json . dumps ( req ))

ws = websocket . WebSocketApp (

     "wss://api.alltick.co/stock/tick" ,

    on_open = on_open ,

    on_message = on_message

)

ws . run_forever ()

这个订阅方式很直观，连接建好就开始推数据。但光这样还不够，跑一段时间就会发现，网络抖动或者服务端主动回收连接的时候，还是会断。

稳定性怎么补上来

后来我加了两层保障：心跳和自动重连。心跳我用的是定时发ping，维持连接活跃。断线重连也很简单——在循环里包一层while True，断开就等几秒重新连。

python

import threading

import time

def heartbeat ( ws ):

     while True :

         try :

            ws . send ( json . dumps ({ "type" : "ping" }))

         except :

             break

        time . sleep ( 10 )

def run_ws ():

    ws = websocket . WebSocketApp (

         "wss://api.alltick.co/stock/tick" ,

        on_open = on_open ,

        on_message = on_message

     )

    threading . Thread ( target = heartbeat , args = ( ws ,), daemon = True ). start ()

    ws . run_forever ()

while True :

     try :

        run_ws ()

     except Exception as e :

         print ( "连接异常:" , e )

        time . sleep ( 3 )

这段代码跑起来之后，断线基本能自动恢复，数据流不会再莫名其妙停掉。另外订阅控制也很重要——我试过一个连接里塞20只股票，推送压力大不说，还容易触发服务端的限流。现在按板块拆分成两三个连接，每个连接只订阅5-8只，稳定多了。

实际使用中的一些感受

在挑选美股数据源的过程中，我试过好几家，有的延迟低但动不动断线，有的很稳但数据延迟明显。后来我慢慢接受一个事实：没有完美的API，关键看你的场景更在意什么。做日级别分析，REST完全够用；做实时预警或者算法执行，就必须上WebSocket，并且把心跳、重连、订阅拆分这些细节做好。

说到底，数据源只是一个起点。真正决定体验的是你如何处理延迟、如何应对断线、如何组织数据流。花点时间把连接管理这部分吃透，后面跑策略或者做界面都会顺畅很多。