跳转到主要内容
测试版功能 - 需要申请访问预处理交易目前处于测试阶段。要申请访问，请通过Telegram或Discord联系Helius团队。
预处理交易是接收Solana交易的最快方式。与等待完整交易处理相比，LaserStream直接从碎片到达验证器时解码交易，使您能够比标准订阅更早地获得交易数据，以毫秒计算。 本指南解释了何时使用预处理交易、可用的数据以及如何在所有LaserStream SDK中实现它们。

​
什么是预处理交易？

在Solana的架构中，交易在完全处理前会通过几个阶段：
  1. 碎片接收 → 验证器接收交易碎片（数据片段）
  2. 碎片解码 → 碎片被解码为原始交易 ← 预处理交易在此处可用
  3. 交易执行 → 交易由运行时执行
  4. 元数据生成 → 计算预/后余额、日志和错误信息
  5. 确认 → 交易达到已处理/已确认/已最终状态
标准交易订阅在第5阶段提供数据 - 完整执行和元数据生成之后。预处理订阅在第2阶段提供 - 碎片解码后、执行完成之前。 权衡： 您可以毫秒级更早收到交易数据，但没有执行元数据，如余额变化、日志或错误信息。

​
尽力而为的交付保证

重要： 预处理交易交付是尽力而为，不保证。我们的目标是99.99%的交付率，但某些交易可能在以下情况下丢失：
  • 基础设施更新和重新部署
  • 网络问题或验证器连接问题
  • 碎片解码或处理的极端情况
对于需要保证交付的关键应用程序，请改用标准的事务订阅。

​
可用的数据有哪些？

预处理事务包括完整的事务消息，但缺乏执行元数据：

​
可用数据

  • ✅ Transaction signature - 唯一的事务标识符
  • ✅ Account keys - 事务引用的所有账户
  • ✅ Instructions - 完整的指令数据和程序调用
  • ✅ Recent blockhash - 事务到期引用
  • ✅ Signatures - 所有事务签名
  • ✅ Is vote transaction - 是否是投票交易
  • ✅ Slot number - 该事务所在插槽

​
缺失数据

  • ❌ Transaction metadata - 令牌余额变化、前/后余额、事务状态
  • ❌ Transaction errors - 我们无法确定事务是否失败
  • ❌ Inner instructions - 不包括跨程序调用（CPI）
  • ❌ Log messages - 执行期间生成的程序日志
  • ❌ Compute units consumed - 无法获得执行指标
可以将预处理事务视为接收到“提案”而没有“结果”。您可以看到用户尝试执行的操作，但不知道实际发生了什么。

​
SDK支持和版本要求

所有LaserStream SDK都支持预处理的事务订阅：

JavaScript/TypeScript

版本 0.2.8 或更新版本

Rust

版本 0.1.5 或更新版本

Go

版本 0.1.0 或更新版本

​
实现示例

​
JavaScript/TypeScript

JavaScript SDK 提供了一个专用的subscribePreprocessed函数，带有自动重新连接功能： 
import {
  subscribePreprocessed,
  CommitmentLevel,
  LaserstreamConfig,
  SubscribePreprocessedRequest,
  SubscribePreprocessedUpdate
} from 'helius-laserstream';
import bs58 from 'bs58';

async function streamPreprocessedTransactions() {
  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY',
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com',
  };

  const request: SubscribePreprocessedRequest = {
    transactions: {
      "jupiter-swaps": {
        vote: false,
        accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4']
      }
    }
  };

  const stream = await subscribePreprocessed(
    config,
    request,
    async (update: SubscribePreprocessedUpdate) => {
      if (update.transaction) {
        const tx = update.transaction;
        const signature = bs58.encode(tx.transaction.signature);

        console.log('⚡ Preprocessed transaction received:');
        console.log(`  Signature: ${signature}`);
        console.log(`  Slot: ${tx.slot}`);
        console.log(`  Is Vote: ${tx.transaction.isVote}`);
        console.log(`  Filters: ${update.filters.join(', ')}`);
        console.log('---');
      }
    },
    async (error) => {
      console.error('Stream error:', error);
    }
  );

  console.log(`✅ Preprocessed stream started (id: ${stream.id})`);

  // Graceful shutdown
  process.on('SIGINT', () => {
    console.log('\n🛑 Shutting down stream...');
    stream.cancel();
    process.exit(0);
  });
}

streamPreprocessedTransactions().catch(console.error);
完整示例： preprocessed-transaction-sub.ts

​
Rust

Rust SDK 提供本地性能： 
use futures::StreamExt;
use helius_laserstream::{
    grpc::{SubscribePreprocessedRequest, SubscribePreprocessedRequestFilterTransactions},
    subscribe_preprocessed, LaserstreamConfig,
};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = LaserstreamConfig {
        endpoint: "https://laserstream-mainnet-ewr.helius-rpc.com".to_string(),
        api_key: "YOUR_API_KEY".to_string(),
        ..Default::default()
    };

    let mut request = SubscribePreprocessedRequest::default();
    request.transactions.insert(
        "jupiter-swaps".to_string(),
        SubscribePreprocessedRequestFilterTransactions {
            vote: Some(false),
            account_include: vec![
                "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4".to_string()
            ],
            ..Default::default()
        },
    );

    let (stream, _handle) = subscribe_preprocessed(config, request);
    tokio::pin!(stream);

    println!("✅ Preprocessed stream started");

    while let Some(result) = stream.next().await {
        match result {
            Ok(update) => {
                if let Some(tx) = update.transaction {
                    println!("⚡ Preprocessed transaction:");
                    println!("  Slot: {}", tx.slot);
                    println!("  Is Vote: {}", tx.transaction.is_vote);
                    println!("---");
                }
            }
            Err(e) => {
                eprintln!("Stream error: {:?}", e);
                break;
            }
        }
    }

    Ok(())
}
完整示例：preprocessed_transaction_sub.rs

​
Go

Go SDK 提供惯用的 Go 接口： 
package main

import (
    "log"
    "os"
    "os/signal"
    "syscall"

    laserstream "github.com/helius-labs/laserstream-sdk/go"
    pb "github.com/helius-labs/laserstream-sdk/go/proto"
)

func main() {
    log.SetFlags(0)

    clientConfig := laserstream.LaserstreamConfig{
        Endpoint: "https://laserstream-mainnet-ewr.helius-rpc.com",
        APIKey:   "YOUR_API_KEY",
    }

    voteFilter := false
    subscriptionRequest := &pb.SubscribePreprocessedRequest{
        Transactions: map[string]*pb.SubscribePreprocessedRequestFilterTransactions{
            "jupiter-swaps": {
                Vote: &voteFilter,
                AccountInclude: []string{
                    "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
                },
            },
        },
    }

    client := laserstream.NewPreprocessedClient(clientConfig)

    dataCallback := func(data *pb.SubscribePreprocessedUpdate) {
        if data.Transaction != nil {
            log.Println("⚡ Preprocessed transaction:")
            log.Printf("  Slot: %d\n", data.Transaction.Slot)
            log.Printf("  Is Vote: %t\n", data.Transaction.Transaction.IsVote)
            log.Println("---")
        }
    }

    errorCallback := func(err error) {
        log.Printf("Error: %v", err)
    }

    err := client.Subscribe(subscriptionRequest, dataCallback, errorCallback)
    if err != nil {
        log.Fatalf("Failed to subscribe: %v", err)
    }

    log.Println("✅ Preprocessed stream started")
    log.Println("Press Ctrl+C to exit")

    sigChan := make(chan os.Signal, 1)
    signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
    <-sigChan

    log.Println("\nShutting down...")
    client.Close()
}
完整示例：preprocessed-transaction-sub.go

​
订阅结构和过滤

​
请求结构

预处理订阅请求遵循与标准订阅类似的结构，但具有集中的过滤集： 
interface SubscribePreprocessedRequest {
  transactions: {
    [filterName: string]: SubscribePreprocessedRequestFilterTransactions
  };
  ping?: SubscribeRequestPing;
}

interface SubscribePreprocessedRequestFilterTransactions {
  vote?: boolean;              // Include/exclude vote transactions
  signature?: string;          // Filter by specific transaction signature
  accountInclude?: string[];   // Include transactions touching these accounts
  accountExclude?: string[];   // Exclude transactions touching these accounts
  accountRequired?: string[];  // Require all these accounts to be present
}

​
响应结构

更新附带完整的交易消息和基本元数据： 
interface SubscribePreprocessedUpdate {
  filters: string[];                             // Which filters matched
  transaction?: SubscribePreprocessedTransaction; // The transaction data
  ping?: SubscribeUpdatePing;                    // Keepalive ping
  pong?: SubscribeUpdatePong;                    // Ping response
  createdAt: Date;                               // When update was created
}

interface SubscribePreprocessedTransaction {
  transaction: SubscribePreprocessedTransactionInfo;
  slot: number;                                  // Slot containing transaction
}

interface SubscribePreprocessedTransactionInfo {
  signature: Uint8Array;                         // Transaction signature
  isVote: boolean;                               // Is this a vote transaction
  transaction: solana.storage.Transaction;       // Full transaction message
}
transaction.transaction 字段包含完整的 Solana 交易结构，包括：
  • 消息 - 账户密钥、指令、最近的区块哈希
  • 签名 - 所有交易签名
  • 地址表查询 - 针对版本化交易
这与标准订阅中的交易结构相同，但不包括包含执行结果的 meta 字段。