Mit vorverarbeiteten Transaktionen handeln

preprocessedSubscribe überträgt signierte Transaktionen, bevor sie das Commitment-Level processed erreichen. Die Transaktionen werden direkt bei ihrer Ankunft am Validator aus shreds decodiert. Du benötigst dafür keine eigene Infrastruktur zum Zusammensetzen der shreds. In diesem Leitfaden erstellst du einen Monitor, der ein Handelsprogramm vor der Ausführung beobachtet, doppelte Einträge aus dem Feed entfernt, unter dem Backpressure-Limit des Servers bleibt und die Daten vor einer Aktion mit verarbeiteten Daten abgleicht.

Vorverarbeitete Transaktionen sind in allen kostenpflichtigen Tarifen verfügbar und kosten 0,1 Credits pro Nachricht. Pro API key sind bis zu 10 gleichzeitige Verbindungen möglich.

Beschränke das Abonnement auf dein Ziel

Es gibt keinen ungefilterten Stream: accountInclude und accountRequired müssen zusammen mindestens ein Konto angeben. Füge für einen Handelsmonitor das Programm hinzu, mit dem du handelst, und schließe irrelevante Daten aus, für die du sonst bezahlen würdest:

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

Filter werden mit AND kombiniert. Jede Liste akzeptiert bis zu 5.000 Adressen. Helius löst Adress-Lookup-Tabellen serverseitig auf, sodass auch ein über eine ALT geladenes Konto übereinstimmt. Wenn du die Interaktionen einer bestimmten Wallet mit dem Programm beobachten möchtest, trage stattdessen beide in das Feld accountRequired ein.

Decodiere Frames und entferne Duplikate anhand der Signatur

Benachrichtigungen treffen als binäre Frames ein: zuerst ein Präfix mit 73 Byte, danach die mit bincode serialisierte Transaktion. Die Signatur befindet sich im Präfix. Du kannst Duplikate daher entfernen, ohne den Inhalt zu decodieren. Der Stream bündelt mehrere Quellen vor der Ausführung, sodass dieselbe Transaktion mehrfach eintreffen kann:

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

Verarbeite Daten schneller, als der Stream sie liefert

Helius puffert Daten für langsame Verbraucher nicht unbegrenzt. Wenn sich serverseitig mehr als 4.000 Nachrichten stauen, wird die Verbindung geschlossen. Deshalb liest der obige Handler nur das 73-Byte-Präfix und stellt die Nachricht in die Warteschlange. Die Deserialisierung und die Strategielogik laufen in einer separaten Schleife:

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

Wenn die Warteschlange unbegrenzt wächst, schränke die Filter stärker ein. Transaktionen, die du clientseitig verwirfst, kosten weiterhin jeweils 0,1 Credits und werden weiterhin auf das Backpressure-Limit angerechnet.

Gleiche die Daten mit verarbeiteten Daten ab

Eine vorverarbeitete Transaktion zeigt, was der Absender versucht hat, nicht was tatsächlich passiert ist. Sie enthält weder einen Ausführungsstatus noch Kontostandsänderungen oder Protokolle. Sie kann fehlschlagen, verworfen werden oder auf einem anderen Fork landen. Die Zustellung erfolgt nach dem Best-Effort-Prinzip und ohne historisches Replay. Deshalb gilt:

Gleiche die Transaktion bei einem Commitment von processed oder confirmed mit transactionSubscribe ab, bevor deine Strategie etwas als Tatsache verbucht.
Stelle nach einem Verbindungsabbruch sofort ein neues Abonnement her und akzeptiere die Lücke. Es gibt kein Replay für einen backfill.
Wenn du statt Transaktionsabsichten den Kontostatus in Echtzeit benötigst, ist dieser erst nach der Ausführung verfügbar. Verwende LaserStream gRPC mit dem Commitment processed.

preprocessedSubscribe reference

Vollständige Struktur des payload, Filterregeln, Backpressure und Preise

Trade on Preconfirmations

Das früheste Transaktionssignal von Helius, direkt vom Scheduler

Hier starten

Echtzeitdaten

Trading mit niedriger Latenz

Historische Daten und Wallet-Daten

Anleitungen zu RPC-Methoden

Produktionsreife

Orb verwenden

Weitere Anleitungen

Mit vorverarbeiteten Transaktionen handeln

Beschränke das Abonnement auf dein Ziel

Decodiere Frames und entferne Duplikate anhand der Signatur

Verarbeite Daten schneller, als der Stream sie liefert

Gleiche die Daten mit verarbeiteten Daten ab

Verwandte Leitfäden

preprocessedSubscribe reference

Trade on Preconfirmations

​Beschränke das Abonnement auf dein Ziel

​Decodiere Frames und entferne Duplikate anhand der Signatur

​Verarbeite Daten schneller, als der Stream sie liefert

​Gleiche die Daten mit verarbeiteten Daten ab

​Verwandte Leitfäden

preprocessedSubscribe reference

Trade on Preconfirmations

Beschränke das Abonnement auf dein Ziel

Decodiere Frames und entferne Duplikate anhand der Signatur

Verarbeite Daten schneller, als der Stream sie liefert

Gleiche die Daten mit verarbeiteten Daten ab

Verwandte Leitfäden