devbox
凡人多烦事01
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

java web3j4.8.4版本的使用记录_org.web3j.protocol.core.methods.response.log canno

作者：凡人多烦事01 | 2024-04-14 01:43:31

赞

踩

org.web3j.protocol.core.methods.response.log cannot be cast to org.web3j.pro

最近公司做NFT市场开发，特记录一下自己在使用web3j组件测试调用区块链合约的时使用的方法和踩过的坑，便于自己以后查看。

主要用到工具有4个

idea,谷歌浏览,小狐狸钱包(metamask)插件，remix在线智能合约平台

1、准备工作

1.1、java项目

 在pom.xml中添加引用仓库地址，添加web3j的引入

  1.     <repositories>
  2.         <repository>
  3.             <id>jitpack.io</id>
  4.             <url>https://jitpack.io</url>
  5.         </repository>
  6.     </repositories>
  7.  
  8.     <dependencies>
  9.  
  10.         <!--web3j-->
  11.         <dependency>
  12.             <groupId>org.web3j</groupId>
  13.             <artifactId>core</artifactId>
  14.             <version>4.8.4</version>
  15.             <exclusions>
  16.                 <exclusion>
  17.                     <groupId>org.jetbrains.kotlin</groupId>
  18.                     <artifactId>kotlin-stdlib</artifactId>
  19.                 </exclusion>
  20.                 <exclusion>
  21.                     <groupId>com.squareup.okhttp3</groupId>
  22.                     <artifactId>okhttp</artifactId>
  23.                 </exclusion>
  24.             </exclusions>
  25.         </dependency>
  26.     </dependencies>

1.2、智能合约

        开始前，必须有一个用于测试的区块链智能合约，进入以太坊官网提供的在线平台，地址为：https://remix.ethereum.org/，编写测试合约。

        编写完成，编译测试无误后，部署合约，方法选择如下

        因为选择通过web3的方式来发布合约，所以同步会要求登录小狐狸（MetaMask），我这里事先就已经添加好了币安测试链，如果各位没有添加的话，自己自行添加哈

1.3 合约转化

         合约发布成功后，测试一下合约内的方法是否可以正常使用，一切OK了以后，在remix中的编译模块内，将abi和bin保存放入本地文件中用于生成java文件。

说明一下哦，在生成java文件时，本地要有web3j的资源文件，我事先已经做好了准备工作了，如果你们没有的话，就自己查下哈。

进入cmd命令窗口

命令如下

web3j solidity generate --abiFile=abi文件地址 -o 文件生成地址 -p 文件包名

 

 以下是我的合约生成的java文件

  1. package com.XX.XXX.contracts.constants;
  2.  
  3. import io.reactivex.Flowable;
  4. import io.reactivex.functions.Function;
  5. import java.math.BigInteger;
  6. import java.util.ArrayList;
  7. import java.util.Arrays;
  8. import java.util.Collections;
  9. import java.util.List;
  10. import org.web3j.abi.EventEncoder;
  11. import org.web3j.abi.TypeReference;
  12. import org.web3j.abi.datatypes.Address;
  13. import org.web3j.abi.datatypes.Event;
  14. import org.web3j.abi.datatypes.Type;
  15. import org.web3j.abi.datatypes.Utf8String;
  16. import org.web3j.abi.datatypes.generated.Uint256;
  17. import org.web3j.crypto.Credentials;
  18. import org.web3j.protocol.Web3j;
  19. import org.web3j.protocol.core.DefaultBlockParameter;
  20. import org.web3j.protocol.core.RemoteFunctionCall;
  21. import org.web3j.protocol.core.methods.request.EthFilter;
  22. import org.web3j.protocol.core.methods.response.BaseEventResponse;
  23. import org.web3j.protocol.core.methods.response.Log;
  24. import org.web3j.protocol.core.methods.response.TransactionReceipt;
  25. import org.web3j.tx.Contract;
  26. import org.web3j.tx.TransactionManager;
  27. import org.web3j.tx.gas.ContractGasProvider;
  28.  
  29. /**
  30.  * <p>Auto generated code.
  31.  * <p><strong>Do not modify!</strong>
  32.  * <p>Please use the <a href="https://docs.web3j.io/command_line.html">web3j command line tools</a>,
  33.  * or the org.web3j.codegen.SolidityFunctionWrapperGenerator in the 
  34.  * <a href="https://github.com/web3j/web3j/tree/master/codegen">codegen module</a> to update.
  35.  *
  36.  * <p>Generated with web3j version 4.5.5.
  37.  */
  38. @SuppressWarnings("rawtypes")
  39. public class EventTest extends Contract {
  40.     private static final String BINARY = "Bin file was not provided";
  41.  
  42.     public static final String FUNC_CHANGENAME = "changeName";
  43.  
  44.     public static final String FUNC_COUNTS = "counts";
  45.  
  46.     public static final String FUNC_INCREMENT = "increment";
  47.  
  48.     public static final String FUNC_NAME = "name";
  49.  
  50.     public static final Event INCREMENT_EVENT = new Event("Increment", 
  51.             Arrays.<TypeReference<?>>asList(new TypeReference<Uint256>(true) {}, new TypeReference<Address>() {}));
  52.     ;
  53.  
  54.     public static final Event CHANGENAMEEVENT_EVENT = new Event("changeNameEvent", 
  55.             Arrays.<TypeReference<?>>asList(new TypeReference<Utf8String>() {}, new TypeReference<Address>() {}));
  56.     ;
  57.  
  58.     @Deprecated
  59.     protected EventTest(String contractAddress, Web3j web3j, Credentials credentials, BigInteger gasPrice, BigInteger gasLimit) {
  60.         super(BINARY, contractAddress, web3j, credentials, gasPrice, gasLimit);
  61.     }
  62.  
  63.     protected EventTest(String contractAddress, Web3j web3j, Credentials credentials, ContractGasProvider contractGasProvider) {
  64.         super(BINARY, contractAddress, web3j, credentials, contractGasProvider);
  65.     }
  66.  
  67.     @Deprecated
  68.     protected EventTest(String contractAddress, Web3j web3j, TransactionManager transactionManager, BigInteger gasPrice, BigInteger gasLimit) {
  69.         super(BINARY, contractAddress, web3j, transactionManager, gasPrice, gasLimit);
  70.     }
  71.  
  72.     protected EventTest(String contractAddress, Web3j web3j, TransactionManager transactionManager, ContractGasProvider contractGasProvider) {
  73.         super(BINARY, contractAddress, web3j, transactionManager, contractGasProvider);
  74.     }
  75.  
  76.     public List<IncrementEventResponse> getIncrementEvents(TransactionReceipt transactionReceipt) {
  77.         List<Contract.EventValuesWithLog> valueList = extractEventParametersWithLog(INCREMENT_EVENT, transactionReceipt);
  78.         ArrayList<IncrementEventResponse> responses = new ArrayList<IncrementEventResponse>(valueList.size());
  79.         for (Contract.EventValuesWithLog eventValues : valueList) {
  80.             IncrementEventResponse typedResponse = new IncrementEventResponse();
  81.             typedResponse.log = eventValues.getLog();
  82.             typedResponse.which = (BigInteger) eventValues.getIndexedValues().get(0).getValue();
  83.             typedResponse.who = (String) eventValues.getNonIndexedValues().get(0).getValue();
  84.             responses.add(typedResponse);
  85.         }
  86.         return responses;
  87.     }
  88.  
  89.     public Flowable<IncrementEventResponse> incrementEventFlowable(EthFilter filter) {
  90.         return web3j.ethLogFlowable(filter).map(new Function<Log, IncrementEventResponse>() {
  91.             @Override
  92.             public IncrementEventResponse apply(Log log) {
  93.                 Contract.EventValuesWithLog eventValues = extractEventParametersWithLog(INCREMENT_EVENT, log);
  94.                 IncrementEventResponse typedResponse = new IncrementEventResponse();
  95.                 typedResponse.log = log;
  96.                 typedResponse.which = (BigInteger) eventValues.getIndexedValues().get(0).getValue();
  97.                 typedResponse.who = (String) eventValues.getNonIndexedValues().get(0).getValue();
  98.                 return typedResponse;
  99.             }
  100.         });
  101.     }
  102.  
  103.     public Flowable<IncrementEventResponse> incrementEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
  104.         EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
  105.         filter.addSingleTopic(EventEncoder.encode(INCREMENT_EVENT));
  106.         return incrementEventFlowable(filter);
  107.     }
  108.  
  109.     public List<ChangeNameEventEventResponse> getChangeNameEventEvents(TransactionReceipt transactionReceipt) {
  110.         List<Contract.EventValuesWithLog> valueList = extractEventParametersWithLog(CHANGENAMEEVENT_EVENT, transactionReceipt);
  111.         ArrayList<ChangeNameEventEventResponse> responses = new ArrayList<ChangeNameEventEventResponse>(valueList.size());
  112.         for (Contract.EventValuesWithLog eventValues : valueList) {
  113.             ChangeNameEventEventResponse typedResponse = new ChangeNameEventEventResponse();
  114.             typedResponse.log = eventValues.getLog();
  115.             typedResponse.str = (String) eventValues.getNonIndexedValues().get(0).getValue();
  116.             typedResponse.who = (String) eventValues.getNonIndexedValues().get(1).getValue();
  117.             responses.add(typedResponse);
  118.         }
  119.         return responses;
  120.     }
  121.  
  122.     public Flowable<ChangeNameEventEventResponse> changeNameEventEventFlowable(EthFilter filter) {
  123.         return web3j.ethLogFlowable(filter).map(new Function<Log, ChangeNameEventEventResponse>() {
  124.             @Override
  125.             public ChangeNameEventEventResponse apply(Log log) {
  126.                 Contract.EventValuesWithLog eventValues = extractEventParametersWithLog(CHANGENAMEEVENT_EVENT, log);
  127.                 ChangeNameEventEventResponse typedResponse = new ChangeNameEventEventResponse();
  128.                 typedResponse.log = log;
  129.                 typedResponse.str = (String) eventValues.getNonIndexedValues().get(0).getValue();
  130.                 typedResponse.who = (String) eventValues.getNonIndexedValues().get(1).getValue();
  131.                 return typedResponse;
  132.             }
  133.         });
  134.     }
  135.  
  136.     public Flowable<ChangeNameEventEventResponse> changeNameEventEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
  137.         EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
  138.         filter.addSingleTopic(EventEncoder.encode(CHANGENAMEEVENT_EVENT));
  139.         return changeNameEventEventFlowable(filter);
  140.     }
  141.  
  142.     public RemoteFunctionCall<TransactionReceipt> changeName(String str) {
  143.         final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
  144.                 FUNC_CHANGENAME, 
  145.                 Arrays.<Type>asList(new org.web3j.abi.datatypes.Utf8String(str)), 
  146.                 Collections.<TypeReference<?>>emptyList());
  147.         return executeRemoteCallTransaction(function);
  148.     }
  149.  
  150.     public RemoteFunctionCall<TransactionReceipt> counts(BigInteger param0) {
  151.         final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
  152.                 FUNC_COUNTS, 
  153.                 Arrays.<Type>asList(new org.web3j.abi.datatypes.generated.Uint256(param0)), 
  154.                 Collections.<TypeReference<?>>emptyList());
  155.         return executeRemoteCallTransaction(function);
  156.     }
  157.  
  158.     public RemoteFunctionCall<TransactionReceipt> increment(BigInteger which) {
  159.         final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
  160.                 FUNC_INCREMENT, 
  161.                 Arrays.<Type>asList(new org.web3j.abi.datatypes.generated.Uint256(which)), 
  162.                 Collections.<TypeReference<?>>emptyList());
  163.         return executeRemoteCallTransaction(function);
  164.     }
  165.  
  166.     public RemoteFunctionCall<TransactionReceipt> name() {
  167.         final org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
  168.                 FUNC_NAME, 
  169.                 Arrays.<Type>asList(), 
  170.                 Collections.<TypeReference<?>>emptyList());
  171.         return executeRemoteCallTransaction(function);
  172.     }
  173.  
  174.     @Deprecated
  175.     public static EventTest load(String contractAddress, Web3j web3j, Credentials credentials, BigInteger gasPrice, BigInteger gasLimit) {
  176.         return new EventTest(contractAddress, web3j, credentials, gasPrice, gasLimit);
  177.     }
  178.  
  179.     @Deprecated
  180.     public static EventTest load(String contractAddress, Web3j web3j, TransactionManager transactionManager, BigInteger gasPrice, BigInteger gasLimit) {
  181.         return new EventTest(contractAddress, web3j, transactionManager, gasPrice, gasLimit);
  182.     }
  183.  
  184.     public static EventTest load(String contractAddress, Web3j web3j, Credentials credentials, ContractGasProvider contractGasProvider) {
  185.         return new EventTest(contractAddress, web3j, credentials, contractGasProvider);
  186.     }
  187.  
  188.     public static EventTest load(String contractAddress, Web3j web3j, TransactionManager transactionManager, ContractGasProvider contractGasProvider) {
  189.         return new EventTest(contractAddress, web3j, transactionManager, contractGasProvider);
  190.     }
  191.  
  192.     public static class IncrementEventResponse extends BaseEventResponse {
  193.         public BigInteger which;
  194.  
  195.         public String who;
  196.     }
  197.  
  198.     public static class ChangeNameEventEventResponse extends BaseEventResponse {
  199.         public String str;
  200.  
  201.         public String who;
  202.     }
  203. }

 2、测试合约方法的调用和合约事件监听

   说明：

        web3j通过rpc的方式建立连接，连接方式我测试时，用了两种方式，一种是http的方式调用合约的方法，websocket的方式调用的事件监听，两种方式测试都是OK的

  1. package com.xx.xxx.contracts.util;
  2.  
  3. import com.nft.service.contracts.constants.ContractConstants;
  4. import com.nft.service.contracts.constants.EventTest;
  5. import org.slf4j.Logger;
  6. import org.slf4j.LoggerFactory;
  7. import org.web3j.abi.EventValues;
  8. import org.web3j.abi.datatypes.Type;
  9. import org.web3j.crypto.Credentials;
  10. import org.web3j.protocol.Web3j;
  11. import org.web3j.protocol.core.DefaultBlockParameterName;
  12. import org.web3j.protocol.core.RemoteFunctionCall;
  13. import org.web3j.protocol.core.methods.request.Transaction;
  14. import org.web3j.protocol.core.methods.response.EthEstimateGas;
  15. import org.web3j.protocol.core.methods.response.EthGetTransactionCount;
  16. import org.web3j.protocol.core.methods.response.Log;
  17. import org.web3j.protocol.core.methods.response.TransactionReceipt;
  18. import org.web3j.protocol.http.HttpService;
  19. import org.web3j.protocol.websocket.WebSocketService;
  20. import org.web3j.tx.Contract;
  21. import org.web3j.tx.ReadonlyTransactionManager;
  22. import org.web3j.tx.TransactionManager;
  23. import org.web3j.tx.gas.DefaultGasProvider;
  24.  
  25. import java.io.IOException;
  26. import java.math.BigInteger;
  27. import java.net.ConnectException;
  28. import java.util.concurrent.ExecutionException;
  29.  
  30. /**
  31.  * @author viowio
  32.  * @version v1.0
  33.  * @date 17:52 2022/4/9
  34.  * @description ERC20工具类
  35.  */
  36. public class TestUtil {
  37.  
  38.  
  39.     private static Web3j web3j = Web3j.build(new HttpService("https://data-seed-prebsc-2-s1.binance.org:8545/"));
  40.     private static final Logger logger = LoggerFactory.getLogger(TestUtil.class);
  41.  
  42.     public static void changeName(){
  43.         String token = "合约地址";
  44.         try {
  45.             Credentials credentials = Credentials.create("换成自己的测试钱包地址私钥");
  46.             BigInteger currentGasPrice = web3j.ethGasPrice().sendAsync().get().getGasPrice();
  47.             EventTest eventTest = EventTest.load(token, web3j, credentials, new DefaultGasProvider() {
  48.                 /**
  49.                  * 使用动态获取的 Gas Price
  50.                  * @return
  51.                  */
  52.                 @Override
  53.                 public BigInteger getGasPrice() {
  54.                     return currentGasPrice;
  55.                 }
  56.             });
  57.             
  58.             RemoteFunctionCall<TransactionReceipt> changeNames = eventTest.changeName("0x7503D2667a3Af2a5f5268B9628F7Bb0A3E6282B4");
  59.             TransactionReceipt transactionReceipt = changeNames.sendAsync().get();
  60.             String transactionHash = transactionReceipt.getTransactionHash();
  61.             logger.info("changeName hash: {}",transactionHash);
  62.         }catch (ExecutionException | InterruptedException ex){
  63.             logger.info(ex.getMessage());
  64.         } catch (Exception e) {
  65.             e.printStackTrace();
  66.         }
  67.     }
  68.     public static void changeNameEvent() throws ConnectException {
  69.         String token = "合约地址";
  70.         String wsurl = ContractConstants.WEBSOCKET_RPC;
  71.         //实例化websocket
  72.         WebSocketService webSocketService = new WebSocketService(wsurl,true);
  73.         //建立连接
  74.         webSocketService.connect();
  75.         //实例化web3j
  76.         Web3j client = Web3j.build(webSocketService);
  77.         TransactionManager transactionManager = new ReadonlyTransactionManager(web3j, token);
  78.         try {
  79.             //方式一
  80.             /* client.ethLogFlowable(
  81.                     new EthFilter(
  82.                             DefaultBlockParameterName.EARLIEST,
  83.                             DefaultBlockParameterName.LATEST,
  84.                             // 合约地址
  85.                             token
  86.                     )
  87.             ).subscribe(event -> {
  88.                 System.out.println(event);
  89.                 // => Log{removed=false, logIndex='0x39', transactionIndex='0x13', transactionHash='0x9c3653c27946cb39c3a256229634cfedbca54f146a740f46b661b986590f8358', blockHash='0x1e674b9d111601519f977b75f9a1865ba359b474550ff5d0d87daec1f543d64d', blockNumber='0xb83ccd', address='0x7b52aae43e962ce6a9a1b7e79f549582ae8bcff9', data='0x', type='null', topics=[0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef, 0x0000000000000000000000000000000000000000000000000000000000000000, 0x0000000000000000000000006ab3d0bd875f8667026d2a9bb3060ec44380bcc2, 0x0000000000000000000000000000000000000000000000000000000000000017]}
  90.             }, Throwable::printStackTrace);*/
  91.  
  92.             //方式二
  93.             /*Credentials credentials = Credentials.create("换成自己的测试钱包地址私钥");
  94.             BigInteger currentGasPrice = web3j.ethGasPrice().sendAsync().get().getGasPrice();
  95.             EventTest eventTest = EventTest.load(token, web3j, credentials, new DefaultGasProvider() {
  96.                 *//**
  97.                  * 使用动态获取的 Gas Price
  98.                  * @return
  99.                  *//*
  100.                 @Override
  101.                 public BigInteger getGasPrice() {
  102.                     return currentGasPrice;
  103.                 }
  104.             });
  105.             eventTest
  106.                     .changeNameEventEventFlowable(DefaultBlockParameterName.EARLIEST, DefaultBlockParameterName.LATEST)
  107.                     .subscribe(event -> {
  108.                         Log log = event.log;
  109.                         EventValues eventValues = Contract.staticExtractEventParameters(EventTest.CHANGENAMEEVENT_EVENT, log);
  110.                         for (Type nonIndexedValue : eventValues.getNonIndexedValues()) {
  111.                             System.out.println(nonIndexedValue.getValue());
  112.                         }
  113.                     });*/
  114.             //方式3
  115.             Credentials credentials = Credentials.create("换成自己的测试钱包地址私钥");
  116.             BigInteger currentGasPrice = client.ethGasPrice().sendAsync().get().getGasPrice();
  117.             EventTest eventTest = EventTest.load(token, client, credentials, new DefaultGasProvider() {
  118.                 /**
  119.                  * 使用动态获取的 Gas Price
  120.                  * @return
  121.                  */
  122.                 @Override
  123.                 public BigInteger getGasPrice() {
  124.                     return currentGasPrice;
  125.                 }
  126.             });
  127.             eventTest
  128.                     .changeNameEventEventFlowable(DefaultBlockParameterName.EARLIEST, DefaultBlockParameterName.LATEST)
  129.                     .subscribe(event -> {
  130.                         Log log = event.log;
  131.                         logger.info("transactionHash: {}",log.getTransactionHash());
  132.                         //解析时间返回的参数
  133.                         EventValues eventValues = Contract.staticExtractEventParameters(EventTest.CHANGENAMEEVENT_EVENT, log);
  134.                         for (Type nonIndexedValue : eventValues.getNonIndexedValues()) {
  135.                             System.out.println(nonIndexedValue.getValue());
  136.                         }
  137.                     });
  138.         }catch (Exception e) {
  139.             e.printStackTrace();
  140.         }
  141.     }
  142. }

事件测试结果

  1. 16:32:05.978 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xd4fac21ba08d7496d8025281c37e932b914ea3bb9dce48e73bd3c08ac934fdd3
  2. test
  3. 0x5ae241178c67689ead468bf5170b3105011a5766
  4. 16:32:05.979 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x42aff4ead062feb340a2fa68c73b5024a0d58029287a2f0acc62156c60780d97
  5. test
  6. 0x5ae241178c67689ead468bf5170b3105011a5766
  7. 16:32:05.980 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x1050583b9e907378fb61289ab5b373f195f4d332c5fd7d273e2c817554c90f7b
  8. 123
  9. 0x5ae241178c67689ead468bf5170b3105011a5766
  10. 16:32:05.980 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xc86374d895f83bfef380a9a1f4cc5a15ddfcc78090305cff5e4367460d423af4
  11. 1237
  12. 0x5ae241178c67689ead468bf5170b3105011a5766
  13. 16:32:05.981 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xf76fbd23e603109752215c5455e3920a08583de8728c2a42699f61aa45959d29
  14. 12374
  15. 0x5ae241178c67689ead468bf5170b3105011a5766
  16. 16:32:05.981 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0x0d751916f7ae66162959138c0a700feb136153fabee8d8b25a10e410fe74f904
  17. 1237455
  18. 0x5ae241178c67689ead468bf5170b3105011a5766
  19. 16:32:05.981 [restartedMain] INFO  c.n.s.c.u.TestUtil - [lambda$changeNameEvent$0,146] - transactionHash: 0xe03249489b93e287e9d033f547c2a36a741c7b3ae49e5c95542315816f4af572
  20. 12374556
  21. 0x5ae241178c67689ead468bf5170b3105011a5766

OK，暂时完事了。

最后补充一下

如果没有的rpc地址的，可以搜一下，也可以使用我上面的那个地址，不过仅限于测试用哦。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/凡人多烦事01/article/detail/419541
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号