① 查询链上数据用的rpc(本示例是binance的,测试网可以使用:https://data-seed-prebsc-2-s2.binance.org:8545)
② 自己还要有一个测试链上部署好的合约,合约中要有一个方法emit了事件。
③ 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模块中获取,代码如下(这一步懒得做的可以跳过,在第二步传合约地址的时候,直接传一个字符串也行。这里就是顺手存一下这个方法,其实实际使用也是直接传的字符串,具体可以看页面最下方的”三、“)
/**
* 通过合约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增加过滤条件
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();
}
}
}
/**
* 解析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);
}
三、为了方便以后复制粘贴(不是),最下面再传一个不生成合约的版本
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换成查询的方法,做个记录
把这段代码
subscribe = web3j.ethLogFlowable(ethFilter).subscribe(tx -> {
//逻辑...
}
换成
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;
}
//逻辑...
}
文章浏览阅读7.6k次。 首先需要明确一点的是,计算机系统中生成一个随机数,需要依赖一个随机量,这个随机量称为随机数种子。否则生成的就是伪随机数。随机数种子的值越多样化,生成的数就越随机。通常,随机数种子从计算机系统外部引入,例如人的操作、ADC采集到的值等。 C语言的标准库,提供了srand()和rand()两个函数用于产生随机数。下面的例程提供了生成一个指定范围的随机数的方法:#..._c 真随机数
文章浏览阅读1.4w次,点赞4次,收藏41次。我们在进行数据分析的时候,并不是所有的数据都需要进行分析。这就要求我们要对数据进行按条件选择。本文我将用IBM SPSS Statistics演示如何进行按条件筛选数据。1、打开数据如图所示,是一个学生个人信息的数据集。我将在此基础上演示如何筛选出语文成绩大于78的学生。图1:数据展示2、菜单位置如图所示,第一步我们点击菜单栏中的“数据”按钮,第二步选择下级菜单中的“选择个案”。图2:菜单位置3、选择条件如图所示,我们先选中语文成绩,在点击“如果条件满足”.._spss如何按条件分类
文章浏览阅读591次。//集合的差集程序实现#include<stdio.h>//降序排序数组void sort( int a[],int n ){ int i,j,k,temp; for( i=0;i<n-1;i++ ){ k=i; for( j=i+1;j<n;j++ ){ if( a[j]>a[k] ) k=j; } if( k!=i ){ temp=a[k]; a[k]=a[i]; a[i]=temp; } }}//计算差集._用c++实现离散数学差运算
文章浏览阅读524次,点赞14次,收藏14次。ndex-editionrecommend 如果没有今天,明天会不会有昨天?[瑞士]伊夫·博萨尔特(YvesBossart) 2017-1。
文章浏览阅读1w次。CentOS6与CentOS7添加防火墙例外端口的命令不同,需单独来说:(1)CentOS6下添加防火墙例外端口#vim/ets/sysconfig/iptables在 -A INPUT -m state--state NEW -m tcp -p tcp --dport 22 -j ACCEPT一行的后台添加类似的一行命令即可,如 # Firewall configura..._centos7域控服务器里防火墙需要例外那些端口
文章浏览阅读2.9k次,点赞8次,收藏10次。我相信在很多地方,大家在进行数据结构的比较的时候,说到数组,第一反应就是—快,但是为什么快呢?数组到底快在哪里呢?不知道大家是否有思考过这个问题,这篇文章,我就讲讲我对数组的一些看法,抛砖引玉,希望大家多多交流!文章目录数组到底哪里快?查找快吗?为什么数组能支持随机访问呢?答案:举例分析:我们要分析的第一个问题是:数组到底哪里快?查找快吗?可能有的同学第一反应利用数组进行查找的话,时间...
文章浏览阅读371次。1.解决办法:安装低版本的XAMPP(<7.0版本)2.遇到的问题:安装bugfree,我先安装了XAMPP来搭建环境,但是XAMPP7.0+版本安装成功了,但是后面到了安装bugfree时,输入了http://localhost/bugfree/install,后出现了检测到未安装MySQL数据库,打了一个红色叉子。3.解决过程:我尝试了各种版本的XAMPP和bugfree版本,发现,只要是XAMPP的版本太高,比如是7.0+的,b..._bugfree 显示mysql未安装
文章浏览阅读1w次。在做设计过程中,需要把数据内容导入到Excel中,可是每次导入EXcel之后,总有一些数据不能正常显示,比如'123456789012'显示为科学技术形式'1.23457E+11’,还有以'0’开头的数据总会把0撇开再显示。在VB中好像这么更改Excel更改单元格式:Worksheets("Sheet1").Range("A17").NumberFormat = "General" //对A17 单元格格式进行设置Worksheets("S_delphi excelapp.worksheets[j].columns[2].numberformatlocal
文章浏览阅读2.5k次。php的错误和异常处理机制。1、php错误分类;2、error_reporting、display_errors、log_errors、log_errors_max_len、error_log等配置;3、set_error_handler的使用;4、set_exception_handler 的使用;5、用trigger_error触发错误;6、捕获异常try/catch/finally的使用方式_php exception输出错误行
文章浏览阅读476次。Dijkstra算法是一个经典的解决最短路径问题的算法,在路由算法、导航系统等领域都有广泛的应用。它通过逐步选择距离起始节点最近的节点,并更新其邻接节点的最短距离,最终得到起始节点到其他所有节点的最短路径。然后,在一个循环中,每次选择距离最小且未加入最短路径集合的节点,将其加入最短路径集合,并更新其邻接节点的最短路径长度。它遍历所有未加入最短路径集合(shortestPathTreeSet)的节点,查找距离最小且未加入最短路径集合的节点,并返回其索引。数组来追踪起始节点到其他节点的最短路径长度,_路由最短路径代码java
文章浏览阅读2w次,点赞13次,收藏36次。123_mybatisplus selectone
文章浏览阅读1.6k次,点赞15次,收藏22次。参考:hl=zh-cnhl=zh-cnhl=zh-cn。_android 蓝牙框架