过滤器简介

yochain.java过滤器提供YOUChain网络发生的某些事件的通知。目前支持三类过滤器:

  • 块、交易过滤器(Block/Transaction filters)
  • 再现过滤器(Pending transaction filters)
  • 主题过滤器(Topic filters)

块过滤器和未决交易过滤器提供了在网络上创建新交易或块的通知。

主题过滤器更灵活。允许根据提供的特定标准创建过滤器。

不幸的是,除非你使用WebSocket连接到客户端,否则通过JSON-RPC API来处理过滤器是一个繁琐的过程, 这里需要轮询YOUChain客户端,以便了解HTTP和IPC所请求的实时同步特征,是否有任何新的更新到你的过滤器。 此外,块和交易过滤器只提供交易或区块链hash值,因此需要进一步的请求来获得hash对应的实际交易或块。

web3j的过滤器解决了这些问题,因此你有一个完全异步的基于事件的API来处理过滤器。它使用RXJava的可观测性Observables, 它提供了与事件协同工作的一致API,这有助于通过功能组合将JSON-RPC调用链接在一起。

块和交易过滤器

块过滤器:接收所有新块把它们添加到区块链(false参数指定我们只需要块就ok,而不需要嵌入交易)

Flowable<YOUBlock> flowable = youChain.blockFlowable(false);
flowable.subscribe(block -> {
    logger.info("blockNumber={}", block.getBlock().getNumber().toString());
});

交易过滤器:接收所有新交易,把它们添加到块链

Flowable<Transaction> flowable = youChain.transactionFlowable();
flowable.subscribe(tx -> {
    logger.info("blockNumber={} txHash={}", tx.getBlockNumber().toString(), tx.getHash());
});

未决交易过滤器:接收所有待提交交易并提交到网络(即在它们被分组在一起之前)

Flowable<Transaction> flowable = youChain.pendingTransactionFlowable();
flowable.subscribe(tx -> {
    logger.info("blockNumber={} txHash={}", tx.getBlockNumber().toString(), tx.getHash());
});

不再需要的时候取消订阅unsubscribe

flowable.unsubscribeOn(new SingleScheduler());

再现过滤器

youchain.java提供用于再现块和交易历史的过滤器。 从区块链再现一系列块:

BigInteger startBlock = BigInteger.valueOf(24850);
DefaultBlockParameter start = DefaultBlockParameter.valueOf(startBlock);
Flowable<YOUBlock> flowable = youChain.replayPastBlocksFlowable(start, DefaultBlockParameterName.LATEST, false);
flowable.subscribe(block -> {
    logger.info("blockNumber={}", block.getBlock().getNumber().toString());
});

Flowable<YOUBlock> flowable = youChain.replayPastAndFutureBlocksFlowable(start, false);
flowable.subscribe(block -> {
    logger.info("blockNumber={}", block.getBlock().getNumber().toString());
});

再现包含在一个块范围内的单个交易:

BigInteger startBlock = BigInteger.valueOf(24850);
DefaultBlockParameter start = DefaultBlockParameter.valueOf(startBlock);
Flowable<Transaction> flowable = youChain.replayPastTransactionsFlowable(start, DefaultBlockParameterName.LATEST);
flowable.subscribe(tx -> {
    logger.info("blockNumber={} txHash={}", tx.getBlockNumber().toString(), tx.getHash());
});

Flowable<Transaction> flowable = youChain.replayPastAndFutureTransactionsFlowable(start);
flowable.subscribe(tx -> {
    logger.info("blockNumber={} txHash={}", tx.getBlockNumber().toString(), tx.getHash());
});

主题过滤器和YOUChain虚拟机事件

主题过滤器捕获在网络中发生的YOUChain虚拟机事件的细节。这些事件是由智能合约创建的,并存储在与智能合约相关联的交易日志中。

使用YOUFilter类型指定希望应用于过滤器的主题。这可以包括希望应用过滤器的智能合约的地址。你还可以提供特定的主题进行筛选。其中单个主题表示智能合约上的索引参数。

Event event = new Event("Transfer", Arrays.asList(
        new TypeReference<Address>() {
        },
        new TypeReference<Address>() {
        },
        new TypeReference<Uint256>() {
        }));
String encodedEventSignature = EventEncoder.encode(event);
YOUFilter youFilter = new YOUFilter(
        DefaultBlockParameter.valueOf(startBlock),
        DefaultBlockParameterName.LATEST,
        CONTRACT_ADDRESS);
youFilter.addSingleTopic(encodedEventSignature);
Flowable<Log> flowable = youChain.youLogFlowable(youFilter);
flowable.subscribe(log -> {
    this.handleTransferEvents(log);
});

过滤器主题只能引用索引的Solidity事件参数。不可能对非索引事件参数进行筛选。此外,对于可变长度数组类型(如字符串和字节)的任何索引事件参数, 它们的值的Keccak-256 hash 存储在YOUChain虚拟机日志上。不可能使用它们的全部值来存储或筛选。

如果创建一个没有与之相关联的主题的过滤器实例,则在网络中发生的所有YOUChain虚拟机事件都将由过滤器捕获。

通知

youchain.java提供四种类型通知,分别如下:
1、newHeadsNotifications 新块被添加到区块链时的通知
2、newPendingTransactionsNotifications 新的交易被添加的节点中时的通知
3、syncingStatusNotifications 节点开始同步或结束同步时的通知
4、logsNotifications 日志被加载到新导入的区块时的通知

Flowable<NewHeadsNotification> flowable = youChain.newHeadsNotifications();
flowable.subscribe(notfication -> {
     NewHead head = notfication.getParams().getResult();
     String blockHash = head.getHash();
},
error -> {
 logger.error("onError");
});
Flowable<PendingTransactionNotification> flowable = youChain.newPendingTransactionsNotifications();
flowable.subscribe(notfication -> {
    logger.info("transaction hash={}", notfication.getParams().getResult());
},
error -> {
    logger.error("onError");
});
Flowable<SyncingNotfication> flowable = youChain.syncingStatusNotifications();
flowable.subscribe(notfication -> {
    YOUSyncing youSyncing = notfication.getParams().getResult();
    logger.info("isSyncing={}", youSyncing.isSyncing());
    YOUSyncing.Result result = youSyncing.getResult();
    if (result instanceof YOUSyncing.Syncing) {
        YOUSyncing.Syncing syncing = (YOUSyncing.Syncing) result;
        logger.info("startingBlock={}", syncing.getStartingBlock());
        logger.info("currentBlock={}", syncing.getCurrentBlock());
        logger.info("highestBlock={}", syncing.getHighestBlock());
    }
},
error -> {
    logger.error("onError testSyncingStatusNotifications");
});
Flowable<LogNotification> flowable = youChain.logsNotifications(Arrays.asList(address, contractAddress), new ArrayList<>());
flowable.subscribe(logs -> {
    Log log = logs.getParams().getResult();
    List<String> topics = log.getTopics();
    String fromAddress = topics.get(1);
    String toAddress = topics.get(2);
    String addressLog = log.getAddress();
    String transactionHash = log.getTransactionHash();
    String blockHash = log.getBlockHash();
},
error -> {
    logger.error("on Error");
});