{"content":{"title":"使用Jupiter API创建Solana交易机器人","body":"### 概述 \r\n\r\nJupiter 是Solan 领先的交换汇总器和路由协议，是开发者构建交易工具、去中心化应用 (dApps) 和其他 DeFi 应用程序的强大工具。在本指南中，我们将学习如何使用Jupiter的 v6 API 和 QuickNode 的 Metis 插件创建一个简单的Solana交易机器人。本指南面向对 TypeScript 和Solana区块链有扎实理解的开发者。无论你是希望增强投资组合、尝试新交易策略，还是探索Solana及其 DeFi 应用的能力，本指南都将为你提供必要的支持。\r\n\r\n> 偏好视频操作指南？跟随 Sahil，学习[如何使用Jupiter API 创建一个Solana交易机器人](https://www.youtube.com/watch?v=u8Qr1JI3pUM)。\r\n\r\n \r\n##### 你将做哪些事情 \r\n\r\n在本指南中，你将：\r\n\r\n1. 获取Jupiter的概述\r\n2. 学习如何使用Jupiter的 v6 API\r\n3. 创建一个基于类的交易机器人，该机器人使用Jupiter的 API 将 SOL 交换为 USDC。该机器人将使用Jupiter API 监控市场特定条件，并在条件满足时执行Jupiter交易。\r\n\r\n##### 你将需要\r\n\r\n- 基础的 [Solana 基础知识](https://learnblockchain.cn/article/11166)\r\n- 对Solana [版本化交易](https://learnblockchain.cn/article/11165) 的基本经验\r\n- 安装 [Node.js](https://nodejs.org/en/)（版本 18.16 或更高）\r\n- 安装最新版本的 [Typescript](https://www.typescriptlang.org/) 和 [ts-node](https://www.npmjs.com/package/ts-node)\r\n- 拥有 SOL 和 USDC 余额的 [Solana 文件系统钱包](https://docs.solanalabs.com/cli/wallets/file-system)\r\n\r\n通过 QuickNode 提升性能\r\n\r\n可靠且高性能的区块链基础设施是充分利用你的Solana交易机器人的关键。QuickNode 提供快速和可扩展的Solana RPC 节点端点，极大地提高了你的机器人的响应能力和效率。 [注册](https://www.quicknode.com/signup?utm_source=internal&utm_campaign=guides&utm_content=jupiter-api-trading-bot) 免费账户，今天就开始使用 QuickNode。\r\n\r\n除了可靠的 RPC 端点，考虑利用 [QuickNode 的Jupiter API 插件 Metis](https://marketplace.quicknode.com/add-on/metis-jupiter-v6-swap-api) 来优化交易执行。此附加组件可让你充分利用Jupiter的 V6 Swap API。无需担心服务器的设置或维护，我们提供滚动重启和低延迟，市场和流动池会立即显示。\r\n\r\n**此附加组件将不会使用你的账户积分，因为它依赖于它自己的Solana验证者节点，与我们的专业网络隔离，以最大限度地提高可靠性。**\r\n\r\n或者，你可以在这里访问Jupiter API 的公共端点: [https://www.jupiterapi.com/](https://www.jupiterapi.com/?utm_source=guides-jup-trading-bot)。\r\n\r\n### Jupiter是什么？ \r\n\r\nJupiter是Solana上的一个 Web3 交换程序。Jupiter允许用户寻找在Solana上交换代币的高效路径。代币交换是 DeFi 的核心特征，使用户能够在考虑每个代币市场价值的情况下，交换一种代币为另一种代币。\r\n\r\n_来源: [jup.ag](https://jup.ag/swap/SOL-USDC)_\r\n\r\nJupiter会从许多去中心化交易所 (DEXs) 和自动化做市商 (AMMs) 中聚合定价，并采用一种名为“智能路由”的独特算法，使用户能够寻找其交换的最佳价格。\r\n\r\n_来源: [Jupiter文档: Jupiter如何工作](https://station.jup.ag/docs/legacy/how-does-jupiter-work)_\r\n\r\nJupiter还将搜索中间交换（例如，_USDC-mSOL-SOL_ 而不是 _USDC-SOL_）中的低效之处，以便为用户找到更低的成本。在执行交换时，Jupiter还利用了一个名为 _交易拆分_ 的概念，该概念将交易拆分为跨多个 DEX 的小型交易，以找到最佳价格。\r\n\r\n### 使用Jupiter的 v6 API \r\n\r\nJupiter交换 API 是开发者构建交易工具、去中心化应用 (dApps) 和其他 DeFi 应用的强大工具。该 API 提供对Jupiter智能路由算法的访问，允许开发者找到最佳的交换价格并创建Solana交易/指令以执行交易。该 API 包含五个主要方法：\r\n\r\n| 端点 | JS 方法名称 | 类型 | 描述 |\r\n| --- | --- | --- | --- |\r\n| `/quote` | `quoteGet`
`quoteGetRaw` | GET | 获取两个代币和交换金额所给出的最佳价格报价 |\r\n| `/swap` | `swapPost`
`swapPostRaw` | POST | 从报价返回Solana交换事务 |\r\n| `/swap-instructions` | `swapInstructionsPost`
`swapInstructionsPostRaw` | POST | 从报价返回Solana交换指令 |\r\n| `/program-id-to-label` | `programIdToLabelGet`
`programIdToLabelGetRaw` | GET | 返回所有程序 ID 的名称/标签映射 |\r\n| `/indexed-route-map` | `indexedRouteMapGet`
`indexedRouteMapGetRaw` | GET | 返回一个哈希图，输入铸造作为键，作为值的有效输出铸造的数组 |\r\n\r\n请求可以采用以下格式：`{server}/{endpoint}?{query/body}`。以下是一个 cURL 示例，用于获取将 100 USDC 交换为 SOL 的报价：\r\n\r\n```\r\ncurl -L 'https://jupiter-swap-api.quiknode.pro/YOUR_ENDPOINT/quote?inputMint=EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v&outputMint=So11111111111111111111111111111111111111112&amount=100000000' \\\r\n-H 'Accept: application/json'\r\n```\r\n\r\n**确保将 `https://jupiter-swap-api.quiknode.pro/YOUR_ENDPOINT` 替换为你自己的 Metis 端点（或者，你可以使用我们的公共端点：[https://public.jupiterapi.com](https://public.jupiterapi.com/) - 尽管某些方法可能不可用）。你可以从你的 QuickNode 数据仪表板的附加组件页面 ( `https://dashboard.quicknode.com/endpoints/YOUR_ENDPOINT/add-ons`) 找到你的 Metis 地址：**\r\n\r\n\r\n\r\n要使用Jupiter JS 客户端，你可以通过 npm 安装它：\r\n\r\n```\r\nnpm install @jup-ag/api\r\n```\r\n\r\n你需要创建Jupiter API 客户端的一个实例，并传递你的 Metis 密钥（例如，`https://jupiter-swap-api.quiknode.pro/YOUR_ENDPOINT`）或在此处找到的公共端点 [可用链接](https://www.jupiterapi.com/?utm_source=guides-jup-trading-bot)：\r\n\r\n```\r\nimport { createJupiterApiClient } from '@jup-ag/api';\r\n\r\nconst ENDPOINT = `https://jupiter-swap-api.quiknode.pro/XX123456`; // 👈 用你的 Metis 密钥或公共端点替换 https://www.jupiterapi.com/\r\nconst CONFIG = {\r\n basePath: ENDPOINT\r\n};\r\nconst jupiterApi = createJupiterApiClient(CONFIG);\r\n```\r\n\r\n然后调用你需要的方法，例如：\r\n\r\n```\r\n jupiterApi.quoteGet({\r\n inputMint: \"EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v\",\r\n outputMint: \"So11111111111111111111111111111111111111112\",\r\n amount: 100_000_000,\r\n }).then((quote) => {\r\n console.log(quote.outAmount, quote.outputMint);\r\n }).catch((error) => {\r\n console.error(error);\r\n });\r\n```\r\n\r\n所有方法和文档可在 \\[Jupiter站点\\] 查找：\r\n\r\n- [OpenAPI](https://station.jup.ag/api-v6/introduction) 和\r\n- [文档](https://station.jup.ag/docs/apis/swap-api)\r\n\r\n让我们通过创建一个简单的交易机器人来测试一下，它使用Jupiter的 API 监控市场特定条件，并在满足条件时执行交易。\r\n\r\n### 交易机器人 \r\n\r\n开始之前\r\n\r\n这个示例只是用于教育目的。请勿在生产环境中使用此代码。在Solana主网执行的交易是不可逆的，并可能导致财务损失。在做出任何投资决定之前，请务必进行自己的研究并咨询财务顾问。\r\n\r\n下面是我们的机器人将要做的事情：\r\n\r\n- 机器人将期待一个拥有 SOL 和 USDC 余额的钱包。\r\n- 机器人将在指定的时间间隔内监控市场（使用Jupiter的获取报价方法）。\r\n- 机器人将在市场价格满足我们定义的条件时，使用Jupiter的交换方法执行交易。\r\n- 如果我们的交换成功，机器人将记录这次交换，并更新下一个交易条件，以便机器人将在之前交换的预定义百分比变化基础上执行下一个交换。\r\n- 机器人将运行，直到我们终止它或 SOL 不足以执行下一次交易。\r\n\r\n### 设置你的项目 \r\n\r\n首先，让我们创建一个新的项目目录：\r\n\r\n```\r\nmkdir jupiter-trading-bot\r\ncd jupiter-trading-bot\r\n```\r\n\r\n然后，初始化一个新的 Node.js 项目：\r\n\r\n```\r\nnpm init -y\r\n```\r\n\r\n接下来，安装依赖项。我们将需要Jupiter API、Solana Web3.js、Solana SPL Token 程序和 dotenv：\r\n\r\n```\r\nnpm install @jup-ag/api @solana/web3.js@1 dotenv @solana/spl-token\r\n```\r\n\r\n在你的项目目录中创建三个文件：`bot.ts`、`index.ts` 和 `.env`：\r\n\r\n```\r\necho > bot.ts && echo > index.ts && echo > .env\r\n```\r\n\r\n#### 定义 .env 变量 \r\n\r\n打开 `.env` 文件，添加以下变量：\r\n\r\n```\r\n## 用你的 Solana 钱包秘密密钥替换\r\nSECRET_KEY=[00, 00, ... 00]\r\n## 用你的 QuickNode Solana 主网 RPC 端点替换\r\nSOLANA_ENDPOINT=https://example.solana-mainnet.quiknode.pro/123456/\r\n## 用你的 QuickNode Jupiter API 端点替换（或公共端点：https://www.jupiterapi.com/）\r\nMETIS_ENDPOINT=https://jupiter-swap-api.quiknode.pro/123456\r\n```\r\n\r\n确保用你自己的变量替换这些。如果你没有文件系统钱包，可以通过运行以下命令创建一个：\r\n\r\n```\r\nsolana-keygen new --no-bip39-passphrase --silent --outfile ./my-keypair.json\r\n```\r\n\r\n#### 导入依赖项 \r\n\r\n打开 `bot.ts` 并导入必要的依赖项：\r\n\r\n```\r\nimport { Keypair, Connection, PublicKey, VersionedTransaction, LAMPORTS_PER_SOL, TransactionInstruction, AddressLookupTableAccount, TransactionMessage, TransactionSignature, TransactionConfirmationStatus, SignatureStatus } from \"@solana/web3.js\";\r\nimport { createJupiterApiClient, DefaultApi, ResponseError, QuoteGetRequest, QuoteResponse, Instruction, AccountMeta } from '@jup-ag/api';\r\nimport { getAssociatedTokenAddressSync } from \"@solana/spl-token\";\r\nimport * as fs from 'fs';\r\nimport * as path from 'path';\r\n```\r\n\r\n#### 定义接口 \r\n\r\n让我们创建几个接口来定义机器人的配置和交易条件：\r\n\r\n```\r\ninterface ArbBotConfig {\r\n solanaEndpoint: string; // 例如，“https://ex-am-ple.solana-mainnet.quiknode.pro/123456/”\r\n metisEndpoint: string; // 例如，“https://jupiter-swap-api.quiknode.pro/123456/”\r\n secretKey: Uint8Array;\r\n firstTradePrice: number; // 例如 94 USDC/SOL\r\n targetGainPercentage?: number;\r\n checkInterval?: number;\r\n initialInputToken: SwapToken;\r\n initialInputAmount: number;\r\n}\r\n\r\ninterface NextTrade extends QuoteGetRequest {\r\n nextTradeThreshold: number;\r\n}\r\n\r\nexport enum SwapToken {\r\n SOL,\r\n USDC\r\n}\r\n\r\ninterface LogSwapArgs {\r\n inputToken: string;\r\n inAmount: string;\r\n outputToken: string;\r\n outAmount: string;\r\n txId: string;\r\n timestamp: string;\r\n}\r\n```\r\n\r\n- **ArbBotConfig** 将用于定义机器人的配置，包括Solana和Jupiter API 端点、秘密密钥、初始交易价格、目标收益百分比、检查间隔以及初始输入代币和金额。\r\n- **NextTrade** 将用于定义下一个交易的条件，包括输入和输出代币、金额和阈值。\r\n- **LogSwapArgs** 将用于记录每次交易的详细信息到 JSON 文件中。\r\n\r\n#### 定义机器人类 \r\n\r\n让我们构建一个 **ArbBot** 类来处理机器人的逻辑。我们将预定义类及其方法，然后在下一节中填充详细信息。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\nexport class ArbBot {\r\n private solanaConnection: Connection;\r\n private jupiterApi: DefaultApi;\r\n private wallet: Keypair;\r\n private usdcMint: PublicKey = new PublicKey(\"EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v\");\r\n private solMint: PublicKey = new PublicKey(\"So11111111111111111111111111111111111111112\");\r\n private usdcTokenAccount: PublicKey;\r\n private solBalance: number = 0;\r\n private usdcBalance: number = 0;\r\n private checkInterval: number = 1000 * 10;\r\n private lastCheck: number = 0;\r\n private priceWatchIntervalId?: NodeJS.Timeout;\r\n private targetGainPercentage: number = 1;\r\n private nextTrade: NextTrade;\r\n private waitingForConfirmation: boolean = false;\r\n\r\n constructor(config: ArbBotConfig) {\r\n // TODO\r\n }\r\n\r\n async init(): Promise {\r\n console.log(`🤖 为钱包: ${this.wallet.publicKey.toBase58()} 启动套利机器人。`)\r\n await this.refreshBalances();\r\n console.log(`🏦 当前余额:\\nSOL: ${this.solBalance / LAMPORTS_PER_SOL},\\nUSDC: ${this.usdcBalance}`);\r\n this.initiatePriceWatch();\r\n }\r\n\r\n private async refreshBalances(): Promise {\r\n // TODO\r\n }\r\n\r\n private initiatePriceWatch(): void {\r\n // TODO\r\n }\r\n\r\n private async getQuote(quoteRequest: QuoteGetRequest): Promise {\r\n // TODO\r\n }\r\n\r\n private async evaluateQuoteAndSwap(quote: QuoteResponse): Promise {\r\n // TODO\r\n }\r\n\r\n private async confirmTransaction(\r\n connection: Connection,\r\n signature: TransactionSignature,\r\n desiredConfirmationStatus: TransactionConfirmationStatus = 'confirmed',\r\n timeout: number = 30000,\r\n pollInterval: number = 1000,\r\n searchTransactionHistory: boolean = false\r\n ): Promise {\r\n // TODO\r\n }\r\n\r\n private async executeSwap(route: QuoteResponse): Promise {\r\n // TODO\r\n }\r\n\r\n private async updateNextTrade(lastTrade: QuoteResponse): Promise {\r\n // TODO\r\n }\r\n\r\n private async logSwap(args: LogSwapArgs): Promise {\r\n const { inputToken, inAmount, outputToken, outAmount, txId, timestamp } = args;\r\n const logEntry = {\r\n inputToken,\r\n inAmount,\r\n outputToken,\r\n outAmount,\r\n txId,\r\n timestamp,\r\n };\r\n\r\n const filePath = path.join(__dirname, 'trades.json');\r\n\r\n try {\r\n if (!fs.existsSync(filePath)) {\r\n fs.writeFileSync(filePath, JSON.stringify([logEntry], null, 2), 'utf-8');\r\n } else {\r\n const data = fs.readFileSync(filePath, { encoding: 'utf-8' });\r\n const trades = JSON.parse(data);\r\n trades.push(logEntry);\r\n fs.writeFileSync(filePath, JSON.stringify(trades, null, 2), 'utf-8');\r\n }\r\n console.log(`✅ 记录交换: ${inAmount} ${inputToken} -> ${outAmount} ${outputToken},\\n TX: ${txId}}`);\r\n } catch (error) {\r\n console.error('记录交换时出错:', error);\r\n }\r\n }\r\n\r\n private terminateSession(reason: string): void {\r\n console.warn(`❌ 正在终止机器人...${reason}`);\r\n console.log(`当前余额:\\nSOL: ${this.solBalance / LAMPORTS_PER_SOL},\\nUSDC: ${this.usdcBalance}`);\r\n if (this.priceWatchIntervalId) {\r\n clearInterval(this.priceWatchIntervalId);\r\n this.priceWatchIntervalId = undefined; // 清除对间隔的引用\r\n }\r\n setTimeout(() => {\r\n console.log('机器人已被终止。');\r\n process.exit(1);\r\n }, 1000);\r\n }\r\n\r\n private instructionDataToTransactionInstruction (\r\n instruction: Instruction | undefined\r\n ) {\r\n if (instruction === null || instruction === undefined) return null;\r\n return new TransactionInstruction({\r\n programId: new PublicKey(instruction.programId),\r\n keys: instruction.accounts.map((key: AccountMeta) => ({\r\n pubkey: new PublicKey(key.pubkey),\r\n isSigner: key.isSigner,\r\n isWritable: key.isWritable,\r\n })),\r\n data: Buffer.from(instruction.data, \"base64\"),\r\n });\r\n };\r\n\r\n private async getAdressLookupTableAccounts (\r\n keys: string[], connection: Connection\r\n ): Promise {\r\n const addressLookupTableAccountInfos =\r\n await connection.getMultipleAccountsInfo(\r\n keys.map((key) => new PublicKey(key))\r\n );\r\n\r\n return addressLookupTableAccountInfos.reduce((acc, accountInfo, index) => {\r\n const addressLookupTableAddress = keys[index];\r\n if (accountInfo) {\r\n const addressLookupTableAccount = new AddressLookupTableAccount({\r\n key: new PublicKey(addressLookupTableAddress),\r\n state: AddressLookupTableAccount.deserialize(accountInfo.data),\r\n });\r\n acc.push(addressLookupTableAccount);\r\n }\r\n\r\n return acc;\r\n }, new Array());\r\n };\r\n\r\n private async postTransactionProcessing(quote: QuoteResponse, txid: string): Promise {\r\n const { inputMint, inAmount, outputMint, outAmount } = quote;\r\n await this.updateNextTrade(quote);\r\n await this.refreshBalances();\r\n await this.logSwap({ inputToken: inputMint, inAmount, outputToken: outputMint, outAmount, txId: txid, timestamp: new Date().toISOString() });\r\n }\r\n}\r\n```\r\n\r\n在继续之前，让我们用以下内容概述一下这里的内容：\r\n\r\n- 首先，我们定义了一些类属性，包括Solana连接、Jupiter API、钱包、USDC 和 SOL 代币及其流动池、余额、检查间隔、上次检查时间、价格监控间隔 ID、目标收益百分比、下一个交易条件，以及一个标志以指示机器人是否在等待确认。我们将利用这些属性来跟踪机器人的状态并管理其交易逻辑。\r\n- 我们定义一个构造函数，接收配置对象并初始化机器人的属性。我们还定义了一个 `init` 方法，用于启动机器人并获取初始余额。\r\n- 我们定义了一些助手方法：\r\n - `logSwap` 将用于记录每次交易的详细信息到 JSON 文件中。\r\n - `terminateSession` 将用于终止机器人并记录终止原因。\r\n - `instructionDataToTransactionInstruction` 将把一条指令转换为交易指令。\r\n - `getAdressLookupTableAccounts` 将用于获取地址查找表账户。\r\n - `postTransactionProcessing` 将在成功完成交换后触发必要步骤（`updateNextTrade`、`refreshBalances` 和 `logSwap`）。我们将在下一节中定义这些方法。\r\n\r\n#### 构造函数 \r\n\r\n让我们构建构造函数以初始化 _ArbBot_ 的实例。我们已经定义了 _ArbBotConfig_ 接口，所以可以用于定义构造函数的参数。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n constructor(config: ArbBotConfig) {\r\n const {\r\n solanaEndpoint,\r\n metisEndpoint,\r\n secretKey,\r\n targetGainPercentage,\r\n checkInterval,\r\n initialInputToken,\r\n initialInputAmount,\r\n firstTradePrice\r\n } = config;\r\n this.solanaConnection = new Connection(solanaEndpoint);\r\n this.jupiterApi = createJupiterApiClient({ basePath: metisEndpoint });\r\n this.wallet = Keypair.fromSecretKey(secretKey);\r\n this.usdcTokenAccount = getAssociatedTokenAddressSync(this.usdcMint, this.wallet.publicKey);\r\n if (targetGainPercentage) { this.targetGainPercentage = targetGainPercentage }\r\n if (checkInterval) { this.checkInterval = checkInterval }\r\n this.nextTrade = {\r\n inputMint: initialInputToken === SwapToken.SOL ? this.solMint.toBase58() : this.usdcMint.toBase58(),\r\n outputMint: initialInputToken === SwapToken.SOL ? this.usdcMint.toBase58() : this.solMint.toBase58(),\r\n amount: initialInputAmount,\r\n nextTradeThreshold: firstTradePrice,\r\n };\r\n }\r\n```\r\n\r\n- 首先，我们对配置对象进行结构解构，并将属性分配给类实例。\r\n- 然后使用其各自的端点创建新的Solana连接和Jupiter API 客户端。\r\n- 我们还定义从秘密密钥构建的新钱包实例。\r\n- 然后我们蒐集与钱包相关的 USDC 代币账户。\r\n- 如果提供了目标收益百分比和检查间隔，则为它们赋值（如我们在类中设置了默认值）。\r\n- 最后，我们基于初始输入代币（和金额）及首次交易价格设置下一个交易条件。交易的方向依据传入初始输入代币配置参数的代币决定。\r\n\r\n我们已经定义了公共的 `.init()` 方法。此方法可以与构造函数结合使用，以初始化机器人并启动价格监控间隔。以下是在客户端中可能的用法示例：\r\n\r\n```\r\n const bot = new ArbBot({\r\n solanaEndpoint: process.env.SOLANA_ENDPOINT ?? defaultConfig.solanaEndpoint,\r\n metisEndpoint: process.env.METIS_ENDPOINT ?? defaultConfig.jupiter,\r\n secretKey: decodedSecretKey,\r\n firstTradePrice: 0.1036 * LAMPORTS_PER_SOL,\r\n targetGainPercentage: 0.15,\r\n initialInputToken: SwapToken.USDC,\r\n initialInputAmount: 10_000_000,\r\n });\r\n\r\n await bot.init();\r\n```\r\n\r\n现在让我们定义 `refreshBalances` 和 `initiatePriceWatch` 方法，这两个方法是构造函数的 `init` 中的调用。\r\n\r\n#### 刷新余额 \r\n\r\n`refreshBalances` 方法将用于获取机器人钱包的当前 SOL 和 USDC 余额。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private async refreshBalances(): Promise {\r\n try {\r\n const results = await Promise.allSettled([\\\r\n this.solanaConnection.getBalance(this.wallet.publicKey),\\\r\n this.solanaConnection.getTokenAccountBalance(this.usdcTokenAccount)\\\r\n ]);\r\n\r\n const solBalanceResult = results[0];\r\n const usdcBalanceResult = results[1];\r\n\r\n if (solBalanceResult.status === 'fulfilled') {\r\n this.solBalance = solBalanceResult.value;\r\n } else {\r\n console.error('获取 SOL 余额时出错:', solBalanceResult.reason);\r\n }\r\n\r\n if (usdcBalanceResult.status === 'fulfilled') {\r\n this.usdcBalance = usdcBalanceResult.value.value.uiAmount ?? 0;\r\n } else {\r\n this.usdcBalance = 0;\r\n }\r\n\r\n if (this.solBalance < LAMPORTS_PER_SOL / 100) {\r\n this.terminateSession(\"SOL 余额低。\");\r\n }\r\n } catch (error) {\r\n console.error('刷新余额时意外出错:', error);\r\n }\r\n }\r\n```\r\n\r\n以下是我们所做的：\r\n\r\n- 使用 `Promise.allSettled` 同时获取 SOL 和 USDC 余额，使用 `getBalance` 和 `getTokenAccountBalance` 方法来获取。\r\n- 然后根据结果更新机器人的 SOL 和 USDC 余额，如果成功则更新，否则记录错误。\r\n- 我们还检查 SOL 余额是否低于 0.01 SOL，如果是，则终止机器人。\r\n\r\n#### 启动价格监控 \r\n\r\n`initiatePriceWatch` 方法将用于启动价格监控间隔。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private initiatePriceWatch(): void {\r\n this.priceWatchIntervalId = setInterval(async () => {\r\n const currentTime = Date.now();\r\n if (currentTime - this.lastCheck >= this.checkInterval) {\r\n this.lastCheck = currentTime;\r\n try {\r\n if (this.waitingForConfirmation) {\r\n console.log('等待之前的交易确认...');\r\n return;\r\n }\r\n const quote = await this.getQuote(this.nextTrade);\r\n this.evaluateQuoteAndSwap(quote);\r\n } catch (error) {\r\n console.error('获取报价时出错:', error);\r\n }\r\n }\r\n }, this.checkInterval);\r\n }\r\n```\r\n\r\n这只是一个简单的间隔，这将在：\r\n\r\n- 上次检查时间与检查间隔时间大于时。\r\n- 机器人没有在等待确认的情况下继续执行（我们将在 `executeSwap` 和 `postTransactionProcessing` 方法中对这个标志进行开关，以确保机器人在等待确认时不会执行交易）。\r\n\r\n让我们接下来定义 `getQuote`、`evaluateQuoteAndSwap` 和 `executeSwap` 方法。\r\n\r\n#### 获取报价 \r\n\r\n要获取报价，我们将依赖Jupiter的 `quoteGet` 方法。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private async getQuote(quoteRequest: QuoteGetRequest): Promise {\r\n try {\r\n const quote: QuoteResponse | null = await this.jupiterApi.quoteGet(quoteRequest);\r\n if (!quote) {\r\n throw new Error('未找到报价');\r\n }\r\n return quote;\r\n } catch (error) {\r\n if (error instanceof ResponseError) {\r\n console.log(await error.response.json());\r\n }\r\n else {\r\n console.error(error);\r\n }\r\n throw new Error('无法找到报价');\r\n }\r\n }\r\n```\r\n\r\n这应该与我们在概述部分的示例类似。我们只是将报价请求传递给 `quoteGet` 方法，并在存在报价的情况下返回。如果发现错误，则记录错误并抛出新错误。如果你回头看看 `initiatePriceWatch`，你会看到我们将 `this.nextTrade` 传递给了此方法，我们的 **NextTrade** 接口扩展了 **QuoteGetRequest** 接口，因此我们可以直接将其传递给 `quoteGet` 方法。\r\n\r\n#### 评估报价并交换 \r\n\r\n我们需要一种方法来确保报价满足我们的条件，然后才能执行交易。我们将定义 `evaluateQuoteAndSwap` 方法来处理它。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private async evaluateQuoteAndSwap(quote: QuoteResponse): Promise {\r\n let difference = (parseInt(quote.outAmount) - this.nextTrade.nextTradeThreshold) / this.nextTrade.nextTradeThreshold;\r\n console.log(`📈 当前价格: ${quote.outAmount} 高于或低于下次交易阈值: ${this.nextTrade.nextTradeThreshold} 的差异为 ${Math.abs(difference * 100).toFixed(2)}%。`);\r\n if (parseInt(quote.outAmount) > this.nextTrade.nextTradeThreshold) {\r\n try {\r\n this.waitingForConfirmation = true;\r\n await this.executeSwap(quote);\r\n } catch (error) {\r\n console.error('执行交换时出错:', error);\r\n }\r\n }\r\n }\r\n```\r\n\r\n我们的 `evaluateQuoteAndSwap` 方法将接受来自 `quoteGet` 方法的响应，然后计算报价的输出金额和下一个交易阈值之间的差异。如果差异为正，我们将执行交换。我们还将将 `waitingForConfirmation` 标志设置为 true，以防止机器人在等待确认时尝试执行其他交易。为了调试/演示，我们还将记录当前价格以及当前价格和下一个交易阈值之间的差异。\r\n\r\n#### 确认交易 \r\n\r\n我们需要一种方式确保交易得到确认。我们将定义 `confirmTransaction` 方法来处理它。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private async confirmTransaction(\r\n connection: Connection,\r\n signature: TransactionSignature,\r\n desiredConfirmationStatus: TransactionConfirmationStatus = 'confirmed',\r\n timeout: number = 30000,\r\n pollInterval: number = 1000,\r\n searchTransactionHistory: boolean = false\r\n ): Promise {\r\n const start = Date.now();\r\n\r\n while (Date.now() - start < timeout) {\r\n const { value: statuses } = await connection.getSignatureStatuses([signature], { searchTransactionHistory });\r\n\r\n if (!statuses || statuses.length === 0) {\r\n throw new Error('获取签名状态失败');\r\n }\r\n\r\n const status = statuses[0];\r\n\r\n if (status === null) {\r\n await new Promise(resolve => setTimeout(resolve, pollInterval));\r\n continue;\r\n }\r\n\r\n if (status.err) {\r\n throw new Error(`交易失败: ${JSON.stringify(status.err)}`);\r\n }\r\n\r\n if (status.confirmationStatus && status.confirmationStatus === desiredConfirmationStatus) {\r\n return status;\r\n }\r\n\r\n if (status.confirmationStatus === 'finalized') {\r\n return status;\r\n }\r\n\r\n await new Promise(resolve => setTimeout(resolve, pollInterval));\r\n }\r\n\r\n throw new Error(`交易确认超时，持续时间为 ${timeout}ms`);\r\n };\r\n```\r\n\r\n此方法将轮询Solana网络以查看交易状态，直到其确认或超时到达。我们为超时和轮询间隔中包括了一些默认值，但你可以根据需要调整它们。\r\n\r\n#### 执行交换 \r\n\r\n最后，如果我们的机器人检测到市场条件适宜以满足我们的交易要求，我们应该执行交易。我们将为此方法打包很多内容：\r\n\r\n1. 从Jupiter的 API 获取交换指令\r\n2. 将接收到的指令数据重构为交易指令\r\n3. 获取地址查找表账户\r\n4. 创建并发送Solana交易\r\n5. 成功后，记录交换并更新下一个交易条件\r\n\r\n让我们添加我们的代码，然后我们将分解它：\r\n\r\n```\r\n private async executeSwap(route: QuoteResponse): Promise {\r\n try {\r\n const {\r\n computeBudgetInstructions,\r\n setupInstructions,\r\n swapInstruction,\r\n cleanupInstruction,\r\n addressLookupTableAddresses,\r\n } = await this.jupiterApi.swapInstructionsPost({\r\n swapRequest: {\r\n quoteResponse: route,\r\n userPublicKey: this.wallet.publicKey.toBase58(),\r\n prioritizationFeeLamports: 'auto'\r\n },\r\n });\r\n\r\n const instructions: TransactionInstruction[] = [\\\r\n ...computeBudgetInstructions.map(this.instructionDataToTransactionInstruction),\\\r\n ...setupInstructions.map(this.instructionDataToTransactionInstruction),\\\r\n this.instructionDataToTransactionInstruction(swapInstruction),\\\r\n this.instructionDataToTransactionInstruction(cleanupInstruction),\\\r\n ].filter((ix) => ix !== null) as TransactionInstruction[];\r\n\r\n const addressLookupTableAccounts = await this.getAdressLookupTableAccounts(\r\n addressLookupTableAddresses,\r\n this.solanaConnection\r\n );\r\n\r\n const { blockhash, lastValidBlockHeight } = await this.solanaConnection.getLatestBlockhash();\r\n\r\n const messageV0 = new TransactionMessage({\r\n payerKey: this.wallet.publicKey,\r\n recentBlockhash: blockhash,\r\n instructions,\r\n }).compileToV0Message(addressLookupTableAccounts);\r\n\r\n const transaction = new VersionedTransaction(messageV0);\r\n transaction.sign([this.wallet]);\r\n\r\n const rawTransaction = transaction.serialize();\r\n const txid = await this.solanaConnection.sendRawTransaction(rawTransaction, {\r\n skipPreflight: true,\r\n maxRetries: 2\r\n });\r\n const confirmation = await this.confirmTransaction(this.solanaConnection, txid);\r\n if (confirmation.err) {\r\n throw new Error('交易失败');\r\n }\r\n await this.postTransactionProcessing(route, txid);\r\n } catch (error) {\r\n if (error instanceof ResponseError) {\r\n console.log(await error.response.json());\r\n }\r\n else {\r\n console.error(error);\r\n }\r\n throw new Error('无法执行交换');\r\n } finally {\r\n this.waitingForConfirmation = false;\r\n }\r\n }\r\n```\r\n\r\n- 首先，我们通过调用 `this.jupiterApi.swapInstructionsPost` 从Jupiter的 API 中获取交换指令。我们将使用来自 `getQuote` 方法的报价、钱包的公钥（这对于构建用户特定的指令集是必要的）以及优先费用（我们将其设置为“自动”，以便让Jupiter确定费用）。可以通过查看 [Jupiter API 文档](https://station.jup.ag/api-v6/post-swap) 来探索其他可选参数。\r\n- 然后我们利用 `instructionDataToTransactionInstruction` 方法将接收到的指令数据重构为交易指令。这样做的主要原因是为了从数组中删除可能为 _null_ 或 _undefined_ 的指令，并确保我们有一个干净且扁平化的指令数组，可以传递给Solana交易。\r\n- 然后，我们使用之前定义的 `getAdressLookupTableAccounts` 方法查询地址查找表账户。此举对交易指令特别有用，因为它使我们能够将多个账户传递给该交易部分。\r\n- 然后我们使用指令、地址查找表账户和最新的区块哈希创建并发送Solana交易。使用我们的钱包对交易进行签名并将其发送到Solana网络。\r\n- 在确认交易成功后，我们调用 `postTransactionProcessing` 方法来触发成功交换后必要的步骤（`updateNextTrade`、`refreshBalances` 和 `logSwap`）。我们已经定义了 `refreshBalances` 和 `logSwap`，因此我们将在下一部分定义 `updateNextTrade`。\r\n\r\n#### 更新下一个交易 \r\n\r\n最后，在交易执行之后，我们需要改变下一个交换的参数（重新定义我们的 _NextTrade_ 接口）。我们将定义 `updateNextTrade` 方法来处理此事。将以下内容添加到 `bot.ts`：\r\n\r\n```\r\n private async updateNextTrade(lastTrade: QuoteResponse): Promise {\r\n const priceChange = this.targetGainPercentage / 100;\r\n this.nextTrade = {\r\n inputMint: this.nextTrade.outputMint,\r\n outputMint: this.nextTrade.inputMint,\r\n amount: parseInt(lastTrade.outAmount),\r\n nextTradeThreshold: parseInt(lastTrade.inAmount) * (1 + priceChange),\r\n };\r\n }\r\n```\r\n\r\n为简单起见，在这个例子中，我们将仅交换输入和输出铸造（这意味着，如果我们之前使用 USDC 买 SOL，则下一个交换应该是以 SOL 卖出 USDC）。我们还将设置接下来的交易阈值。我们的 `amount` 是我们将在下次交易中投入的代币数量——我们把它设置为之前交易中获得的代币数量。我们的 `nextTradeThreshold` 是我们将在下次交易中执行的价格。我们将其定义为输入我们交易的代币数量加上我们的目标收益百分比。例如，如果我们使用 10 USDC 兑换 0.1 SOL，而我们的目标收益百分比是 15%；下一个交易输入（`amount`）将是 0.1 SOL，下一个交易阈值将是 11.5 USDC （这意味着我们期望下次触发将产生 11.5 USDC）。\r\n\r\n很好！你现在已经定义了我们的交易机器人的核心逻辑。我们只需要创建一个客户端并运行机器人。现在让我们这样做。\r\n\r\n### 创建客户端 \r\n\r\n打开 `index.ts` 并添加以下代码：\r\n\r\n```\r\nimport { LAMPORTS_PER_SOL, clusterApiUrl } from \"@solana/web3.js\";\r\nimport { ArbBot, SwapToken } from './bot';\r\nimport dotenv from \"dotenv\";\r\n\r\ndotenv.config({\r\n path: \".env\",\r\n});\r\n\r\nconst defaultConfig = {\r\n solanaEndpoint: clusterApiUrl(\"mainnet-beta\"),\r\n jupiter: \"https://quote-api.jup.ag/v6\",\r\n};\r\n\r\nasync function main() {\r\n if (!process.env.SECRET_KEY) {\r\n throw new Error(\"SECRET_KEY 环境变量未设置\");\r\n }\r\n let decodedSecretKey = Uint8Array.from(JSON.parse(process.env.SECRET_KEY));\r\n```\r\n```javascript\r\nconst bot = new ArbBot({\r\n solanaEndpoint: process.env.SOLANA_ENDPOINT ?? defaultConfig.solanaEndpoint,\r\n metisEndpoint: process.env.METIS_ENDPOINT ?? defaultConfig.jupiter,\r\n secretKey: decodedSecretKey,\r\n firstTradePrice: 0.11 * LAMPORTS_PER_SOL,\r\n targetGainPercentage: 1.5,\r\n initialInputToken: SwapToken.USDC,\r\n initialInputAmount: 10_000_000,\r\n });\r\n\r\n await bot.init();\r\n\r\n}\r\n\r\nmain().catch(console.error);\r\n```\r\n\r\n这个简单的客户端将创建我们的 `ArbBot` 的一个实例并调用 `init` 方法。我们还使用 `dotenv` 包从 `.env` 文件加载环境变量。如果未设置环境变量，我们包含了一个将被使用的默认配置对象。让我们解释一下其他输入参数，以确保我们理解发生了什么：\r\n\r\n- `firstTradePrice` 是我们期望在第一次交易中获得的价格。在我们的例子中，我们将在知道可以用我们的 `inputTokenAmount` 购买 0.11 SOL 时购买 SOL。\r\n- `targetGainPercentage` 是我们希望在交易中实现的百分比收益。在我们的例子中，我们将其设置为 1.5%。这意味着后续交易将在 SOL 的价格高于或低于上一次交易的 1.5% 时被触发。\r\n- `initialInputToken` 是我们将用于启动第一次交易的代币。在我们的例子中，我们将其设置为 USDC。\r\n- `initialInputAmount` 是我们将用于启动第一次交易的代币数量。在我们的例子中，我们将其设置为 10 USDC。\r\n\r\n简而言之，我们正在设置我们的机器人，在可用时以 10 USDC 买入 0.11 SOL。当 SOL 的价格高于或低于上一次交易的 1.5% 时，将触发后续交易。\r\n\r\n### 运行机器人\r\n\r\n在主网进行交易\r\n\r\n当前，Jupiter 交易 API 仅可用于主网，这意味着任何执行的交易将是真实的且不可逆转。在将在主网上运行之前，请确保对机器人的逻辑和潜在风险有充分的理解。\r\n\r\n在你的终端中，运行以下命令以启动机器人：\r\n\r\n```\r\nts-node index.ts\r\n```\r\n\r\n就这样！你应该看到我们的 `🤖` 日志启动机器人以及价格更新和成功交易确认的常规日志！\r\n\r\n```\r\nQuickNode $ts-node index.ts\r\n🤖 为钱包启动套利机器人: JUPz...Q1ie.\r\n🏦 当前余额:\r\nSOL: 0.01271548,\r\nUSDC: 10.087\r\n📈 当前价格: 97624457 低于下一个交易阈值: 100000000 2.38%。\r\n```\r\n\r\n干得不错。\r\n\r\n你可以在我们的 [GitHub](https://github.com/quiknode-labs/qn-guide-examples/tree/main/solana/jupiter-bot) 上找到我们的完整代码。\r\n\r\n### 总结\r\n\r\n你现在已经尝试了 Jupiter API 和 QuickNode 的 Metis 附加组件。你还构建了一个简单的交易机器人，它使用 Jupiter 的 API 监控市场特定条件，并在满足这些条件时执行交易。你现在可以尝试不同的交易条件和策略，看看机器人表现如何。想找点灵感？以下是一些想法：\r\n\r\n- 将 [durable nonces](https://learnblockchain.cn/article/11207) 集成到你的机器人中，以提高交易速度\r\n- 利用 [Solana 的 Websocket 方法](https://learnblockchain.cn/article/11172) 实时监控你机器人的交易活动\r\n- 在你的网站中集成 [Jupiter Terminal](https://learnblockchain.cn/article/11206)\r\n\r\n如果你有问题或想要分享的想法，请在 [Discord](https://discord.gg/quicknode) 或 [Twitter](https://twitter.com/QuickNode) 上给我们留言！\r\n\r\n \r\n\r\n### 资源\r\n\r\n- [Jupiter API 文档](https://station.jup.ag/docs/apis/swap-api)\r\n- [Jupiter API GitHub](https://github.com/jup-ag/jupiter-quote-api-node)\r\n- [Metis：QuickNode Jupiter API 附加组件](https://marketplace.quicknode.com/add-on/metis-jupiter-v6-swap-api)\r\n- [JupiterAPI.com - 公共 Jupiter API 端点](https://www.jupiterapi.com/?utm_source=guides-jup-trading-bot)\r\n\r\n\r\n>- 原文链接： [quicknode.com/guides/sol...](https://www.quicknode.com/guides/solana-development/3rd-party-integrations/jupiter-api-trading-bot)\r\n>- 登链社区 AI 助手，为大家转译优秀英文文章，如有翻译不通的地方，还请包涵～"},"author":{"user":"https://learnblockchain.cn/people/25306","address":null},"history":"bafkreidzyaozqai23aje7ylr47uwmmmamv4quqjmvqrgfanpvt7rzx7aha","timestamp":1740466221,"version":1}