web3j开发以太坊过滤器(filter)和智能合约事件(event)
web3j过滤器提供以太坊网络发生的某些事件的通知,对java和安卓程序员来说很有用。在Ethereum以太坊中支持三类过滤器:
- 块滤波器(Block filters)
- 未决交易过滤器(Pending transaction filters)
- 主题过滤器(Topic filters)
主题过滤器更灵活。允许根据提供的特定标准创建过滤器。
不幸的是,除非你使用
WebSocket
连接到Geth,否则通过JSON-RPC API来处理过滤器是一个繁琐的过程,这里需要轮询以太坊客户端,以便了解HTTP和IPC所请求的实时同步特征,是否有任何新的更新到你的过滤器。此外,块和交易过滤器只提供交易或区块链hash值,因此需要进一步的请求来获得hash对应的实际交易或块。web3j的过滤器解决了这些问题,因此你有一个完全异步的基于事件的API来处理过滤器。它使用RXJava的可观测性Observables,它提供了与事件协同工作的一致API,这有助于通过功能组合将JSON-RPC调用链接在一起。
注:
Infura
不支持过滤器。块和交易过滤器
接收所有新块把它们添加到区块链(false参数指定我们只需要块就ok,而不需要嵌入交易):
Subscription subscription = web3j.blockObservable(false).subscribe(block -> {
...
});
接收所有新交易,把它们添加到块链:
Subscription subscription = web3j.transactionObservable().subscribe(tx -> {
...
});
接收所有待提交交易并提交到网络(即在它们被分组在一起之前):
Subscription subscription = web3j.pendingTransactionObservable().subscribe(tx -> {
...
});
不再需要的时候取消订阅
unsubscribe
:subscription.unsubscribe();
另外还提供了其他回调,它们简单地提供了块或交易hash,这些细节涉及Web3JRX接口。
再现过滤器
webjs还提供用于再现块和交易历史的过滤器。
从区块链再现一系列块:
Subscription subscription = web3j.replayBlocksObservable(
, , )
.subscribe(block -> {
...
});
再现包含在一个块范围内的单个交易:
Subscription subscription = web3j.replayTransactionsObservable(
, )
.subscribe(tx -> {
...
});
也可以获得Web3J再现最新的块,并在你看过后提供通知(通过提交
Observable
):Subscription subscription = web3j.catchUpToLatestBlockObservable(
, , )
.subscribe(block -> {
...
});
或者,也可以在你再现最新的块后,通知新创建的后续块:
Subscription subscription = web3j.catchUpToLatestAndSubscribeToNewBlocksObservable(
, )
.subscribe(block -> {
...
});
如上所述,并包含在块内的交易:
Subscription subscription = web3j.catchUpToLatestAndSubscribeToNewTransactionsObservable(
)
.subscribe(tx -> {
...
});
所有上述过滤器都是通过Web3JRX接口导出的。
主题过滤器和EVM事件
主题过滤器捕获在网络中发生的以太坊虚拟机(EVM)事件的细节。这些事件是由智能合约创建的,并存储在与智能合约相关联的交易日志中。
solidity文档提供了EVM事件的良好概述。
使用EthFilter类型指定希望应用于过滤器的主题。这可以包括希望应用过滤器的智能合约的地址。你还可以提供特定的主题进行筛选。其中单个主题表示智能合约上的索引参数:
EthFilter filter = new EthFilter(DefaultBlockParameterName.EARLIEST,
DefaultBlockParameterName.LATEST, )
[.addSingleTopic(...) | .addOptionalTopics(..., ...) | ...];
然后可以使用类似于上面的块和交易过滤器的语法创建该过滤器:
web3j.ethLogObservable(filter).subscribe(log -> {
...
});
过滤器主题只能引用索引的Solidity事件参数。不可能对非索引事件参数进行筛选。此外,对于可变长度数组类型(如字符串和字节)的任何索引事件参数,它们的值的
Keccak-256
hash 存储在EVM日志上。不可能使用它们的全部值来存储或筛选。如果创建一个没有与之相关联的主题的过滤器实例,则在网络中发生的所有EVM事件都将由过滤器捕获。
操作组合标注
除了
send()
和sendAsync
之外,所有JSON-RPC方法在web3j中都实现了支持observable()方法来创建可观察的异步执行请求。这使得将JSON-RPC调用组合成新的函数是非常容易和直接的。例如, blockObservable本身由许多单独的JSON-RPC调用组成:
public Observable blockObservable(
boolean fullTransactionObjects, long pollingInterval) {
return this.ethBlockHashObservable(pollingInterval)
.flatMap(blockHash ->
web3j.ethGetBlockByHash(blockHash, fullTransactionObjects).observable());
}
【web3j开发以太坊过滤器(filter)和智能合约事件(event)】在这里,我们首先创建一个可观察的,它提供每个新创建的块的块哈希的通知。然后,我们使用
flatMap
调用ethGetBlockByHash
,以获得完整的块细节,这是传递给可观察者的订阅服务器的细节。进一步的例子
请参阅ObservableIT,进一步举例说明。
对于使用手动筛选器API的演示,可以查看EventFilterIT。
原文出处:web3j教程:过滤器(Filters)和事件(Events)
- 以太坊入门教程,主要介绍智能合约与dapp应用开发,适合入门。
- 以太坊开发进阶教程,主要是介绍使用node.js、mongodb、区块链、ipfs实现去中心化电商DApp实战,适合进阶。
- java以太坊开发教程,主要是针对java和android程序员进行区块链以太坊开发的web3j详解。
- python以太坊,主要是针对python工程师使用web3.py进行区块链以太坊开发的详解。
- php以太坊,主要是介绍使用php进行智能合约开发交互,进行账号创建、交易、转账、代币开发以及过滤器和交易等内容。
- C#以太坊,主要讲解如何使用C#开发基于.Net的以太坊应用,包括账户管理、状态与交易、智能合约开发与交互、过滤器和交易等。
- php比特币开发教程,本课程面向初学者,内容即涵盖比特币的核心概念,例如区块链存储、去中心化共识机制、密钥与脚本、交易与UTXO等,同时也详细讲解如何在Php代码中集成比特币支持功能,例如创建地址、管理钱包、构造裸交易等,是Php工程师不可多得的比特币开发学习课程。
- java比特币开发教程,本课程面向初学者,内容即涵盖比特币的核心概念,例如区块链存储、去中心化共识机制、密钥与脚本、交易与UTXO等,同时也详细讲解如何在Java代码中集成比特币支持功能,例如创建地址、管理钱包、构造裸交易等,是Java工程师不可多得的比特币开发学习课程。
- EOS入门教程,本课程帮助你快速入门EOS区块链去中心化应用的开发,内容涵盖EOS工具链、账户与钱包、发行代币、智能合约开发与部署、使用代码与智能合约交互等核心知识点,最后综合运用各知识点完成一个便签DApp的开发。
推荐阅读
- 深入理解Go之generate
- 标签、语法规范、内联框架、超链接、CSS的编写位置、CSS语法、开发工具、块和内联、常用选择器、后代元素选择器、伪类、伪元素。
- 以太坊中的计量单位及相互转换
- 我的软件测试开发工程师书单
- echart|echart 双轴图开发
- NPDP拆书(三)(新产品开发战略(经营与创新战略))
- 芯灵思SinlinxA33开发板Linux内核定时器编程
- 常用git命令总结
- 藏族开发的修路人——记致富援乡的斯定那珠
- ASP.NET|ASP.NET Core应用开发思维导图