Gemini Websocket feeds的概述

Gemini API通过其Websocket Feed提供实时市场数据，使开发人员和交易者能够接收有关订单簿更改，交易和股票信息的瞬时更新。这些提要对于需要低延迟数据的应用程序至关重要，例如算法交易系统，市场监控工具和价格警报服务。与需要进行轮询的REST API不同，WebSocket连接保持持久的双向通信渠道，减少开销并确保及时提供数据。

Gemini的主要Websocket端点是wss://api.gemini.com/v1/marketdata 。此端点流提供公共市场数据，并且不需要身份验证以进行基本访问。所有消息均以JSON格式传递，使其易于解析并集成到各种编程环境中。

可用的Websocket频道

双子座支持几个Websocket渠道，每个渠道旨在提供特定类型的市场数据。可用渠道包括：

• 市场数据提要：订单簿上的实时更新，包括投标，询问和贸易执行。
• 心跳消息：表明连接处于活动状态并传输数据的周期信号。
• 股票更新：摘要级别的价格信息，包括最后价格，数量和出价/询问差。
• 贸易执行通知：交易所完成交易的实时报告。

在建立WebSocket连接时，可以通过指定所需的符号来访问每个通道。例如，连接到BTCUSD或ETHUSD将传输特定于该交易对的数据。

连接到双子座Websocket

要建立与双子座Websocket Feed的连接，请按照以下步骤：

• 使用受支持的库（例如Python中的websocket-client或Node.js中的ws打开Websocket客户端。
• 连接到端点： wss://api.gemini.com/v1/marketdata 。
• 使用查询字符串中的symbols参数指定交易对。例如： wss://api.gemini.com/v1/marketdata/BTCUSD 。
• 聆听传入的消息并相应处理JSON有效载荷。

这是使用Python的示例：

 import websocket import json def on_message（WS，消息）：






data = json.loads(message) print(data) DEF ON_ERROR（WS，错误）： data = json.loads(message) print(data)
 
def on_close（ws，close_status_code，close_msg）： print(f'Error: {error}')
 
def on_open（WS）： print('Connection closed')
 
建立连接print('Connected to Gemini WebSocket')
 ws = websocket.websocketapp（'wss：//api.gemini.com/v1/marketdata/btcusd'，
 
 on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close) ws.run_forever（） on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close)

该脚本连接到BTCUSD市场数据供稿并打印所有传入消息。收到的数据包括事件类型，符号，投标，询问和交易。

了解Websocket消息结构

从Gemini Websocket收到的每条消息都包含标准化的JSON结构。关键字段包括：

• 类型：指示消息类别，例如update ， heartbeat或initial 。
• EventID ：事件的唯一标识符。
• 时间戳：事件发生时的UNIX时间戳。
• 符号：交易对（例如， BTCUSD ）。
• 出价和询问：价格水平和相应数量的阵列。
• 更改：订单簿的更新清单，显示价格，金额和侧面（ buy ） sell

示例更新消息：

 { 'type': 'update', 'eventId': 123456789, 'timestamp': 1717000000000, 'symbol': 'BTCUSD', 'changes': [ ['buy', '65000.00', '0.5'], ['sell', '65001.50', '0.3']

这是给出的}

在此示例中，更改阵列显示为0.5 BTC的65000.00的新出价，并在65001.50处显示为0.3 BTC的新竞标。客户必须维护订单簿的本地副本，并逐步应用这些更改以反映当前的市场状态。

处理订单书同步

由于Websocket更新的增量性质，正确初始化订单簿至关重要。 Gemini在连接时发送了一个初始快照，然后是更新消息。确保准确性：

• 存储初始出价，并在收到第一条消息后询问。
• 将每个随后的changes条目应用于本地订单书。
• 按降序排序竞标，并按价格提高顺序。
• 当数量达到零时，请删除价格水平。

例如，在处理['buy', '65000.00', '0.0']的更改时，应从订单书中删除以65000.00的出价。维护此逻辑可确保您的应用程序反映了市场的真实状态。

费率限制和连接管理

Gemini并未对Websocket连接施加严格的速率限制，因为它们是为连续流媒体设计的。但是，由于不活动或消息积压过多，连接可能会终止。保持可靠性：

• 用指数向后进行重新连接逻辑。
• 监视Connection closed事件并重新启动会话。
• 使用心跳机制来验证连接健康。
• 限制并发订阅的数量，以避免淹没客户端。

每个连接只能订阅一个符号。要监视多对，请为每个对建立单独的Websocket实例。

常见问题

如何同时订阅多个交易对？要接收多个符号的数据，请为每个交易对打开一个单独的Websocket连接。例如，将一个连接用于BTCUSD ，而将另一个连接用于ETHUSD 。单个插座上没有多个符号的广播模式。

更改阵列中的“ 0”数量是多少？更改字段中的“ 0.0”数量表示相应的价格水平已从订单簿中删除。例如， ['sell', '65001.50', '0.0']表示在65001.50处的询问已完全填充或取消。

访问Websocket Feed需要身份验证吗？不，公共市场数据Websocket Feed不需要API键或身份验证。所有用户都可以访问它。但是，私人提要（例如，用于订单状态）需要通过Gemini Exchange API进行身份验证的Websocket连接。

心跳多久发送一次？心跳消息大约每5秒发送一次。它们包含一种type: 'heartbeat'字段，可用于确认连接处于活动状态，并实时传递消息。