Berdagang dengan Transaksi Praproses

preprocessedSubscribe mengalirkan transaksi yang telah ditandatangani sebelum mencapai tingkat commitment processed, yang didekode dari shred saat tiba di validator, tanpa memerlukan infrastruktur deshredding di sisi Anda. Panduan ini membuat pemantau yang mengawasi program perdagangan sebelum eksekusi, menghapus duplikasi dari feed, tetap berada di bawah batas tekanan balik server, dan merekonsiliasi dengan data processed sebelum mengambil tindakan.

Transaksi Praproses tersedia di semua paket berbayar dan dikenai biaya 0,1 kredit per pesan, dengan maksimal 10 koneksi bersamaan per API key.

Batasi cakupan langganan ke target Anda

Tidak ada stream tanpa filter: accountInclude dan accountRequired harus mencantumkan setidaknya satu akun di antara keduanya. Untuk pemantau perdagangan, sertakan program yang menjadi lawan perdagangan Anda dan kecualikan noise yang jika tidak akan tetap Anda bayar:

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

Filter digabungkan dengan AND, setiap daftar menerima hingga 5.000 alamat, dan Helius me-resolve tabel pencarian alamat di sisi server, sehingga akun yang dimuat melalui ALT tetap cocok. Untuk memantau interaksi dompet tertentu dengan program, masukkan keduanya ke bidang accountRequired.

Dekode frame dan hapus duplikasi berdasarkan signature

Notifikasi diterima sebagai frame biner: prefiks 73 byte, lalu transaksi yang diserialisasi dengan bincode. Signature berada di dalam prefiks sehingga Anda dapat menghapus duplikasi tanpa mendekode isi. Stream menggabungkan beberapa sumber praeksekusi, dan transaksi yang sama dapat diterima lebih dari sekali:

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

Pastikan loop penerimaan lebih cepat daripada stream

Helius tidak melakukan buffering tanpa batas untuk konsumen yang lambat: jika lebih dari 4.000 pesan menumpuk di sisi server, koneksi akan ditutup. Karena itu, handler di atas hanya membaca prefiks 73 byte dan memasukkannya ke antrean. Deserialisasi dan logika strategi berjalan dalam loop terpisah:

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);
  }
});

Jika antrean terus bertambah tanpa batas, persempit filternya. Setiap transaksi yang Anda buang di sisi klien tetap dikenai biaya 0,1 kredit dan tetap diperhitungkan dalam batas tekanan balik.

Rekonsiliasi dengan data processed

Transaksi praproses menunjukkan apa yang coba dilakukan pengirim, bukan apa yang benar-benar terjadi. Transaksi ini tidak memuat status eksekusi, perubahan saldo, atau log, serta dapat gagal, dibatalkan, atau masuk ke fork lain. Pengiriman dilakukan berdasarkan upaya terbaik tanpa pemutaran ulang historis, jadi:

Rekonsiliasi dengan transactionSubscribe pada commitment processed atau confirmed sebelum strategi Anda mencatat apa pun sebagai fakta.
Jika koneksi terputus, segera berlangganan kembali dan terima adanya celah karena tidak ada pemutaran ulang untuk mengisinya.
Jika Anda memerlukan status akun secara real-time alih-alih intensi transaksi, data tersebut hanya tersedia setelah eksekusi: gunakan LaserStream gRPC pada processed.

Mulai di Sini

Data Waktu Nyata

Perdagangan Latensi Rendah

Data Historis & Dompet

Panduan Metode RPC

Kesiapan Produksi

Menggunakan Orb

Panduan Praktis Lainnya

Berdagang dengan Transaksi Praproses

Batasi cakupan langganan ke target Anda

Dekode frame dan hapus duplikasi berdasarkan signature

Pastikan loop penerimaan lebih cepat daripada stream

Rekonsiliasi dengan data processed

Panduan terkait

preprocessedSubscribe reference

Trade on Preconfirmations

​Batasi cakupan langganan ke target Anda

​Dekode frame dan hapus duplikasi berdasarkan signature

​Pastikan loop penerimaan lebih cepat daripada stream

​Rekonsiliasi dengan data processed

​Panduan terkait

preprocessedSubscribe reference

Trade on Preconfirmations

Batasi cakupan langganan ke target Anda

Dekode frame dan hapus duplikasi berdasarkan signature

Pastikan loop penerimaan lebih cepat daripada stream

Rekonsiliasi dengan data processed

Panduan terkait