• 关于利用webase-front节点控制台一键导出的java项目解析

    搭建区块链系统和管理平台分别用的的fisco、webase。

    关于我们在利用java开发DApp(去中心化引用)，与区块链系统交互，可以用:

    1.webase前置服务给开发者提供的api：我们在搭建好fisco链之后，在搭一个webase-front服务，我们就能通过front服务提供的api，间接在fisco上面,进行部署、调用合约、获取块高，等与区块链系统交互的行为。

    webase-front接口说明: 接口说明 — WeBASE v1.5.5 文档 (webasedoc.readthedocs.io)

     2.利用fisco官方为Java开发者提供的 fisco-sdk：通过引入他调用相关的方法，与区块链系统交互。

    fisco-java-sdk快速入门: 快速入门 — FISCO BCOS v2 v2.9.0 文档 (fisco-bcos-documentation.readthedocs.io)

    嗯,...但是按照官方文档，一旦我们项目大起来，其实就相对比较麻烦了(也不麻烦),然后我们可以利用webase-front节点控制台，将合约上传后，将合约对应的Java项目一键导出。

    如下图:

    这次我们利用webase-front搭建好，默认自带的Asset合约，来进行演示。

    PS: 利用fisco-sdk 开发Dapp,先建议看fisco、webase有一定的基础之后，再建议尝试。

    利用fisco-jdk第一次交互，可以看看这个,里面引用了Linux的IDEA、Maven、Java的安装:fisco Java-sdk 快速入门案例-CSDN博客

    梦开始的地方

    项目导出后，是一个boot项目,包管理工具是gradle，我习惯用Maven，因此我新建一个Maven项目，并将包移植到我自己的项目里。

    pom.xml

    我的 jdk 是 14。测试了jdk 11、8、14  ,就14不会报错对应fisco-sdk 2.9.2

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>org.examplegroupId>
    8.     <artifactId>fiscoDemoartifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.  
    11.     <properties>
    12.         <java.version>14java.version>
    13.         <spring-boot.version>2.6.13spring-boot.version>
    14.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    15.         <project.reporting.outputEncoding>UTF-8project.reporting.outputEncoding>
    16.     properties>
    17.     <dependencies>
    18.         
    19.         <dependency>
    20.             <groupId>org.springframework.bootgroupId>
    21.             <artifactId>spring-boot-starter-webartifactId>
    22.         dependency>
    23.         
    24.         <dependency>
    25.             <groupId>org.springframework.bootgroupId>
    26.             <artifactId>spring-boot-starter-testartifactId>
    27.             <scope>testscope>
    28.         dependency>
    29.         
    30.         <dependency>
    31.             <groupId>org.projectlombokgroupId>
    32.             <artifactId>lombokartifactId>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.slf4jgroupId>
    36.             <artifactId>slf4j-apiartifactId>
    37.             <version>1.7.36version>
    38.         dependency>
    39.         
    40.         <dependency>
    41.             <groupId>org.fisco-bcos.java-sdkgroupId>
    42.             <artifactId>fisco-bcos-java-sdkartifactId>
    43.             <version>2.9.2version>
    44.             
    45.             <exclusions>
    46.                 <exclusion>
    47.                     <artifactId>*artifactId>
    48.                     <groupId>org.slf4jgroupId>
    49.                 exclusion>
    50.             exclusions>
    51.         dependency>
    52.  
    53.  
    54.  
    55.  
    56.     dependencies>
    57.     <dependencyManagement>
    58.         <dependencies>
    59.             <dependency>
    60.                 <groupId>org.springframework.bootgroupId>
    61.                 <artifactId>spring-boot-dependenciesartifactId>
    62.                 <version>${spring-boot.version}version>
    63.                 <type>pomtype>
    64.                 <scope>importscope>
    65.             dependency>
    66.         dependencies>
    67.     dependencyManagement>
    68.  
    69.     <build>
    70.         <plugins>
    71.             <plugin>
    72.                 <groupId>org.apache.maven.pluginsgroupId>
    73.                 <artifactId>maven-compiler-pluginartifactId>
    74.                 <version>3.8.1version>
    75.                 <configuration>
    76.                     <source>1.8source>
    77.                     <target>1.8target>
    78.                     <encoding>UTF-8encoding>
    79.                 configuration>
    80.             plugin>
    81.  
    82.         plugins>
    83.     build>
    84.  
    85.  
    86. project>

    项目结构大体概览图 

    第一个红框:

    contracts:存放合约的目录，没啥用。

    第二个红框:

    接触java web之后,应该都知道。

    第三个红框:

    abi:与合约交互用的abi； bin: 合约编译之后生成二进制文件;  conf: 存放证书用到的目录。

     接下来，我们从第2个红框开始，从上往下，依次讲解学习主要的目录:

     config

    SystemConfig

    1. package org.example.demo.config;
    2.  
    3. import java.lang.String;
    4. import lombok.Data;
    5. import org.springframework.boot.context.properties.ConfigurationProperties;
    6. import org.springframework.boot.context.properties.NestedConfigurationProperty;
    7. import org.springframework.context.annotation.Configuration;
    8.  
    9. /**
    10.  * 自动配置类 对应 配置文件信息（网络/群组/证书文件。。。）
    11.  */
    12. @Data
    13. @Configuration
    14. @ConfigurationProperties(
    15.     prefix = "system"
    16. )
    17. public class SystemConfig {
    18.   private String peers;
    19.  
    20.   private int groupId = 1;
    21.  
    22.   private String certPath;
    23.  
    24.   private String hexPrivateKey;
    25.  
    26.   @NestedConfigurationProperty
    27.   private ContractConfig contract;
    28. }

     boot的自动装配类，当boot项目启动时，自动读取application.properties/yaml/yml中的自定义配置信息。并且，我们可以在spring 容器中获取到他。

    对应的配置信息:

    application.properties

    1. # 搭建区块链第一个节点(node0)的,ip:port
    2. system.peers=127.0.0.1:20200
    3. # 合约所属群组id
    4. system.groupId=1
    5. # 证书所放的目录
    6. system.certPath=conf
    7. # 可选: 私钥文件
    8. system.hexPrivateKey=19eb7fd7a47a487265c6c109d560929deaee8e378fd4990dcce7cebd8a34f195
    9. #可选: 合约地址
    10. system.contract.assetAddress=0x385dfad96f483042686273d5fda5c379b111bb20
    11.  
    12.  
    13. server.port=8088
    14. server.session.timeout=60
    15. banner.charset=UTF-8
    16. spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
    17. spring.jackson.time-zone=GMT+8

    ContractConfig

    1. @Data
    2. public class ContractConfig {
    3.   private String assetAddress;
    4. }

    自动配置类所需要的类，创建对应的对象，将地址填充进去对应的字段。 

    PS:属性名要对应配置字段。

    SdkBeanConfig

    1. package org.example.demo.config;
    2.  
    3. import java.math.BigInteger;
    4. import java.util.Arrays;
    5. import java.util.HashMap;
    6. import java.util.List;
    7. import java.util.Map;
    8. import java.util.stream.Collectors;
    9. import lombok.extern.slf4j.Slf4j;
    10. import org.fisco.bcos.sdk.BcosSDK;
    11. import org.fisco.bcos.sdk.client.Client;
    12. import org.fisco.bcos.sdk.config.ConfigOption;
    13. import org.fisco.bcos.sdk.config.exceptions.ConfigException;
    14. import org.fisco.bcos.sdk.config.model.ConfigProperty;
    15. import org.springframework.beans.factory.annotation.Autowired;
    16. import org.springframework.context.annotation.Bean;
    17. import org.springframework.context.annotation.Configuration;
    18.  
    19.  
    20. /**
    21.  *  读取我们配置类的信息，初始化Client
    22.  **/
    23. @Configuration
    24. @Slf4j
    25. public class SdkBeanConfig {
    26.  
    27.     @Autowired
    28.     private SystemConfig config;
    29.  
    30.     /**
    31.      * 读取配置信息，初始化client并返回
    32.      */
    33.     @Bean
    34.     public Client client() throws Exception {
    35.         String certPaths = this.config.getCertPath();
    36.         String[] possibilities = certPaths.split(",|;");
    37.         for(String certPath: possibilities ) {
    38.             try{
    39.                 ConfigProperty property = new ConfigProperty();
    40.                 configNetwork(property); // concat network
    41.                 configCryptoMaterial(property,certPath); // concat cerpath
    42.  
    43.                 ConfigOption configOption = new ConfigOption(property);
    44.                 Client client = new BcosSDK(configOption).getClient(config.getGroupId());
    45.  
    46.                 BigInteger blockNumber = client.getBlockNumber().getBlockNumber();
    47.                 log.error("Chain connect successful. Current block number {}", blockNumber);
    48.  
    49.                 configCryptoKeyPair(client);
    50.                 log.error("is Gm:{}, address:{}", client.getCryptoSuite().cryptoTypeConfig == 1, client.getCryptoSuite().getCryptoKeyPair().getAddress());
    51.                 return client;
    52.             }
    53.             catch (Exception ex) {
    54.                 log.error(ex.getMessage());
    55.                 try{
    56.                     Thread.sleep(5000);
    57.                 }catch (Exception e) {}
    58.             }
    59.         }
    60.         throw new ConfigException("Failed to connect to peers:" + config.getPeers());
    61.     }
    62.  
    63.     /** 
    64.      * 设置 network
    65.      * @param configProperty 
    66.      */
    67.     public void configNetwork(ConfigProperty configProperty) {
    68.         String peerStr = config.getPeers();
    69.         List peers = Arrays.stream(peerStr.split(",")).collect(Collectors.toList());
    70.         Map networkConfig = new HashMap<>();
    71.         networkConfig.put("peers", peers);
    72.  
    73.         configProperty.setNetwork(networkConfig);
    74.     }
    75.  
    76.     /**
    77.      * 设置 证书
    78.      * @param configProperty 
    79.      * @param certPath
    80.      */
    81.     public void configCryptoMaterial(ConfigProperty configProperty,String certPath) {
    82.         Map cryptoMaterials = new HashMap<>();
    83.         cryptoMaterials.put("certPath", certPath);
    84.         configProperty.setCryptoMaterial(cryptoMaterials);
    85.        
    86.         
    87.     }
    88.  
    89.     /**
    90.      * 设置密钥
    91.      * @param client 
    92.      */
    93.     public void configCryptoKeyPair(Client client) {
    94.         if (config.getHexPrivateKey() == null || config.getHexPrivateKey().isEmpty()){
    95.             client.getCryptoSuite().setCryptoKeyPair(client.getCryptoSuite().createKeyPair());
    96.             return;
    97.         }
    98.         String privateKey;
    99.         if (!config.getHexPrivateKey().contains(",")) {
    100.             privateKey = config.getHexPrivateKey();
    101.         } else {
    102.             String[] list = config.getHexPrivateKey().split(",");
    103.             privateKey = list[0];
    104.         }
    105.         if (privateKey.startsWith("0x") || privateKey.startsWith("0X")) {
    106.             privateKey = privateKey.substring(2);
    107.             config.setHexPrivateKey(privateKey);
    108.         }
    109.         client.getCryptoSuite().setCryptoKeyPair(client.getCryptoSuite().createKeyPair(privateKey));
    110.     }
    111. }

    我们读取了SystemConfig中的配置信息，封装到ConfigProperty对象里,并又将其封装到ConfigOption这个对象里面,通过下面这段代码

     Client client = new BcosSDK(configOption).getClient(config.getGroupId());

    获得了一个Client，通过调用Client的方法我们能与fisco交互，可以获取块高等..。

     service

    AssetService

    1. package org.example.demo.service;
    2.  
    3. import java.lang.Exception;
    4. import java.lang.String;
    5. import java.util.Arrays;
    6. import javax.annotation.PostConstruct;
    7. import lombok.Data;
    8. import lombok.NoArgsConstructor;
    9. import org.example.demo.model.bo.AssetBalancesInputBO;
    10. import org.example.demo.model.bo.AssetIssueInputBO;
    11. import org.example.demo.model.bo.AssetSendInputBO;
    12. import org.fisco.bcos.sdk.client.Client;
    13. import org.fisco.bcos.sdk.transaction.manager.AssembleTransactionProcessor;
    14. import org.fisco.bcos.sdk.transaction.manager.TransactionProcessorFactory;
    15. import org.fisco.bcos.sdk.transaction.model.dto.CallResponse;
    16. import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
    17. import org.springframework.beans.factory.annotation.Autowired;
    18. import org.springframework.beans.factory.annotation.Value;
    19. import org.springframework.stereotype.Service;
    20.  
    21. /**
    22.  *  对应合约的Service,方法 -> 合约变量 和 合约函数
    23.  *  发送交易 获取 响应
    24.  */
    25. @Service
    26. @NoArgsConstructor
    27. @Data
    28. public class AssetService {
    29.   public static final String ABI = org.example.demo.utils.IOUtil.readResourceAsString("abi/Asset.abi");
    30.  
    31.   public static final String BINARY = org.example.demo.utils.IOUtil.readResourceAsString("bin/ecc/Asset.bin");
    32.  
    33.   public static final String SM_BINARY = org.example.demo.utils.IOUtil.readResourceAsString("bin/ecc/Asset.bin");
    34.  
    35.   @Value("${system.contract.assetAddress}")
    36.   private String address;
    37.  
    38.   @Autowired
    39.   private Client client;
    40.  
    41.   AssembleTransactionProcessor txProcessor;
    42.  
    43.   @PostConstruct
    44.   public void init() throws Exception {
    45.     this.txProcessor = TransactionProcessorFactory.createAssembleTransactionProcessor(this.client, this.client.getCryptoSuite().getCryptoKeyPair());
    46.   }
    47.  
    48.   public TransactionResponse issue(AssetIssueInputBO input) throws Exception {
    49.     return this.txProcessor.sendTransactionAndGetResponse(this.address, ABI, "issue", input.toArgs());
    50.   }
    51.  
    52.   public TransactionResponse send(AssetSendInputBO input) throws Exception {
    53.     return this.txProcessor.sendTransactionAndGetResponse(this.address, ABI, "send", input.toArgs());
    54.   }
    55.  
    56.   public CallResponse balances(AssetBalancesInputBO input) throws Exception {
    57.     return this.txProcessor.sendCall(this.client.getCryptoSuite().getCryptoKeyPair().getAddress(), this.address, ABI, "balances", input.toArgs());
    58.   }
    59.  
    60.   public CallResponse issuer() throws Exception {
    61.     return this.txProcessor.sendCall(this.client.getCryptoSuite().getCryptoKeyPair().getAddress(), this.address, ABI, "issuer", Arrays.asList());
    62.   }
    63. }

    AssertService就是webase-front遵循业务层规则，生成的基于fisco-sdk封装的service类。通过这个service类，我们能与合约进行交互。

    看代码，我们都是调用了这个 AssembleTransactionProcessor对象的上方法，

    1.调用合约函数，是调用了这个方法。

    方法参数为: 调用函数的合约地址、合约abi、被调用合约函数的函数名、函数参数列表

    2.获取状态变量，是调用这个方法。

    方法参数为：调用者的地址、调用函数的合约地址、合约abi、被调用合约函数的函数名、函数参数列表

     

     raw

    Asset

    1. package org.example.demo.raw;
    2.  
    3. import java.math.BigInteger;
    4. import java.util.ArrayList;
    5. import java.util.Arrays;
    6. import java.util.Collections;
    7. import java.util.List;
    8. import org.fisco.bcos.sdk.abi.FunctionReturnDecoder;
    9. import org.fisco.bcos.sdk.abi.TypeReference;
    10. import org.fisco.bcos.sdk.abi.datatypes.Address;
    11. import org.fisco.bcos.sdk.abi.datatypes.Event;
    12. import org.fisco.bcos.sdk.abi.datatypes.Function;
    13. import org.fisco.bcos.sdk.abi.datatypes.Type;
    14. import org.fisco.bcos.sdk.abi.datatypes.generated.Uint256;
    15. import org.fisco.bcos.sdk.abi.datatypes.generated.tuples.generated.Tuple2;
    16. import org.fisco.bcos.sdk.client.Client;
    17. import org.fisco.bcos.sdk.contract.Contract;
    18. import org.fisco.bcos.sdk.contract.precompiled.crud.TableCRUDService;
    19. import org.fisco.bcos.sdk.crypto.CryptoSuite;
    20. import org.fisco.bcos.sdk.crypto.keypair.CryptoKeyPair;
    21. import org.fisco.bcos.sdk.eventsub.EventCallback;
    22. import org.fisco.bcos.sdk.model.CryptoType;
    23. import org.fisco.bcos.sdk.model.TransactionReceipt;
    24. import org.fisco.bcos.sdk.model.callback.TransactionCallback;
    25. import org.fisco.bcos.sdk.transaction.model.exception.ContractException;
    26.  
    27. /**
    28.  * 这里就是我们能跟区块链系统中的合约对应交互的java类
    29.  * 发送交易 获取凭证
    30.  *
    31.  * 这两个最终执行逻辑是同一个类上的不同方法
    32.  */
    33. @SuppressWarnings("unchecked")
    34. public class Asset extends Contract {
    35.     public static final String[] BINARY_ARRAY = {"608060405234801561001057600080fd5b50336000806101000a81548173ffffffffffffffffffffffffffffffffffffffff021916908373ffffffffffffffffffffffffffffffffffffffff16021790555061044f806100606000396000f300608060405260043610610062576000357c0100000000000000000000000000000000000000000000000000000000900463ffffffff1680631d1438481461006757806327e235e3146100be578063867904b414610115578063d0679d3414610162575b600080fd5b34801561007357600080fd5b5061007c6101af565b604051808273ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff16815260200191505060405180910390f35b3480156100ca57600080fd5b506100ff600480360381019080803573ffffffffffffffffffffffffffffffffffffffff1690602001909291905050506101d4565b6040518082815260200191505060405180910390f35b34801561012157600080fd5b50610160600480360381019080803573ffffffffffffffffffffffffffffffffffffffff169060200190929190803590602001909291905050506101ec565b005b34801561016e57600080fd5b506101ad600480360381019080803573ffffffffffffffffffffffffffffffffffffffff16906020019092919080359060200190929190505050610299565b005b6000809054906101000a900473ffffffffffffffffffffffffffffffffffffffff1681565b60016020528060005260406000206000915090505481565b6000809054906101000a900473ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff163373ffffffffffffffffffffffffffffffffffffffff1614151561024757610295565b80600160008473ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff168152602001908152602001600020600082825401925050819055505b5050565b80600160003373ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff1681526020019081526020016000205410156102e55761041f565b80600160003373ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff1681526020019081526020016000206000828254039250508190555080600160008473ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff168152602001908152602001600020600082825401925050819055507f3990db2d31862302a685e8086b5755072a6e2b5b780af1ee81ece35ee3cd3345338383604051808473ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff1681526020018373ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff168152602001828152602001935050505060405180910390a15b50505600a165627a7a723058204e0edbb0e9bfd782dfaee2a435005414f5f84d50f4ead01144060672399fe6720029"};
    36.  
    37.     public static final String BINARY = org.fisco.bcos.sdk.utils.StringUtils.joinAll("", BINARY_ARRAY);
    38.  
    39.     public static final String[] SM_BINARY_ARRAY = {};
    40.  
    41.     public static final String SM_BINARY = org.fisco.bcos.sdk.utils.StringUtils.joinAll("", SM_BINARY_ARRAY);
    42.  
    43.     public static final String[] ABI_ARRAY = {"[{\"constant\":true,\"inputs\":[],\"name\":\"issuer\",\"outputs\":[{\"name\":\"\",\"type\":\"address\"}],\"payable\":false,\"stateMutability\":\"view\",\"type\":\"function\"},{\"constant\":true,\"inputs\":[{\"name\":\"\",\"type\":\"address\"}],\"name\":\"balances\",\"outputs\":[{\"name\":\"\",\"type\":\"uint256\"}],\"payable\":false,\"stateMutability\":\"view\",\"type\":\"function\"},{\"constant\":false,\"inputs\":[{\"name\":\"receiver\",\"type\":\"address\"},{\"name\":\"amount\",\"type\":\"uint256\"}],\"name\":\"issue\",\"outputs\":[],\"payable\":false,\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"constant\":false,\"inputs\":[{\"name\":\"receiver\",\"type\":\"address\"},{\"name\":\"amount\",\"type\":\"uint256\"}],\"name\":\"send\",\"outputs\":[],\"payable\":false,\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[],\"payable\":false,\"stateMutability\":\"nonpayable\",\"type\":\"constructor\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":false,\"name\":\"from\",\"type\":\"address\"},{\"indexed\":false,\"name\":\"to\",\"type\":\"address\"},{\"indexed\":false,\"name\":\"amount\",\"type\":\"uint256\"}],\"name\":\"Sent\",\"type\":\"event\"}]"};
    44.  
    45.     public static final String ABI = org.fisco.bcos.sdk.utils.StringUtils.joinAll("", ABI_ARRAY);
    46.  
    47.     // 调用合约对应的函数名 和状态变量名
    48.     public static final String FUNC_ISSUER = "issuer";
    49.  
    50.     public static final String FUNC_BALANCES = "balances";
    51.  
    52.     public static final String FUNC_ISSUE = "issue";
    53.  
    54.     public static final String FUNC_SEND = "send";
    55.  
    56.     public static final Event SENT_EVENT = new Event("Sent", 
    57.             Arrays.>asList(new TypeReference
      () {}, new TypeReference
      () {}, new TypeReference() {}));
    58.  
    59.  
    60.     /**
    61.      * 下面 load函数本质上和这个一样都是根据现有合约地址加载，以调用
    62.      * @param contractAddress
    63.      * @param client
    64.      * @param credential
    65.      */
    66.     protected Asset(String contractAddress, Client client, CryptoKeyPair credential) {
    67.         super(getBinary(client.getCryptoSuite()), contractAddress, client, credential);
    68.     }
    69.  
    70.     public static String getBinary(CryptoSuite cryptoSuite) {
    71.         return (cryptoSuite.getCryptoTypeConfig() == CryptoType.ECDSA_TYPE ? BINARY : SM_BINARY);
    72.     }
    73.  
    74.     public String issuer() throws ContractException {
    75.         final Function function = new Function(FUNC_ISSUER, 
    76.                 Arrays.asList(), 
    77.                 Arrays.>asList(new TypeReference
      () {}));
    78.         return executeCallWithSingleValueReturn(function, String.class);
    79.     }
    80.  
    81.     public BigInteger balances(String param0) throws ContractException {
    82.         final Function function = new Function(FUNC_BALANCES, 
    83.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(param0)), 
    84.                 Arrays.>asList(new TypeReference() {}));
    85.         return executeCallWithSingleValueReturn(function, BigInteger.class);
    86.     }
    87.  
    88.     /**
    89.      * 无回调函数的对应和合约调用
    90.      * 
    91.      * @param receiver
    92.      * @param amount
    93.      * @return  TransactionReceipt 交易凭证
    94.      */
    95.     public TransactionReceipt issue(String receiver, BigInteger amount) {
    96.         final Function function = new Function(
    97.                 FUNC_ISSUE, 
    98.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    99.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    100.                 Collections.>emptyList());
    101.         return executeTransaction(function);
    102.     }
    103.  
    104.     /**
    105.      * 调用合约函数，并传入一个回调函数
    106.      *
    107.      * @param receiver
    108.      * @param amount
    109.      * @param callback
    110.      */
    111.     public void issue(String receiver, BigInteger amount, TransactionCallback callback) {
    112.         final Function function = new Function(
    113.                 FUNC_ISSUE, 
    114.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    115.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    116.                 Collections.>emptyList());
    117.                 asyncExecuteTransaction(function, callback);
    118.     }
    119.  
    120.     /**
    121.      * 获取Issue合约函数的交易签名
    122.      * @param receiver
    123.      * @param amount
    124.      * @return
    125.      */
    126.     public String getSignedTransactionForIssue(String receiver, BigInteger amount) {
    127.         final Function function = new Function(
    128.                 FUNC_ISSUE, 
    129.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    130.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    131.                 Collections.>emptyList());
    132.         return createSignedTransaction(function);
    133.     }
    134.  
    135.  
    136.     /**
    137.      * 获取 IssurInpt输入的参数
    138.      * @param transactionReceipt
    139.      * @return 元组(封装输入的数据)
    140.      */
    141.     public Tuple2 getIssueInput(TransactionReceipt transactionReceipt) {
    142.         String data = transactionReceipt.getInput().substring(10);
    143.         final Function function = new Function(FUNC_ISSUE, 
    144.                 Arrays.asList(), 
    145.                 Arrays.>asList(new TypeReference
      () {}, new TypeReference() {}));
    146.         List results = FunctionReturnDecoder.decode(data, function.getOutputParameters());
    147.  
    148.         return new Tuple2(
    149.  
    150.                 (String) results.get(0).getValue(), 
    151.                 (BigInteger) results.get(1).getValue()
    152.                 );
    153.     }
    154.  
    155.  
    156.  
    157.     public TransactionReceipt send(String receiver, BigInteger amount) {
    158.         final Function function = new Function(
    159.                 FUNC_SEND, 
    160.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    161.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    162.                 Collections.>emptyList());
    163.         return executeTransaction(function);
    164.     }
    165.  
    166.     public void send(String receiver, BigInteger amount, TransactionCallback callback) {
    167.         final Function function = new Function(
    168.                 FUNC_SEND, 
    169.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    170.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    171.                 Collections.>emptyList());
    172.                 asyncExecuteTransaction(function, callback);
    173.     }
    174.  
    175.     public String getSignedTransactionForSend(String receiver, BigInteger amount) {
    176.         final Function function = new Function(
    177.                 FUNC_SEND, 
    178.                 Arrays.asList(new org.fisco.bcos.sdk.abi.datatypes.Address(receiver), 
    179.                 new org.fisco.bcos.sdk.abi.datatypes.generated.Uint256(amount)), 
    180.                 Collections.>emptyList());
    181.         return createSignedTransaction(function);
    182.     }
    183.  
    184.     public Tuple2 getSendInput(TransactionReceipt transactionReceipt) {
    185.         String data = transactionReceipt.getInput().substring(10);
    186.         final Function function = new Function(FUNC_SEND, 
    187.                 Arrays.asList(), 
    188.                 Arrays.>asList(new TypeReference
      () {}, new TypeReference() {}));
    189.         List results = FunctionReturnDecoder.decode(data, function.getOutputParameters());
    190.         return new Tuple2(
    191.  
    192.                 (String) results.get(0).getValue(), 
    193.                 (BigInteger) results.get(1).getValue()
    194.                 );
    195.     }
    196.  
    197.     public List getSentEvents(TransactionReceipt transactionReceipt) {
    198.         List valueList = extractEventParametersWithLog(SENT_EVENT, transactionReceipt);
    199.         ArrayList responses = new ArrayList(valueList.size());
    200.         for (Contract.EventValuesWithLog eventValues : valueList) {
    201.             SentEventResponse typedResponse = new SentEventResponse();
    202.             typedResponse.log = eventValues.getLog();
    203.             typedResponse.from = (String) eventValues.getNonIndexedValues().get(0).getValue();
    204.             typedResponse.to = (String) eventValues.getNonIndexedValues().get(1).getValue();
    205.             typedResponse.amount = (BigInteger) eventValues.getNonIndexedValues().get(2).getValue();
    206.             responses.add(typedResponse);
    207.         }
    208.         return responses;
    209.     }
    210.  
    211.     public void subscribeSentEvent(String fromBlock, String toBlock, List otherTopics, EventCallback callback) {
    212.         String topic0 = eventEncoder.encode(SENT_EVENT);
    213.         subscribeEvent(ABI,BINARY,topic0,fromBlock,toBlock,otherTopics,callback);
    214.     }
    215.  
    216.     public void subscribeSentEvent(EventCallback callback) {
    217.         String topic0 = eventEncoder.encode(SENT_EVENT);
    218.         subscribeEvent(ABI,BINARY,topic0,callback);
    219.     }
    220.     /**
    221.      * 加载已有的合约地址，返回一个已有的Contract对象
    222.      * @param contractAddress
    223.      * @param client
    224.      * @param credential
    225.      * @return
    226.      */
    227.     public static Asset load(String contractAddress, Client client, CryptoKeyPair credential) {
    228.         return new Asset(contractAddress, client, credential);
    229.     }
    230.  
    231.     /**
    232.      * 通过此方法，我们可以部署合约,产生一个新的Contract对象
    233.      * @param client
    234.      * @param credential
    235.      * @return
    236.      * @throws ContractException
    237.      */
    238.     public static Asset deploy(Client client, CryptoKeyPair credential) throws ContractException {
    239.         return deploy(Asset.class, client, credential, getBinary(client.getCryptoSuite()), "");
    240.     }
    241.  
    242.     public static class SentEventResponse {
    243.         public TransactionReceipt.Logs log;
    244.  
    245.         public String from;
    246.  
    247.         public String to;
    248.  
    249.         public BigInteger amount;
    250.     }
    251. }

    其实对比上述AssetService和Asset上封装调用的方法，发现最终都是调用一类对象上的不同方法。因此，看看就可以了。

    AssembleTransactionProcessor 是AssetService层封装调用的。

    TransactionProcessor 是Aseet层封装调用的。

    abi、bin、conf

    • abi:存放合约abi的目录。定义外部调用合约的一种规则，本质上就是json文件，通过他，外部能与合约进行交互。
    • bin:bin文件存放目录。合约编译之后，形成的二进制文件、我们部署合约需要用到他。
    • conf: 存放fisco证书的目录。

    测试文件

    1. package org.example.demo;
    2.  
    3.  
    4.  
    5.  
    6.  
    7. import org.example.demo.model.bo.AssetBalancesInputBO;
    8. import org.example.demo.model.bo.AssetIssueInputBO;
    9. import org.example.demo.model.bo.AssetSendInputBO;
    10. import org.example.demo.raw.Asset;
    11. import org.example.demo.service.AssetService;
    12. import org.fisco.bcos.sdk.abi.datatypes.generated.tuples.generated.Tuple2;
    13. import org.fisco.bcos.sdk.client.Client;
    14. import org.fisco.bcos.sdk.crypto.keypair.CryptoKeyPair;
    15. import org.fisco.bcos.sdk.model.TransactionReceipt;
    16. import org.fisco.bcos.sdk.model.callback.TransactionCallback;
    17. import org.fisco.bcos.sdk.transaction.model.dto.CallResponse;
    18. import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
    19. import org.fisco.bcos.sdk.transaction.model.exception.ContractException;
    20. import org.junit.jupiter.api.Test;
    21. import org.springframework.beans.factory.annotation.Autowired;
    22. import org.springframework.boot.test.context.SpringBootTest;
    23.  
    24. import java.math.BigInteger;
    25.  
    26. @SpringBootTest
    27. public class AssetTest {
    28.  
    29.    @Autowired
    30.    private AssetService assetService;
    31.  
    32.     @Test
    33.     public void testAssetService() throws Exception {
    34.         String testAddress1 = "0xb537616a39a710d7590716c4422977953518c555";
    35.         String testAddress2 = "0x7700375543650bd19b716bb2a1d5bf609177ba39";
    36.         // 初始化
    37.         assetService.init();
    38.         // 调用issue
    39.         AssetIssueInputBO input = new AssetIssueInputBO();
    40.         input.setReceiver(testAddress1);
    41.         input.setAmount(new BigInteger("2"));
    42.         TransactionResponse issue = assetService.issue(input);
    43.         System.out.println(issue.getReturnMessage());
    44.         // 调用send
    45.         AssetSendInputBO send = new AssetSendInputBO();
    46.         send.setAmount(new BigInteger("1"));
    47.         send.setReceiver(testAddress2);
    48.         TransactionResponse send1 = assetService.send(send);
    49.         System.out.println(send1.getReturnMessage());
    50.  
    51.         // 调用balances
    52.         AssetBalancesInputBO balancesBo = new AssetBalancesInputBO();
    53.         balancesBo.setArg0("0xb537616a39a710d7590716c4422977953518c555"); // 因为balances是一个map,因此我们需要传入一个用户地址,用来获取balance
    54.         CallResponse balances = assetService.balances(balancesBo);
    55.         System.out.println(1);
    56.  
    57.  
    58.  
    59.     }
    60.  
    61.     @Autowired
    62.     private Client client;
    63.  
    64.     @Test
    65.     public void testAsset() throws ContractException {
    66.         String receiver = "0x7700375543650bd19b716bb2a1d5bf609177ba39";
    67.         BigInteger amount = new BigInteger("2");
    68.  
    69.         CryptoKeyPair cryptoKeyPair = client.getCryptoSuite().getCryptoKeyPair();
    70.         // 1.部署新合约
    71.         Asset newInstance = Asset.deploy(client, cryptoKeyPair);
    72.         // 2.实现TransactionCallback类
    73.         TransactionCallback transactionCallback = new TransactionCallback() { //
    74.             @Override
    75.             // 这代码有问题，反正成功调用，这代码就是不调用
    76.             public void onResponse(TransactionReceipt receipt) {
    77.                 System.out.println("我被调用了");
    78.  
    79. //                String newAddress = receipt.getContractAddress();
    80. //                Asset load = Asset.load(newAddress, client, cryptoKeyPair);// 加载返回新合约的地址
    81. //                TransactionReceipt issue = load.issue(receiver, amount);
    82.             }
    83.         };
    84.         // 3.调用issue方法
    85.        newInstance.issue(receiver, amount,transactionCallback);
    86.        System.out.println(1);
    87.         TransactionReceipt transactionReceipt = newInstance.issue(receiver, amount);
    88.         // 4.获取issue方法的输入参数
    89.         Tuple2 issueInput = newInstance.getIssueInput(transactionReceipt);
    90.  
    91.  
    92.     }
    93.  
    94. }

  • 相关阅读:
    洛谷 P4956 [COCI2017-2018#6] Davor
    室分知识点整理版
    基于C#和OpenVINO在英特尔独立显卡上部署PP-TinyPose模型
    原装芯片现货，价格优惠，实单可谈
    科研Tetrazine-PEG-valine 四嗪-聚乙二醇-缬氨酸、色氨酸、鸟氨酸、精氨酸
    从阿里、头条面试回来，面试官最喜欢问的 Jvm 和 Redis 你了解多少？
    HTML+CSS详细知识点复习（上）
    ABP集成SqlSugar
    React16.8新增特性Hooks--概念理解
    HTTP响应详解
  • 原文地址：https://blog.csdn.net/Qhx20040819/article/details/133930422