如何使用 preconfSubscribe

使用 Sender Max（最低小费：0.001 SOL）来处理预确认。 预确认只有在您的交易首先抵达时才有回报——Sender Max 是最快的方法。从一开始就使用 Sender Max 来充分利用预确认。

什么是`preconfSubscribe`？

preconfSubscribe 是一种 Helius WebSocket 方法，它流式传输 Preconfirmations——在交易被分解之前在预定交易阶段交付的交易。这是 Helius 提供的最低延迟交易信号。访问需要专业计划或更高级别——请参见定价。

流不是连续的。覆盖范围随着转发到 Helius 的权益份额而波动，因此请预料到会有没有消息的插槽——请优雅地处理这些间隙。参见覆盖范围。

preconfSubscribe 从 wss://beta.helius-rpc.com 提供服务 —— Helius Gatekeeper 端点 —— 而不是 mainnet.helius-rpc.com。使用您的 API 密钥作为查询参数进行认证。

wss://beta.helius-rpc.com/?api-key=<API_KEY>

beta 主机名指的是 Gatekeeper 的发布，而不是预确认的成熟度。预确认首先在 Gatekeeper 端点启动；随着 Helius 将流量迁移到 Gatekeeper，它将成为标准端点。

过滤

默认情况下，preconfSubscribe 会流动每个计划的交易。要缩小流，请将过滤对象作为 params 的第一个元素传递。过滤在服务器端进行，因此您只需支付并接收您关心的交易。

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "failed": false,
      "regionInclude": ["ewr", "fra"],
      "accountInclude": ["9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM"],
      "accountExclude": ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"],
      "accountRequired": ["11111111111111111111111111111111"]
    }
  ]
}

每个字段都是可选的——缺失的字段意味着该谓词没有“约束”，因此一个空的过滤器（或没有 params）匹配每个交易。

字段	类型	语义
`failed`	`boolean`	`false` 丢弃失败（回滚）的交易；成功和未知状态的交易仍会通过。`true` — 类似于省略该字段 — 保留每个状态。
`regionInclude`	`string[]`	如果非空，则交易必须来自这些地区中的一个。
`accountInclude`	`string[]`	如果非空，则交易必须引用这些账户中的至少一个。
`accountExclude`	`string[]`	如果交易引用了这些账户中的任何一个，则将其丢弃。优先于 `accountInclude`。
`accountRequired`	`string[]`	交易必须引用所有这些账户。

过滤规则：

所有谓词按 regionInclude → accountExclude → accountRequired → accountInclude 的顺序进行按位和。
帐户是 base58 编码的公钥。无效值将返回 JSON-RPC 错误 -32602（无效参数）。
每个账户列表最多包含 500 条目。

地址查找表 (ALT) 解析

账户过滤器匹配的不仅仅是交易的静态账户密钥——Helius 在服务器端解析 v0 地址查找表，因此 accountInclude、accountExclude 和 accountRequired 也会匹配通过 ALT 加载的账户。这意味着您可以过滤交易接触到的任何账户，即使它仅出现在查找表后面——无需维护 ALT 映射或自行解析表。只需传递账户的公钥，Helius 会在应用过滤器之前处理解析。

位置过滤

使用 regionInclude 来只接收来自特定 Helius 区域的交易。传递一个或多个区域代码；当其起始区域与其中任何一个匹配时，交易将通过。

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "regionInclude": ["ewr", "fra"] }]
}

有效的区域代码：

Code	Location
`slc`	盐湖城
`fra`	法兰克福
`lon`	伦敦
`pit`	匹兹堡
`sgp`	新加坡
`ewr`	纽瓦克
`tyo`	东京
`ams`	阿姆斯特丹
`dal`	达拉斯
`dub`	都柏林
`mia`	迈阿密
`lax`	洛杉矶
`iad`	阿什本
`sea`	西雅图

当设置 regionInclude 时，不携带区域信息的交易将被丢弃。未识别的区域代码将返回 JSON-RPC 错误 -32602（无效参数）。

通知有效负载

通知以 二进制 WebSocket 帧（而不是 JSON）传递。每个帧都是一个打包的字节布局，携带一个预定的交易：

字节	字段	类型	描述
0	`version`	`u8`	有效负载模式版本。目前为 `1`。
1–8	`slot`	`u64`（小端）	交易预定在的插槽。
9–16	`tx_index`	`u64`（小端）	插槽内交易的索引。
17	`status`	`u8`	交易状态：`0` = 失败，`1` = 成功，`2` = 未知。执行状态由验证者根据最大努力基础报告——如果不可用，则为 `2`。
18+	`transaction`	`bincode(VersionedTransaction)`	预定的交易，bincode 序列化。

按顺序读取字段，然后将剩余字节 bincode 反序列化为 VersionedTransaction 以读取指令、账户和签名。

始终首先读取和检查 version 字节。 目前为 1。如果 Helius 需要更新有效负载格式，版本将递增——根据版本进行分支，以便解码器在模式变更时继续工作。

预确认是一个早期信号，而不是保证。交易尚未上链，仍可能失败或被丢弃。通过标准承诺检查确认上链后再将其视为最终状态。

示例

const WebSocket = require('ws');

const ws = new WebSocket('wss://beta.helius-rpc.com/?api-key=<API_KEY>');

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe'
    // Optional: only successful txs from EWR/FRA touching a given account
    // params: [{ failed: false, regionInclude: ['ewr', 'fra'], accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
  }));

  // Keep the connection alive
  setInterval(() => ws.ping(), 30_000);
});

ws.on('message', (data, isBinary) => {
  // The subscribe acknowledgement arrives as a JSON text frame
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // Notifications arrive as binary frames:
  // version (u8) | slot (u64 LE) | tx_index (u64 LE) | status (u8) | bincode(VersionedTransaction)
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0); // currently 1 — branch on this if it changes
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9);
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const txBytes = buf.subarray(18); // bincode-serialized VersionedTransaction

  console.log('Scheduled transaction:', { version, slot, txIndex, status, bytes: txBytes.length });
  // Deserialize txBytes (bincode) into a VersionedTransaction with your Solana tooling
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1));

取消订阅

要停止接收通知，请使用从 preconfSubscribe 返回的订阅 ID 调用 preconfUnsubscribe。

{
  "jsonrpc": "2.0",
  "id": 2,
  "method": "preconfUnsubscribe",
  "params": [24040]
}

{
  "jsonrpc": "2.0",
  "result": true,
  "id": 2
}

定价

预确认需要 专业计划或更高级别 并且每条消息花费 10 积分——每个流式交易一条消息——从您的计划中扣除。详情请参阅积分。

预确认是一款新产品，定价可能会有所变更。

Preconfirmations Overview

什么是预确认以及它们在验证器流程中的位置。

transactionSubscribe

使用丰富的过滤功能流式传输已确认提交的交易。

preconfSubscribe API reference

请求参数、过滤字段和二进制通知布局。

入门指南

数据流和事件监听

数据 API 和 RPC

交易

发送交易

钱包服务

隐私

指南

资源

如何使用 preconfSubscribe

什么是`preconfSubscribe`？

订阅

订阅响应

过滤

地址查找表 (ALT) 解析

位置过滤

通知有效负载

示例

取消订阅

定价

相关

Preconfirmations Overview

transactionSubscribe

preconfSubscribe API reference

​什么是preconfSubscribe？

​订阅

​订阅响应

​过滤

​地址查找表 (ALT) 解析

​位置过滤

​通知有效负载

​示例

​取消订阅

​定价

​相关

Preconfirmations Overview

transactionSubscribe

preconfSubscribe API reference

什么是`preconfSubscribe`？

订阅

订阅响应

过滤

地址查找表 (ALT) 解析

位置过滤

通知有效负载

示例

取消订阅

定价

相关