Mempool

Mempool（Memory Pool）是指在区块链网络中，尚未被打包进区块的所有待处理交易的集合。交易首先被广播到网络，并存储在每个节点的 Mempool 中，直到矿工将这些交易打包到一个新的区块中。

Mempool 的主要特点

• 临时存储： Mempool 是交易在区块链上被确认之前的临时存储区。
• 交易优先级： 矿工通常根据交易费用（Gas 费）优先选择哪些交易要优先打包进区块。因此，支付更高费用的交易通常会更快地被打包。
• 网络健康： Mempool 的大小和处理时间可以反映网络的拥堵情况。如果 Mempool 中的交易数量过多，可能意味着网络负荷较高，交易确认时间可能会变长。

Mempool 的工作流程

1. 广播交易： 用户发起一笔交易并将其广播到区块链网络。
2. 交易验证： 节点验证交易的合法性（例如，签名是否正确，账户余额是否充足）。
3. 存储交易： 验证通过的交易会被放入节点的 Mempool 中，等待被打包。
4. 打包交易： 矿工从 Mempool 中选择交易打包进一个新的区块，并将区块广播到全网。

示例图示

1. 用户发起交易
     ↓
2. 交易广播到区块链网络
     ↓
3. 节点验证交易合法性
     ↓
4. 交易存储在 Mempool 中
     ↓
5. 矿工从 Mempool 中选择交易打包到区块中
     ↓
6. 新区块广播到全网，交易从 Mempool 中移除

监控脚本

const { ethers } = require('ethers');

const provider = new ethers.WebSocketProvider('wss://eth-mainnet.g.alchemy.com/v2/ged06NfoHIbeQK9sMoJpm_RatVPnguAp');

let network = provider.getNetwork()
network.then(res => console.log(`[${(new Date).toLocaleTimeString()}] 连接到 chain ID ${res.chainId}`));

function throttle(fn, delay) {
    let timer;
    return function(){
        if(!timer) {
            fn.apply(this, arguments)
            timer = setTimeout(()=>{
                clearTimeout(timer)
                timer = null
            },delay)
        }
    }
}

const main = async () => {
    let i = 0;
    // 3. 监听pending交易，获取txHash
    console.log("\n3. 监听pending交易，打印txHash。")
    provider.on("pending", async (txHash) => {
        if (txHash && i < 100) {
            // 打印txHash
            console.log(`[${(new Date).toLocaleTimeString()}] 监听Pending交易 ${i}: ${txHash} \r`);
            i++
            }
    });

    // 4. 监听pending交易，并获取交易详情
    console.log("\n4. 监听pending交易，获取txHash，并输出交易详情。")
    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));
};

main()