如何使用 ethers.js 监听待处理交易

• 原文：https://www.quicknode.com/guides/defi/how-to-stream-pending-transactions-with-ethers-js
• 译文出自：登链翻译计划
• 译者：darren
• 校对：Tiny 熊
• 本文永久链接：learnblockchain.cn/article…

概述

如果你喜欢观看而不是阅读，这里有一个视频指南：https://www.youtube.com/embed/YjQj6uk9M98

在以太坊上，在形成一个区块中之前，交易会保留在待处理交易队列、交易池或内存池中——它们的意义相同。然后，矿工从这个队列中选择待处理交易池的子集进行出块——对于交易者、想要节省 gas 费用的人等能够访问和分析这些信息将会得到很多好处。

在这份指南中，我们将学会如何在以太坊和相似链使用 ethers.js 处理待处理交易流

准备条件

• 在你的电脑上安装Nodejs
• 一个文本编辑器
• 命令行终端
• 一个以太坊节点

什么是待处理交易

要在以太坊网络编写或者更新任何内容，需要有人创建，签署和发送交易。交易是外部世界与以太坊网络通信的方式。当发送到以太坊网络时，交易会停留在称为“mempool”的队列中，交易等待旷工被处理----- 处于这种等待交易称为待处理交易。发送交易所需要的少量费用称为gas;交易被旷工包含在一个区块中，并且根据它们包含的给旷工的gas 价格来确定优先级 。

查看这里, 将得到关于内存池和待处理交易的更多信息。

我为什么需要查看未处理的交易呢？

通过检查待处理的交易，可以执行以下操作：

• 估计gas：理论上我们可以查看待处理的交易来预测下一个区块的最优gas价格。
• 用于交易分析：我们可以分析去中心化交易所中的待处理交易，以便预测市场趋势。
• 交易抢跑：在 DeFi 中，你可以预览即将到来的与价格（预言机）相关的交易，并可能对 MKR、COMP 和其他协议的保险库发出清算。

处理待处理交易流可能有很多案例——我们不会在这里全部介绍。

我们将使用 ethers.js， - （中文文档） 通过 WebSockets 处理这些待处理的交易流。在编写代码之前， 看看如何安装 ethers.js。

安装ethers.js

我们的第一步是检查系统上是否安装了 node.js。为此，请将以下内容复制粘贴到你的终端

$ node -v

如果没有安装，可以从 官网下载 LTS 版本的 NodeJS。

现在我们已经安装了 node.js，让我们使用 node.js 附带的 npm（节点包管理器）安装 ethers.js 库。

$ npm i ethers

此步骤中最常见的问题是 node-gyp 的内部故障。你可以按照 node-gyp 安装说明在这里。

注意：如果遇到 node-gyp 问题，你需要让你的 python 版本与上述说明中列出的兼容版本之一匹配。

另一个常见问题是缓存过时。只需在终端中键入以下内容即可清除 npm 缓存：

$ npm cache clean

如果一切是正常的，ethers.js将安装到了你的操作系统。

启动我们的以太坊节点

对于我们今天的目的，我们几乎可以使用任何以太坊客户端，例如 Geth 或 OpenEthereum (之前称为 Parity)。由于要处理传入的新待处理的交易流，节点连接必须稳定可靠； 维护一个节点是一项具有挑战性的任务，我们只需 从 QuickNode 获取一个免费的端点 来简化这项工作。创建免费的以太坊端点后，复制你的 WSS (WebSocket) Provider 端点。

你以后会需要它的，因此这会复制并且保存它。

处理待处理交易流

创建一个脚本文件pending.js，它将对传入的待处理交易进行交易过滤。将以下内容复制粘贴到文件中：

var ethers = require("ethers");
var url = "ADD_YOUR_ETHEREUM_NODE_WSS_URL";

var init = function () {
  var customWsProvider = new ethers.providers.WebSocketProvider(url);

  customWsProvider.on("pending", (tx) => {
    customWsProvider.getTransaction(tx).then(function (transaction) {
      console.log(transaction);
    });
  });

  customWsProvider._websocket.on("error", async () => {
    console.log(`Unable to connect to ${ep.subdomain} retrying in 3s...`);
    setTimeout(init, 3000);
  });
  customWsProvider._websocket.on("close", async (code) => {
    console.log(
      `Connection lost with code ${code}! Attempting reconnect in 3s...`
    );
    customWsProvider._websocket.terminate();
    setTimeout(init, 3000);
  });
};

init();

所以继续用上面部分中的 WSS (WebSocket) Provider 替换 ADD_YOUR_ETHEREUM_NODE_WSS_URL。

以上代码解释如下：

第 1 行：导入 ethers 库。

第 2 行：设置我们的以太坊节点 URL。

第 4 行：创建 init 函数。

第 5 行：实例化一个 ethers WebSocketProvider 实例。

第 7 行：为待处理的交易创建一个事件侦听器，每次从节点发送新的交易哈希时都会运行该事件侦听器。

第 8-10 行：使用从上一步获得的交易哈希获取整个交易，并在控制台中打印交易。

第 13-16 行：如果连接遇到错误，则重新启动 WebSocket 连接的函数。

第 17-21 行：如果连接终止，则重新启动 WebSocket 连接的函数。

第 24 行：调用 init 函数。

现在 ，让我一起运行这段脚本：

$ node pending

如果一切执行得顺利， 你会看到传入的待处理交易，像这样：

使用 Ctrl+c 来停止这段脚本的运行。

结论

在这里，我们看到了如何使用 ethers.sjs 从以太坊网络获取待处理的交易，这里有相应的文档。

订阅我们的 newsletter 以获取有关以太坊的更多文章和指南。如果你有任何反馈，请随时通过 Twitter 与我们联系。你可以随时在我们的 Discord 社区服务器上与我们聊天，其中包含你将遇到的一些最酷的开发人员 :)

本翻译由 Duet Protocol 赞助支持。