跳转到主要内容

​
什么是 Yellowstone gRPC?

Yellowstone gRPC 通过高性能流式传输提供对 Solana 区块链数据的直接访问。与传统 RPC 轮询不同,gRPC 以最小延迟提供实时更新,非常适合:
  • 交易机器人 - 通过实时数据更快执行交易
  • DeFi 应用 - 即时监控流动性池和代币兑换
  • 分析平台 - 即时追踪链上活动
  • 套利系统 - 以毫秒级精度检测机会

​
快速开始

1

订阅 Yellowstone gRPC

独立 gRPC 方案 €200/月，或与 RPC Business、Professional 方案免费捆绑。详见 定价与限制。订阅 Yellowstone gRPC您将获得:
  • 两个区域端点:
    • 欧盟区: https://grpc.solanatracker.io
    • 美国区: https://grpc-us.solanatracker.io
  • Jito Shreds - 数据交付快 50-100 毫秒
  • 无带宽费用 - 无限数据流
  • 24/7 正常运行 - 自动故障切换和监控
选择离您基础设施最近的端点以获得最佳性能。在同一数据中心同址部署以获得亚毫秒级延迟。
2

获取您的 API 凭据

订阅后,检索您的身份验证凭据:获取您的 API 令牌您将收到:
  • x-token - 您用于 gRPC 请求的身份验证令牌
  • 端点 URL - 欧盟和美国区域
  • 配置指南 - 推荐设置
请妥善保管您的令牌!
  • 切勿将令牌提交到版本控制
  • 使用环境变量
  • 定期轮换令牌
3

安装依赖

安装 Yellowstone gRPC 客户端:
npm install @triton-one/yellowstone-grpc

​
完整工作示例

下面是一个完整的、生产可用的示例,用于监控交易: 
const Client = require("@triton-one/yellowstone-grpc").default;
const { CommitmentLevel } = require("@triton-one/yellowstone-grpc");

// Initialize and connect to Yellowstone gRPC
const getClient = async () => {
  let client = false;
  try {
    client = new Client(
      "https://grpc.solanatracker.io",
      "your-api-key-here",
      {
        "grpc.max_receive_message_length": 100 * 1024 * 1024,
      }
    );
    const version = await client.getVersion();
    if (version) {
      console.log("Connected! Version:", version);
      return client;
    }
  } catch (e) {
    console.error("Failed to connect:", e);
  }
  if (!client) {
    throw new Error("Failed to connect!");
  }
};

(async () => {
  const client = await getClient();
  const stream = await client.subscribe();

  // Handle stream lifecycle
  const streamClosed = new Promise((resolve, reject) => {
    stream.on("error", (error) => {
      console.error("Stream error:", error);
      reject(error);
    });
    stream.on("end", () => {
      console.log("Stream ended");
      resolve();
    });
    stream.on("close", () => {
      console.log("Stream closed");
      resolve();
    });
  });

  // Handle incoming data
  stream.on("data", (data) => {
    if (data?.transaction) {
      const tx = data.transaction.transaction;
      console.log("\n[Transaction]");
      console.log("  Signature:", tx.signature);
      console.log("  Slot:", data.transaction.slot);
      console.log("  Success:", !tx.meta?.err);
      if (tx.meta?.fee) {
        console.log("  Fee:", (tx.meta.fee / 1e9).toFixed(6), "SOL");
      }
    }
  });

  // Subscribe to Token Program transactions
  const request = {
    accounts: {},
    slots: {},
    transactions: {
      tokenTransactions: {
        vote: false,
        failed: false,
        signature: undefined,
        accountInclude: ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"],
        accountExclude: [],
        accountRequired: [],
      },
    },
    transactionsStatus: {},
    entry: {},
    blocks: {},
    blocksMeta: {},
    accountsDataSlice: [],
    ping: undefined,
    commitment: CommitmentLevel.CONFIRMED,
  };

  // Send subscribe request
  await new Promise((resolve, reject) => {
    stream.write(request, (err) => {
      if (err === null || err === undefined) {
        console.log("Subscribed to Token Program transactions");
        resolve();
      } else {
        reject(err);
      }
    });
  }).catch((reason) => {
    console.error("Subscribe failed:", reason);
    throw reason;
  });

  await streamClosed;
})();

​
此示例的功能

  1. 连接到 Yellowstone gRPC,带有适当的错误处理
  2. 创建流,带有生命周期事件处理程序
  3. 订阅交易,涉及代币程序
  4. 处理每笔交易并记录关键详情
  5. 优雅地处理错误,具有适当的清理

​
监控不同的数据类型

监控账户变化:
const request = {
  accounts: {
    myAccounts: {
      account: ["YourAccountAddress"],
      owner: [],
      filters: []
    }
  },
  slots: {},
  transactions: {},
  transactionsStatus: {},
  entry: {},
  blocks: {},
  blocksMeta: {},
  accountsDataSlice: [],
  ping: undefined,
  commitment: CommitmentLevel.CONFIRMED,
};

stream.on("data", (data) => {
  if (data?.account) {
    const account = data.account.account;
    console.log("Account Update:", account.pubkey);
    console.log("Lamports:", account.lamports);
  }
});

​
环境变量

安全地存储您的凭据: 
# .env file
GRPC_ENDPOINT=https://grpc.solanatracker.io
GRPC_API_KEY=your-api-key-here

require('dotenv').config();

const client = new Client(
  process.env.GRPC_ENDPOINT,
  process.env.GRPC_API_KEY,
  {
    "grpc.max_receive_message_length": 100 * 1024 * 1024,
  }
);

​
接下来做什么?

交易监控

监控 DEX 交易和程序活动

账户监控

追踪代币持有者和账户变化

Pump.fun 示例

构建 Pump.fun 交易机器人

最佳实践

生产环境优化

​
常见问题

​
我应该使用哪个端点?

根据您的位置选择:
  • 欧洲/全球: https://grpc.solanatracker.io
  • 北美: https://grpc-us.solanatracker.io
测试两个端点并使用从您部署区域延迟较低的那个。通过在同一数据中心同址部署达到约 1 毫秒延迟。

​
如何处理重新连接?

将您的连接逻辑包装在重试函数中: 
async function connectWithRetry(maxRetries = 5) {
  for (let i = 0; i < maxRetries; i++) {
    try {
      return await getClient();
    } catch (e) {
      console.log(`Retry ${i + 1}/${maxRetries}...`);
      await new Promise(resolve => setTimeout(resolve, 1000 * Math.pow(2, i)));
    }
  }
  throw new Error("Max retries exceeded");
}

​
我应该使用什么确认级别?

确认级别:
  • PROCESSED - 最快,但可能被回滚
  • CONFIRMED - 平衡速度和最终性(推荐)
  • FINALIZED - 最慢,但保证最终化
对于大多数应用程序,CONFIRMED 是最佳选择。

​
如何过滤交易?

在您的订阅请求中使用过滤字段: 
transactions: {
  myTransactions: {
    vote: false,                    // Exclude vote transactions
    failed: false,                  // Exclude failed transactions
    accountInclude: ["Address1"],   // Must include any of these (OR)
    accountRequired: ["Address2"],  // Must include all of these (AND)
    accountExclude: ["Address3"],   // Must not include any of these
  }
}

​
支持与资源

支持

获取实施帮助support@solanatracker.io

Yellowstone gRPC 源代码

完整 protobuf 定义和协议规格查看仓库