在 Hyperledger Fabric 1.0 从零开始（十二）——fabric-sdk-java应用 中我已经把官方sdk具体改良办法，即使用办法发出来了，所有的类及文件都是完整的，在文章的结尾也说明了用法主要都依赖于ChaincodeManager这个智能合约管理器，建议以单例的形式生成该对象。

 

鉴于新入门的朋友在实际运用上可能需要更加简单明了的方案，这里就把最直接的方案给出，具体是写了一个FabricManager管理器，这个管理器将会接管整个java sdk与peer节点服务器及orderer排序服务器的通讯过程，包括event等时间的拦截等等，但是这里还是给一个demo级的，具体实际运用需要大家根据自己的实际场景进行简单的修改和完善。

 

在此之前，请现将 Hyperledger Fabric 1.0 从零开始（十二）——fabric-sdk-java应用 这篇文章中的类及结构按照自己的需要结合到自己的项目中，确保不会报错。

然后我们开始编写FabricManager管理器，这个管理器包含两个简单部分，第一部分是项目配置，第二部分是调用方法。

 

项目配置

节点服务器设置

 

复制代码
 1     /**
 2      * 根据节点作用类型获取节点服务器配置
 3      * 
 4      * @param type
 5      *            服务器作用类型（1、执行；2、查询）
 6      * @return 节点服务器配置
 7      */
 8     private FabricConfig getConfig() {
 9         FabricConfig config = new FabricConfig();//创建配置
10         config.setOrderers(getOrderers());//设置排序服务器
11         config.setPeers(getPeers());//[]设置节点服务器对象
12         config.setChaincode(getChaincode("xxx","xxxcc", "github.com/hyperledger/fabric/chaincode/go/release/xxx", "1.0"));//设置智能合约对象
13         config.setCryptoConfigPath(getCryptoConfigPath());//设置crypto-config所在路径
14         return config;
15     }
复制代码

 

 

 

创建配置

 

 

FabricConfig.java类创建配置，在构造器里设置crypto-config所在路径，默认路径为src/main/resources/fabric/crypto-config/

1     public FabricConfig() {
2         // 默认channel-artifacts所在路径 /xxx/WEB-INF/classes/fabric/channel-artifacts/
3         channelArtifactsPath = getChannlePath() + "/channel-artifacts/";
4         // 默认crypto-config所在路径 /xxx/WEB-INF/classes/fabric/crypto-config/
5         cryptoConfigPath = getChannlePath() + "/crypto-config/";
6     }

如下图未知：

 

设置排序服务器

 

通过getOrderers()方法新建排序服务器，在由config.setOrderers()方法添加排序服务器到设置。

复制代码
1     private Orderers getOrderers() {
2         Orderers orderer = new Orderers();
3         orderer.setOrdererDomainName("example.com");//设置排序服务器所在的根域名
4         orderer.addOrderer("orderer0.example.com", "grpc://x.x.x.x");//新增排序服务器
5         orderer.addOrderer("orderer1.example.com", "grpc://x.x.x.xx");
6         orderer.addOrderer("orderer2.example.com", "grpc://x.x.x.xxx");
7         return orderer;
8     }
复制代码

排序服务器可以添加一个或多个，排序服务器的域名和排序服务器的访问地址按提供的文件填写。

 

 

设置节点服务器对象

 

通过getPeers ()方法新建节点服务器，在由config. setPeers ()方法添加节点服务器到设置。

复制代码
1     private Peers Peers() {
2         Peers peers = new Peers();
3         peers.setOrgName("XXX");//设置组织名称
4         peers.setOrgMSPID("XXXMSP");//组织名称+MSP
5         peers.setOrgDomainName("xxx.example.com");//设置组织根域名
6         peers.addPeer("peer1.xxx.example.com", "peer1.xxx.example.com", "grpc://x.x.x.x:7051", "grpc://x.x.x.x:7053", "http://x.x.x.x:7054");//添加排序服务器
7         return peers;
8     }
复制代码

组织名称、MSPID、组织根域名根据实际情况填写。

 

设置智能合约对象

通过getChaincode ()方法获取智能合约对象，在由config. setChaincode ()方法添加智能合约对象到设置。

复制代码
 1     private Chaincode getChaincode(String channelName, String chaincodeName, String chaincodePath, String chaincodeVersion) {
 2         Chaincode chaincode = new Chaincode();
 3         chaincode.setChannelName(channelName);//设置当前将要访问的智能合约所属频道名称
 4         chaincode.setChaincodeName(chaincodeName);//设置智能合约名称
 5         chaincode.setChaincodePath(chaincodePath);//设置智能合约安装路径
 6         chaincode.setChaincodeVersion(chaincodeVersion);//设置智能合约版本号
 7         chaincode.setInvokeWatiTime(100000);
 8         chaincode.setDeployWatiTime(120000);
 9         return chaincode;
10     }
复制代码

 

项目配置到这里基本就完成了，接下来是调用过程。

在述说调用过程之前，我把完整的代码粘贴出来，当然还是demo级的，但已经可以使用于生产了，如下：

复制代码
  1 package cn.xx.xxx.util;
  2 
  3 import java.io.File;
  4 import java.io.IOException;
  5 import java.security.NoSuchAlgorithmException;
  6 import java.security.NoSuchProviderException;
  7 import java.security.spec.InvalidKeySpecException;
  8 
  9 import org.hyperledger.fabric.sdk.exception.CryptoException;
 10 import org.hyperledger.fabric.sdk.exception.InvalidArgumentException;
 11 import org.hyperledger.fabric.sdk.exception.TransactionException;
 12 
 13 import cn.aberic.fabric.ChaincodeManager;
 14 import cn.aberic.fabric.FabricConfig;
 15 import cn.aberic.fabric.bean.Chaincode;
 16 import cn.aberic.fabric.bean.Orderers;
 17 import cn.aberic.fabric.bean.Peers;
 18 import lombok.extern.slf4j.Slf4j;
 19 
 20 @Slf4j
 21 public class FabricManager {
 22 
 23     private ChaincodeManager manager;
 24 
 25     private static FabricManager instance = null;
 26 
 27     public static FabricManager obtain()
 28             throws CryptoException, InvalidArgumentException, NoSuchAlgorithmException, NoSuchProviderException, InvalidKeySpecException, TransactionException, IOException {
 29         if (null == instance) {
 30             synchronized (FabricManager2.class) {
 31                 if (null == instance) {
 32                     instance = new FabricManager();
 33                 }
 34             }
 35         }
 36         return instance;
 37     }
 38 
 39     private FabricManager()
 40             throws CryptoException, InvalidArgumentException, NoSuchAlgorithmException, NoSuchProviderException, InvalidKeySpecException, TransactionException, IOException {
 41         manager = new ChaincodeManager(getConfig());
 42     }
 43 
 44     /**
 45      * 获取节点服务器管理器
 46      * 
 47      * @return 节点服务器管理器
 48      */
 49     public ChaincodeManager getManager() {
 50         return manager;
 51     }
 52 
 53     /**
 54      * 根据节点作用类型获取节点服务器配置
 55      * 
 56      * @param type
 57      *            服务器作用类型（1、执行；2、查询）
 58      * @return 节点服务器配置
 59      */
 60     private FabricConfig getConfig() {
 61         FabricConfig config = new FabricConfig();
 62         config.setOrderers(getOrderers());
 63         config.setPeers(getPeers());
 64         config.setChaincode(getChaincode("xxx", "xxxcc", "github.com/hyperledger/fabric/chaincode/go/release/xxx", "1.0"));
 65         config.setChannelArtifactsPath(getChannleArtifactsPath());
 66         config.setCryptoConfigPath(getCryptoConfigPath());
 67         return config;
 68     }
 69 
 70     private Orderers getOrderers() {
 71         Orderers orderer = new Orderers();
 72         orderer.setOrdererDomainName("example.com");
 73         orderer.addOrderer("orderer1.example.com", "grpc://x.x.x.x:7050");
 74         orderer.addOrderer("orderer0.example.com", "grpc://x.x.x.xx:7050");
 75         orderer.addOrderer("orderer2.example.com", "grpc://x.x.x.xxx:7050");
 76         return orderer;
 77     }
 78 
 79     /**
 80      * 获取节点服务器集
 81      * 
 82      * @return 节点服务器集
 83      */
 84     private Peers getPeers() {
 85         Peers peers = new Peers();
 86         peers.setOrgName("XXX");
 87         peers.setOrgMSPID("XXXMSP");
 88         peers.setOrgDomainName("xxx.example.com");
 89         peers.addPeer("peer1.xxx.example.com", "peer1.xxx.example.com", "grpc://x.x.x.x:7051", "grpc://x.x.x.x:7053", "http://x.x.x.x:7054");
 90         return peers;
 91     }
 92 
 93     /**
 94      * 获取智能合约
 95      * 
 96      * @param channelName
 97      *            频道名称
 98      * @param chaincodeName
 99      *            智能合约名称
100      * @param chaincodePath
101      *            智能合约路径
102      * @param chaincodeVersion
103      *            智能合约版本
104      * @return 智能合约
105      */
106     private Chaincode getChaincode(String channelName, String chaincodeName, String chaincodePath, String chaincodeVersion) {
107         Chaincode chaincode = new Chaincode();
108         chaincode.setChannelName(channelName);
109         chaincode.setChaincodeName(chaincodeName);
110         chaincode.setChaincodePath(chaincodePath);
111         chaincode.setChaincodeVersion(chaincodeVersion);
112         chaincode.setInvokeWatiTime(100000);
113         chaincode.setDeployWatiTime(120000);
114         return chaincode;
115     }
116 
117     /**
118      * 获取channel-artifacts配置路径
119      * 
120      * @return /WEB-INF/classes/fabric/channel-artifacts/
121      */
122     private String getChannleArtifactsPath() {
123         String directorys = FabricManager.class.getClassLoader().getResource("fabric").getFile();
124         log.debug("directorys = " + directorys);
125         File directory = new File(directorys);
126         log.debug("directory = " + directory.getPath());
127 
128         return directory.getPath() + "/channel-artifacts/";
129     }
130 
131     /**
132      * 获取crypto-config配置路径
133      * 
134      * @return /WEB-INF/classes/fabric/crypto-config/
135      */
136     private String getCryptoConfigPath() {
137         String directorys = FabricManager.class.getClassLoader().getResource("fabric").getFile();
138         log.debug("directorys = " + directorys);
139         File directory = new File(directorys);
140         log.debug("directory = " + directory.getPath());
141 
142         return directory.getPath() + "/crypto-config/";
143     }
144 
145 }
复制代码

 

 

调用过程

 

调用过程其实就是对FabricManager管理器的具体应用，一般都在impl中进行，具体可执行代码如下：

1 ChaincodeManager manager = FabricManager.obtain().getManager();
2 
3 manager.invoke(fcn, arguments);
4 
5 manager.query(fcn, arguments);

具体返回结果的运用需要各位智能合约编写返回结果的解析来支持，这里需要结合业务来实操，无法说的详尽。

需要注意区块链的事务处理，另外还有invoke和query的区别。

 

至此整个java sdk的改良使用和调用方法应该就完成了，如果还有什么问题，可以留言讨论。

 

 
 
转自：https://www.cnblogs.com/aberic/p/8269244.html