Kalshi Edge 订阅者连接
连接到 DoubleZero 即表示我同意 DoubleZero 使用条款。请注意,数据仅供您内部使用,不得转播(参见第 2(e) 节)。
Kalshi 数据源通过 DoubleZero Edge 网络以 UDP 组播方式传送永续合约和体育市场数据。共有四个数据源:
- 永续合约最优报价 (TOB)
- 永续合约逐档行情 (MBP)
- 体育最优报价 (TOB)
- 体育逐档行情 (MBP)
我应该选择哪种方式?
| # | 方式 | 最适合 | 工作量 |
|---|---|---|---|
| 1 | Edge Connect | 希望通过简单 CLI 和 WebSocket 解码 JSON 获取数据的代理和应用 | 最低 |
| 2 | 原生组播 | 自行构建针对原始线路格式的解码器 | 最高 |
在选择任何方式之前:请在 doublezero.xyz/edge/subscribe 购买所需的数据源。购买即表示您同意 DoubleZero 使用条款 和 Kalshi 服务条款。
1. Edge Connect(推荐)
从这里开始。 doublezero-edge-connect 是对代理友好的方式:一条安装命令,主机加入 DoubleZero,您的应用通过 WebSocket 上的解码 JSON(ws://<host>:8081)消费数据,无需解码二进制组播。
Edge Connect 满足其不断增长的用户群的需求。这是最简单的连接方法,除非您有特定的技术需求,否则应优先使用此方式。
简要步骤:
curl -fsSL https://get.doublezero.xyz/connect | bash
安装程序会要求您输入密钥:一个 DZ_… 访问令牌或拥有访问通行证 / 数据源购买的 Solana 密钥对 JSON 文件的路径。
如果主机上已经运行了 doublezerod,它和容器自身的守护进程都会绑定 UDP 端口 44880,因此容器的守护进程在启动后会立即退出。安装程序会提示停止并禁用主机守护进程,当设置了 DZ_ASSUME_YES=1 时则无需询问直接执行。手动操作方法:
sudo systemctl stop doublezerod
sudo systemctl disable doublezerod
然后在容器内部验证状态(期望看到 BGP Session Up 和您的 Kalshi 组),并将 WebSocket 客户端连接到 :8081:
docker exec doublezero-edge-connect doublezero status
WebSocket 协议: PROTOCOL.md。
2. 原生组播(高级)
需要更深入的技术知识
原生组播意味着您自行加入组播组并在主机上解码 原始 Edge 线路格式。只有技术能力最强的用户才应选择此方式。您需要阅读并理解相关规范,从 market-by-price/spec.md 和 edge-feed-spec 的其余部分开始。除非您有必须自行拥有解码器的硬性要求,否则请优先选择 Edge Connect。
DoubleZero 客户端设置
按照设置说明安装和配置 DoubleZero 客户端。保持客户端为最新版本:
sudo apt update && sudo apt install doublezero
购买数据源
在 doublezerod 运行的情况下,购买前先确定延迟最低的设备:
doublezero latency
在 https://doublezero.xyz/edge/subscribe 购买。
配置防火墙
允许 GRE、BGP、PIM 和 Kalshi 数据源流量。Kalshi UDP 端口范围为 30000–59999:首位数字是流量类别(3 行情数据、4 参考数据、5 快照),第二位数字是数据源编号,因此参考数据端口始终是行情数据端口 + 10000,快照端口始终是行情数据端口 + 20000。在 doublezero1 上开放整个端口段,这样新增频道和数据源无需再次修改防火墙 — 参见数据源地址。
iptables:
sudo iptables -A OUTPUT -p gre -j ACCEPT
sudo iptables -A INPUT -i doublezero1 -s 169.254.0.0/16 -d 169.254.0.0/16 -p tcp --dport 179 -j ACCEPT
sudo iptables -A OUTPUT -o doublezero1 -s 169.254.0.0/16 -d 169.254.0.0/16 -p tcp --dport 179 -j ACCEPT
sudo iptables -A OUTPUT -o doublezero1 -p pim -j ACCEPT
# Kalshi 行情 / 参考 / 快照(所有数据源)
sudo iptables -A INPUT -i doublezero1 -p udp --dport 30000:59999 -j ACCEPT
UFW:
sudo ufw allow proto gre from any to any
sudo ufw allow in on doublezero1 from 169.254.0.0/16 to 169.254.0.0/16 port 179 proto tcp
sudo ufw allow out on doublezero1 from 169.254.0.0/16 to 169.254.0.0/16 port 179 proto tcp
# Kalshi 行情 / 参考 / 快照(所有数据源)
sudo ufw allow in on doublezero1 to any port 30000:59999 proto udp
UFW 没有 pim 协议。出站 PIM 由 UFW 的默认出站策略允许;如果您拒绝出站流量,请在 /etc/ufw/before.rules 中为 PIM 添加原始规则。
订阅
加入您购买的所有数据源(客户端 v0.35.0 或更高版本):
doublezero connect multicast
或通过数据源代码指定数据源,以空格分隔:
doublezero connect multicast --subscribe-feed kalshi-perps-tob kalshi-perps-mbp kalshi-sports-tob kalshi-sports-mbp
使用数据源代码(kalshi-…),而不是每个都市区的数据源名称,也不是组代码(edge-kalshi-…)。对已购买的通行证使用 --subscribe 按组代码订阅会失败。
期望看到 ✅ User Provisioned。等待约 60 秒,然后:
doublezero status
期望在正确的 DoubleZero 网络上看到 BGP Session Up。
doublezero user list --client-ip <your ip>
您的数据源会显示在 groups 列中。使用以下命令查看组 IP:
doublezero multicast group list
自行解码线路格式
Schema 版本为 3 — 丢弃解码器未实现版本的数据报。权威布局定义:edge-feed-spec,包括 market-by-price/spec.md。
每个数据报以 24 字节的数据报头部开始,后面跟一个或多个应用消息,打包至 MTU 上限。数据报为小端序和固定布局。
| 字段 | 说明 |
|---|---|
| Magic | 偏移 0 处的 u16:TOB 为 0x445A,MBP 为 0x4442。需验证此值。 |
| Schema 版本 | 3 |
| 频道 ID | 用于多路分解共享端口的频道 |
| 序列号 | 按源 IP 地址、频道 ID 和目标端口单调递增 — 每个端口有独立的序列。用于间隔检测。 |
| 发送时间戳 | 自 Unix 纪元以来的纳秒数 |
| 消息计数 | 此数据报中打包的消息数 |
| 重置计数 | 任何变化(包括 255 → 0 的回绕)即为重置;丢弃该发布者的频道状态。MBP 也可能在会话中因场所级别的重新种子而递增此值。 |
| 数据报长度 | 总字节数 |
应用消息 (TOB)
| 类型 | ID | 大小 | 端口 | 内容 |
|---|---|---|---|---|
| Heartbeat | 0x01 |
16 B | market | 市场安静时的活跃性探测 |
| InstrumentDefinition | 0x02 |
130 B | reference | 合约代码、指数、最小价格变动和最小手数、到期时间 |
| Quote | 0x03 |
60 B | market | 最优买价和卖价、价格和数量、更新标志 |
| Trade | 0x04 |
52 B | market | 价格、数量、主动方向、成交 ID |
| EndOfSession | 0x06 |
12 B | market | 正常关闭 |
| ManifestSummary | 0x07 |
24 B | reference | 有效标志、Manifest Seq 变更计数器、合约数量、时间戳 |
| PerpStats | 0x30 |
124 B | sibling | 资金费率、标记价和预言机价、持仓量、日成交量 |
Kalshi 在 edge-feed-spec 注册表中的 Source ID 为 3。从每个 InstrumentDefinition 中读取 price_exponent 和 qty_exponent — 不要硬编码它们。
MBP 数据源使用 market-by-price 消息集。请参阅 edge-feed-spec 中的 market-by-price 和 reference-data 规范。
传输采用即发即忘的 UDP,无重传,参考数据端口不修复行情数据:它仅重复发送 InstrumentDefinition(至少每 30 秒一次)和 ManifestSummary(至少每 1 秒一次)。丢失的 TOB Quote 在该市场的最优买价或卖价发生变化之前将一直丢失。只有 MBP 数据源有修复路径 — 快照循环 — 且 MBP 冷启动必须绑定快照端口。基于 (合约 ID, 成交 ID) 去重成交记录,切勿仅使用成交 ID。
数据源地址
| 数据源代码 | 组代码 | 描述 | 组播组 | 行情数据 | 参考数据 | 快照 |
|---|---|---|---|---|---|---|
kalshi-perps-tob |
edge-kalshi-perps-tob |
永续合约最优报价 | 233.84.178.3 |
31000 |
41000 |
— |
kalshi-perps-mbp |
edge-kalshi-perps-mbp |
永续合约逐档行情 | 233.84.178.4 |
32000 |
42000 |
52000 |
kalshi-sports-tob |
edge-kalshi-sports-tob |
体育最优报价 | 233.84.178.17 |
33000 + id |
43000 + id |
— |
kalshi-sports-mbp |
edge-kalshi-sports-mbp |
体育逐档行情 | 233.84.178.20 |
34000 + id |
44000 + id |
54000 + id |
使用数据源代码订阅;doublezero status 和 multicast group list 显示组代码。
端口方案:首位数字是流量类别(3 行情、4 参考、5 快照);第二位数字是数据源编号。参考数据端口 = 行情数据端口 + 10000;快照端口 = 行情数据端口 + 20000。永续合约端口是固定的。体育端口为 基础端口 + 频道 id(例如,edge-kalshi-sports-mbp 上 id 为 10 的频道使用 34010 / 44010 / 54010)。
组选择数据源;端口选择其中的行情数据、参考数据或快照。组播复制按源 IP 地址和组进行,网络架构不检查 UDP 端口,因此加入一个组会通过 DoubleZero 隧道传送该组上的所有内容。端口是在字节到达后在您自己的主机上应用的套接字过滤器。
故障排除
如果您遇到此处未涵盖的问题,请在进行变通处理之前通过现有渠道联系我们。如果您没有现有渠道,请参阅支持。
确保客户端为最新版本
运行:sudo apt update && sudo apt install doublezero
没有数据报到达
- 确认已在 https://doublezero.xyz/edge/subscribe 购买了数据源。未购买的数据源不会传送流量。
- 确认 BGP 已建立:
doublezero status应在正确的 DoubleZero 网络上显示BGP Session Up。 - 确认订阅处于活动状态:
doublezero user list --client-ip <your ip>应在groups下列出该数据源。 - 确认已在正确的接口上加入组播组。组播到达
doublezero1,而不是doublezero0。 - 确认防火墙允许数据源的 UDP 端口在
doublezero1上的入站流量。
序列间隔
按源 IP 地址、频道 ID 和目标端口跟踪序列号;仅按频道 ID 跟踪的解码器会看到虚假间隔。真正的间隔意味着数据报丢失。在 MBP 数据源上,受影响的市场会在下一个快照循环中恢复。在 TOB 数据源上没有修复机制:市场的报价在其最优买价或卖价下次变化时才会恢复为最新。
重置计数变化
重置计数的任何变化意味着该发布者重新启动或重新种子了频道。丢弃该源 IP 地址和频道的状态,从参考数据端口重新收集定义,在 MBP 数据源上从快照端口重建订单簿。
隧道未建立
- Edge Connect: 在容器内运行状态检查 —
docker exec doublezero-edge-connect doublezero status。当数据源正常时,主机上的doublezero status通常会失败(容器拥有守护进程)。确认主机doublezerod已停止。 - 原生方式: 验证主机守护进程正在运行:
sudo systemctl status doublezerod - 验证防火墙规则已就位(GRE、BGP、PIM 以及
doublezero1上的数据源端口) - 从连接的同一位置(容器或主机)检查连接状态 — 期望在正确的 DoubleZero 网络上看到
BGP Session Up
客户端 IP 从主机的公网 IP 自动发现。验证它与您购买数据源时使用的 IP 是否匹配。
研究参考设计
可选。如果您已在主机上拥有 DoubleZero 隧道和订阅,并希望记录和图表化数据源数据,研究参考设计通过 Docker Compose 运行 组播 → 解析器 → topofbook-bot → ClickHouse → Grafana 流水线:
github.com/malbeclabs/edge-multicast-ref/tree/main/demo
此示例指向 Kalshi 永续合约 TOB。如需其他数据源,请使用数据源地址中对应的组和端口:
cd demo
cp .env.example .env
sed -i -e 's/^DZ_MULTICAST_GROUP=.*/DZ_MULTICAST_GROUP=233.84.178.3/' \
-e 's/^DZ_MARKETDATA_PORT=.*/DZ_MARKETDATA_PORT=31000/' \
-e 's/^DZ_REFDATA_PORT=.*/DZ_REFDATA_PORT=41000/' \
-e 's/^DZ_INTERFACE=.*/DZ_INTERFACE=doublezero1/' .env
docker compose up -d --build
Grafana 通常在主机的 http://localhost:3000 上访问。详情和仪表板:demo README。
这只是将您已经接收的数据可视化。它不能替代数据源购买、订阅或上述任何一种连接方式。