什么是 Solana 上的数据流?
数据流允许应用程序在 Solana 区块链上发生事件时接收实时更新。与其反复轮询更新,不如建立持久连接,当交易被处理、账户发生变化或区块生成时,立即将数据推送到您的应用程序。 这对于需要秒级数据的应用程序至关重要,例如:- 交易应用程序 监控价格变化和清算
- DeFi 协议 跟踪用户交互和状态变化
- NFT 市场 检测销售、上市和转移
- 分析平台 收集全面的区块链指标
- 钱包 显示实时余额和交易更新
为什么选择 Helius 进行数据流?
超低延迟
直接连接到Solana节点,确保数据传递在一秒以内
企业可靠性
多节点冗余和自动故障切换,确保99.9%的正常运行时间
24小时历史重播
自动回填功能确保不会错过数据
全球基础设施
在多个区域提供端点,以实现全球范围内的最佳性能
我应该使用哪个流媒体解决方案?
选择与您需要的数据阶段和您的应用想要如何消费它相匹配的产品。下表将每个选项映射到其传递形式和最适合的负载类型。| 解决方案 | 最适合 | 协议 | 延迟 | 计划 | 重播 |
|---|---|---|---|---|---|
| Shred Delivery (原始/预处理) | 高频交易、MEV、套利—预执行数据 | UDP / gRPC | 尽早 | VIP服务 (Beta) | ❌ |
| LaserStream gRPC | 关键任务的后端、索引器、多区域故障转移 | gRPC | 超低 | 商业+ (主网),开发者+ (测试网) | ✅ 24小时 |
| LaserStream WebSocket | Web应用、实时用户界面、广泛的客户端兼容性 | WebSocket | 低 | 免费+ | ❌ |
| Webhooks | 服务器到服务器的事件通知、低量集成 | HTTP POST | 推送 (可变) | 免费+ | ❌ |
根据您优化的目标进行选择
基于分片的产品和LaserStream的承诺水平处于交易生命周期的不同点。你要接收的内容和协议同样重要:| 目标 | 最快路径 |
|---|---|
| 最早的交易信号 | 原始碎片(UDP) → 预处理交易(gRPC)(大约比processed提前8毫秒)→ LaserStream gRPC 在 processed |
| 最早的账户/程序更新 | LaserStream gRPC 在 processed — 碎片和预处理交易仅携带交易数据,不包含账户状态。账户更新由执行期间的运行时生成,因此在处理完成之前不可用。 |
| 最早确认的交易或账户 | LaserStream gRPC 在 confirmed — 不会回滚的最快承诺级别 |
常见问题: 如果您需要实时的账户或程序状态变化(例如,监控AMM的绑定曲线账户或用户的代币余额),碎片传递无助于此 — 这些更新在碎片阶段不存在。请改用 LaserStream gRPC 在
processed。Helius 流解决方案
碎片传递(测试版)
碎片传递 是 Helius 的预执行数据产品。它有两种形式:- 原始碎片(UDP) — 最早的信号。Helius 是按股份计算的顶级验证者,因此我们在较低股份的验证者和未持股的RPC节点之前接收到碎片。您需要自行实现碎片重组。
- 预处理交易(gRPC,公开测试版) — 解码的碎片。跳过碎片重组步骤,平均比
processed承诺级别提前约8毫秒交付交易。任何专业计划订阅者都可以使用,每 1 MB 需 20 积分。
最佳用途
预执行数据非常适合于以毫秒计算盈利的低延迟关键策略:- 高频交易桌
- 套利交易员
- 清算系统
- MEV 搜索者
LaserStream gRPC(开发者+ Devnet,企业+ Mainnet)
LaserStream gRPC通过gRPC提供超低延迟数据流,具有历史重放、自动重连和多节点可靠性等高级功能。LaserStream与开放的Yellowstone gRPC协议线缆兼容,因此任何Yellowstone客户端都能正常工作。主要特点
- 开箱即用:无需管理硬件或升级即可获得更快的gRPC流
- 24小时历史重放:自动补充最多24小时的丢失数据
- 自动重连:内置连接管理和智能重试逻辑
- 全球终端:在全球9个地区提供,优化延迟
- Yellowstone兼容:可以替代现有
@triton-one/yellowstone-grpc设置
最佳适用
- 后端服务
- 高吞吐量应用程序
- 需要保证数据传输的关键任务系统
LaserStream WebSocket
LaserStream WebSocket是LaserStream的WebSocket协议变体。它提供标准的Solana JSON-RPC订阅方法(accountSubscribe,programSubscribe,logsSubscribe,…),以及Helius特定扩展如transactionSubscribe用于高级过滤,所有这些都在同一统一端点上,由与gRPC产品相同的LaserStream后端支持。
主要特点
- 完全支持Solana:兼容任何Solana WebSocket客户端库
- Helius扩展:
transactionSubscribe和增强的accountSubscribe用于更丰富的过滤 - 比标准Agave RPC基础的WebSockets快多达200毫秒
- 统一端点:
wss://mainnet.helius-rpc.com和wss://devnet.helius-rpc.com用于标准和Helius扩展方法
最佳适用
实时前端应用程序,中等量后端,广泛生态系统兼容性Webhooks
事件驱动的服务器到服务器的webhook通知,用于链上活动发送到您的端点。主要功能
- 解析事件数据:人类可读的交易数据,包括销售、交换等
- 多种类型:增强型、原始型和 Discord webhook 选项
- 交易过滤:订阅特定事件类型和地址
- 可靠传递:自动重试和传递确认
适用范围
事件驱动的架构、通知、与外部服务的集成入门指南
获取您的 API 密钥
在 dashboard.helius.dev 上注册并获取您的 API 密钥。
数据流快速入门
在几分钟内启动并运行您的第一个流连接
支持与社区
文档
所有流方法的综合 API 参考和指南
Discord 社区
加入数千名使用 Helius 在 Solana 上构建的开发者
企业支持
为企业和专业客户提供优先支持渠道