使用Web3j连接以太坊客户端，从入门到实践

在区块链技术落地的过程中,应用层与底层区块链网络的交互是核心环节，以太坊作为全球最大的智能合约平台，其客户端（如Geth、Parity、Nethermind等）提供了节点服务，而Java/Android开发者若要与以太坊交互，Web3j是目前最主流的工具库，本文将详细介绍如何使用Web3j连接以太坊客户端，涵盖环境准备、连接方式、核心操作及注意事项，帮助开发者快速上手。

前置准备：环境与工具安装

在开始使用Web3j之前,需确保以下环境已正确配置：

以太坊客户端运行

以太坊客户端是Web3j连接的“目标节点”，需提前启动并开放API接口，以常用的Geth（Go Ethereum）为例，启动命令如下：

geth --http --http.addr "0.0.0.0" --http.port "8545" --http.api "eth,net,web3,personal" --syncmode "full"

参数说明：

• --http：启用HTTP API服务（默认端口8545）；
• --http.addr "0.0.0.0"：允许任意IP访问（生产环境建议限制为特定IP）；
• --http.api：开放的API模块（至少包含eth、net、web3）；
• --syncmode "full"：全量同步模式（开发环境可用fast模式加速）。

启动后,可通过curl http://localhost:8545测试节点是否响应（返回JSON格式的节点信息）。

Java开发环境

Web3j是基于Java开发的库,需安装JDK 8或更高版本，并配置JAVA_HOME环境变量，可通过java -version检查版本。

项目构建工具

推荐使用Maven或Gradle管理Web3j依赖,本文以Maven为例，Gradle配置可参考Web3j官方文档。

Web3j集成：添加项目依赖

在Maven项目的pom.xml中添加Web3j核心依赖（建议使用最新稳定版）：

<dependency>
    <groupId>org.web3j</groupId>
    <artifactId>core</artifactId>
    <version>4.9.8</version> <!-- 请替换为最新版本 -->
</dependency>

若需支持Android开发,可额外添加android模块依赖（处理Android特定兼容性问题）。

连接以太坊客户端：核心代码实现

Web3j支持多种连接方式,包括HTTP、WebSocket和IPC（进程间通信），其中HTTP是最常用的方式，适用于大多数场景。

HTTP连接（开发环境首选）

通过HTTP协议连接以太坊节点,代码如下：

import org.web3j.protocol.Web3j;
import org.web3j.protocol.http.HttpService;
import org.web3j.protocol.core.DefaultBlockParameterName;
import org.web3j.protocol.core.methods.response.EthBlockNumber;
import org.web3j.protocol.core.methods.response.EthGetBalance;
public class Web3jHttpConnection {
    public static void main(String[] args) throws Exception {
        // 1. 创建Web3j实例，指定节点HTTP地址
        String nodeUrl = "http://localhost:8545";
        Web3j web3j = Web3j.build(new HttpService(nodeUrl));
        // 2. 测试连接：获取最新区块号
        EthBlockNumber blockNumber = web3j.ethBlockNumber().send();
        System.out.println("Latest block number: " + blockNumber.getBlockNumber());
        // 3. 获取账户余额（需替换为实际地址）
        String address = "0xYourAddressHere";
        EthGetBalance balance = web3j.ethGetBalance(address, DefaultBlockParameterName.LATEST).send();
        System.out.println("Balance of " + address + ": " + balance.getBalance());
    }
}

关键步骤说明：

• Web3j.build(new HttpService(nodeUrl))：创建Web3j实例，HttpService封装了HTTP请求逻辑；
• ethBlockNumber().send()：调用节点API获取最新区块号，.send()表示同步发送请求（异步调用可使用.sendAsync()）；
• ethGetBalance()：查询指定地址的以太币余额，DefaultBlockParameterName.LATEST表示查询最新区块的状态。

WebSocket连接（实时监听场景）

若需实时监听节点事件（如新区块生成、交易状态变更），可使用WebSocket连接：

import org.web3j.protocol.Web3j;
import org.web3j.protocol.websocket.WebSocketService;
import org.web3j.protocol.core.methods.response.NewBlockHeaders;
public class Web3jWebSocketConnection {
    public static void main(String[] args) throws InterruptedException {
        String nodeUrl = "ws://localhost:8546"; // WebSocket默认端口8546
        WebSocketService webSocketService = new WebSocketService(nodeUrl, false); // false表示不重连
        webSocketService.connect(); // 手动连接
        Web3j web3j = Web3j.build(webSocketService);
        // 监听新区块头事件
        web3j.newBlockHeadersFlowable().subscribe(blockHeader -> {
            System.out.println("New block received: " + blockHeader.getNumber());
        });
        // 保持主线程运行（实际项目中需通过线程管理）
        Thread.sleep(60000); // 监听1分钟
        webSocketService.close(); // 关闭连接
    }
}

注意：WebSocket连接需节点开启WebSocket服务（Geth启动时添加--ws --ws.addr "0.0.0.0" --ws.port "8546"）。

IPC连接（本地节点优化）

若以太坊客户端与Java应用运行在同一台机器,IPC（Unix Domain Socket或Windows命名管道）性能更优（无需网络IO）：

import org.web3j.protocol.ipc.IpcService;
import org.web3j.protocol.Web3j;
public class Web3jIpcConnection {
    public static void main(String[]