準備工作

將最新版本的web3j加入到專案配置中

Maven

Java 8:

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

Android:

<dependency>
  <groupId>org.web3j</groupId>
  <artifactId>
 
core-android</artifactId>
  <version>2.1.0</version>
</dependency>

Gradle

Java 8:

compile ('org.web3j:core:2.2.1')

Android:

compile ('org.web3j:core-android:2.1.0')

啟動客戶端

如果已經啟動客戶端，則不需要再次啟動。
使用geth腳步進行啟動

$ geth --fast --cache=512 --rpcapi personal,db,eth,net,web3
 
 --rpc --testnet

使用Parity啟動

$ parity --chain testnet

使用Infura提供的免費客戶端啟動

Web3j web3 = Web3j.build(new InfuraHttpService("https://morden.infura.io/your-token"));

請求傳送

使用Future傳送非同步請求

Web3j web3 = Web3j.build(new HttpService());  // defaults to http://localhost:8545/
Web3ClientVersion web3ClientVersion = web3.web
 
3ClientVersion().sendAsync().get();
String clientVersion = web3ClientVersion.getWeb3ClientVersion();

使用RxJava的Observable

Web3j web3 = Web3j.build(new HttpService());  // defaults to http://localhost:8545/
web3.web3ClientVersion().observable().subscribe(x -> {
    String clientVersion = x.getWeb3ClientVersion();
    ...
});

傳送同步請求

Web3j web3 = Web3j.build(new HttpService());  // defaults to http://localhost:8545/
Web3ClientVersion web3ClientVersion = web3.web3ClientVersion().send();
String clientVersion = web3ClientVersion.getWeb3ClientVersion();

Android使用方式

Web3j web3 = Web3jFactory.build(new HttpService()); // defaults to http://localhost:8545/ ...

IPC

web3j同樣支援快速的IPC程序間通訊，可使用檔案套接字在同一個host上執行多個客戶端作為web3j。建立服務時使用相關IpcService的實現，而不是使用HttpService。

// OS X/Linux/Unix:
Web3j web3 = Web3j.build(new UnixIpcService("/path/to/socketfile"));
...

// Windows
Web3j web3 = Web3j.build(new WindowsIpcService("/path/to/namedpipefile"));
...

注意：IPC通訊在web3j-android中時不可用的。

Filters

web3j的響應式函式能夠很簡單的使觀察者通過事件去通知訂閱者，並記錄在區塊鏈中。
接受所有新的區塊並把它們新增到區塊鏈中。

Subscription subscription = web3j.blockObservable(false).subscribe(block -> {
    ...
});

接受所有新的交易並把它們新增到區塊鏈中。

Subscription subscription = web3j.transactionObservable().subscribe(tx -> {
    ...
});

接受所有已經提交到網路中的等待處理的交易。(它們必須分在同一個區塊中。)

Subscription subscription = web3j.pendingTransactionObservable().subscribe(tx -> {
    ...
});

如果你重置了所有的區塊到最新的，那麼將被隨後新建的區塊通知。

Subscription subscription = catchUpToLatestAndSubscribeToNewBlocksObservable(
        <startBlockNumber>, <fullTxObjects>)
        .subscribe(block -> {
            ...
});

一部分其他的交易和區塊可重置觀察，詳細描述可見 Filters and Events。

主題過濾同樣被支援：

EthFilter filter = new EthFilter(DefaultBlockParameterName.EARLIEST,
        DefaultBlockParameterName.LATEST, <contract-address>)
             .addSingleTopic(...)|.addOptionalTopics(..., ...)|...;
web3j.ethLogObservable(filter).subscribe(log -> {
    ...
});

當訂閱不在需要時，訂閱應該被取消。

subscription.unsubscribe();

注意：filters在Infura中不支援。
需要了解更多有關過濾器和事件的資訊可以檢視Filters and Events和Web3jRx 的介面

Transactions