web3j的基础用法-6合约的监听器事件Event和过滤器EthFilter，以及NullPointed，调用失败导致的bug解决-Toy模板网

这篇具有很好参考价值的文章主要介绍了web3j的基础用法-6合约的监听器事件Event和过滤器EthFilter，以及NullPointed，调用失败导致的bug解决。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

简单的监听一下某个合约的Transfer事件

本篇以Uniswap为例（https://uniswap.org/）

web3j event获取交易记录,web3j,以太坊,smart-contract,区块链,java,以太坊,web3

合约地址：0x1f9840a85d5af5bf1d1762f925bdaddc4201f984 （Uni）

监听合约Tranfer事件

调用代码

   private void run1() throws Exception {
        log.info("hello eth,hello web3j");

        Web3j web3j = Web3jInfo.connect();
//        BigInteger total = TokenClient.getTokenTotalSupply(web3j, "0xff9c1b15b16263c61d017ee9f65c50e4ae0113d7");
//        System.out.println("loot（0xff9c1b15b16263c61d017ee9f65c50e4ae0113d7） total:" + total);

        TransMonitor.getInstance().setWeb3j(web3j);
        TransMonitor.getInstance().subscribeContract("0x1f9840a85d5af5bf1d1762f925bdaddc4201f984", new Action1<Log>() {
            @Override
            public void call(Log log) {
                System.out.println("transBlockNo:" + log.getBlockNumber());
                System.out.println("transHash:" + log.getTransactionHash());
                List<String> topics = log.getTopics();
                for (String topic : topics) {
                    System.out.println("transTopic:" + topic);
                }
            }
        });
    }

核心代码实现在这里

  /**
     * 监听合约的交易事件
     **/
    public Subscription subscribeContract(String contractAddress, final Action1<? super Log> onNext) {
        if (this.web3j == null) return null;

        // 要监听的合约事件 交易
        EthFilter filter = new EthFilter(
                DefaultBlockParameter.valueOf(BigInteger.valueOf(13763721L)),
                DefaultBlockParameterName.LATEST,
                contractAddress);
        Event event = new Event("Transfer",
                Arrays.<TypeReference<?>>asList(
                        new TypeReference<Address>(true) {
                        },
                        new TypeReference<Address>(true) {
                        },

                        new TypeReference<Uint256>(false) {
                        }));

        filter.addSingleTopic(EventEncoder.encode(event));
        return web3j.ethLogObservable(filter).subscribe(onNext);
    }

    public void unsubscribeContract(Subscription subscription) {
        if (this.web3j == null) return;
        subscription.unsubscribe();
    }