以太坊>> fabric-sdk-java-commons>> 返回
项目作者： hooj0

项目描述 ：
:twisted_rightwards_arrows: Hyperledger fabric java sdk assembly of public, core functional methods, providing further calls to other frameworks.
高级语言： Java
项目地址: git://github.com/hooj0/fabric-sdk-java-commons.git
创建时间： 2018-07-21T09:33:30Z
项目社区：https://github.com/hooj0/fabric-sdk-java-commons
开源协议：MIT License
下载


fabric sdk java commons framework

:twisted_rightwards_arrows: Hyperledger fabric java sdk assembly of public, core functional methods, providing further calls to other frameworks.

发布

准备

fabric sdk java commons framework 使用 fabric-sdk-java 的 1.3 版本。

1、基本配置

1.1、添加 Chaincode 必要的配置资源

在项目文件夹中添加目录 /fabric-sdk-commons/src/test/fixture/integration，目录中增加资源配置。必须了解 end-to-end sample 实例的运行方式，这里不增加额外的赘述。

1.2、添加 fabric区块链网络链接配置

根据自己的需要可以适当的修改配置内容，这里的配置依赖上面配置资源/fabric-sdk-commons/src/test/fixture/integration。配置文件位置 fabric-sdk-commons/src/test/resources/fabric-chaincode.properties。
内容如下：

  1. #@changelog properties file fabric configuration
  2. #Sat Jul 28 20:10:31 CST 2018
  3. # 区块链网络版本
  4. fabric.network.configtx.version=v1.0
  6. # 用户 & 密码
  7. hyperledger.fabric.sdk.commons.network.ca.admin.name=admin
  8. hyperledger.fabric.sdk.commons.network.ca.admin.passwd=adminpw
  9. hyperledger.fabric.sdk.commons.network.orgs.member.users=user1
  11. hyperledger.fabric.sdk.commons.network.tls.enable=false
  13. # 公共的根目录
  14. hyperledger.fabric.sdk.commons.config.root.path=src/test/fixture/integration
  15. # peer & order 证书配置
  16. hyperledger.fabric.sdk.commons.crypto.channel.config.root.path=/e2e-2Orgs
  17. # channel & block 配置
  18. hyperledger.fabric.sdk.commons.channel.artifacts.root.path=/channel-artifacts
  19. # Chaincode source code 目录
  20. #hyperledger.fabric.sdk.commons.chaincode.source.code.root.path=/gocc/sample_11
  21. hyperledger.fabric.sdk.commons.chaincode.source.code.root.path=/gocc/sample1
  22. # 背书配置
  23. hyperledger.fabric.sdk.commons.endorsement.policy.file.path=chaincode-endorsement-policy.yaml
  24. # 网络配置文件所在目录
  25. hyperledger.fabric.sdk.commons.network.config.root.path=network_configs

1.3、添加 Key Value 持久化存储配置

持久化缓存配置文件 /fabric-sdk-commons/fabric-kv-store.properties，存储通道或用户的缓存信息，方便下次直接使用而不用重复创建用户和通道。

2、扩展配置

fabric sdk java commons框架支持自定义 FabricConfiguration 和 FabricKeyValueStore 的配置。如果需要自定义扩展配置，需要实现这两个特定的接口。然后在使用的时候传入自定义实现的实例即可。

  1. public ChaincodeDeployTemplate(String channelName, String orgName, FabricConfiguration config, FabricKeyValueStore store) {
  2.     super(channelName, orgName, config, store, ChaincodeDeployTemplate.class);
  3.     this.init();
  4. }

2.1、自定义 config 配置

FabricConfiguration支持两种网络链接配置方式，一种是 properties 配置文件的实现方式，参考代码：FabricPropertiesConfiguration.java，另一种则是 class 内存的配置方式，参考代码：FabricClassConfiguration.java。
可以在创建 ChaincodeDeployTemplate 或 ChaincodeTransactionTemplate 模板实例的时候，传入自己想要的配置模式。

  • properties config 配置的模板

    以下是 properties config 配置的模板，可以在模板的基础上修改配置定制

  1. #@changelog properties file fabric configuration
  2. #Sat Jul 28 20:10:31 CST 2018
  3. fabric.network.configtx.version=v1.1
  5. hyperledger.fabric.sdk.commons.network.ca.admin.name=admin
  6. hyperledger.fabric.sdk.commons.network.ca.admin.passwd=adminpw
  7. hyperledger.fabric.sdk.commons.network.orgs.member.users=user1
  9. hyperledger.fabric.sdk.commons.invoke.wait.time=10
  10. hyperledger.fabric.sdk.commons.deploy.wait.time=100
  11. hyperledger.fabric.sdk.commons.proposal.wait.time=1000
  13. hyperledger.fabric.sdk.commons.network.tls.enable=false
  14. hyperledger.fabric.sdk.commons.network.domain=example.com
  15. hyperledger.fabric.sdk.commons.configtxlater.url=http\://192.168.8.8\:7059
  17. hyperledger.fabric.sdk.commons.config.root.path=src/test/fixture/integration
  18. hyperledger.fabric.sdk.commons.crypto.channel.config.root.path=/e2e-2Orgs
  19. hyperledger.fabric.sdk.commons.channel.artifacts.root.path=/channel-artifacts
  20. hyperledger.fabric.sdk.commons.chaincode.source.code.root.path=/gocc/sample11
  21. hyperledger.fabric.sdk.commons.endorsement.policy.file.path=chaincode-endorsement-policy.yaml
  22. hyperledger.fabric.sdk.commons.network.config.root.path=network_configs
  24. hyperledger.fabric.sdk.commons.network.org.peerOrg1.mspid=Org1MSP
  25. hyperledger.fabric.sdk.commons.network.org.peerOrg1.caName=ca0
  26. hyperledger.fabric.sdk.commons.network.org.peerOrg1.domname=org1.example.com
  27. hyperledger.fabric.sdk.commons.network.org.peerOrg1.ca_location=http\://192.168.8.8\:7054
  28. hyperledger.fabric.sdk.commons.network.org.peerOrg1.orderer_locations=orderer.example.com@grpc\://192.168.8.8\:7050
  29. hyperledger.fabric.sdk.commons.network.org.peerOrg1.peer_locations=peer0.org1.example.com@grpc\://192.168.8.8\:7051, peer1.org1.example.com@grpc\://192.168.8.8\:7056
  30. hyperledger.fabric.sdk.commons.network.org.peerOrg1.eventhub_locations=peer0.org1.example.com@grpc\://192.168.8.8\:7053, peer1.org1.example.com@grpc\://192.168.8.8\:7058
  33. hyperledger.fabric.sdk.commons.network.org.peerOrg2.mspid=Org2MSP
  34. hyperledger.fabric.sdk.commons.network.org.peerOrg2.domname=org2.example.com
  35. hyperledger.fabric.sdk.commons.network.org.peerOrg2.ca_location=http\://192.168.8.8\:8054
  36. hyperledger.fabric.sdk.commons.network.org.peerOrg2.orderer_locations=orderer.example.com@grpc\://192.168.8.8\:7050
  37. hyperledger.fabric.sdk.commons.network.org.peerOrg2.peer_locations=peer0.org2.example.com@grpc\://192.168.8.8\:8051, peer1.org2.example.com@grpc\://192.168.8.8\:8056
  38. hyperledger.fabric.sdk.commons.network.org.peerOrg2.eventhub_locations=peer0.org2.example.com@grpc\://192.168.8.8\:8053, peer1.org2.example.com@grpc\://192.168.8.8\:8058

  • class config 配置的模板

    以下是 class config 配置的模板，可以调用FabricClassConfiguration.getInstance()修改配置定制

  1. FabricClassConfiguration config = FabricClassConfiguration.getInstance();
  3. String orgName = "peerOrg1";
  5. config.setNetworkDomain("example.com");
  7. config.setMspId(orgName, "Org1MSP");
  8. config.setOrgDomain(orgName, "org1." + config.getNetworkDomain());
  9. config.setCaName(orgName, "ca0");
  10. config.setCaLocation(orgName, "http://" + config.getFabricNetworkHost() + ":7054");
  11. config.setOrdererLocation(orgName, "orderer.example.com@grpc://" + config.getFabricNetworkHost() + ":7050");
  12. config.setPeerLocation(orgName, "peer0.org1.example.com@grpc://" + config.getFabricNetworkHost() + ":7051, peer1.org1.example.com@grpc://" + config.getFabricNetworkHost() + ":7056");
  13. config.setEventHubLocation(orgName, "peer0.org1.example.com@grpc://" + config.getFabricNetworkHost() + ":7053, peer1.org1.example.com@grpc://" + config.getFabricNetworkHost() + ":7058");
  15. orgName = "peerOrg2";
  16. config.setMspId(orgName, "Org2MSP");
  17. config.setOrgDomain(orgName, "org2." + config.getNetworkDomain());
  18. // config.setCaName(orgName, "ca1");
  19. config.setCaLocation(orgName, "http://" + config.getFabricNetworkHost() + ":8054");
  20. config.setOrdererLocation(orgName, "orderer.example.com@grpc://" + config.getFabricNetworkHost() + ":7050");
  21. config.setPeerLocation(orgName, "peer0.org2.example.com@grpc://" + config.getFabricNetworkHost() + ":8051, peer1.org2.example.com@grpc://" + config.getFabricNetworkHost() + ":8056");
  22. config.setEventHubLocation(orgName, "peer0.org2.example.com@grpc://" + config.getFabricNetworkHost() + ":8053, peer1.org2.example.com@grpc://" + config.getFabricNetworkHost() + ":8058");
  25. config.settingPropertyValue(FabricConfigurationPropertyKey.FABRIC_CONFIGTX_VERSION, "v1.1");
  27. config.settingPropertyValue(FabricConfigurationPropertyKey.CONFIG_TXLATER_URL, "http://" + config.getFabricNetworkHost() + ":7059");
  29. config.settingPropertyValue(FabricConfigurationPropertyKey.INVOKE_WAIT_TIME, "10");
  30. config.settingPropertyValue(FabricConfigurationPropertyKey.DEPLOY_WAIT_TIME, "100");
  31. config.settingPropertyValue(FabricConfigurationPropertyKey.PROPOSAL_WAIT_TIME, "1000");
  33. config.settingPropertyValue(FabricConfigurationPropertyKey.NETWORK_TLS_ENABLED, "true");
  35. config.settingPropertyValue(FabricConfigurationPropertyKey.COMMON_CONFIG_ROOT_PATH, "src/test/fixture/integration");
  36. config.settingPropertyValue(FabricConfigurationPropertyKey.CRYPTO_CHANNEL_CONFIG_ROOT_PATH, "/e2e-2Orgs");
  37. config.settingPropertyValue(FabricConfigurationPropertyKey.CHAINCODE_SOURCE_ROOT_PATH, "/gocc/sample11");
  38. config.settingPropertyValue(FabricConfigurationPropertyKey.CHANNEL_ARTIFACTS_ROOT_PATH, "/channel-artifacts");
  39. config.settingPropertyValue(FabricConfigurationPropertyKey.ENDORSEMENT_POLICY_FILE_PATH, "chaincode-endorsement-policy.yaml");
  40. config.settingPropertyValue(FabricConfigurationPropertyKey.NETWORK_CONFIG_ROOT_PATH, "network_configs");
  42. config.settingPropertyValue(FabricConfigurationPropertyKey.NETWORK_CA_ADMIN_NAME, "admin");
  43. config.settingPropertyValue(FabricConfigurationPropertyKey.NETWORK_CA_ADMIN_PASSWD, "adminpw");
  44. config.settingPropertyValue(FabricConfigurationPropertyKey.NETWORK_ORGS_MEMBER_USERS, "user1");

2.2、自定义 store 配置

FabricKeyValueStore是KV持久化缓存配置，KV 也支持两种配置方式，一种是 FileSystemKeyValueStore 文件系统的配置方式，另一种是 MemoryKeyValueStore 内存系统的配置方式。如果有必要可以实现自己的持久化缓存存储，具体可以实现接口 io.github.hooj0.fabric.sdk.commons.store.FabricKeyValueStore，同样可以在创建 ChaincodeDeployTemplate 或 ChaincodeTransactionTemplate 模板实例的时候，传入自己想要的配置模式。

3、部署 Chaincode

公共的代码常量，通道和对等节点以及 ChaincodeId

  1. public class BasedTemplateTest {
  3.     final static String foo = "mychannel";
  4.     final static String bar = "mychannel2";
  5.     final static String org1 = "peerOrg1";
  6.     final static String org2 = "peerOrg2";
  8.     static String CHAIN_CODE_NAME = "example_cc_go";
  9.     static String CHAIN_CODE_PATH = "github.com/example_cc";
  10.     static String CHAIN_CODE_VERSION = "1";
  11.     static String CHAIN_CODE_VERSION_11 = "11";
  12.     static Type CHAIN_CODE_LANG = Type.GO_LANG;
  14.     ChaincodeID chaincodeID_1 = ChaincodeID.newBuilder().setName(CHAIN_CODE_NAME).setPath(CHAIN_CODE_PATH).setVersion(CHAIN_CODE_VERSION).build();
  15.     ChaincodeID chaincodeID_11 = ChaincodeID.newBuilder().setName(CHAIN_CODE_NAME).setPath(CHAIN_CODE_PATH).setVersion(CHAIN_CODE_VERSION_11).build();
  16.     ChaincodeID chaincodeID_11_2 = ChaincodeID.newBuilder().setName(CHAIN_CODE_NAME).setPath(CHAIN_CODE_PATH).setVersion("11.2").build();
  17. }

3.1、创建 Chaincode 部署模板类实例

  1. private ChaincodeDeployOperations operations;
  3. @Before
  4. public void setup() {
  5.     operations = new ChaincodeDeployTemplate(foo, org1, FabricPropertiesConfiguration.getInstance()); 
  7.     // 自定义 key value store 文件位置
  8.     //operations = new ChaincodeDeployTemplate(foo, org1, FabricClassConfiguration.getInstance(), new File("my-kv-store.properties")); 
  9.     // 使用 内存 key value store 文件位置
  10.     //operations = new ChaincodeDeployTemplate(foo, org1, FabricPropertiesConfiguration.getInstance(), new MemoryKeyValueStore()); 
  11. }

3.2、安装 Chaincode

传入必要的参数 chaincodeID 和 Chaincode 的文件路径，以及 chaincode 的类型

  1. @Test
  2. public void testInstallDeployTemplate() {
  4.     InstallOptions options = new InstallOptions();
  5.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  7.     String chaincodeSourceFile = operations.getConfig().getChaincodeRootPath();
  8.     operations.install(options, chaincodeSourceFile);
  9. }

3.3、实例化 Chaincode

实例化支持多种结果返回形式，以及多种参数签名发送。

  1. @Test
  2. public void testInstantiateDeployTemplate() {
  4.     InstantiateOptions options = new InstantiateOptions();
  5.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  6.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  8.     ResultSet rs = operations.instantiate(options, "init", "a", 200, "b", 300);
  9.     System.out.println("-------->>>>>>>" + rs);
  10. }
  12. @Test
  13. public void testInstantiate2DeployTemplate() {
  15.     InstantiateOptions options = new InstantiateOptions();
  17.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  18.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  20.     LinkedHashMap<String, Object> args = Maps.newLinkedHashMap();
  21.     args.put("a", 300);
  22.     args.put("b", 500);
  24.     ResultSet rs = operations.instantiate(options, "init", args);
  25.     System.out.println("-------->>>>>>>" + rs);
  26. }
  28. @Test
  29. public void testInstantiate3DeployTemplate() throws Exception {
  31.     InstantiateOptions options = new InstantiateOptions();
  33.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  34.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  36.     LinkedHashMap<String, Object> args = Maps.newLinkedHashMap();
  37.     args.put("a", 300);
  38.     args.put("b", 500);
  40.     CompletableFuture<TransactionEvent> future = operations.instantiateAsync(options, "init", args);
  41.     future.thenApply((BlockEvent.TransactionEvent transactionEvent) -> {
  43.         // 必须是有效交易事件
  44.         checkArgument(transactionEvent.isValid(), "没有签名的交易事件");
  45.         // 必须有签名
  46.         checkNotNull(transactionEvent.getSignature(), "没有签名的交易事件");
  47.         // 必须有交易区块事件发生
  48.         BlockEvent blockEvent = checkNotNull(transactionEvent.getBlockEvent(), "交易事件的区块事件对象为空");
  50.         try {
  51.             System.out.println("成功实例化Chaincode，本次实例化交易ID：" +  transactionEvent.getTransactionID());
  52.             System.out.println(transactionEvent.getChannelId());
  53.             checkArgument(StringUtils.equals(blockEvent.getChannelId(), operations.getChannel().getName()), "事件名称和对应通道名称不一致");
  55.             // 检查
  56.             if (!operations.checkInstantiatedChaincode(options.getChaincodeId())) {
  57.                 throw new AssertionError("chaincode 1 没有实例化");
  58.             }
  59.         } catch (Exception e) {
  60.             throw new RuntimeException(e);
  61.         }
  63.         return "success";
  64.     }).exceptionally(e -> {
  65.         if (e instanceof CompletionException && e.getCause() != null) {
  66.             e = e.getCause();
  67.         }
  69.         if (e instanceof TransactionEventException) {
  70.             BlockEvent.TransactionEvent te = ((TransactionEventException) e).getTransactionEvent();
  71.             if (te != null) {
  72.                 e.printStackTrace(System.err);
  73.                 fail(format("Transaction with txid %s failed. %s", te.getTransactionID(), e.getMessage()));
  74.             }
  75.         }
  77.         e.printStackTrace(System.err);
  78.         fail(format("Test failed with %s exception %s", e.getClass().getName(), e.getMessage()));
  80.         return null;
  81.     }).get(operations.getConfig().getTransactionWaitTime(), TimeUnit.SECONDS); 
  82. }
  84. @Test
  85. public void testInstantiate4DeployTemplate() {
  87.     InstantiateOptions options = new InstantiateOptions();
  89.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  90.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  92.     LinkedHashMap<String, Object> args = Maps.newLinkedHashMap();
  93.     args.put("a", 300);
  94.     args.put("b", 500);
  96.     TransactionEvent event = operations.instantiateFor(options, "init", args);
  97.     System.out.println("-------------->>>>>>>" + event);
  98. }

3.4、升级 Chaincode

升级后，每笔交易会发生在两个链码上。

  1. @Test
  2. public void testUpgradeDeployTemplate() throws Exception {
  4.     if (!operations.checkChaincode(chaincodeID_11, operations.getOrganization())) {
  5.         fail(chaincodeID_11 + " not install | instantiate.");
  6.     }
  8.     if (!operations.checkInstallChaincode(chaincodeID_11_2)) {
  9.         InstallOptions options = new InstallOptions();
  10.         options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  11.         options.setChaincodeUpgradeVersion("11.2");
  13.         operations.install(options, operations.getConfig().getChaincodeRootPath());
  14.     }
  16.     if (operations.checkInstallChaincode(chaincodeID_11_2) && !operations.checkInstantiatedChaincode(chaincodeID_11_2)) {
  17.         UpgradeOptions upgradeOptions = new UpgradeOptions();
  19.         upgradeOptions.setChaincodeId(chaincodeID_11_2).setChaincodeType(CHAIN_CODE_LANG);
  20.         upgradeOptions.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  22.         ResultSet rs = operations.upgrade(upgradeOptions, "init");
  23.         System.out.println("-------------->>>>>>>" + rs);
  24.     }
  25. }
  27. @Test
  28. public void testUpgrade2DeployTemplate() throws Exception {
  30.     UpgradeOptions options = new UpgradeOptions();
  32.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG).setChaincodeVersion("11.2");
  33.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  35.     InstallOptions installOptions = new InstallOptions().setChaincodeUpgradeVersion("11.2");
  36.     installOptions.setChaincodeId(options.getChaincodeId()).setChaincodeType(CHAIN_CODE_LANG);
  38.     String chaincodeSourceFile = operations.getConfig().getChaincodeRootPath();
  39.     if (!operations.checkInstallChaincode(installOptions.getChaincodeId())) {
  40.         operations.install(installOptions, chaincodeSourceFile);
  41.     }
  43.     CompletableFuture<TransactionEvent> future = operations.upgradeAsync(options, "init", "a", "100", "b", "100");
  44.     Object result = future.thenApply((TransactionEvent event) -> {
  46.         System.out.println(event.isValid());
  47.         System.out.println(event.getBlockEvent());
  48.         System.out.println(event.getChannelId());
  49.         System.out.println(event.getTimestamp());
  50.         System.out.println(event.getSignature());
  51.         System.out.println(event.getValidationCode());
  52.         System.out.println(event.getType());
  54.         return event.getTransactionID();
  55.     }).exceptionally(e -> {
  56.         e.printStackTrace();
  57.         return null;
  58.     }).get(10000, TimeUnit.MILLISECONDS);
  60.     System.out.println("-------------->>>>>>>" + result);
  61. }
  63. @Test
  64. public void testUpgrade3DeployTemplate() throws Exception {
  66.     UpgradeOptions options = new UpgradeOptions();
  68.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG).setChaincodeVersion("11.2");
  69.     options.setEndorsementPolicyFile(Paths.get(operations.getConfig().getEndorsementPolicyFilePath()).toFile());
  71.     InstallOptions installOptions = new InstallOptions().setChaincodeUpgradeVersion("11.2");
  72.     installOptions.setChaincodeId(options.getChaincodeId()).setChaincodeType(CHAIN_CODE_LANG);
  74.     String chaincodeSourceFile = operations.getConfig().getChaincodeRootPath();
  75.     if (!operations.checkInstallChaincode(installOptions.getChaincodeId())) {
  76.         operations.install(installOptions, chaincodeSourceFile);
  77.     }
  79.     TransactionEvent event = operations.upgradeFor(options, "init");
  81.     System.out.println("-------------->>>>>>>" + event);
  82. }

4、交易 Chaincode

交易是最常用的业务接口调用方式，一般交易分为查询交易和修改交易请求两种。

4.1、创建交易模板类 ChaincodeTransactionOperations

同样可以支持自定义传入 config 和 store 的实现

  1. private ChaincodeTransactionOperations operations;
  3. @Before
  4. public void setup() {
  5.     operations = new ChaincodeTransactionTemplate(foo, org1, FabricPropertiesConfiguration.getInstance()); 
  6.     //operations = new ChaincodeTransactionTemplate(foo, org1, FabricPropertiesConfiguration.getInstance(), new File("my-kv-store.properties")); 
  7.     //operations = new ChaincodeTransactionTemplate(foo, org1, FabricPropertiesConfiguration.getInstance(), new MemoryKeyValueStore()); 
  8. }

4.2、Chaincode invoke

执行交易执行3种不同方式的结果返回形式，普通的结果封装 ResultSet 和 异步线程模型结果 CompletableFuture<TransactionEvent> 以及 TransactionEvent 结果返回，适用于不同的业务场景需求。

  1. @Test
  2. public void testInvokeTransactionTemplate() {
  4.     InvokeOptions options = new InvokeOptions();
  6.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  8.     options.setClientUserContext(operations.getOrganization().getUser("user1"));
  10.     ResultSet rs = operations.invoke(options, "move", "a", "b", 20);
  11.     System.out.println(rs);
  13.     try {
  14.         TransactionEvent event = operations.getChannel().sendTransaction(rs.getResponses()).get();
  15.         System.out.println(event.isValid());
  16.         System.out.println(event.getBlockEvent());
  17.     } catch (InterruptedException | ExecutionException e) {
  18.         e.printStackTrace();
  19.     }
  20. }
  22. @Test
  23. public void testInvokeTransactionTemplate2() throws InterruptedException, ExecutionException, TimeoutException {
  25.     InvokeOptions options = new InvokeOptions();
  26.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  28.     options.setClientUserContext(operations.getOrganization().getUser("user1"));
  30.     CompletableFuture<TransactionEvent> future = operations.invokeAsync(options, "move", "b", "a", 3);
  31.     future.thenApply((BlockEvent.TransactionEvent transactionEvent) -> {
  33.         // 必须是有效交易事件
  34.         checkArgument(transactionEvent.isValid(), "没有签名的交易事件");
  35.         // 必须有签名
  36.         checkNotNull(transactionEvent.getSignature(), "没有签名的交易事件");
  37.         // 必须有交易区块事件发生
  38.         BlockEvent blockEvent = checkNotNull(transactionEvent.getBlockEvent(), "交易事件的区块事件对象为空");
  40.         try {
  41.             System.out.println("成功实例化Chaincode，本次实例化交易ID：" +  transactionEvent.getTransactionID());
  42.             System.out.println(transactionEvent.getChannelId());
  43.             checkArgument(StringUtils.equals(blockEvent.getChannelId(), operations.getChannel().getName()), "事件名称和对应通道名称不一致");
  44.         } catch (Exception e) {
  45.             throw new RuntimeException(e);
  46.         }
  48.         QueryOptions options2 = new QueryOptions();
  49.         options2.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  51.         options2.setProposalWaitTime(100000);
  52.         options2.setSpecificPeers(false);
  54.         //operations.instantiate("hoojo3");
  55.         options2.setClientUserContext(operations.getOrganization().getUser("hoojo5"));
  57.         String a = operations.query(options2, "query", "a");
  58.         String b = operations.query(options2, "query", "b");
  60.         System.out.println("a mount ---->" + a);
  61.         System.out.println("b mount ---->" + b);
  63.         return "success";
  64.     }).exceptionally(e -> {
  65.         if (e instanceof CompletionException && e.getCause() != null) {
  66.             e = e.getCause();
  67.         }
  69.         if (e instanceof TransactionEventException) {
  70.             BlockEvent.TransactionEvent te = ((TransactionEventException) e).getTransactionEvent();
  71.             if (te != null) {
  72.                 e.printStackTrace(System.err);
  73.                 fail(format("Transaction with txid %s failed. %s", te.getTransactionID(), e.getMessage()));
  74.             }
  75.         }
  77.         e.printStackTrace(System.err);
  78.         fail(format("Test failed with %s exception %s", e.getClass().getName(), e.getMessage()));
  80.         return null;
  81.     }).get(operations.getConfig().getTransactionWaitTime(), TimeUnit.SECONDS); 
  82. }
  84. @Test
  85. public void testInvokeTransactionTemplate3() {
  87.     InvokeOptions options = new InvokeOptions();
  88.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  90.     options.setClientUserContext(operations.getOrganization().getUser("user1"));
  92.     TransactionEvent event = operations.invokeFor(options, "move", "a", "b", 5);
  93.     System.out.println(event.getTransactionID());
  94.     System.out.println(event.getCreator().getId());
  95. }

4.3、Chaincode query

查询支持两种结果返回的方式，返回字符串和封装的结果集 ResultSet。

  1. @Test
  2. public void testQueryTransactionTemplate() {
  4.     QueryOptions options = new QueryOptions();
  5.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  7.     options.setProposalWaitTime(100000);
  8.     options.setSpecificPeers(false);
  10.     operations.instantiate("hoojo3");
  12.     options.setClientUserContext(operations.getOrganization().getUser("hoojo3"));
  13.     // options.setRequestUser(requestUser);
  15.     String rs = operations.query(options, "query", "a");
  16.     System.out.println(rs);
  17.     rs = operations.query(options, "query", "b");
  18.     System.out.println(rs);
  19. }
  21. @Test
  22. public void testQueryTransactionTemplate2() {
  24.     QueryOptions options = new QueryOptions();
  25.     options.setChaincodeId(chaincodeID_11).setChaincodeType(CHAIN_CODE_LANG);
  27.     operations.instantiate("hoojo3");
  28.     options.setClientUserContext(operations.getOrganization().getUser("user1"));
  29.     options.setRequestUser(operations.getOrganization().getUser("hoojo3"));
  31.     ResultSet rs = operations.queryFor(options, "query", "a");
  32.     System.out.println(rs);
  33. }

5、问题反馈

如果有任何疑问或交流的想法，欢迎在 issues 发布话题，我会及时跟进。