【web3j】java通过web3j监听并解析合约中的事件(event/emit)

news/2024/7/21 11:51:20 标签: web3, 区块链, java

① 查询链上数据用的rpc（本示例是binance的，测试网可以使用：https://data-seed-prebsc-2-s2.binance.org:8545）

② 自己还要有一个测试链上部署好的合约，合约中要有一个方法emit了事件。

③ java依赖

java"><dependency>
    <groupId>org.web3j</groupId>
    <artifactId>core</artifactId>
    <version>4.9.7</version>
</dependency>
<dependency>
    <groupId>org.web3j</groupId>
    <artifactId>codegen</artifactId>
    <version>4.9.7</version>
</dependency>

一、通过自己合约的abi和bin生成一个java文件，abi和bin可以在remix的compiler模块中获取，代码如下（这一步懒得做的可以跳过，在第二步传合约地址的时候，直接传一个字符串也行。这里就是顺手存一下这个方法，其实实际使用也是直接传的字符串，具体可以看页面最下方的”三、“）

java">    /**
     * 通过合约abi和bin获得java文件
     */
    public void getJavaFileBySolidity(){
        // 生成的java类名，同ABI文件同名，自动首字母大写
        String packageName = "";
        String outDirPath = "/Users/maomo/Desktop/";
        String binDirPath = "/Users/maomo/Desktop/xxxbin.txt";
        String abiDirPath = "/Users/maomo/Desktop/xxxabi.txt";
        String[] arr = Arrays.asList(
                "-b", binDirPath,
                "-a", abiDirPath,
                "-p", packageName,
                "-o", outDirPath
        ).toArray(new String[0]);
        SolidityFunctionWrapperGenerator.main(arr);
    }

二、通过web3j查询事件，通过event和ethFilter增加过滤条件

java">    public void testSub() {
        Web3j web3j = Web3j.build(new HttpService("https://data-seed-prebsc-2-s2.binance.org:8545"));
        //第一步生成的合约实体
        Contract contract;
        Disposable subscribe = null;
        try {
            Web3ClientVersion web3ClientVersion = web3j.web3ClientVersion().send();
            String clientVersion = web3ClientVersion.getWeb3ClientVersion();
            log.info("wen3j subscribe --clientVersion-- :{} ", clientVersion);
            //设置谁调用合约
            TransactionManager transactionManager = new ClientTransactionManager(web3j, "这里可以输入自己的钱包地址");
            //加载智能合约（此处可以跳过，下面穿合约地址的地方 直接传字符串）
            contract = Contract.load("你要监听的合约地址", web3j, transactionManager, ManagedTransaction.GAS_PRICE, org.web3j.tx.Contract.GAS_LIMIT);
            //设置过滤条件 这个示例是监听最新的1000个块
            BigInteger blockNumber = web3j.ethBlockNumber().send().getBlockNumber()
                                        .subtract(new BigInteger("1000"));
            EthFilter ethFilter = new EthFilter(DefaultBlockParameter.valueOf(blockNumber),DefaultBlockParameterName.LATEST, contract.getContractAddress());
            //监听哪个事件，合约中的event写了几个参数，这里就写几个，类型对应好
            Event event = new Event("startEvent",
                    Arrays.<TypeReference<?>>asList(
                            new TypeReference<Address>(true) {},
                            new TypeReference<Address>(true) {},
                            new TypeReference<Uint256>(true) {},
                            new TypeReference<Uint256>(false) {},
                            new TypeReference<Uint256>(false) {},
                            new TypeReference<Uint256>(false) {}));
            ethFilter.addSingleTopic(EventEncoder.encode(event));
            subscribe = web3j.ethLogFlowable(ethFilter).subscribe(tx -> {
                int newBlock = tx.getBlockNumber().intValue();
                log.info("wen3j subscribe --newBlock-- :{} ", newBlock);
                log.info("wen3j subscribe --tx-- :{} ", tx);
                EventValues eventValues = staticExtractEventParameters(event, tx);
                //定义接收参数(本示例使用的事件返回了6个，具体按自己合约来)
                String address1 = "";String address2 = "";int uint1 = 0;
                int uint2 = 0;int uint3 = 0;int uint4 = 0;
                List<Type> indexedValues = eventValues.getIndexedValues();
                if (ObjectUtils.isNotEmpty(indexedValues) && indexedValues.size() == 3) {
                    Type type1 = indexedValues.get(0);
                    address1 = type1.getValue().toString();
                    Type type2 = indexedValues.get(1);
                    address2 = type2.getValue().toString();
                    Type type3 = indexedValues.get(2);
                    uint1 = Integer.parseInt(type3.getValue().toString());
                }
                List<Type> nonIndexedValues = eventValues.getNonIndexedValues();
                if (ObjectUtils.isNotEmpty(nonIndexedValues) && nonIndexedValues.size() == 3) {
                    Type type1 = nonIndexedValues.get(0);
                    uint2 = Integer.parseInt(type1.getValue().toString());
                    Type type2 = nonIndexedValues.get(1);
                    uint3 = Integer.parseInt(type2.getValue().toString());
                    Type type3 = nonIndexedValues.get(2);
                    uint4 = Integer.parseInt(type3.getValue().toString());
                }
                log.info("address1:{};address2:{};uint1:{};uint2:{};uint3:{};uint4:{}",address1, address2, uint1, uint2, uint3, uint4);
            });
        }catch (Exception e) {
            e.printStackTrace();
        }finally {
            //关闭监听
            if(ObjectUtils.isNotEmpty(subscribe) && !subscribe.isDisposed()){
                subscribe.dispose();
            }
        }
    }
java">    /**
     * 解析log返回的data
     * @param event 合约中定义的事件
     * @param log 监听到的log
     * @return 解析后的数据
     */
    public EventValues staticExtractEventParameters(Event event, Log log) {
        final List<String> topics = log.getTopics();
        String encodedEventSignature = EventEncoder.encode(event);
        if (topics == null || topics.size() == 0 || !topics.get(0).equals(encodedEventSignature)) {
            return null;
        }
        List<Type> indexedValues = new ArrayList<>();
        List<Type> nonIndexedValues = FunctionReturnDecoder.decode(
                log.getData(), event.getNonIndexedParameters());
        List<TypeReference<Type>> indexedParameters = event.getIndexedParameters();
        for (int i = 0; i < indexedParameters.size(); i++) {
            Type value = FunctionReturnDecoder.decodeIndexedValue(
                    topics.get(i + 1), indexedParameters.get(i));
            indexedValues.add(value);
        }
        return new EventValues(indexedValues, nonIndexedValues);
    }

三、为了方便以后复制粘贴(不是)，最下面再传一个不生成合约的版本

java">    public void testSub() {
        Web3j web3j = Web3j.build(new HttpService("https://data-seed-prebsc-2-s2.binance.org:8545"));
        //第一步生成的合约实体
        Contract contract;
        Disposable subscribe = null;
        try {
            Web3ClientVersion web3ClientVersion = web3j.web3ClientVersion().send();
            String clientVersion = web3ClientVersion.getWeb3ClientVersion();
            log.info("wen3j subscribe --clientVersion-- :{} ", clientVersion);
            //设置过滤条件 这个示例是监听最新的1000个块
            BigInteger blockNumber = web3j.ethBlockNumber().send().getBlockNumber()
                                        .subtract(new BigInteger("1000"));
            EthFilter ethFilter = new EthFilter(DefaultBlockParameter.valueOf(blockNumber),DefaultBlockParameterName.LATEST, "输入合约地址");
            //监听哪个事件，合约中的event写了几个参数，这里就写几个，类型对应好
            Event event = new Event("startEvent",
                    Arrays.<TypeReference<?>>asList(
                            new TypeReference<Address>(true) {},
                            new TypeReference<Address>(true) {},
                            new TypeReference<Uint256>(true) {},
                            new TypeReference<Uint256>(false) {},
                            new TypeReference<Uint256>(false) {},
                            new TypeReference<Uint256>(false) {}));
            ethFilter.addSingleTopic(EventEncoder.encode(event));
            subscribe = web3j.ethLogFlowable(ethFilter).subscribe(tx -> {
                int newBlock = tx.getBlockNumber().intValue();
                log.info("wen3j subscribe --newBlock-- :{} ", newBlock);
                log.info("wen3j subscribe --tx-- :{} ", tx);
                EventValues eventValues = staticExtractEventParameters(event, tx);
                //定义接收参数(本示例使用的事件返回了6个，具体按自己合约来)
                String address1 = "";String address2 = "";int uint1 = 0;
                int uint2 = 0;int uint3 = 0;int uint4 = 0;
                List<Type> indexedValues = eventValues.getIndexedValues();
                if (ObjectUtils.isNotEmpty(indexedValues) && indexedValues.size() == 3) {
                    Type type1 = indexedValues.get(0);
                    address1 = type1.getValue().toString();
                    Type type2 = indexedValues.get(1);
                    address2 = type2.getValue().toString();
                    Type type3 = indexedValues.get(2);
                    uint1 = Integer.parseInt(type3.getValue().toString());
                }
                List<Type> nonIndexedValues = eventValues.getNonIndexedValues();
                if (ObjectUtils.isNotEmpty(nonIndexedValues) && nonIndexedValues.size() == 3) {
                    Type type1 = nonIndexedValues.get(0);
                    uint2 = Integer.parseInt(type1.getValue().toString());
                    Type type2 = nonIndexedValues.get(1);
                    uint3 = Integer.parseInt(type2.getValue().toString());
                    Type type3 = nonIndexedValues.get(2);
                    uint4 = Integer.parseInt(type3.getValue().toString());
                }
                log.info("address1:{};address2:{};uint1:{};uint2:{};uint3:{};uint4:{}",address1, address2, uint1, uint2, uint3, uint4);
            });
        }catch (Exception e) {
            e.printStackTrace();
        }finally {
            //关闭监听
            if(ObjectUtils.isNotEmpty(subscribe) && !subscribe.isDisposed()){
                subscribe.dispose();
            }
        }
    }

=========================分割线=========================

还有一种把web3j.ethLogFlowable(ethFilter).subscribe换成查询的方法，做个记录

把这段代码

java">subscribe = web3j.ethLogFlowable(ethFilter).subscribe(tx -> {

    //逻辑...
}

换成

java">List<EthLog.LogResult> resp = web3j.ethGetLogs(ethFilter).send().getLogs();
    for (EthLog.LogResult logItem : resp) {
                EthLog.LogObject tx = ObjectUtils.isNotEmpty(logItem.get()) ? (EthLog.LogObject) logItem.get() : null;
                if(ObjectUtils.isEmpty(tx)){
                    return false;
                }

    //逻辑...

    }


http://www.niftyadmin.cn/n/235332.html

相关文章

软件测试员----面试，你准备好了么？

软件测试员----面试，你准备好了么？

最近有机会做一些面试工作&#xff0c;主要负责面试软件测试人员招聘的技术面试。 之前一直是应聘者的角色&#xff0c;经历了不少次的面试之后&#xff0c;多少也积累一点面试的经验&#xff0c;现在发生了角色转变。初次的面试就碰到个工作年限比我长的&#xff0c;也没有时间…
阅读更多...
CentOS7---部署LNMP数据存储到redis

CentOS7---部署LNMP数据存储到redis

一、部署LNMP及redis 1、部署LNMP&#xff0c;需要将 tengine-2.2.0.tar.gz 拷贝到虚拟机的 /root 目录下 步骤一&#xff1a;安装nginx 源码安装相关软件包 # pcre-devel做正则匹配&#xff0c;zlib-devel做数据压缩 [roottemplate ~]# yum -y install gcc pcre-devel zlib-de…
阅读更多...
Linux cat 命令常见使用方法

Linux cat 命令常见使用方法

在Linux操作系统中&#xff0c;cat是一个非常常用的命令&#xff0c;用于连接和显示文件的内容。下面是一些cat命令的常见用法 显示文件内容&#xff1b;使用cat命令来显示一个或多个文件的内容。 例如&#xff1a; cat filename连接多个文件&#xff1b;使用cat命令来连接多…
阅读更多...
计算机类专业的普通校招生毕业如何“卷”一份好工作？

计算机类专业的普通校招生毕业如何“卷”一份好工作？

毕业差不多两年的校招生有感一、为什么写这篇文章&#xff1f;二、我 → 一名普通的校招生前身三、我 → 一名普通的校招生养成四、校招如何拿到offer&#xff1f;五、总结一、为什么写这篇文章&#xff1f; 一开始我写CSDN是为了记录自己学习技术的小日记&#xff0c;小总结&…
阅读更多...
TS代码规范

TS代码规范

TypeScript 是一种静态类型的编程语言&#xff0c;它支持 JavaScript 的所有语法&#xff0c;并且增加了许多额外的语法和特性。下面是一些常用的 TypeScript 代码规范&#xff0c;以及相应的示例代码&#xff1a; 缩进&#xff1a;使用 2 个空格缩进。 function foo(): void…
阅读更多...
Unity2021之OpenXR接入HTC Vive

Unity2021之OpenXR接入HTC Vive

一.前言 目前VR领域，最流行的设备要当属HTC VIVE了。以前在Unity端接入HTC VIVE设备时，都是通过SteamVR+VRTK来接入的。但是随着Unity的版本升级和OpenXR标准的流行，再加上VR设备的逐渐增多。SteamVR+VRTK的方式已经无法更好的满足大家的需求。 我今天为大家分享的就是，如…
阅读更多...
VS2019使用OpenCppCoverage插件生成覆盖率报告的方法及该插件的一些设置【详细图解】

VS2019使用OpenCppCoverage插件生成覆盖率报告的方法及该插件的一些设置【详细图解】

今天来分享windows下VS2019使用OpenCppCoverage插件生成覆盖率报告的方法&#xff0c;以及怎样过滤掉不想要生成的源文件&#xff0c;都是博主每一步实验过成功的步骤。 目录1.OpenCppCoverage插件说明2.OpenCppCoverage插件安装方法2.1.下载OpenCppCoverage插件&#xff0c;运…
阅读更多...
算法刷题总结 (七) 双指针

算法刷题总结 (七) 双指针

算法总结7 双指针一、双指针的概念1.1、什么是双指针&#xff1f;1.2、常见类型1.2.1、快慢指针1.2.2、左右端点指针1.2.3、区间指针 - 滑动窗口汇总二、经典例题2.1、快慢指针&#xff08;1&#xff09;、链表判环141. 环形链表142. 环形链表 II287. 寻找重复数876. 链表的中间…
阅读更多...
最新文章

Copyright @ 2022~2023