1.通知机制

以太坊的通知机制是建立在日志基础之上，如果智能合约触发了一个事件，那么该事件将写入以太坊日志；如果外部应用订阅了这个事件，那么应用就可以在日志中出现该事件后及时监测到，进而获取日志信息。

2.监听新块的产生

Web3j 中的 blockObservable()方法可以创建一个块事件可观测对象。

    @Test
    public void listener() throws Exception {
        Web3j web3j = Web3j.build(new HttpService("http://localhost:8545"),100, Async.defaultExecutorService());//设定询问周期为100毫秒
        web3j.blockObservable(true).subscribe(ethBlock -> {
            EthBlock.Block block = ethBlock.getBlock();
            System.out.println("hash:"+block.getHash());
            System.out.println("number:"+block.getNumber());
        });//监听新块产生
        //模拟第一个账户向第二个账户转账1个以太币
        String account1 = web3j.ethAccounts().send().getAccounts().get(0);
        String to = web3j.ethAccounts().send().getAccounts().get(1);
        ClientTransactionManager clientTransactionManager = new ClientTransactionManager(web3j, account1);
        TransactionReceipt transactionReceiptRemoteCall = new Transfer(web3j, clientTransactionManager).sendFunds(to, new BigDecimal("1"), Convert.Unit.ETHER).send();
    }

执行结果：

3.监听新交易事件

与监听新块产生类似，代码如下：

Subscription sub = web3j.transactionObservable().subscribe(tx -> {
 System.out.println("hash: " + tx.getHash());
 System.out.println("from: " + tx.getFrom());
 System.out.println("to: " + tx.getTo());
});

4.监听待定交易

Subscription sub = web3j.pendingTransactionObservable().subscribe(tx -> {
 System.out.println("hash: " + tx.getHash());
});

5.监听合约事件

合约事件的监听通过主题过滤器实现，对于 Voting 合约中的事件 Vote，web3j 包装类中将自动为其生成对应的可观测对象生成函数voteEventObservable()。

EthFilter filter = new EthFilter();
voting.voteEventObservable(filter).subscribe(event -> {
 System.out.println(event.voter + " : " + new String(event.candidate));
});