事前処理されたトランザクションでの取引

preprocessedSubscribe は署名されたトランザクションを processed コミットメントレベルに達する前にストリームするため、デシュレッディングのインフラを必要とせずに、トランザクションがバリデータに届くときにシュレッドからデコードされます。このガイドでは、取引プログラムを実行前に監視し、フィードを重複排除し、サーバーのバックプレッシャー制限内に留まり、処理済みデータと照合してから実行するモニターを構築します。

事前処理されたトランザクションはすべての有料プランで利用でき、1メッセージあたり0.1クレジットがかかり、1つのAPIキーで最大10の同時接続が可能です。

サブスクリプションをターゲットに絞る

フィルターされていないストリームはありません：accountInclude と accountRequired は少なくとも1つのアカウントをその間に指定する必要があります。取引モニターでは、取引するプログラムを含め、余計なノイズを除外してください。そうしないと余計なコストがかかります：

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preprocessedSubscribe",
  "params": {
    "accountInclude": ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"],
    "accountExclude": ["Vote111111111111111111111111111111111111111"],
    "accountRequired": []
  }
}

フィルターはANDで組み合わせられ、各リストは最大5,000のアドレスを受け入れ、Heliusはサーバー側でアドレスのルックアップテーブルを解決するため、ALTを通じてロードされたアカウントも一致します。特定のウォレットとプログラムとのインタラクションを監視するには、両方をaccountRequiredフィールドに入れます。

フレームをデコードし、署名で重複排除

通知はバイナリフレームとして届きます：73バイトのプレフィックスに続いて、bincodeでシリアル化されたトランザクションです。プレフィックスに署名が含まれているため、本体をデコードせずに重複排除できます。このストリームは複数の実行前ソースを集約しており、同じトランザクションが複数回届くことがあります：

monitor.js

const WebSocket = require('ws');
const bs58module = require('bs58');
const bs58 = bs58module.default ?? bs58module;

const ws = new WebSocket('wss://beta.helius-rpc.com/?api-key=YOUR_API_KEY');
const seen = new Set(); // rotate or expire entries in production
const queue = [];       // decode off the receive path; see next step

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preprocessedSubscribe',
    params: {
      accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4'],
      accountExclude: ['Vote111111111111111111111111111111111111111'],
      accountRequired: []
    }
  }));
  setInterval(() => ws.ping(), 30_000);
});

ws.on('message', (data, isBinary) => {
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // version (u8) | slot (u64 LE) | signature ([u8; 64]) | bincode(VersionedTransaction)
  const buf = Buffer.from(data);
  if (buf.readUInt8(0) !== 1) return; // unknown schema version; update your decoder
  const signature = bs58.encode(buf.subarray(9, 73));
  if (seen.has(signature)) return;
  seen.add(signature);

  queue.push({
    slot: buf.readBigUInt64LE(1),
    signature,
    txBytes: buf.subarray(73)
  });
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1)); // supervisor restarts and resubscribes

受信ループをストリームより速く保つ

Heliusは遅い消費者に無期限にバッファリングしません：サーバー側で4,000以上のメッセージがバックアップされた場合、接続は終了されます。そのため、上記のハンドラは73バイトのプレフィックスのみを読み取り、エンキューするという仕様です。デシリアライズと戦略ロジックは別のループで実行されます：

setImmediate(async function drain() {
  const { VersionedTransaction } = require('@solana/web3.js');
  while (true) {
    const item = queue.shift();
    if (!item) { await new Promise(r => setTimeout(r, 1)); continue; }
    const tx = VersionedTransaction.deserialize(item.txBytes);
    strategy.onPreExecution(item.slot, item.signature, tx);
  }
});

もしキューが無限に成長する場合は、フィルターを強化してください。クライアント側で破棄するトランザクションも、1件あたり0.1クレジットがかかり、バックプレッシャー制限にカウントされます。

処理済みデータと照合

事前処理されたトランザクションは、送信者が何をしようとしたかを示しますが、実際に何が起こったかは示しません。実行ステータス、残高変動、ログは含まれておらず、失敗したり、ドロップされたり、異なるフォークに着陸することがあります。配信は最善の努力で行われ、履歴のリプレイはないため：

あなたの戦略が何かを事実として記録する前に、transactionSubscribeで processed または confirmed コミットメントと照合します。
切断時には、隙間を受け入れながらただちに再サブスクライブしてください。バックフィルするリプレイがないためです。
取引の意図ではなく、リアルタイムのアカウント状態が必要な場合、それは実行後にのみ存在します：LaserStream gRPCをprocessedで使用してください。

preprocessedSubscribe リファレンス

完全なペイロードレイアウト、フィルタールール、バックプレッシャー、そして価格設定

事前確認での取引

スケジューラ自体からのHeliusが提供する最早のトランザクションシグナル

ここから始める

リアルタイムデータ

低遅延取引

履歴 & ウォレットデータ

RPCメソッドガイド

プロダクション準備

Orbを使用する

その他のハウツー

事前処理されたトランザクションでの取引

サブスクリプションをターゲットに絞る

フレームをデコードし、署名で重複排除

受信ループをストリームより速く保つ

処理済みデータと照合

関連ガイド

preprocessedSubscribe リファレンス

事前確認での取引

​サブスクリプションをターゲットに絞る

​フレームをデコードし、署名で重複排除

​受信ループをストリームより速く保つ

​処理済みデータと照合

​関連ガイド

preprocessedSubscribe リファレンス

事前確認での取引

サブスクリプションをターゲットに絞る

フレームをデコードし、署名で重複排除

受信ループをストリームより速く保つ

処理済みデータと照合

関連ガイド