Mit Preconfirmations handeln

Preconfirmations überträgt Transaktionen per stream, bevor sie zu shred verarbeitet werden. Helius sendet Preconfirmations in dem Moment, in dem der Leader sie ausführt, zusammen mit ihrem Ausführungsstatus. In diesem Leitfaden erstellst du einen Listener, der ein Zielkonto überwacht, jede Transaktion dekodiert und mit Sender Max reagiert.

Preconfirmations sind in allen kostenpflichtigen Tarifen verfügbar und kosten 10 Credits pro zugestellter Nachricht. Für einen slot ohne zugestellte Nachrichten fallen keine Credits an. Sobald ein slot mindestens eine Nachricht zustellt, gilt für jedes Abonnement ein Mindestbetrag von 300 Credits. Weitere Informationen findest du unter Preise.

Grenze den stream ein, bevor du dich verbindest

Ein ungefiltertes preconfSubscribe stellt jede Transaktion für jeweils 10 Credits zu. Filtere serverseitig, damit dir nur die Transaktionen berechnet werden, mit denen du handelst. Jedes Abonnement wird unabhängig abgerechnet, sobald es in einem berechtigten, abgedeckten slot mindestens eine Nachricht empfängt. Fasse Kontofilter daher nach Möglichkeit in einem Abonnement zusammen. Verwende regionInclude, um die Abrechnung auf die benötigten Regionen zu beschränken. Lege includeSource: ["helius"] fest, wenn du BAM nicht benötigst, und überwache deine Credits im Helius Dashboard.

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "includeSource": ["helius"],
      "failed": false,
      "regionInclude": ["ewr"],
      "accountInclude": ["TARGET_WALLET_OR_PROGRAM"]
    }
  ]
}

Drei Filter decken die meisten Trading-Listener ab:

failed: false verwirft Transaktionen, von denen bereits bekannt ist, dass sie rückgängig gemacht wurden. Es gibt keinen Grund, bei ihnen um Schnelligkeit zu konkurrieren.
regionInclude bindet den stream an die Region, die deiner Infrastruktur am nächsten liegt. So verbraucht ein regionsübergreifender Hop nicht deinen Vorsprung.
accountInclude findet jede Transaktion, die dein Ziel referenziert, etwa eine Wallet, einen AMM-Pool oder ein Programm. Helius löst Address Lookup Tables serverseitig auf. Der Filter greift daher auch, wenn das Konto über eine ALT geladen wird.

Verbinden, abonnieren und dekodieren

preconfSubscribe wird über den Gatekeeper endpoint (wss://beta.helius-rpc.com) bereitgestellt. Benachrichtigungen kommen als binäre Frames statt als JSON an. Jeder Frame besteht aus einem festen 18-Byte-Präfix, gefolgt von der mit bincode serialisierten Transaktion:

listener.js

const WebSocket = require('ws');
const { VersionedTransaction } = require('@solana/web3.js');

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

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe',
    params: [{
      failed: false,
      regionInclude: ['ewr'],
      accountInclude: ['TARGET_WALLET_OR_PROGRAM']
    }]
  }));
  setInterval(() => ws.ping(), 30_000); // keep the connection alive
});

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) | tx_index (u64 LE) | status (u8) | bincode(VersionedTransaction)
  const buf = Buffer.from(data);
  if (buf.readUInt8(0) !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const tx = VersionedTransaction.deserialize(buf.subarray(18));

  onScheduledTransaction({ slot, status, tx });
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1)); // let your supervisor restart and resubscribe

Prüfe zuerst das Versionsbyte. Wenn Helius das payload-Format aktualisiert, wird die Version erhöht. Eine Verzweigung anhand der Version sorgt dafür, dass dein Decoder weiter funktioniert. Die deserialisierte Transaktion liefert dir die Anweisungen, Konten und die Signatur.

Mit Sender Max reagieren

Eine Preconfirmation lohnt sich nur, wenn deine response zuerst landet. Sende deine Reaktion über Sender Max: Der Tip von 0,001 SOL gelangt in den Priority-Tip-Puffer und wird über alle Hochgeschwindigkeitsrouten weitergeleitet:

async function onScheduledTransaction({ slot, status, tx }) {
  if (!strategy.shouldReact(tx)) return;

  // strategy is your own code: it decides whether to react and returns a
  // signed, base64-encoded transaction that includes the tip and priority fee
  const reaction = await strategy.buildTransaction(tx);
  await fetch('http://ewr-sender.helius-rpc.com/fast', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      jsonrpc: '2.0',
      id: Date.now().toString(),
      method: 'sendTransaction',
      params: [reaction, { encoding: 'base64', skipPreflight: true, maxRetries: 0 }]
    })
  });
}

Halte diesen Handler kurz. Entscheide und sende. Verschiebe Logging, Abrechnung und Abstimmung aus dem Empfangspfad. Unter Trades mit Sender landen findest du den vollständigen Sendeablauf, einschließlich des Aufwärmens der Verbindung und der Gebührenschätzung.

Landung bestätigen und mit Lücken rechnen

Eine Preconfirmation bietet nur einen frühen Einblick. Die Transaktion ist noch nicht gelandet und kann weiterhin fehlschlagen oder verworfen werden. Deshalb gelten zwei Regeln:

Bestätige die Landung mit den üblichen Prüfungen über commitment (getSignatureStatuses oder einen stream mit processed-commitment), bevor du die beobachtete Transaktion oder deine Reaktion als final behandelst.
Rechne mit Lücken. Die Abdeckung hängt vom Anteil des Stake ab, der an Helius weitergeleitet wird. Deshalb erzeugen manche slot keine Nachrichten. Das ist erwartetes Verhalten und keine unterbrochene Verbindung. Der Keepalive-Ping hilft dir, beides zu unterscheiden. Abonniere nach dem Schließen erneut.

Weitere Leitfäden

preconfSubscribe API reference

Vollständige Filtersemantik, Regionscodes und Aufbau des binären payload

Trade on Preprocessed Transactions

Abdeckung vor der Ausführung für 0,1 Credits pro Nachricht in allen kostenpflichtigen Tarifen

Hier starten

Echtzeitdaten

Trading mit niedriger Latenz

Historische Daten und Wallet-Daten

Anleitungen zu RPC-Methoden

Produktionsreife

Orb verwenden

Weitere Anleitungen

Mit Preconfirmations handeln

Grenze den stream ein, bevor du dich verbindest

Verbinden, abonnieren und dekodieren

Mit Sender Max reagieren

Landung bestätigen und mit Lücken rechnen

Weitere Leitfäden

preconfSubscribe API reference

Trade on Preprocessed Transactions

​Grenze den stream ein, bevor du dich verbindest

​Verbinden, abonnieren und dekodieren

​Mit Sender Max reagieren

​Landung bestätigen und mit Lücken rechnen

​Weitere Leitfäden

preconfSubscribe API reference

Trade on Preprocessed Transactions

Grenze den stream ein, bevor du dich verbindest

Verbinden, abonnieren und dekodieren

Mit Sender Max reagieren

Landung bestätigen und mit Lücken rechnen

Weitere Leitfäden