使用Web3j监控以太坊代币交易的完整实战指南

在区块链应用开发中,实时监控以太坊上的代币（Token）交易是一项非常常见的需求，无论是构建交易所、钱包应用、支付网关，还是数据分析平台，都离不开对链上交易的追踪，Web3j 作为 Java 生态中最流行的以太坊交互库，提供了强大而灵活的 API 来实现这一目标，本文将详细介绍如何使用 Web3j 监控以太坊网络并查询代币交易。

Web3j 简介

Web3j 是一个轻量级、高度模块化的 Java 库，用于与以太坊节点交互，它的主要特性包括：

• 通过 JSON-RPC 与以太坊节点通信（HTTP / WebSocket）
• 支持原生 Java 类型与以太坊类型的自动转换
• 提供响应式 API（基于 RxJava 的 Flowable）
• 支持智能合约的自动包装生成
• 无需依赖 Geth 等节点程序的额外安装

环境准备

添加 Maven 依赖

<dependency>
    <groupId>org.web3j</groupId>
    <artifactId>core</artifactId>
    <version>4.10.3</version>
</dependency>

准备 RPC 节点

可以选择以下任意一种方式接入以太坊网络：

• Infura：最常用的第三方 RPC 服务，注册即可获取 API Key
• Alchemy：提供免费的 RPC 端点
• 自建节点：运行 Geth 或 Erigon 客户端

连接以太坊网络

import org.web3j.protocol.Web3j;
import org.web3j.protocol.http.HttpService;
public class EthereumMonitor {
    public static void main(String[] args) throws Exception {
        // 连接以太坊主网
        Web3j web3j = Web3j.build(
            new HttpService("https://mainnet.infura.io/v3/你的PROJECT_ID")
        );
        // 测试连接是否正常
        String clientVersion = web3j.web3ClientVersion().send().getWeb3ClientVersion();
        System.out.println("节点版本: " + clientVersion);
        web3j.shutdown();
    }
}

如果需要实时推送（而非轮询），建议使用 WebSocket 方式连接：

WebSocketService wsService = new WebSocketService(
    "wss://mainnet.infura.io/ws/v3/你的PROJECT_ID", true);
wsService.connect();
Web3j web3j = Web3j.build(wsService);

监控新区块与交易

监听每一个新生成的区块,并遍历其中的交易：

import org.web3j.protocol.core.methods.response.EthBlock;
import io.reactivex.functions.Consumer;
import io.reactivex.disposables.Disposable;
Disposable disposable = web3j.blockFlowable(true).subscribe(block -> {
    EthBlock.Block ethBlock = block.getBlock();
    System.out.println("捕获新区块: #" + ethBlock.getNumber());
    // 遍历区块内的所有交易
    for (EthBlock.TransactionResult<?> txResult : ethBlock.getTransactions()) {
        EthBlock.TransactionObject tx = 
            (EthBlock.TransactionObject) txResult.get();
        // 判断是否为代币合约调用
        String toAddress = tx.getTo();
        if (目标代币合约地址.equalsIgnoreCase(toAddress)) {
            System.out.println("发现代币交易, Hash: " + tx.getHash());
        }
    }
});

⚠️ 注意：一笔交易“发送到代币合约地址”只说明它调用了该合约，具体的转账细节需要通过交易回执（Receipt）中的日志来解析。

解析 ERC-20 代币 Transfer 事件

ERC-20 标准的代币转账会触发 Transfer 事件，其事件签名的 Hash 为：

0xddf252ad1be2c89b69c2b068fc378daa952ba7f163