如何高效模拟内存池待处理交易并提取售币信息？

1. 优化内存池交易过滤，降低CPU负载 #

别仅依赖value=0筛选，结合目标代币合约+方法签名实现精准过滤：

• 针对ERC20售币场景（如转币到DEX）：过滤调用transfer(address,uint256)（方法签名0xa9059cbb）或transferFrom(address,address,uint256)（方法签名0x23b872dd）的交易，同时校验交易To字段是否属于你的目标代币合约数组。
• 针对DEX兑换场景（如代币换ETH）：过滤调用swapExactTokensForETH(uint256,uint256,address[],address,uint256)（方法签名0x18cbafe5）或swapTokensForExactETH(uint256,uint256,address[],address,uint256)（方法签名0xfb3bdb41）的交易，且路径中包含目标代币。
• 实现方式：提取交易Input字段的前4字节（方法签名）匹配上述标识，同时校验To字段，大幅减少待处理交易数量。

2. 高效获取交易发送方From #

go-ethereum内置方法可快速恢复Sender，代码量极小，完全适配每秒11-14笔的量级：

import (
    "github.com/ethereum/go-ethereum/core/types"
    "github.com/ethereum/go-ethereum/common"
)

func getTransactionSender(tx *types.Transaction) (common.Address, error) {
    signer := types.LatestSignerForChainID(tx.ChainId())
    return signer.Sender(tx)
}

直接调用该函数即可从pending交易中提取From地址，无需额外工具，类型转换简单高效。

3. 解析拟售出的代币数量 #

根据交易类型解析Input数据：

• ERC20 Transfer/TransferFrom交易：Input数据第4-36字节为接收方地址，第36-68字节是uint256格式的代币数量，直接解析即可。
• DEX Swap交易：以Uniswap V2的swapExactTokensForETH为例，Input数据第4-36字节是amountIn（售出代币数量），可借助go-ethereum/accounts/abi包自动解析：

import (
    "github.com/ethereum/go-ethereum/accounts/abi"
    "github.com/ethereum/go-ethereum/common"
    "math/big"
    "strings"
    "errors"
)

// 加载Uniswap V2 Router简化ABI（仅包含swapExactTokensForETH）
var routerABI, _ = abi.JSON(strings.NewReader(`[{"constant":false,"inputs":[{"name":"amountIn","type":"uint256"},{"name":"amountOutMin","type":"uint256"},{"name":"path","type":"address[]"},{"name":"to","type":"address"},{"name":"deadline","type":"uint256"}],"name":"swapExactTokensForETH","outputs":[{"name":"amountOut","type":"uint256"}],"payable":false,"stateMutability":"nonpayable","type":"function"}]`))

func parseSwapAmountIn(tx *types.Transaction, targetRouter common.Address) (*big.Int, error) {
    if tx.To() == nil || *tx.To() != targetRouter {
        return nil, errors.New("not target swap tx")
    }
    var amountIn *big.Int
    err := routerABI.UnpackIntoInterface(&amountIn, "swapExactTokensForETH", tx.Data()[4:])
    return amountIn, err
}

4. 简化交易模拟流程 #

拿到From地址后，直接填充到Alchemy API的模拟请求参数中即可。结合前面的精准过滤，仅对匹配的交易执行模拟，进一步降低资源消耗。

内容的提问来源于stack exchange，提问作者solo11