preconfSubscribe

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

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeSource": ["helius"] }]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "instructions": [
        {
          "programId": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P",
          "memcmp": [
            {
              "offset": 0,
              "bytes": "66063d1201daebea",
              "encoding": "hex"
            }
          ]
        }
      ]
    }
  ]
}

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' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeSource: ['helius'] }]
  }));

  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) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM; may be 0 for other sources
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Preconfirmation:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        transaction index when available (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

启动 Preconfirmations 订阅——这些交易会在被收集到条目并转换为 shred 之前交付。这是 Helius 提供的最低延迟交易信号。一个订阅会同时传输 Helius 预确认和 BAM 预确认：前者在领导者执行交易的瞬间发出，并携带执行状态；后者在验证者承诺执行交易时发出。使用 includeSource 选择任一来源。

端点

preconfSubscribe 从 Helius Gatekeeper 端点提供服务：

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

beta 主机名指的是 Gatekeeper 投放，而不是预确认的成熟程度——随着流量迁移到 Gatekeeper，它将成为标准端点。

流不是连续的。覆盖范围随网络股份转发至 Helius 或运行 BAM 的份额而变化，因此预期有不带消息的槽位——优雅地处理这些间隙。参见覆盖范围。

授权

string

必填

你的 Helius API 密钥，作为 api-key 查询参数传递。所有付费套餐均可使用 Preconfirmations。

正文

array

可选。省略 params 以接收来自 Helius 和 BAM 的每个交易。要缩小流范围，请将过滤器对象作为第一个元素传递 — 过滤在服务器端发生，因此您只需支付并接收您关心的交易。

隐藏 Filter

所有字段均为可选字段——缺少某个字段表示该谓词“不设约束”，因此空过滤器会匹配来自两个来源的所有交易。已设置的字段使用 AND 组合，并按 includeSource → failed → regionInclude → signatures → accountExclude → accountRequired → accountInclude → signerExclude → signerInclude → instructions 的顺序求值。

string[]

默认值:"[]"

要接收的来源。支持的值为 helius 和 bam。省略该字段或传递空数组可接收两个来源。使用 ["helius"] 或 ["bam"] 仅接收一个来源。未知值和非数组值会返回 -32602（参数无效）。

为实现向后兼容，已弃用的 includeBam 过滤器仍然可用。includeBam: false 等同于 includeSource: ["helius"]。includeBam: true 或省略该字段会选择两个来源。请勿同时发送 includeBam 和 includeSource。

boolean

true 仅返回失败（已回滚）的交易；false 仅返回成功的交易。无论使用哪个值，都会排除状态未知的 Helius 交易。省略该字段可接收所有状态。如果状态未知的预确认与来源、区域、账户和签名者过滤器匹配，仍会被交付。

string[]

如果非空，交易必须来自这些区域中的任意一个。设置此字段后，没有区域信息的交易会被丢弃。

string[]

如果非空，交易必须引用这些账户（base58 公钥）中的至少一个。最多 10,000 个条目。

string[]

如果交易引用这些账户中的任意一个，则会被丢弃。其优先级高于 accountInclude。最多 10,000 个条目。

string[]

交易必须引用这些账户中的全部账户。最多 10,000 个条目。

string[]

如果非空，交易必须由这些账户中的至少一个签名。最多 10,000 个条目。

string[]

如果交易由这些账户中的任意一个签名，则会被丢弃。其优先级高于 signerInclude。最多 10,000 个条目。

string[]

如果非空，交易的第一个签名必须与这些 base58 签名中的任意一个匹配。最多 1,000 个条目。

object[]

如果非空，至少有一个顶层指令必须与这些指令过滤器中的任意一个匹配。最多 16 个条目。

显示 Instruction filter

string

必填

该指令所调用程序的 base58 公钥。

object[]

比较指令数据中指定偏移量处的已解码字节。所有条目都必须匹配。最多四个条目。每个条目都需要一个非负的 offset 和一个 bytes 字符串。可选的 encoding 可以是 base58、base64 或 hex，默认值为 base58。每个值解码后必须为 1–128 字节。

number

指令数据的确切字节长度。最大为 4,096 字节。

无效的来源、公钥、签名、指令过滤器或区域代码会返回 JSON-RPC 错误 -32602（参数无效）。将 includeSource 与已弃用的 includeBam 字段组合使用也会返回 -32602。指令过滤器仅检查顶层指令，不会匹配通过跨程序调用（CPI）调用的指令。memcmp 的结束偏移量和 dataSize 不得超过 4,096 字节。账户过滤器不仅匹配交易的静态账户密钥——Helius 会在服务器端解析 v0 地址查找表，因此 accountInclude、accountExclude 和 accountRequired 也会匹配交易通过 ALT 加载的账户。

区域代码

代码	位置	代码	位置
`slc`	盐湖城	`tyo`	东京
`fra`	法兰克福	`ams`	阿姆斯特丹
`lon`	伦敦	`dal`	达拉斯
`pit`	匹兹堡	`dub`	都柏林
`sgp`	新加坡	`mia`	迈阿密
`ewr`	纽瓦克	`lax`	洛杉矶
`iad`	阿什本	`sea`	西雅图
`hkg`	香港	`sqq`	立陶宛希奥利艾

对于 Helius 预确认，区域是 Helius 接收交易的位置。对于 BAM 预确认，区域是发出预确认的 BAM 区域端点，而不是 Helius 接收交易的位置。BAM 的新加坡和达拉斯端点分别映射到 sgp 和 dal。

响应

integer

订阅 ID（取消订阅时需要）

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

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeSource": ["helius"] }]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "instructions": [
        {
          "programId": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P",
          "memcmp": [
            {
              "offset": 0,
              "bytes": "66063d1201daebea",
              "encoding": "hex"
            }
          ]
        }
      ]
    }
  ]
}

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' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeSource: ['helius'] }]
  }));

  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) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM; may be 0 for other sources
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Preconfirmation:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        transaction index when available (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

通知

返回 JSON 确认后，通知会以二进制 WebSocket 帧（而非 JSON）的形式交付。Helius 和 BAM 预确认采用相同的布局。每个帧都是经过紧凑编码的字节布局，携带一笔交易：

字节	字段	类型	描述
0	`version`	`u8`	载荷架构版本。当前为 `1`。
1–8	`slot`	`u64`（小端序）	交易计划所在的时隙。
9–16	`tx_index`	`u64`（小端序）	交易在时隙中的索引（如果可用）。BAM 预确认始终报告 `0`；没有可用的交易索引时，其他来源也可能报告 `0`。
17	`status`	`u8`	交易状态：`0` = 失败，`1` = 成功，`2` = 未知。
18+	`transaction`	`bytes`	Solana 线格式的交易。请参阅解码交易。

载荷没有来源字段。不要根据 tx_index = 0 推断其来自 BAM，因为其他来源也可能报告 0。

始终先读取并检查 version 字节。 当前值为 1。如果 Helius 需要更新载荷格式，版本号将递增——请根据版本号进行分支处理，以确保解码器在架构变更后仍能正常工作。

预确认是一种早期信号，而非保证。交易尚未落到链上，仍可能失败或被丢弃。在将其视为最终结果之前，请通过标准确认级别检查来确认交易已落地。

解码交易

交易字节会完全按照验证者序列化的结果转发，并采用该交易版本的标准线编码。旧版和 v0 交易使用 bincode 生成的签名优先布局。交易 v1（SIMD-0385）使用消息优先布局，签名位于末尾，因此 bincode 无法处理 v1 载荷。请使用可处理所有版本的解码器。在 Rust 中，agave-transaction-view 可就地解析旧版、v0 和 v1 交易，是推荐选项；搭配当前 Solana SDK VersionedTransaction 使用的 wincode 也可以。在 JavaScript 中，请确保你的库版本支持交易 v1。有关 Rust 示例，请参阅指南。

重复通知

Helius 和 BAM 预确认会分别按来源去重，而不会跨来源去重。一小部分交易会同时通过两者到达 Helius，因此你可能会收到两次相同的签名，而且两份通知可能报告不同的时隙。请在客户端按签名去重，并确保由交易触发的操作具有幂等性。请参阅指南。

定价

Preconfirmations 适用于所有付费套餐：Developer、Business、Professional 和 Enterprise。免费套餐不符合使用条件。详情请参阅积分。即使某个时隙在 Preconfirmations 的覆盖范围内，只要交付的消息数为零，就不会消耗积分。当某个时隙至少交付一条消息时，每个打开的 preconfSubscribe 订阅将按 300 积分或每条已交付消息 10 积分中的较高者计费。未覆盖的时隙不消耗积分。有关来源和区域的计费资格，请参阅定价。

覆盖时隙中交付的消息数	计费积分
0	0
10	300
30	300
100	1,000

每个并发订阅在收到至少一条消息时都会单独计费。使用 preconfUnsubscribe 关闭不再需要的订阅。使用 includeSource: ["helius"] 时，仅由 BAM 覆盖的时隙不会计费。设置 regionInclude 后，所选区域之外的覆盖时隙不会消耗该订阅的积分；只有当订阅收到至少一条消息时，匹配的时隙才会计费。计费按消息计算，而不是按唯一签名计算。如果一笔交易同时由 Helius 和 BAM 交付，则会计算两次。如果你只需要 Helius Preconfirmations，请设置 includeSource: ["helius"]。

为了控制成本，请尽可能将账户过滤器合并到一个订阅中，使用 regionInclude 将计费限制在你需要的区域，不需要 BAM 时设置 includeSource: ["helius"]，并在 Helius 控制面板中监控积分。

Preconfirmations Overview

了解 Preconfirmations 的含义及其在验证者流水线中的位置。

preconfUnsubscribe

使用订阅 ID 停止订阅。

⌘I

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

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeSource": ["helius"] }]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "instructions": [
        {
          "programId": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P",
          "memcmp": [
            {
              "offset": 0,
              "bytes": "66063d1201daebea",
              "encoding": "hex"
            }
          ]
        }
      ]
    }
  ]
}

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' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeSource: ['helius'] }]
  }));

  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) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM; may be 0 for other sources
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Preconfirmation:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        transaction index when available (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

开始使用

交易

发送交易

账户管理

端点

授权

正文

区域代码

响应

通知

解码交易

重复通知

定价

相关内容

Preconfirmations Overview

preconfUnsubscribe

​端点

​授权

​正文

​区域代码

​响应

​通知

​解码交易

​重复通知

​定价

​相关内容

Preconfirmations Overview

preconfUnsubscribe

端点

授权

正文

区域代码

响应

通知

解码交易

重复通知

定价

相关内容