gavindiaz/sol-trade-sdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
main
sol-trade-sdk/README_CN.md
T
0xfnzero cf3bef0dd5 feat(swqos): add Glaive transaction sender
2026-07-18 23:20:57 +08:00

33 KiB
Executable File
Raw Permalink Blame History

🚀 Sol Trade SDK

全面的 Rust SDK，用于无缝 Solana DEX 交易

一个面向低延迟 Solana DEX 交易机器人的高性能 Rust SDK。该 SDK 以速度和效率为核心设计，支持与 PumpFun、Pump AMM（PumpSwap）、Bonk、Meteora DAMM v2、Raydium AMM v4 以及 Raydium CPMM 进行无缝、高吞吐量的交互，适用于对延迟高度敏感的交易策略。

Crates.io Documentation License GitHub stars GitHub forks

Rust Solana DEX Trading

中文 | English | Website | Telegram | Discord

☕ 支持本项目

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

捐赠钱包： 6oW7AXz1yRb57pYSxysuXnMs2aR1ha5rzGzReZ1MjPV8

📋 目录

📦 SDK 版本

本 SDK 提供多种语言版本：

语言 仓库 描述
Rust sol-trade-sdk 超低延迟，零拷贝优化
Node.js sol-trade-sdk-nodejs TypeScript/JavaScript，Node.js 支持
Python sol-trade-sdk-python 原生 async/await 支持
Go sol-trade-sdk-golang 并发安全，goroutine 支持

这个 SDK 适合什么场景

sol-trade-sdk 是 FnZero Solana 交易 SDK 系列的 Rust 版本，重点服务于低延迟交易构建和提交，适合 Solana DEX 交易机器人、跟单系统、狙击机器人、套利策略和私有交易基础设施。

方向 覆盖范围
DEX 协议 PumpFun、PumpSwap、Bonk、Meteora DAMM v2、Raydium AMM v4、Raydium CPMM
提交通道 默认 Solana RPC，以及 Jito、Nextblock、ZeroSlot、Temporal、Bloxroute、FlashBlock、BlockRazor、Node1、Astralane、Glaive、SpeedLanding 等 SWQoS 服务
交易流程 买入/卖出、精确输入/输出、跟单交易、狙击交易、地址查找表、durable nonce、中间件、共享基础设施
热路径设计 调用方传入 recent blockhash 或 durable nonce；交易执行阶段不再查询 RPC 获取 blockhash、账户或余额

🔖 当前版本

Rust crate: sol-trade-sdk = "4.0.23"

本版本适配 PumpSwap 2026 年 7 月的虚拟 quote 储备升级。Pool 与事件 schema 新增 virtual_quote_reserves，PumpSwap 买入、卖出、报价和动态费率计算统一使用 quote_vault_balance + virtual_quote_reserves。

✨ 项目特性

  1. PumpFun 交易: SDK 侧统一为 buy、sell、buy_exact_quote_in 流程，native SOL 优先走 V1，USDC/非 SOL quote 或显式 WSOL 结算才走 V2
  2. PumpSwap 交易: 支持 PumpSwap 池的交易操作
  3. Bonk 交易: 支持 Bonk 的交易操作
  4. Raydium CPMM 交易: 支持 Raydium CPMM (Concentrated Pool Market Maker) 的交易操作
  5. Raydium AMM V4 交易: 支持 Raydium AMM V4 (Automated Market Maker) 的交易操作
  6. Meteora DAMM V2 交易: 支持 Meteora DAMM V2 (Dynamic AMM) 的交易操作
  7. 多种 MEV 保护: 支持 Jito、Nextblock、ZeroSlot、Temporal、Bloxroute、FlashBlock、BlockRazor、Node1、Astralane、Glaive、SpeedLanding、LunarLander 等服务
  8. 并发交易: 所有已配置的 SWQoS 通道和默认 RPC 通道都会发出提交；首个成功只影响返回，较慢通道会继续提交
  9. 统一交易接口: 使用统一的交易协议枚举进行交易操作
  10. 中间件系统: 支持自定义指令中间件，可在交易执行前对指令进行修改、添加或移除
  11. 共享基础设施: 多钱包可共享同一套 RPC 与 SWQoS 客户端，降低资源占用
  12. 热路径 RPC 边界: 交易执行使用调用方传入的 blockhash 或 durable nonce，不在热路径查询 blockhash、账户或余额

📦 安装

直接克隆

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

cd your_project_root_directory
git clone https://github.com/0xfnzero/sol-trade-sdk

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

# 添加到您的 Cargo.toml
sol-trade-sdk = { path = "./sol-trade-sdk", version = "4.0.23" }

使用 crates.io

# 添加到您的 Cargo.toml
sol-trade-sdk = "4.0.23"

🛠️ 使用示例

📋 使用示例

1. 创建 TradingClient 实例

可参考 示例：创建 TradingClient 实例。

方式一：简单创建（单钱包）

// 钱包
let payer = Keypair::from_base58_string("use_your_payer_keypair_here");
// RPC 地址
let rpc_url = "https://mainnet.helius-rpc.com/?api-key=xxxxxx".to_string();
let commitment = CommitmentConfig::processed();
// 可配置多个 SWQoS 服务
let swqos_configs: Vec<SwqosConfig> = vec![
    SwqosConfig::Default(rpc_url.clone()),
    SwqosConfig::Jito("your uuid".to_string(), SwqosRegion::Frankfurt, None),
    SwqosConfig::Temporal("your api_token".to_string(), SwqosRegion::Frankfurt, None),
    SwqosConfig::FlashBlock("your api_token".to_string(), SwqosRegion::Frankfurt, None),
    SwqosConfig::BlockRazor("your api_token".to_string(), SwqosRegion::Frankfurt, None),
    // Astralane：第4个参数为 AstralaneTransport — Binary（默认）、Plain（/iris）或 Quic
    SwqosConfig::Astralane("your_astralane_api_key".to_string(), SwqosRegion::Frankfurt, None, None), // Binary /irisb
    SwqosConfig::SpeedLanding("your api_token".to_string(), SwqosRegion::Frankfurt, None),
    // Lunar Lander：第4个参数 None 为 QUIC（默认）；Some(SwqosTransport::Http) 为 binary HTTP
    SwqosConfig::LunarLander("your_hellomoon_api_key".to_string(), SwqosRegion::Frankfurt, None, None),
    SwqosConfig::LunarLander(
        "your_hellomoon_api_key".to_string(),
        SwqosRegion::Frankfurt,
        None,
        Some(SwqosTransport::Http),
    ),
    // Glaive：None 为 QUIC（默认，UDP/4000）；Some(Http) 为 binary HTTP
    SwqosConfig::Glaive(
        "your_glaive_uuid_v4_api_key".to_string(),
        SwqosRegion::Frankfurt,
        None,
        None,
    ),
];
// 创建 TradeConfig 实例
let trade_config = TradeConfig::builder(rpc_url, swqos_configs, commitment)
    // .create_wsol_ata_on_startup(true)  // 默认: true  - 初始化时检查并创建 WSOL ATA
    // .use_seed_optimize(true)            // 默认: true  - ATA 操作启用 seed 优化
    // .log_enabled(true)                  // 默认: true  - SDK 计时 / SWQOS 日志
    // .check_min_tip(false)               // 默认: false - 过滤低于最低小费的 SWQOS
    // .swqos_cores_from_end(false)        // 默认: false - 将 SWQOS 绑定到末尾 N 个 CPU 核心
    // .mev_protection(false)              // 默认: false - Astralane / BlockRazor / Glaive 的 MEV 保护
    .build();

// 创建 TradingClient
let client = TradingClient::new(Arc::new(payer), trade_config).await;

方式二：共享基础设施（多钱包）

多钱包场景下可先创建一份基础设施，再复用到多个钱包。参见 示例：共享基础设施。

// 创建一次基础设施（开销较大）
let infra_config = InfrastructureConfig::new(rpc_url, swqos_configs, commitment);
let infrastructure = Arc::new(TradingInfrastructure::new(infra_config).await);

// 基于同一基础设施创建多个客户端（开销小）
let client1 = TradingClient::from_infrastructure(Arc::new(payer1), infrastructure.clone(), true);
let client2 = TradingClient::from_infrastructure(Arc::new(payer2), infrastructure.clone(), true);

2. 配置 Gas Fee 策略

有关 Gas Fee 策略的详细信息，请参阅 Gas Fee 策略参考手册。

// 创建 GasFeeStrategy 实例
let gas_fee_strategy = GasFeeStrategy::new();
// 设置全局策略
gas_fee_strategy.set_global_fee_strategy(150000, 150000, 500000, 500000, 0.001, 0.001);

3. 构建交易参数

有关所有交易参数的详细信息，请参阅 交易参数参考手册。

use sol_trade_sdk::{
    AccountPolicy, BuyAmount, DexType, SimpleBuyParams, TradeTokenType,
    trading::core::params::DexParamEnum,
};

let buy_params = SimpleBuyParams::new(
    DexType::PumpFun,
    // 支付币种。PumpFun V2 的 SOL/WSOL quote 池，如果你想花原生 SOL，
    // 这里仍然传 SOL；SDK 内部会按 V2 账户布局处理。
    TradeTokenType::SOL,
    // 要买入的 meme/token mint。
    mint_pubkey,
    // 常规 PumpFun/PumpSwap buy。SDK 先估算能买到多少 token，
    // 再把滑点应用到最大 quote 成本上。
    BuyAmount::WithMaxInput { quote_amount: buy_sol_amount },
    // 协议状态参数，通常来自 parser/RPC 缓存，例如 PumpFunParams::from_trade(...)。
    DexParamEnum::PumpFun(pumpfun_params),
    // 传入外部缓存的 recent_blockhash；SDK 不在热路径里临时获取。
    recent_blockhash,
    gas_fee_strategy.clone(),
)
// 300 = 3%。
.slippage_basis_points(300)
// Bot/狙击推荐：假设 ATA 已提前准备好，交易内不创建/关闭 ATA，体积更小。
.account_policy(AccountPolicy::HotPathMinimal);

4. 执行交易

client.buy_simple(buy_params).await?;

⚡ 交易参数

新接入建议优先使用 SimpleBuyParams / SimpleSellParams。它们描述交易意图，SDK 内部处理底层 ATA 参数。多数用户只需要选择：

  • pay_with / receive_as：买入时用什么 quote 支付，卖出时收什么 quote。钱包实际花/收原生 SOL 就传 SOL。PumpFun V2 的 SOL 配对池虽然 quote_mint 是 WSOL，但你想用原生 SOL 结算时这里仍传 SOL。
  • amount：交易数量语义。用一个枚举表达意图，不再同时理解 input_token_amount、fixed_output_token_amount、use_exact_sol_amount。
  • account_policy：账户创建策略。Bot 通常用 HotPathMinimal；普通应用可以保留默认 Auto。
参数 含义 推荐场景
BuyAmount::ExactInput(amount) 精确花费指定 quote 数量；滑点保护最小买到数量。 普通买入
BuyAmount::WithMaxInput { quote_amount } PumpFun/PumpSwap 常规 buy，滑点作用在最大 quote 成本上。 狙击、套利
BuyAmount::ExactOutput { output_amount, max_input_amount } 精确买到指定 token 数量，并限制最大 quote 成本。 精确输出
SellAmount::ExactInput(amount) 精确卖出指定 token 数量。 普通卖出
SellAmount::ExactOutput { output_amount, max_input_amount } 精确收到指定 quote 数量，并限制最多卖出多少 token；取决于 DEX 是否支持。 精确输出卖出
AccountPolicy::Auto SDK 按交易路径创建必要 ATA。 普通用户
AccountPolicy::HotPathMinimal 交易内避免创建/关闭 ATA。 Bot、狙击、低延迟
AccountPolicy::CreateMissing 尽量在交易内创建缺失 ATA。 优先方便，不追求最小交易体积
AccountPolicy::AssumePrepared 调用方保证所有 ATA 已准备好。 高级确定性流程

可选 builder 方法：

方法 含义
.slippage_basis_points(300) 设置滑点。300 表示 3%。
.address_lookup_table_account(alt) 传入 ALT 以减少交易体积。PumpFun V2 交易较大时很有用。
.wait_tx_confirmed(true) 等链上确认后再返回。追求最快提交时通常关闭。
.wait_for_all_submits(true) 等待所有 SWQoS 通道返回，并拿到已提交签名。recent blockhash 多路交易不互斥；durable nonce 多路交易互斥。
.simulate(true) 只构建并模拟交易，不真正发送。
.grpc_recv_us(ts) 传入上游收到事件的微秒时间戳，用于延迟追踪。
.durable_nonce(nonce_info) 使用 durable nonce，并清空 recent_blockhash。如果你从 SimpleBuyParams::new(...) / SimpleSellParams::new(...) 开始构造，推荐用这个。
SimpleBuyParams::with_durable_nonce(...) / SimpleSellParams::with_durable_nonce(...) 直接用 durable nonce 构造参数，不使用 recent_blockhash。
SimpleSellParams::with_tip(false) 关闭卖出交易 relay tip。买入的 tip 使用 gas fee strategy 控制。

TradeBuyParams 和 TradeSellParams 仍保留为高级低层接口。详细说明见 交易参数参考手册。

关于shredstream

当你使用 shred 订阅事件时，由于 shred 的特性，你无法获取到交易事件的完整信息。 请你在使用时，确保你的交易逻辑依赖的参数，在shred中都能获取到。

客户端预热、blockhash/nonce、交易模式、事件状态新鲜度和 6040 重报价规则见 低延迟 Bot 集成清单。

📊 使用示例汇总表格

完整双语索引和安全分类见 examples/README_CN.md。

描述 运行命令 使用说明
简化买卖参数 API cargo run --package simple_trading README
创建和配置 TradingClient cargo run --package trading_client README
多钱包共享基础设施 cargo run --package shared_infrastructure README
PumpFun 狙击 cargo run --package pumpfun_sniper_trading README
PumpFun 跟单 cargo run --package pumpfun_copy_trading README
PumpSwap 低延迟事件流 cargo run --package pumpswap_trading README
PumpSwap 直接 RPC 流程 cargo run --package pumpswap_direct_trading README
Raydium CPMM cargo run --package raydium_cpmm_trading README
Raydium AMM V4 cargo run --package raydium_amm_v4_trading README
Meteora DAMM V2 cargo run --package meteora_damm_v2_direct_trading README
Bonk 狙击 cargo run --package bonk_sniper_trading README
Bonk 跟单 cargo run --package bonk_copy_trading README
指令中间件 cargo run --package middleware_system README
地址查找表 cargo run --package address_lookup README
Durable nonce cargo run --package nonce_cache README
SOL/WSOL 包装与解包 cargo run --package wsol_wrapper README
Seed 优化 cargo run --package seed_trading README
Gas fee 策略 cargo run --package gas_fee_strategy README
多 DEX CLI 模板 cargo run --package cli_trading README

⚙️ SWQoS 服务配置说明

在配置 SWQoS 服务时，需要注意不同服务的参数要求：

  • Jito: 第一个参数为 UUID（如无 UUID 请传入空字符串 ""）
  • 其他的MEV服务，第一个参数为 API Token

自定义 URL 支持

每个 SWQoS 服务现在都支持可选的自定义 URL 参数：

// 使用自定义 URL（第三个参数）
let jito_config = SwqosConfig::Jito(
    "your_uuid".to_string(),
    SwqosRegion::Frankfurt, // 这个参数仍然需要，但会被忽略
    Some("https://custom-jito-endpoint.com".to_string()) // 自定义 URL
);

// 使用默认区域端点（第三个参数为 None）
let temporal_config = SwqosConfig::Temporal(
    "your_api_token".to_string(),
    SwqosRegion::NewYork, // 将使用该区域的默认端点
    None // 没有自定义 URL，使用 SwqosRegion
);

URL 优先级逻辑：

  • 如果提供了自定义 URL（Some(url)），将使用自定义 URL 而不是区域端点
  • 如果没有提供自定义 URL（None），系统将使用指定 SwqosRegion 的默认端点
  • 这提供了最大的灵活性，同时保持向后兼容性
  • Glaive 自定义 QUIC 地址格式为 host:4000；自定义 HTTP 地址必须是完整的 http:// 或 https:// 基础 URL，SDK 会自动追加 /binary 和鉴权参数。

当使用多个 MEV 服务时，需要使用 Durable Nonce。先获取最新 nonce，再挂到新的 buy/sell 参数上：

use sol_trade_sdk::{fetch_nonce_info, AccountPolicy, BuyAmount, SimpleBuyParams};

let nonce_info = fetch_nonce_info(&client.infrastructure.rpc, nonce_account)
    .await
    .expect("nonce account must be initialized");

let buy_params = SimpleBuyParams::new(
    DexType::PumpFun,
    TradeTokenType::SOL,
    mint_pubkey,
    BuyAmount::WithMaxInput { quote_amount: buy_sol_amount },
    DexParamEnum::PumpFun(pumpfun_params),
    recent_blockhash, // 会被 `.durable_nonce(...)` 清空
    gas_fee_strategy.clone(),
)
.durable_nonce(nonce_info)
.account_policy(AccountPolicy::HotPathMinimal);

client.buy_simple(buy_params).await?;

Astralane（Binary / Plain / QUIC）

Astralane 支持 Binary HTTP（/irisb）、Plain HTTP（/iris）与 QUIC（host:7000，全局 mev_protection 为 true 时用 :9000）。第四个参数：Some(AstralaneTransport::Plain)、Some(AstralaneTransport::Quic)，或 None 表示 Binary（默认）。全局 mev_protection 会在 HTTP 上附加 mev-protect=true，或为 QUIC 选择 9000 端口。

use sol_trade_sdk::{SwqosConfig, SwqosRegion, AstralaneTransport};

let swqos_configs: Vec<SwqosConfig> = vec![
    SwqosConfig::Default(rpc_url.clone()),
    SwqosConfig::Astralane(
        "your_astralane_api_key".to_string(),
        SwqosRegion::Frankfurt,
        None,
        Some(AstralaneTransport::Quic),
    ),
];
// 然后照常使用 swqos_configs 创建 TradeConfig / TradingClient
  • Binary（默认）：None 或 Some(AstralaneTransport::Binary) — /irisb，bincode 正文。
  • Plain：Some(AstralaneTransport::Plain) — /iris。
  • QUIC：Some(AstralaneTransport::Quic) — 按区域的 host:7000 / :9000（MEV）；同一 API key。

Glaive（Binary HTTP / QUIC）

Glaive 支持 binary HTTP 和持久 QUIC。Glaive 官方将 QUIC 定义为最低延迟路径，因此 SDK 默认使用 QUIC。API key 必须是 UUID v4；每笔交易至少需要 0.0001 SOL tip，SDK 会从 Glaive 官方公布的 6 个 tip 账户中选择一个。

use sol_trade_sdk::{
    swqos::{SwqosConfig, SwqosRegion},
    SwqosTransport,
};

let glaive_quic = SwqosConfig::Glaive(
    "your_glaive_uuid_v4_api_key".to_string(),
    SwqosRegion::Frankfurt,
    None, // fra.glaive.trade:4000
    None, // 默认 QUIC
);

let glaive_http = SwqosConfig::Glaive(
    "your_glaive_uuid_v4_api_key".to_string(),
    SwqosRegion::Frankfurt,
    None, // http://fra.glaive.trade/binary?api-key=...
    Some(SwqosTransport::Http),
);
  • QUIC（默认）：None 或 Some(SwqosTransport::Quic)。使用 UDP 4000、ALPN solana-tpu、SNI glaive-intake；维持一条已鉴权连接，每笔交易使用一个单向流。
  • Binary HTTP：Some(SwqosTransport::Http)。把原始交易字节提交到 /binary?api-key=...，并通过 /health 保持连接池热连接。
  • Some(SwqosTransport::Grpc) 会直接返回错误，因为 Glaive 没有提供 gRPC 提交协议。
  • MEV 保护：.mev_protection(true) 会设置 QUIC 鉴权帧的 flag bit 0，或为 binary HTTP 追加 mev-protect=true。
  • Tip 配置：Glaive 通道的 gas-fee strategy tip 至少应为 0.0001 SOL。.check_min_tip(true) 会在本地过滤低于该值的配置，但不会自动提高用户设置的 tip。
  • 区域：Glaive 原生 PoP 包括 Amsterdam、Frankfurt、London 和 New York；其他 SwqosRegion 会映射到最近的已公布端点。
  • 仅主网：Glaive 当前没有 testnet 端点。
  • 内置 HTTP 地址遵循 Glaive 官方文档中的 http:// 端点。优先使用默认 QUIC；如果 Glaive 为你分配了 HTTPS 地址，也可以通过自定义 URL 使用。

凭证、限流和协议详情请参考 Glaive 官方文档。

🔧 中间件系统说明

SDK 提供了强大的中间件系统，允许您在交易执行前对指令进行修改、添加或移除。中间件按照添加顺序依次执行：

let middleware_manager = MiddlewareManager::new()
    .add_middleware(Box::new(FirstMiddleware))   // 第一个执行
    .add_middleware(Box::new(SecondMiddleware))  // 第二个执行
    .add_middleware(Box::new(ThirdMiddleware));  // 最后执行

🔍 地址查找表

地址查找表 (ALT) 允许您通过将经常使用的地址存储在紧凑的表格格式中来优化交易大小并降低费用。详细信息请参阅 地址查找表指南。

🔍 Durable Nonce

使用 Durable Nonce 来实现交易重放保护和优化交易处理。详细信息请参阅 Nonce 使用指南。

💰 Cashback 支持（PumpFun / PumpSwap）

PumpFun 与 PumpSwap 支持返现（Cashback）：部分手续费可返还给用户。SDK 必须知道该代币是否开启返现，才能为 buy/sell 指令传入正确的账户（例如返现代币需要把 UserVolumeAccumulator 作为 remaining account）。

  • 参数来自 RPC 时：使用 PumpFunParams::from_mint_by_rpc 或 PumpSwapParams::from_pool_address_by_rpc / from_mint_by_rpc 时，SDK 会从链上读取 is_cashback_coin，无需额外传入。
  • 参数来自事件/解析器时：若根据交易事件（如 sol-parser-sdk）构建参数，必须把返现标志传给 SDK：
    • PumpFun：PumpFunParams::from_trade(..., mint, quote_mint, creator, ..., is_cashback_coin, mayhem_mode) 与 PumpFunParams::from_dev_trade(..., is_cashback_coin) 都需要传入 is_cashback_coin。从解析出的事件传入（如 sol-parser-sdk 的 PumpFunTradeEvent.is_cashback_coin）。
    • PumpSwap：PumpSwapParams 有字段 is_cashback_coin。手动构造参数（如从池/交易事件）时，从解析到的池或事件数据中设置该字段。
  • pumpfun_copy_trading、pumpfun_sniper_trading 示例使用 sol-parser-sdk 订阅 gRPC 事件，并在构造参数时传入 e.is_cashback_coin。
  • 领取返现：使用 client.claim_cashback_pumpfun() 和 client.claim_cashback_pumpswap(...) 领取累计的返现。

PumpFun：常见错误与排错思路

实盘集成时若遇 Anchor 2006、NotAuthorized(6000)、Token program 不匹配、6020/6042 等，请参阅专门文档：Pump.fun 常见链上错误与处理思路（中文）。

PumpFun：Creator Rewards Sharing（creator_vault）

部分 PumpFun 代币启用了 Creator Rewards Sharing，链上 creator_vault 可能与默认推导结果不同。若在卖出时复用买入时缓存的 params，可能触发程序错误 2006（seeds constraint violated）。建议：

  • 来自 gRPC/事件（无需 RPC）：creator 与 creator_vault 均可从解析后的事件中直接拿到：
    • sol-parser-sdk：推送前会调用 fill_trade_accounts，从 buy/sell 指令账户补全 creator_vault（buy 索引 9，sell 索引 8）；creator 来自 TradeEvent 日志。用 PumpFunParams::from_trade(..., e.creator, e.creator_vault, ...) 或 from_dev_trade(..., e.creator, e.creator_vault, ...) 即可。
    • solana-streamer：指令解析时从 accounts[9]（buy）/ accounts[8]（sell）写入 creator_vault；creator 来自合并后的 CPI TradeEvent 日志。同样用事件的 e.creator、e.creator_vault 调用 from_trade / from_dev_trade。
  • RPC 后覆盖：若通过 PumpFunParams::from_mint_by_rpc 得到 params，之后又从 gRPC 拿到更新的 creator_vault，在卖出前对 params 调用 .with_creator_vault(latest_creator_vault)。

SDK 不会在每次卖出时通过 RPC 拉取 creator_vault（以避免延迟）；请从 gRPC/事件中传入最新 vault。

PumpSwap：从事件拿 coin_creator_vault（无需 RPC）

PumpSwap（Pump AMM）的 buy/sell 指令需要 coin_creator_vault_ata 与 coin_creator_vault_authority，二者均可从解析事件中拿到，无需 RPC：

  • sol-parser-sdk：指令解析从账户 17、18 写入；若事件来自日志，账户填充器也会从指令补全。用 PumpSwapParams::from_trade(..., e.coin_creator_vault_ata, e.coin_creator_vault_authority, ...) 即可。
  • solana-streamer：指令解析从 accounts.get(17)、accounts.get(18) 写入。同样用事件的 coin_creator_vault_ata、coin_creator_vault_authority 调用 from_trade。

Pump.fun Bonding Curve 统一买卖入口与 v2 指令

Pump.fun 已升级 Bonding Curve 合约，推出统一化 v2 指令，通过固定账户布局同时支持 SOL 和 USDC 配对币。旧版 buy/sell/buy_exact_sol_in 仍可用于 SOL 配对币，且保持为默认选项。

SDK 侧调用入口保持统一：正常使用 buy / sell 流程即可，SDK 会根据 quote_mint 和买/卖的结算 mint 自动选择正确的链上 discriminator 和账户布局。能用 V1 的 native SOL 池会优先用 V1。

v2 指令关键变化：

  • 新增 quote_mint 参数 — native SOL 配对可能表现为默认值、Solscan SOL sentinel（So11111111111111111111111111111111111111111）或 WSOL sentinel（So11111111111111111111111111111111111111112）；USDC/其他真实 quote mint 才选择 V2
  • 27 个固定账户（buy）/ 26 个固定账户（sell）— 无可选账户
  • buyback_fee_recipient、sharing_config 和 6 个 associated_quote_* ATA 变为强制账户
  • SOL 配对币的报价和成本与旧版一致，无额外开销

���用方式：

把事件里的 quote_mint 传给 PumpFunParams::from_trade。quote_mint 不是 PDA，它就是 quote SPL mint 或 native SOL sentinel；Pubkey::default()、Solscan SOL（So11111111111111111111111111111111111111111）和 WSOL_TOKEN_ACCOUNT 都表示 native SOL 配对，正常用 SOL 结算时默认走旧版 V1；USDC 表示 USDC V2：

// native SOL 池：可能是 Pubkey::default()、Solscan SOL sentinel 或 WSOL sentinel
// USDC / 非 SOL 池：就是实际 quote SPL mint
let quote_mint = e.quote_mint;

let params = PumpFunParams::from_trade(
    e.bonding_curve,
    e.associated_bonding_curve,
    e.mint,
    quote_mint,
    e.creator,
    e.creator_vault,
    e.virtual_token_reserves,
    e.virtual_quote_reserves,
    e.real_token_reserves,
    e.real_quote_reserves,
    close_token_account_when_sell,
    e.fee_recipient,
    e.token_program,
    e.is_cashback_coin,
    Some(e.mayhem_mode),
);

// 之后正常交易
client.buy(buy_params).await?;
client.sell(sell_params).await?;

USDC 配对币必须用 USDC 买入、卖出也结算为 USDC；SOL/WSOL 只适用于 SOL 配对的 PumpFun 曲线。SOL 配对的普通热路径请传 SOL，SDK 会用 V1；只有你明确传 WSOL 作为买入输入或卖出输出、希望通过已有 WSOL ATA 结算时，才会选择 V2。 SDK 会在提交前拒绝 USDC quote 池的 SOL 输入，避免链上 6063 失败。 消费 parser 事件时，需要把 quoteMint、virtualQuoteReserves、realQuoteReserves 传进 PumpFunParams::from_trade(...)；USDC 池初始虚拟 quote reserve 是 4_292_000_000。 legacy SOL 事件里如果 quote_mint 是默认值或 Solscan SOL，并且 quote reserve 字段缺失/为 0，应回退使用 virtual_sol_reserves / real_sol_reserves。

quote_mint 实际使用的指令 说明
未设置（默认）/ SOL_TOKEN_ACCOUNT (So111...11111) / WSOL_TOKEN_ACCOUNT (So111...11112) 优先旧版 buy/sell/buy_exact_sol_in native SOL 配对；普通 SOL 结算走 V1，显式 WSOL 结算才走 V2
USDC_TOKEN_ACCOUNT buy_v2/sell_v2/buy_exact_quote_in_v2 USDC 配对（必须使用 v2）

PumpSwap：虚拟 quote 储备

PumpSwap 报价必须使用 effective_quote_reserves = pool_quote_token_account.amount + virtual_quote_reserves。Pool 账户以及 BuyEvent/SellEvent 中的 virtual_quote_reserves 类型均为 i128。

  • PumpSwapParams::from_pool_address_by_rpc 等 RPC 构造器会自动读取并应用 Pool 字段。
  • 事件热路径必须把事件中的原始 pool_quote_token_reserves 和 virtual_quote_reserves 分别传给 PumpSwapParams::from_trade(...) 或 from_trade_with_fee_basis_points(...)，不要在调用前自行相加。
  • SDK 在买入、卖出、报价和动态费率分层中统一使用有效储备；无效的有符号结果会返回错误，不会发生整数回绕。

🛡️ MEV 保护服务

可以通过官网申请密钥：社区官网

  • Jito: 高性能区块空间
  • Temporal: 时间敏感交易
  • FlashBlock: 高速交易执行，支持 API 密钥认证
  • BlockRazor: 高速交易执行，支持 API 密钥认证
  • Astralane: 区块链网络加速（Binary/Plain HTTP 与 QUIC）
  • Glaive: 持久 QUIC 与 binary HTTP 交易投递（最低 tip：0.0001 SOL）
  • SpeedLanding: 高速交易执行，支持 API 密钥认证
  • Node1: 高速交易执行，支持 API 密钥认证
  • LunarLander: HelloMoon 交易着陆服务（最低小费：0.001 SOL）

📁 项目结构

src/
├── common/           # 通用功能和工具
├── constants/        # 常量定义
├── instruction/      # 指令构建
│   └── utils/        # 指令工具函数
├── swqos/            # MEV 服务客户端
├── trading/          # 统一交易引擎
│   ├── common/       # 通用交易工具
│   ├── core/         # 核心交易引擎
│   ├── middleware/   # 中间件系统
│   └── factory.rs    # 交易工厂
├── utils/            # 工具函数
│   ├── calc/         # 数量计算工具
│   └── price/        # 价格计算工具
└── lib.rs            # 主库文件

📄 许可证

MIT 许可证

💬 联系方式

⚠️ 重要注意事项

  1. 在主网使用前请充分测试
  2. 正确设置私钥和 API 令牌
  3. 注意滑点设置避免交易失败
  4. 监控余额和交易费用
  5. 遵循相关法律法规
Reference in New Issue View Git Blame Copy Permalink