一、使用websocket的协议提升传输速度

实时金融股票数据对于投资者和交易员来说至关重要。通过使用WebSocket接入方法，可以轻松获取实时金融股票类数据并及时做出决策。WebSocket是一种高效的双向通信协议，它允许数据的实时推送，避免了不断的轮询请求。这种接入方法具有多个优势。 1、首先，它提供了快速的股票数据传输速度，确保您获取到最新的市场行情数据。其次，WebSocket允许您订阅特定的股票数据源或股票数据产品，只接收您感兴趣的信息，提高了数据的效率和可用性。 2、此外，WebSocket接口通常具有稳定的连接性，能够处理大量的数据推送，满足高频交易和实时分析的需求。 3、通过使用实时金融数据API接口的WebSocket接入方法，您可以更好地监测市场数据动态，及时抓住交易机会，为您的金融决策提供有力支持。

二、接入步骤

2.1、通过API地址传参建立连接

按照下面代码建立连接

WebSocket订阅地址：
数字币：
wss://data.infoway.io/ws?business=crypto&apikey=YourAPIKey
股票:
wss://data.infoway.io/ws?business=stock&apikey=YourAPIKey
外汇、期货、贵金属：
wss://data.infoway.io/ws?business=common&apikey=YourAPIKey

建立连接之后，就可以订阅具体的接口数据了，具体调用方式看第二步

2.2、查看code产品列表

支持以下产品品类:

美股数据

港股数据

A股数据

外汇数据

贵金属数据

商品数据

数字币数据

更详细的产品列表可以在官网下载。

三、开始真正的订阅实时行情数据源报价

当你选择好产品code列表后就可以开始真正的订阅实时行情数据源报价了。

请看下面的实例代码：

import json
import time
import schedule
import threading
import websocket
from loguru import logger

class WebsocketExample:
    def __init__(self):
        self.session = None
        self.ws_url = "wss://data.infoway.io/ws?business=crypto&apikey=yourApikey"
        self.reconnecting = False
        self.is_ws_connected = False  # 添加连接状态标志

    def connect_all(self):
        """建立WebSocket连接并启动自动重连机制"""
        try:
            self.connect(self.ws_url)
            self.start_reconnection(self.ws_url)
        except Exception as e:
            logger.error(f"Failed to connect to {self.ws_url}: {str(e)}")

    def start_reconnection(self, url):
        """启动定时重连检查"""
        def check_connection():
            if not self.is_connected():
                logger.debug("Reconnection attempt...")
                self.connect(url)
        
        # 使用线程定期检查连接状态
        schedule.every(10).seconds.do(check_connection)
        def run_scheduler():
            while True:
                schedule.run_pending()
                time.sleep(1)
        threading.Thread(target=run_scheduler, daemon=True).start()

    def is_connected(self):
        """检查WebSocket连接状态"""
        return self.session and self.is_ws_connected

    def connect(self, url):
        """建立WebSocket连接"""
        try:
            if self.is_connected():
                self.session.close()
            
            self.session = websocket.WebSocketApp(
                url,
                on_open=self.on_open,
                on_message=self.on_message,
                on_error=self.on_error,
                on_close=self.on_close
            )
            
            # 启动WebSocket连接（非阻塞模式）
            threading.Thread(target=self.session.run_forever, daemon=True).start()
        except Exception as e:
            logger.error(f"Failed to connect to the server: {str(e)}")

    def on_open(self, ws):
        """WebSocket连接建立成功后的回调"""
        logger.info(f"Connection opened")
        self.is_ws_connected = True  # 设置连接状态为True
        
        try:
            # 发送实时成交明细订阅请求
            trade_send_obj = {
                "code": 10000,
                "trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
                "data": {"codes": "BTCUSDT"}
            }
            self.send_message(trade_send_obj)
            
            # 不同请求之间间隔一段时间
            time.sleep(5)
            
            # 发送实时盘口数据订阅请求
            depth_send_obj = {
                "code": 10003,
                "trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
                "data": {"codes": "BTCUSDT"}
            }
            self.send_message(depth_send_obj)
            
            # 不同请求之间间隔一段时间
            time.sleep(5)
            
            # 发送实时K线数据订阅请求
            kline_data = {
                "arr": [
                    {
                        "type": 1,
                        "codes": "BTCUSDT"
                    }
                ]
            }
            kline_send_obj = {
                "code": 10006,
                "trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
                "data": kline_data
            }
            self.send_message(kline_send_obj)
            
            # 启动定时心跳任务
            schedule.every(30).seconds.do(self.ping)
            
        except Exception as e:
            logger.error(f"Error sending initial messages: {str(e)}")

    def on_message(self, ws, message):
        """接收消息的回调"""
        try:
            logger.info(f"Message received: {message}")
        except Exception as e:
            logger.error(f"Error processing message: {str(e)}")

    def on_close(self, ws, close_status_code, close_msg):
        """连接关闭的回调"""
        logger.info(f"Connection closed: {close_status_code} - {close_msg}")
        self.is_ws_connected = False  # 设置连接状态为False

    def on_error(self, ws, error):
        """错误处理的回调"""
        logger.error(f"WebSocket error: {str(error)}")
        self.is_ws_connected = False  # 发生错误时设置连接状态为False

    def send_message(self, message_obj):
        """发送消息到WebSocket服务器"""
        if self.is_connected():
            try:
                self.session.send(json.dumps(message_obj))
            except Exception as e:
                logger.error(f"Error sending message: {str(e)}")
        else:
            logger.warning("Cannot send message: Not connected")

    def ping(self):
        """发送心跳包"""
        ping_obj = {
            "code": 10010,
            "trace": "01213e9d-90a0-426e-a380-ebed633cba7a"
        }
        self.send_message(ping_obj)

# 使用示例
if __name__ == "__main__":
    ws_client = WebsocketExample()
    ws_client.connect_all()
    
    # 保持主线程运行
    try:
        while True:
            schedule.run_pending()
            time.sleep(1)
    except KeyboardInterrupt:
        logger.info("Exiting...")
        if ws_client.is_connected():
            ws_client.session.close()

四、解析推送数据

4.1、最新成交报价解析

{
  "s": "BTCUSDT",
  "t": 1752947397177,
  "p": "117783.22",
  "v": "0.00048",
  "vw": "56.5359456",
  "td": 2
}

4.2、最新盘口深度数据解析

{
  "s": "BTCUSDT",
  "t": 1752947435539,
  "a": [
    [
      "117783.22000000",
      "36.18406000"
    ],
    [
      "117783.23000000",
      "0.06819000"
    ]
  ],
  "b": [
    [
      "117783.21000000",
      "1.17501000"
    ],
    [
      "117783.20000000",
      "0.07635000"
    ]
  ]
}

4.3、最新K线数据解析

{
  "s": "BTCUSDT",
  "respList": [
    {
      "t": "1752944400",
      "h": "117984.68000",
      "o": "117974.00000",
      "l": "117745.57000",
      "c": "117825.75000",
      "v": "119.69276",
      "vw": "14107044.9828691",
      "pc": "-0.13%",
      "pca": "-148.24000"
    }
  ]
}

五、整理和总结websocket的优势

通过实时金融数据API接口的WebSocket接入方法，您可以享受到及时、高效的金融数据API服务。这种接入方式为投资者和交易员提供了许多优势和便利。

1、首先，实时数据的获取使您能够紧跟市场的变化，及时获取到最新的股票价格、交易量等关键信息。这对于制定交易决策和执行高频交易策略至关重要。其次，WebSocket的双向通信特性使您能够实时订阅和接收您感兴趣的数据源或产品，避免了不必要的数据冗余和网络资源浪费。

2、此外，WebSocket接口通常具有较低的延迟和可靠的连接性，能够处理大规模的数据推送，确保您获取到准确的实时数据。

3、最重要的是，这种接入方法为您提供了强大的灵活性和定制化能力，您可以根据自己的需要和策略要求订阅特定的数据，进行个性化的数据分析和决策支持。

综上所述，实时金融数据API接口的WebSocket接入方法是现代金融交易和投资领域中不可或缺的工具，它为用户提供了快速、可靠的数据传输和个性化的数据订阅服务，帮助他们在竞争激烈的市场中抢占先机，实现更好的投资回报。