监听Mempool
这一讲,我们将介绍如何读取mempool
(交易内存池)中的交易。
MEV
MEV
(Maximal Extractable Value,最大可提取价值)是个令人着迷的话题。大部分人对它很陌生,因为在支持智能合约的区块链被发明之前它并不存在。它是科学家的盛宴,矿场的友人,散户的噩梦。
在区块链中,矿工可以通过打包、排除或重新排序他们产生的区块中的交易来获得一定的利润,而MEV
是衡量这种利润的指标。
Mempool
在用户的交易被矿工打包进以太坊区块链之前,所有交易会汇集到Mempool(交易内存池)中。矿工也是在这里寻找费用高的交易优先打包,实现利益最大化。通常来说,gas price越高的交易,越容易被打包。
同时,一些MEV
机器人也会搜索mempool
中有利可图的交易。比如,一笔滑点设置过高的swap
交易可能会被 三明治攻击:通过调整gas,机器人会在这笔交易之前插一个买单,之后发送一个卖单,等效于把把代币以高价卖给用户(抢跑)。
监听mempool
你可以利用ethers.js
的Provider
类提供的方法,监听mempool
中的pending
(未决,待打包)交易:
provider.on("pending", listener)
监听mempool脚本
下面,我们写一个监听mempool
脚本。
-
创建
provider
和wallet
。这次我们用的provider
是WebSocket Provider,更持久的监听交易。因此,我们需要将url
换成wss
的。console.log("\n1. 连接 wss RPC") // 准备 alchemy API 可以参考/solidity/p/Alchemy/ const ALCHEMY_MAINNET_WSSURL = 'wss://eth-mainnet.g.alchemy.com/v2/oKmOQKbneVkxgHZfibs-iFhIlIAl6HDN'; const provider = new ethers.providers.WebSocketProvider(ALCHEMY_MAINNET_WSSURL);
-
因为
mempool
中的未决交易很多,每秒上百个,很容易达到免费rpc
节点的请求上限,因此我们需要用throttle
限制请求频率。function throttle(fn, delay) { let timer; return function(){ if(!timer) { fn.apply(this, arguments) timer = setTimeout(()=>{ clearTimeout(timer) timer = null },delay) } } }
-
监听
mempool
的未决交易,并打印交易哈希。let i = 0 provider.on("pending", async (txHash) => { if (txHash && i < 100) { // 打印txHash console.log(`[${(new Date).toLocaleTimeString()}] 监听Pending交易 ${i}: ${txHash} \r`); i++ } });
-
通过未决交易的哈希,获取交易详情。我们看到交易还未上链,它的
blockHash
,blockNumber
,和transactionIndex
都为空。但是我们可以获取到交易的发送者地址from
,燃料费gasPrice
,目标地址to
,发送的以太数额value
,发送数据data
等等信息。机器人就是利用这些信息进行MEV
挖掘的。let j = 0 provider.on("pending", throttle(async (txHash) => { if (txHash && j >= 100) { // 获取tx详情 let tx = await provider.getTransaction(txHash); console.log(`\n[${(new Date).toLocaleTimeString()}] 监听Pending交易 ${j}: ${txHash} \r`); console.log(tx); j++ } }, 1000));
总结
这一讲,我们简单介绍了MEV
和mempool
,并写了个脚本监听mempool
的未决交易。