最近公司做NFT市場(chǎng)開發(fā)，特記錄一下自己在使用web3j組件測(cè)試調(diào)用區(qū)塊鏈合約的時(shí)使用的方法和踩過的坑，便于自己以后查看。
主要用到工具有4個(gè)
idea,谷歌瀏覽,小狐貍錢包(metamask)插件，remix在線智能合約平臺(tái)
1、準(zhǔn)備工作
1.1、java項(xiàng)目
?在pom.xml中添加引用倉(cāng)庫地址，添加web3j的引入
<repositories>
<repository>
<id>jitpack.io</id>
<url>https://jitpack.io</url>
</repository>
</repositories>
<dependencies>
<!--web3j-->
<dependency>
<groupId>org.web3j</groupId>
<artifactId>core</artifactId>
<version>4.8.4</version>
<exclusions>
<exclusion>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-stdlib</artifactId>
</exclusion>
<exclusion>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>1.2、智能合約
? ? ? ? 開始前，必須有一個(gè)用于測(cè)試的區(qū)塊鏈智能合約，進(jìn)入以太坊官網(wǎng)提供的在線平臺(tái)，地址為：https://remix.ethereum.org/，編寫測(cè)試合約。
????????編寫完成，編譯測(cè)試無誤后，部署合約，方法選擇如下
? ? ? ? 因?yàn)檫x擇通過web3的方式來發(fā)布合約，所以同步會(huì)要求登錄小狐貍（MetaMask），我這里事先就已經(jīng)添加好了幣安測(cè)試鏈，如果各位沒有添加的話，自己自行添加哈
1.3 合約轉(zhuǎn)化
? ? ? ? ?合約發(fā)布成功后，測(cè)試一下合約內(nèi)的方法是否可以正常使用，一切OK了以后，在remix中的編譯模塊內(nèi)，將abi和bin保存放入本地文件中用于生成java文件。
說明一下哦，在生成java文件時(shí)，本地要有web3j的資源文件，我事先已經(jīng)做好了準(zhǔn)備工作了，如果你們沒有的話，就自己查下哈。
進(jìn)入cmd命令窗口
命令如下
web3j solidity generate --abiFile=abi文件地址 -o 文件生成地址 -p 文件包名?
?以下是我的合約生成的java文件
package com.XX.XXX.contracts.constants;
import io.reactivex.Flowable;
import io.reactivex.functions.Function;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import org.web3j.abi.EventEncoder;
import org.web3j.abi.TypeReference;
import org.web3j.abi.datatypes.Address;
import org.web3j.abi.datatypes.Event;
import org.web3j.abi.datatypes.Type;
import org.web3j.abi.datatypes.Utf8String;
import org.web3j.abi.datatypes.generated.Uint256;
import org.web3j.crypto.Credentials;
import org.web3j.protocol.Web3j;
import org.web3j.protocol.core.DefaultBlockParameter;
import org.web3j.protocol.core.RemoteFunctionCall;
import org.web3j.protocol.core.methods.request.EthFilter;
import org.web3j.protocol.core.methods.response.BaseEventResponse;
import org.web3j.protocol.core.methods.response.Log;
import org.web3j.protocol.core.methods.response.TransactionReceipt;
import org.web3j.tx.Contract;
import org.web3j.tx.TransactionManager;
import org.web3j.tx.gas.ContractGasProvider;
/**
* <p>Auto generated code.
* <p><strong>Do not modify!</strong>
* <p>Please use the <a >web3j command line tools</a>,
* or the org.web3j.codegen.SolidityFunctionWrapperGenerator in the
* <a >codegen module</a> to update.
*
* <p>Generated with web3j version 4.5.5.
*/
@SuppressWarnings("rawtypes")
public class EventTest extends Contract {
private static final String BINARY = "Bin file was not provided";
public static final String FUNC_CHANGENAME = "changeName";
public static final String FUNC_COUNTS = "counts";
public static final String FUNC_INCREMENT = "increment";
public static final String FUNC_NAME = "name";
public static final Event INCREMENT_EVENT = new Event("Increment",
Arrays.<TypeReference<?>>asList(new TypeReference<Uint256>(true) {}, new TypeReference<Address>() {}));
;
public static final Event CHANGENAMEEVENT_EVENT = new Event("changeNameEvent",
Arrays.<TypeReference<?>>asList(new TypeReference<Utf8String>() {}, new TypeReference<Address>() {}));
;
@Deprecated
protected EventTest(String contractAddress, Web3j web3j, Credentials credentials, BigInteger gasPrice, BigInteger gasLimit) {
super(BINARY, contractAddress, web3j, credentials, gasPrice, gasLimit);
}
protected EventTest(String contractAddress, Web3j web3j, Credentials credentials, ContractGasProvider contractGasProvider) {
super(BINARY, contractAddress, web3j, credentials, contractGasProvider);
}
@Deprecated
protected EventTest(String contractAddress, Web3j web3j, TransactionManager transactionManager, BigInteger gasPrice, BigInteger gasLimit) {
super(BINARY, contractAddress, web3j, transactionManager, gasPrice, gasLimit);
}
protected EventTest(String contractAddress, Web3j web3j, TransactionManager transactionManager, ContractGasProvider contractGasProvider) {
super(BINARY, contractAddress, web3j, transactionManager, contractGasProvider);
}
public List<IncrementEventResponse> getIncrementEvents(TransactionReceipt transactionReceipt) {
List<Contract.EventValuesWithLog> valueList = extractEventParametersWithLog(INCREMENT_EVENT, transactionReceipt);
ArrayList<IncrementEventResponse> responses = new ArrayList<IncrementEventResponse>(valueList.size());
for (Contract.EventValuesWithLog eventValues : valueList) {
IncrementEventResponse typedResponse = new IncrementEventResponse();
typedResponse.log = eventValues.getLog();
typedResponse.which = (BigInteger) eventValues.getIndexedValues().get(0).getValue();
typedResponse.who = (String) eventValues.getNonIndexedValues().get(0).getValue();
responses.add(typedResponse);
}
return responses;
}
public Flowable<IncrementEventResponse> incrementEventFlowable(EthFilter filter) {
return web3j.ethLogFlowable(filter).map(new Function<Log, IncrementEventResponse>() {
@Override
public IncrementEventResponse apply(Log log) {
Contract.EventValuesWithLog eventValues = extractEventParametersWithLog(INCREMENT_EVENT, log);
IncrementEventResponse typedResponse = new IncrementEventResponse();
typedResponse.log = log;
typedResponse.which = (BigInteger) eventValues.getIndexedValues().get(0).getValue();
typedResponse.who = (String) eventValues.getNonIndexedValues().get(0).getValue();
return typedResponse;
}
});
}
public Flowable<IncrementEventResponse> incrementEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
filter.addSingleTopic(EventEncoder.encode(INCREMENT_EVENT));
return incrementEventFlowable(filter);
}
public List<ChangeNameEventEventResponse> getChangeNameEventEvents(TransactionReceipt transactionReceipt) {
List<Contract.EventValuesWithLog> valueList = extractEventParametersWithLog(CHANGENAMEEVENT_EVENT, transactionReceipt);
ArrayList<ChangeNameEventEventResponse> responses = new ArrayList<ChangeNameEventEventResponse>(valueList.size());
for (Contract.EventValuesWithLog eventValues : valueList) {
ChangeNameEventEventResponse typedResponse = new ChangeNameEventEventResponse();
typedResponse.log = eventValues.getLog();
typedResponse.str = (String) eventValues.getNonIndexedValues().get(0).getValue();
typedResponse.who = (String) eventValues.getNonIndexedValues().get(1).getValue();
responses.add(typedResponse);
}
return responses;
}
public Flowable<ChangeNameEventEventResponse> changeNameEventEventFlowable(EthFilter filter) {
return web3j.ethLogFlowable(filter).map(new Function<Log, ChangeNameEventEventResponse>() {
@Override
public ChangeNameEventEventResponse apply(Log log) {
Contract.EventValuesWithLog eventValues = extractEventParametersWithLog(CHANGENAMEEVENT_EVENT, log);
ChangeNameEventEventResponse typedResponse = new ChangeNameEventEventResponse();
typedResponse.log = log;
typedResponse.str = (String) eventValues.getNonIndexedValues().get(0).getValue();
typedResponse.who = (String) eventValues.getNonIndexedValues().get(1).getValue();
return typedResponse;
}
});
}
public Flowable<ChangeNameEventEventResponse> changeNameEventEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
filter.addSingleTopic(EventEncoder.encode(CHANGENAMEEVENT_EVENT));
return changeNameEventEventFlowable(filter);
}
public RemoteFunctionCall<TransactionReceipt> changeName(String str) {
final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
FUNC_CHANGENAME,
Arrays.<Type>asList(new org.web3j.abi.datatypes.Utf8String(str)),
Collections.<TypeReference<?>>emptyList());
return executeRemoteCallTransaction(function);
}
public RemoteFunctionCall<TransactionReceipt> counts(BigInteger param0) {
final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
FUNC_COUNTS,
Arrays.<Type>asList(new org.web3j.abi.datatypes.generated.Uint256(param0)),
Collections.<TypeReference<?>>emptyList());
return executeRemoteCallTransaction(function);
}
public RemoteFunctionCall<TransactionReceipt> increment(BigInteger which) {
final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
FUNC_INCREMENT,
Arrays.<Type>asList(new org.web3j.abi.datatypes.generated.Uint256(which)),
Collections.<TypeReference<?>>emptyList());
return executeRemoteCallTransaction(function);
}
public RemoteFunctionCall<TransactionReceipt> name() {
final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
FUNC_NAME,
Arrays.<Type>asList(),
Collections.<TypeReference<?>>emptyList());
return executeRemoteCallTransaction(function);
}
@Deprecated
public static EventTest load(String contractAddress, Web3j web3j, Credentials credentials, BigInteger gasPrice, BigInteger gasLimit) {
return new EventTest(contractAddress, web3j, credentials, gasPrice, gasLimit);
}
@Deprecated
public static EventTest load(String contractAddress, Web3j web3j, TransactionManager transactionManager, BigInteger gasPrice, BigInteger gasLimit) {
return new EventTest(contractAddress, web3j, transactionManager, gasPrice, gasLimit);
}
public static EventTest load(String contractAddress, Web3j web3j, Credentials credentials, ContractGasProvider contractGasProvider) {
return new EventTest(contractAddress, web3j, credentials, contractGasProvider);
}
public static EventTest load(String contractAddress, Web3j web3j, TransactionManager transactionManager, ContractGasProvider contractGasProvider) {
return new EventTest(contractAddress, web3j, transactionManager, contractGasProvider);
}
public static class IncrementEventResponse extends BaseEventResponse {
public BigInteger which;
public String who;
}
public static class ChangeNameEventEventResponse extends BaseEventResponse {
public String str;
public String who;
}
}
?2、測(cè)試合約方法的調(diào)用和合約事件監(jiān)聽
? ?說明：
? ? ? ? web3j通過rpc的方式建立連接，連接方式我測(cè)試時(shí)，用了兩種方式，一種是http的方式調(diào)用合約的方法，websocket的方式調(diào)用的事件監(jiān)聽，兩種方式測(cè)試都是OK的
package com.xx.xxx.contracts.util;
import com.nft.service.contracts.constants.ContractConstants;
import com.nft.service.contracts.constants.EventTest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.web3j.abi.EventValues;
import org.web3j.abi.datatypes.Type;
import org.web3j.crypto.Credentials;
import org.web3j.protocol.Web3j;
import org.web3j.protocol.core.DefaultBlockParameterName;
import org.web3j.protocol.core.RemoteFunctionCall;
import org.web3j.protocol.core.methods.request.Transaction;
import org.web3j.protocol.core.methods.response.EthEstimateGas;
import org.web3j.protocol.core.methods.response.EthGetTransactionCount;
import org.web3j.protocol.core.methods.response.Log;
import org.web3j.protocol.core.methods.response.TransactionReceipt;
import org.web3j.protocol.http.HttpService;
import org.web3j.protocol.websocket.WebSocketService;
import org.web3j.tx.Contract;
import org.web3j.tx.ReadonlyTransactionManager;
import org.web3j.tx.TransactionManager;
import org.web3j.tx.gas.DefaultGasProvider;
import java.io.IOException;
import java.math.BigInteger;
import java.net.ConnectException;
import java.util.concurrent.ExecutionException;
/**
* @author viowio
* @version v1.0
* @date 17:52 2022/4/9
* @description ERC20工具類
*/
public class TestUtil {
private static Web3j web3j = Web3j.build(new HttpService("https://data-seed-prebsc-2-s1.binance.org:8545/"));
private static final Logger logger = LoggerFactory.getLogger(TestUtil.class);
public static void changeName(){
String token = "合約地址";
try {
Credentials credentials = Credentials.create("換成自己的測(cè)試錢包地址私鑰");
BigInteger currentGasPrice = web3j.ethGasPrice().sendAsync().get().getGasPrice();
EventTest eventTest = EventTest.load(token, web3j, credentials, new DefaultGasProvider() {
/**
* 使用動(dòng)態(tài)獲取的 Gas Price
* @return
*/
@Override
public BigInteger getGasPrice() {
return currentGasPrice;
}
});
RemoteFunctionCall<TransactionReceipt> changeNames = eventTest.changeName("0x7503D2667a3Af2a5f5268B9628F7Bb0A3E6282B4");
TransactionReceipt transactionReceipt = changeNames.sendAsync().get();
String transactionHash = transactionReceipt.getTransactionHash();
logger.info("changeName hash: {}",transactionHash);
}catch (ExecutionException | InterruptedException ex){
logger.info(ex.getMessage());
} catch (Exception e) {
e.printStackTrace();
}
}
public static void changeNameEvent() throws ConnectException {
String token = "合約地址";
String wsurl = ContractConstants.WEBSOCKET_RPC;
//實(shí)例化websocket
WebSocketService webSocketService = new WebSocketService(wsurl,true);
//建立連接
webSocketService.connect();
//實(shí)例化web3j
Web3j client = Web3j.build(webSocketService);
TransactionManager transactionManager = new ReadonlyTransactionManager(web3j, token);
try {
//方式一
/* client.ethLogFlowable(
new EthFilter(
DefaultBlockParameterName.EARLIEST,
DefaultBlockParameterName.LATEST,
// 合約地址
token
)
).subscribe(event -> {
System.out.println(event);
// => Log{removed=false, logIndex='0x39', transactionIndex='0x13', transactionHash='0x9c3653c27946cb39c3a256229634cfedbca54f146a740f46b661b986590f8358', blockHash='0x1e674b9d111601519f977b75f9a1865ba359b474550ff5d0d87daec1f543d64d', blockNumber='0xb83ccd', address='0x7b52aae43e962ce6a9a1b7e79f549582ae8bcff9', data='0x', type='null', topics=[0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef, 0x0000000000000000000000000000000000000000000000000000000000000000, 0x0000000000000000000000006ab3d0bd875f8667026d2a9bb3060ec44380bcc2, 0x0000000000000000000000000000000000000000000000000000000000000017]}
}, Throwable::printStackTrace);*/
//方式二
/*Credentials credentials = Credentials.create("換成自己的測(cè)試錢包地址私鑰");
BigInteger currentGasPrice = web3j.ethGasPrice().sendAsync().get().getGasPrice();
EventTest eventTest = EventTest.load(token, web3j, credentials, new DefaultGasProvider() {
*//**
* 使用動(dòng)態(tài)獲取的 Gas Price
* @return
*//*
@Override
public BigInteger getGasPrice() {
return currentGasPrice;
}
});
eventTest
.changeNameEventEventFlowable(DefaultBlockParameterName.EARLIEST, DefaultBlockParameterName.LATEST)
.subscribe(event -> {
Log log = event.log;
EventValues eventValues = Contract.staticExtractEventParameters(EventTest.CHANGENAMEEVENT_EVENT, log);
for (Type nonIndexedValue : eventValues.getNonIndexedValues()) {
System.out.println(nonIndexedValue.getValue());
}
});*/
//方式3
Credentials credentials = Credentials.create("換成自己的測(cè)試錢包地址私鑰");
BigInteger currentGasPrice = client.ethGasPrice().sendAsync().get().getGasPrice();
EventTest eventTest = EventTest.load(token, client, credentials, new DefaultGasProvider() {
/**
* 使用動(dòng)態(tài)獲取的 Gas Price
* @return
*/
@Override
public BigInteger getGasPrice() {
return currentGasPrice;
}
});
eventTest
.changeNameEventEventFlowable(DefaultBlockParameterName.EARLIEST, DefaultBlockParameterName.LATEST)
.subscribe(event -> {
Log log = event.log;
logger.info("transactionHash: {}",log.getTransactionHash());
//解析時(shí)間返回的參數(shù)
EventValues eventValues = Contract.staticExtractEventParameters(EventTest.CHANGENAMEEVENT_EVENT, log);
for (Type nonIndexedValue : eventValues.getNonIndexedValues()) {
System.out.println(nonIndexedValue.getValue());
}
});
}catch (Exception e) {
e.printStackTrace();
}
}
}
事件測(cè)試結(jié)果
16:32:05.978 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xd4fac21ba08d7496d8025281c37e932b914ea3bb9dce48e73bd3c08ac934fdd3
test
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.979 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x42aff4ead062feb340a2fa68c73b5024a0d58029287a2f0acc62156c60780d97
test
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.980 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x1050583b9e907378fb61289ab5b373f195f4d332c5fd7d273e2c817554c90f7b
123
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.980 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xc86374d895f83bfef380a9a1f4cc5a15ddfcc78090305cff5e4367460d423af4
1237
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.981 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xf76fbd23e603109752215c5455e3920a08583de8728c2a42699f61aa45959d29
12374
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.981 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x0d751916f7ae66162959138c0a700feb136153fabee8d8b25a10e410fe74f904
1237455
0x5ae241178c67689ead468bf5170b3105011a5766
16:32:05.981 [restartedMain] INFO c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xe03249489b93e287e9d033f547c2a36a741c7b3ae49e5c95542315816f4af572
12374556
0x5ae241178c67689ead468bf5170b3105011a5766OK，暫時(shí)完事了。
最后補(bǔ)充一下文章來源：http://www.zghlxwxcb.cn/news/detail-412833.html
如果沒有的rpc地址的，可以搜一下，也可以使用我上面的那個(gè)地址，不過僅限于測(cè)試用哦。文章來源地址http://www.zghlxwxcb.cn/news/detail-412833.html
到了這里，關(guān)于java web3j4.8.4版本的使用記錄的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
