-
Notifications
You must be signed in to change notification settings - Fork 256
Expand file tree
/
Copy pathFilter.java
More file actions
114 lines (102 loc) · 2.89 KB
/
Filter.java
File metadata and controls
114 lines (102 loc) · 2.89 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package com.ethjava;
import com.ethjava.utils.Environment;
import org.web3j.protocol.Web3j;
import org.web3j.protocol.core.DefaultBlockParameter;
import org.web3j.protocol.http.HttpService;
import rx.Subscription;
import java.math.BigInteger;
/**
* filter相关
* 监听区块、交易
* 所有监听都在Web3jRx中
*/
public class Filter {
private static Web3j web3j;
public static void main(String[] args) {
web3j = Web3j.build(new HttpService(Environment.RPC_URL));
/**
* 新区块监听
*/
newBlockFilter(web3j);
/**
* 新交易监听
*/
newTransactionFilter(web3j);
/**
* 遍历旧区块、交易
*/
replayFilter(web3j);
/**
* 从某一区块开始直到最新区块、交易
*/
catchUpFilter(web3j);
/**
* 取消监听
*/
//subscription.unsubscribe();
}
private static void newBlockFilter(Web3j web3j) {
Subscription subscription = web3j.
blockObservable(false).
subscribe(block -> {
System.out.println("new block come in");
System.out.println("block number" + block.getBlock().getNumber());
});
}
private static void newTransactionFilter(Web3j web3j) {
Subscription subscription = web3j.
transactionObservable().
subscribe(transaction -> {
System.out.println("transaction come in");
System.out.println("transaction txHash " + transaction.getHash());
});
}
private static void replayFilter(Web3j web3j) {
BigInteger startBlock = BigInteger.valueOf(2000000);
BigInteger endBlock = BigInteger.valueOf(2010000);
/**
* 遍历旧区块
*/
Subscription subscription = web3j.
replayBlocksObservable(
DefaultBlockParameter.valueOf(startBlock),
DefaultBlockParameter.valueOf(endBlock),
false).
subscribe(ethBlock -> {
System.out.println("replay block");
System.out.println(ethBlock.getBlock().getNumber());
});
/**
* 遍历旧交易
*/
Subscription subscription1 = web3j.
replayTransactionsObservable(
DefaultBlockParameter.valueOf(startBlock),
DefaultBlockParameter.valueOf(endBlock)).
subscribe(transaction -> {
System.out.println("replay transaction");
System.out.println("txHash " + transaction.getHash());
});
}
private static void catchUpFilter(Web3j web3j) {
BigInteger startBlock = BigInteger.valueOf(2000000);
/**
* 遍历旧区块，监听新区块
*/
Subscription subscription = web3j.catchUpToLatestAndSubscribeToNewBlocksObservable(
DefaultBlockParameter.valueOf(startBlock), false)
.subscribe(block -> {
System.out.println("block");
System.out.println(block.getBlock().getNumber());
});
/**
* 遍历旧交易，监听新交易
*/
Subscription subscription2 = web3j.catchUpToLatestAndSubscribeToNewTransactionsObservable(
DefaultBlockParameter.valueOf(startBlock))
.subscribe(tx -> {
System.out.println("transaction");
System.out.println(tx.getHash());
});
}
}