gavindiaz/solana-streamer
1
0
Fork 0
mirror of https://github.com/0xfnzero/solana-streamer.git synced 2026-07-27 17:37:45 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
main
solana-streamer/README_CN.md
T
0xfnzero 9bd0577683 chore: release solana-streamer-sdk 1.5.16
2026-06-20 10:48:53 +08:00

28 KiB
Raw Permalink Blame History

🌊 Solana Streamer

从 Solana DEX 交易程序实时流式传输事件。

一个基于 sol-parser-sdk 的轻量级 Rust 流式封装库，提供低延迟订阅能力，并保持面向 Bot 用户的稳定 API。

Crates.io Documentation License GitHub stars GitHub forks

Rust Solana Real-time Streaming gRPC

中文 | English | Website | Telegram

☕ 支持本项目

本 SDK 完全免费且开源。但维护和持续更新需要消耗大量 AI 算力与 Token。如果这个 SDK 对您的开发有帮助，欢迎每月捐赠任意数量的 SOL，您的支持将帮助这个项目持续运行！

捐赠钱包： 6oW7AXz1yRb57pYSxysuXnMs2aR1ha5rzGzReZ1MjPV8

目录

这个 SDK 适合什么场景

solana-streamer-sdk 是面向 Solana Bot、索引服务、跟单系统、狙击机器人和 DEX 监控工具的 Rust 事件流层，在 Yellowstone gRPC、ShredStream、RPC 交易解析和底层 sol-parser-sdk 解析核心之上提供稳定 API。

方向 覆盖范围
输入来源 Yellowstone gRPC、Jito ShredStream、已获取的 RPC 交易、编码交易数据
DEX 协议 PumpFun、PumpSwap、Pump Fees、Raydium LaunchLab、Raydium CPMM、Raydium CLMM、Raydium AMM V4、Meteora DAMM v2、Meteora DLMM、Meteora DBC、Orca Whirlpool
使用场景 实时 DEX 事件流、代币发射监控、跟单交易、账户状态订阅、Bot 信号管道
解析后端 sol-parser-sdk，默认 Borsh 解析，并可为低延迟场景启用 zero-copy 后端

🚀 项目特性

核心功能

  • 实时事件流: 订阅多个 Solana DEX 协议的实时交易事件
  • SDK 底层解析核心: 交易、RPC、账户和 ShredStream 解析都优先复用 sol-parser-sdk
  • Yellowstone gRPC 支持: 使用 Yellowstone gRPC 进行高性能事件订阅
  • ShredStream 支持: 使用 ShredStream 协议进行替代事件流传输；ALT-loaded 账户会以默认账户占位并尽量解析外层事件
  • 统一事件接口: 在所有支持的协议中保持一致的事件处理

多协议支持

  • PumpFun: 迷因币交易平台事件
  • Pump Fees: Pump 费用分成配置事件
  • PumpSwap: PumpFun 的交换协议事件
  • Raydium LaunchLab: 代币发射平台事件；Protocol::Bonk 和 Protocol::RaydiumLaunchpad 仍作为兼容别名保留
  • Raydium CPMM: Raydium 集中池做市商事件
  • Raydium CLMM: Raydium 集中流动性做市商事件
  • Raydium AMM V4: Raydium 自动做市商 V4 事件
  • Meteora DAMM v2: Meteora DAMM v2 交易和流动性事件
  • Orca Whirlpool: Orca Whirlpool 交易和流动性事件
  • Meteora Pools: Meteora Pools 交易、流动性、启动流动性和费用事件
  • Meteora DBC: Meteora Dynamic Bonding Curve 的 log-side swap、initialize-pool 和 curve-complete 事件
  • Meteora DLMM: Meteora DLMM 交易、流动性、池、bin array 和费用事件

高级功能

  • 事件解析系统: 自动解析和分类协议特定事件
  • 账户状态监控: 实时监控协议账户状态和配置变更
  • 交易与账户事件过滤: 分别过滤交易事件和账户状态变化
  • 动态订阅管理: 运行时过滤器更新而无需重新连接，支持自适应监控策略
  • 多重过滤器支持: 在单个订阅中支持多个交易和账户过滤器
  • 高级账户过滤: 使用 memcmp 过滤器进行精确的账户数据匹配和监控
  • Token2022 支持: 增强对 SPL Token 2022 的支持，包含扩展状态解析
  • RPC 交易解析: 可解析已获取的 RPC 交易，也可按签名拉取并转换为 streamer 事件
  • 高级 SDK 互操作: 通过 parser_sdk 或 sdk_bridge::raw 直接访问底层 sol-parser-sdk

性能与优化

  • 高性能: 针对低延迟事件处理进行优化
  • 批处理优化: 批量处理事件以减少回调开销
  • 性能监控: 内置性能指标监控，包括事件处理速度
  • 内存优化: 对象池和缓存机制减少内存分配
  • 灵活配置系统: 支持自定义批处理大小、背压策略、通道大小等参数
  • 预设配置: 提供高吞吐量、低延迟等预设配置，针对不同使用场景优化
  • 背压处理: 支持阻塞、丢弃等背压策略
  • 运行时配置更新: 支持在运行时动态更新配置参数
  • 优雅关闭: 支持编程式 stop() 方法进行干净的关闭

⚡ 安装

直接克隆

将项目克隆到您的项目目录：

cd your_project_root_directory
git clone https://github.com/0xfnzero/solana-streamer

在您的 Cargo.toml 中添加依赖：

# 添加到您的 Cargo.toml
solana-streamer-sdk = { path = "./solana-streamer", version = "1.5.16" }

使用 crates.io

# 添加到您的 Cargo.toml
solana-streamer-sdk = "1.5.16"

解析后端 feature：

# 默认：sol-parser-sdk parse-borsh 后端
solana-streamer-sdk = "1.5.16"

# 面向低延迟 Bot 的 zero-copy 解析后端
solana-streamer-sdk = { version = "1.5.16", default-features = false, features = ["sdk-parse-zero-copy"] }

如果同时启用 sdk-parse-borsh 和 sdk-parse-zero-copy，sol-parser-sdk 0.5.15+ 会优先使用 zero-copy 后端。

🔄 迁移指南

升级到 v1.5.16

v1.5.16 修复 StreamingOrdered 模式下同一交易解析出多个事件时的投递问题。同一 (slot, tx_index) 的事件会作为一组进入缓冲，streaming watermark 每笔交易只推进一次，并用 stable sort 保留相同交易索引下的解析器输出顺序。同时将 yellowstone-grpc-proto 固定到 sol-parser-sdk 0.5.15 使用的 12.4.x API，避免 CI 和干净安装解析到不兼容的新 proto crate。

升级到 v1.5.15

v1.5.15 跟随 GitHub rev 36ec202 上的 sol-parser-sdk 0.5.15。Pump.fun create_v2 现在会区分 16 账户 SOL sentinel 创建和 19/20 账户 quote-pool 创建；填充账户时会先选择实际的 create/create_v2 指令，再读取 quote 字段。gRPC/RPC inner instruction 解析现在会按 program id + discriminator 守卫解析所有 SDK 已支持 DEX 的 8-byte 普通 CPI instruction，PumpSwap create_pool 因此能从 instruction args 读取 is_cashback_coin 并与 log 事件合并。ShredStream 仍只解析外层指令，但外层 discriminator gate 已和 SDK 统一，避免支持协议之间规则分叉。

升级到 v1.5.14

v1.5.14 使用 crates.io 上的 sol-parser-sdk 0.5.14。Pump.fun canonical create 事件现在会为 create_v2 quote 池暴露 quote_mint、quote_vault、quote_token_program，包括 USDC 池；gRPC/RPC parser bridge 和 ShredStream-backed SDK 输出都会保留这些字段。

升级到 v1.5.13

v1.5.13 使用 crates.io 上的 sol-parser-sdk 0.5.13。Pump.fun gRPC 和 ShredStream create/trade 输出现在会保留真实 WSOL quote mint（So11111111111111111111111111111111111111112）。只有 legacy 数据缺失 quote mint 时，才使用 Solscan SOL sentinel（So11111111111111111111111111111111111111111）。

升级到 v1.5.11

v1.5.11 使用 crates.io 上的 sol-parser-sdk 0.5.11。PumpSwap PumpSwapCreatePoolEvent 现在会在 create_pool instruction args 可用时携带 is_cashback_coin，包括 ShredStream 外层指令解析。log-only 的 CreatePoolEvent payload 因为链上 log event IDL 不包含该字段，仍会保持默认 false。AccountPumpSwapPool 仍是读取池子账户状态里该标记的权威来源。

升级到 v1.5.10

v1.5.10 使用 crates.io 上的 sol-parser-sdk 0.5.10。PumpSwap CreatePoolEvent 现在与链上 IDL 对齐：暴露 is_mayhem_mode，但不暴露 is_cashback_coin。如果需要 cashback 标记，请订阅 AccountPumpSwapPool，并读取 PumpSwapPoolAccountEvent.pool.is_cashback_coin。PumpSwap CreatePool log payload 长度检查现在包含最后的 is_mayhem_mode 字节。

升级到 v1.5.9

v1.5.9 使用 crates.io 上的 sol-parser-sdk 0.5.9。该版本继承 Yellowstone gRPC stop 生命周期修复：stop() 现在会通知、abort 并等待当前订阅任务结束，订阅生命周期切换会串行化，并且 gRPC 流错误日志会标记为 Grpc Stream error，便于和 ShredStream 日志区分。

升级到 v1.5.8

v1.5.8 使用 crates.io 上的 sol-parser-sdk 0.5.8。该版本继承 parser SDK 的 Pump.fun ShredStream 过滤大类语义：PumpFunBuy 覆盖 buy、buy_v2、buy_exact_sol_in、buy_exact_quote_in_v2；PumpFunSell 覆盖 sell、sell_v2；PumpFunTrade 覆盖所有 buy/sell 指令，并且当只请求通用 trade filter 时，parser 可统一输出 trade 事件。

升级到 v1.5.5

v1.5.5 使用 crates.io 上的 sol-parser-sdk 0.5.5。底层 SDK 已将 Raydium LaunchLab 事件统一暴露为 RaydiumLaunchlab*；streamer 仍保留现有 Bonk* 事件结构以及 Protocol::Bonk / Protocol::RaydiumLaunchpad 兼容别名，同时把解析调用和上游 gRPC 事件过滤映射到新的 LaunchLab SDK variant。该版本也同步了 CLMM/CPMM/Orca account bridge、Meteora DAMM v2 initialize-pool、Meteora DBC 事件，以及客户端创建时的 parser warmup。

升级到 v1.5.4

v1.5.4 使用 crates.io 上的 sol-parser-sdk 0.5.4。Pump.fun create 和 create_v2 会统一投递为 canonical PumpFunCreateTokenEvent；订阅 PumpFunCreateToken 或 PumpFunCreateV2Token 任意一个，都能收到同一份完整 create-family 数据。该版本避免 gRPC log + instruction 双路径解析导致新 mint 回调重复，同时在 canonical create 事件上保留 create_v2 账户字段。

升级到 v1.5.3

v1.5.3 使用 crates.io 上的 sol-parser-sdk 0.5.3。该版本会通过 streamer bridge 保留真实的 Pump.fun v2 ix_name，改进 ShredStream 对 Pump.fun v2 短账户列表的 best-effort 解析，并让订阅 PumpFunBuy 或 PumpFunBuyExactSolIn 都能匹配兼容的 buy-family 事件。ShredStream 仍使用直接读取 Entry 的自动重连低延迟路径；回调应避免阻塞，tx_index 仍是 Entry 内 best-effort 索引。

升级到 v1.5.2

v1.5.2 使用 crates.io 上的 sol-parser-sdk 0.5.2。ShredStream 投递使用直接读取 Entry 并调用 SDK parser 的低延迟路径，支持自动重连，避免额外的队列消费任务并复用解析事件缓冲。ShredStream 的 tx_index 是 Entry 内 best-effort 索引，不是 Yellowstone 的 slot 级交易索引。direct-callback 路径中的用户回调运行在读流任务中，应避免阻塞操作。

升级到 v1.5.1

v1.5.1 使用 crates.io 上的 sol-parser-sdk 0.5.1。该版本改进 ShredStream 的 ALT 处理：ALT-loaded 账户会以默认账户占位，外层指令按 data/discriminator 尽量解析；同时增加队列满时的 dropped event 可观测性，并明确 CPI/inner-only 事件仍是 ShredStream 的固有限制。

升级到 v1.5.0

v1.5.0 使用 sol-parser-sdk 0.5.0，打通 Raydium CLMM 账户解析的 SDK bridge，并降低有序缓冲低延迟投递路径中的分配和搬移开销。sol-parser-sdk 0.4.19 和 solana-streamer-sdk 1.4.14 已由 v1.5.0 取代，因为新增公开 parser event variant 应放到 0.5 版本线。

升级到 v1.4.14

v1.4.14 已由 v1.5.0 取代。

升级到 v1.4.13

v1.4.13 使用 sol-parser-sdk 0.4.18，并按 Raydium CLMM 官方升级后 IDL 更新集成：当前 log-side event discriminator、官方 Swap/Liquidity/Create/Collect 事件布局、限价单事件、dynamic fee 相关事件，以及重塑后的 PoolState/TickState 账户结构。

升级到 v1.4.12

v1.4.12 使用 sol-parser-sdk 0.4.17，会把 legacy PumpFun SOL 的 quote_mint 归一为 Solscan SOL sentinel，同时保留真实 USDC quote mint 和 quote reserve 字段。Streamer bridge 与 merger 路径继续保持 Yellowstone gRPC 和 ShredStream 输出与 parser SDK 语义一致。

新增可选能力：

  • solana_streamer_sdk::parser_sdk 重新导出原始 sol-parser-sdk crate。
  • solana_streamer_sdk::sdk_bridge 可将原始 SDK 事件适配回 streamer DexEvent。
  • fetch_rpc_transaction_as_streamer_events 和 parse_encoded_rpc_transaction_as_streamer_events 可将 RPC 交易解析为 streamer 事件。
  • grpc::ClientConfig::order_mode 支持 Unordered、Ordered、StreamingOrdered 和 MicroBatch。
  • sdk-parse-zero-copy 可启用 SDK zero-copy 解析后端。

从 v0.5.x 迁移到 v1.x.x

版本 1.0.0 引入了从基于 trait 的事件处理到基于 enum 的事件的重大架构变更。这提供了更好的类型安全性、改进的性能和更简单的代码模式。

主要变更：

  1. 事件类型变更 - Box<dyn UnifiedEvent> → DexEvent 枚举
  2. 回调签名 - 回调现在接收具体的 DexEvent 而不是 trait 对象
  3. 事件匹配 - 使用标准 Rust match 而不是 match_event! 宏
  4. 元数据访问 - 事件属性现在通过 .metadata() 方法访问

详细的迁移步骤和代码示例，请参阅 MIGRATION.md 或 MIGRATION_CN.md（中文版本）。

快速迁移示例：

// 旧版 (v0.5.x)
let callback = |event: Box<dyn UnifiedEvent>| {
    println!("Event: {:?}", event.event_type());
};

// 新版 (v1.x.x)
let callback = |event: DexEvent| {
    println!("Event: {:?}", event.metadata().event_type);
};

⚙️ 配置系统

您可以自定义客户端配置：

use solana_streamer_sdk::streaming::{
    grpc::{ClientConfig, OrderMode},
    YellowstoneGrpc,
};

// 使用默认配置
let grpc = YellowstoneGrpc::new(endpoint, token)?;

// 或创建自定义配置
let mut config = ClientConfig::default();
config.enable_metrics = true;  // 启用性能监控
config.connection.connect_timeout = 30;  // 30 秒
config.connection.request_timeout = 120;  // 120 秒
config.order_mode = OrderMode::MicroBatch;  // Unordered / Ordered / StreamingOrdered / MicroBatch
config.order_timeout_ms = 100;
config.micro_batch_us = 100;

let grpc = YellowstoneGrpc::new_with_config(endpoint, token, config)?;

可用配置选项：

  • enable_metrics: 启用/禁用性能监控（默认：false）
  • connection.connect_timeout: 连接超时（秒）（默认：10）
  • connection.request_timeout: 请求超时（秒）（默认：60）
  • connection.max_decoding_message_size: 最大消息大小（字节）（默认：10MB）
  • order_mode: 交易事件输出顺序模式（默认：Unordered）
  • order_timeout_ms: Ordered 和 StreamingOrdered 模式的刷新超时（默认：100）
  • micro_batch_us: MicroBatch 模式的微批窗口（默认：100）

最小 gRPC 订阅

use solana_streamer_sdk::streaming::{
    event_parser::{
        common::{filter::EventTypeFilter, EventType},
        core::EventDispatcher,
        DexEvent, Protocol,
    },
    yellowstone_grpc::{AccountFilter, TransactionFilter},
    YellowstoneGrpc,
};

let grpc = YellowstoneGrpc::new(endpoint, token)?;

let protocols = vec![
    Protocol::PumpFun,
    Protocol::PumpFees,
    Protocol::PumpSwap,
    Protocol::RaydiumLaunchpad,
    Protocol::RaydiumCpmm,
    Protocol::RaydiumClmm,
    Protocol::RaydiumAmmV4,
    Protocol::OrcaWhirlpool,
    Protocol::MeteoraPools,
    Protocol::MeteoraDammV2,
    Protocol::MeteoraDlmm,
];

let program_ids = EventDispatcher::get_program_ids(&protocols)
    .into_iter()
    .map(|pubkey| pubkey.to_string())
    .collect::<Vec<_>>();

let transaction_filter = TransactionFilter {
    account_include: program_ids.clone(),
    account_exclude: vec![],
    account_required: vec![],
};
let account_filter = AccountFilter { account: vec![], owner: program_ids, filters: vec![] };

let event_type_filter = Some(EventTypeFilter::include_only(vec![
    EventType::PumpFunBuy,
    EventType::PumpSwapBuy,
    EventType::BonkBuyExactIn,
    EventType::RaydiumCpmmSwapBaseInput,
    EventType::MeteoraDlmmSwap,
]));

grpc.subscribe_events_immediate(
    protocols,
    None,
    vec![transaction_filter],
    vec![account_filter],
    event_type_filter,
    None,
    |event: DexEvent| {
        println!("{:?}", event.metadata().event_type);
    },
)
.await?;

📚 使用示例

使用示例概览表

描述 运行命令 源码路径
使用 Yellowstone gRPC 监控交易事件 cargo run --example grpc_example examples/grpc_example.rs
使用 ShredStream 监控交易事件 cargo run --example shred_example examples/shred_example.rs
解析 Solana 主网交易数据 cargo run --example parse_tx_events examples/parse_tx_events.rs
从 RPC 解析 PumpFun 交易（签名：环境变量 TX_SIGNATURE 或 CLI 参数） cargo run --example parse_pump_tx --release examples/parse_pump_tx.rs
从 RPC 解析 PumpFun quote_mint 边界案例 TX_SIGNATURES=<sig1,sig2> cargo run --example parse_pumpfun_quote_cases --release examples/parse_pumpfun_quote_cases.rs
从 RPC 解析 PumpSwap 交易 cargo run --example parse_pumpswap_tx --release examples/parse_pumpswap_tx.rs
从 RPC 解析 Meteora DAMM v2 交易 TX_SIGNATURE=<sig> cargo run --example parse_meteora_damm_tx --release examples/parse_meteora_damm_tx.rs
调试 PumpFun 交易（拉取、打印 meta/logs、解析） TX_SIGNATURE=<sig> cargo run --example debug_pump_tx --release examples/debug_pump_tx.rs
调试 PumpSwap 交易（拉取、打印 meta、解析） TX_SIGNATURE=<sig> cargo run --example debug_pumpswap_tx --release examples/debug_pumpswap_tx.rs
运行时更新过滤器 cargo run --example dynamic_subscription examples/dynamic_subscription.rs
快速测试：订阅 PumpFun，打印前 10 条或运行 60 秒 cargo run --example pumpfun_quick_test --release examples/pumpfun_quick_test.rs
PumpFun 交易过滤：买入/卖出/创建及延迟统计 cargo run --example pumpfun_trade_filter --release examples/pumpfun_trade_filter.rs
PumpFun gRPC 订阅（含指标） cargo run --example pumpfun_with_metrics --release examples/pumpfun_with_metrics.rs
PumpSwap gRPC 订阅（含指标） cargo run --example pumpswap_with_metrics --release examples/pumpswap_with_metrics.rs
Meteora DAMM v2 gRPC 订阅 cargo run --example meteora_damm_grpc --release examples/meteora_damm_grpc.rs
监控特定代币账户余额变化 cargo run --example token_balance_listen_example examples/token_balance_listen_example.rs
通过账户订阅监控代币精度 cargo run --example token_decimals_listen_example examples/token_decimals_listen_example.rs
跟踪 nonce 账户状态变化 cargo run --example nonce_listen_example examples/nonce_listen_example.rs
使用 memcmp 过滤器监控 PumpSwap 池账户 cargo run --example pumpswap_pool_account_listen_example examples/pumpswap_pool_account_listen_example.rs
使用 memcmp 过滤器监控特定代币的所有关联代币账户 cargo run --example mint_all_ata_account_listen_example examples/mint_all_ata_account_listen_example.rs

事件过滤

库支持灵活的事件过滤以减少处理开销并提升性能：

基础过滤

use solana_streamer_sdk::streaming::event_parser::common::{filter::EventTypeFilter, EventType};

// 无过滤 - 接收所有事件
let event_type_filter = None;

// 过滤特定事件类型 - 只接收 PumpSwap 买入/卖出事件
let event_type_filter = Some(EventTypeFilter::include_only(vec![
    EventType::PumpSwapBuy,
    EventType::PumpSwapSell,
]));

// 排除高频噪声事件，保留其他所有事件
let event_type_filter = Some(EventTypeFilter::exclude_only(vec![EventType::BlockMeta]));

性能影响

事件过滤可以带来显著的性能提升：

  • 减少 60-80% 的不必要事件处理
  • 降低内存使用 通过过滤掉无关事件
  • 减少网络带宽 在分布式环境中
  • 更好的专注性 只处理对应用有意义的事件

按使用场景的过滤示例

交易机器人（专注交易事件）

let event_type_filter = Some(EventTypeFilter::include_only(vec![
    EventType::PumpFunBuy,
    EventType::PumpFunBuyExactSolIn,
    EventType::PumpFunSell,
    EventType::PumpSwapBuy,
    EventType::PumpSwapSell,
    EventType::BonkBuyExactIn,
    EventType::BonkSellExactIn,
    EventType::RaydiumCpmmSwapBaseInput,
    EventType::RaydiumCpmmSwapBaseOutput,
    EventType::RaydiumClmmSwap,
    EventType::RaydiumAmmV4SwapBaseIn,
    EventType::RaydiumAmmV4SwapBaseOut,
    EventType::OrcaWhirlpoolSwap,
    EventType::MeteoraPoolsSwap,
    EventType::MeteoraDammV2Swap,
    EventType::MeteoraDlmmSwap,
]));

池监控（专注流动性事件）

let event_type_filter = Some(EventTypeFilter::include_only(vec![
    EventType::PumpFeesUpdateFeeShares,
    EventType::PumpSwapCreatePool,
    EventType::AccountPumpSwapPool,
    EventType::PumpSwapDeposit,
    EventType::PumpSwapWithdraw,
    EventType::RaydiumCpmmInitialize,
    EventType::RaydiumCpmmDeposit,
    EventType::RaydiumCpmmWithdraw,
    EventType::RaydiumClmmCreatePool,
    EventType::OrcaWhirlpoolPoolInitialized,
    EventType::MeteoraPoolsPoolCreated,
    EventType::MeteoraDammV2AddLiquidity,
    EventType::MeteoraPoolsAddLiquidity,
    EventType::MeteoraDlmmAddLiquidity,
]));

PumpSwapCreatePool 包含 is_mayhem_mode。对于 is_cashback_coin， ShredStream/外层指令解析会从 create_pool instruction args 读取； log-only 的 CreatePoolEvent payload 因为 IDL 不包含该字段，会保持默认 false。账户里的权威值也可通过 PumpSwapPoolAccountEvent.pool.is_cashback_coin 读取。

动态订阅管理

在运行时更新订阅过滤器而无需重新连接到流。

// 在现有订阅上更新过滤器
grpc.update_subscription(
    vec![TransactionFilter {
        account_include: vec!["new_program_id".to_string()],
        account_exclude: vec![],
        account_required: vec![],
    }],
    vec![AccountFilter {
        account: vec![],
        owner: vec![],
        filters: vec![],
    }],
).await?;
  • 无需重新连接: 过滤器变更立即生效，无需关闭流
  • 原子更新: 交易和账户过滤器同时更新
  • 单一订阅: 每个客户端实例只有一个活跃订阅
  • 兼容性: 与立即订阅和高级订阅方法兼容

注意：在同一客户端上多次尝试订阅会返回错误。

🔧 支持的协议

  • PumpFun: 主要迷因币交易平台
  • Pump Fees: Pump 费用分成配置事件
  • PumpSwap: PumpFun 的交换协议
  • Raydium LaunchLab: 代币发射平台；Bonk 和 RaydiumLaunchpad 作为兼容别名保留
  • Raydium CPMM: Raydium 集中池做市商协议
  • Raydium CLMM: Raydium 集中流动性做市商协议
  • Raydium AMM V4: Raydium 自动做市商 V4 协议
  • Meteora DAMM v2: Meteora DAMM v2 协议
  • Orca Whirlpool: Orca Whirlpool 协议
  • Meteora Pools: Meteora Pools 协议
  • Meteora DBC: Meteora Dynamic Bonding Curve 协议
  • Meteora DLMM: Meteora 动态流动性做市商协议
  • 通用/账户事件: Token 账户、Token 元信息、Nonce 账户、区块元数据、ComputeBudget 事件，以及 Raydium CLMM/CPMM、Pump/PumpSwap、Orca Whirlpool 等已支持协议账户状态

🌐 事件流服务

  • Yellowstone gRPC: 高性能 Solana 事件流
  • ShredStream: 替代事件流协议

🏗️ 架构特性

统一事件接口

  • DexEvent 枚举: 包含所有协议事件的类型安全枚举
  • Protocol Enum: 轻松识别事件来源
  • SDK 桥接层: 将 sol-parser-sdk::DexEvent 适配为 streamer DexEvent

事件解析系统

  • sol-parser-sdk facade: Yellowstone gRPC、ShredStream、RPC 交易解析和账户解析中的协议解析都委托给 sol-parser-sdk
  • 本地非 DEX 补充: 本地逻辑仅保留 streamer 基础设施和 ComputeBudget 元数据等非 DEX 兼容场景
  • 可扩展桥接层: streaming::sdk_bridge 暴露原始 SDK 能力，但不强迫已有 Bot 改回调 API

流基础设施

  • Yellowstone gRPC 客户端: 针对 Solana 事件流优化
  • ShredStream 客户端: 替代流实现
  • 高性能处理: 优化的事件处理机制

📁 项目结构

src/
├── common/           # 通用功能和类型
├── protos/           # Protocol buffer 定义
├── streaming/        # 事件流系统
│   ├── event_parser/ # 基于 sol-parser-sdk 的 streamer 兼容事件 facade
│   │   ├── common/   # 公开事件元数据和过滤类型
│   │   ├── core/     # SDK 分发入口和兼容封装
│   │   ├── protocols/# Streamer 事件类型和旧模块路径
│   │   │   └── sol_parser_forward/ # SDK 转发协议事件封装
│   ├── parser_sdk_bridge/ # sol-parser-sdk 事件适配层
│   ├── rpc_parse.rs # RPC 交易解析 helper
│   ├── sdk_bridge.rs # 公开的高级 SDK 互操作模块
│   ├── shred_stream.rs # ShredStream 客户端
│   ├── yellowstone_grpc.rs # Yellowstone gRPC 客户端
│   └── yellowstone_sub_system.rs # Yellowstone 子系统
└── lib.rs            # 主库文件

⚡ 性能考虑

  1. 连接管理: 正确处理连接生命周期和重连
  2. 事件过滤: 使用协议过滤减少不必要的事件处理
  3. 内存管理: 为长时间运行的流实现适当的清理
  4. 错误处理: 对网络问题和服务中断进行健壮的错误处理
  5. 批处理优化: 使用批处理减少回调开销，提高吞吐量
  6. 性能监控: 启用性能监控以识别瓶颈和优化机会
  7. 优雅关闭: 使用 stop() 方法进行干净关闭，并实现信号处理器以正确清理资源

📄 许可证

MIT 许可证

📞 联系方式

⚠️ 重要注意事项

  1. 网络稳定性: 确保稳定的网络连接以进行连续的事件流传输
  2. 速率限制: 注意公共 gRPC 端点的速率限制
  3. 错误恢复: 实现适当的错误处理和重连逻辑
  4. 合规性: 确保遵守相关法律法规

语言版本

Reference in New Issue View Git Blame Copy Permalink