首页 > > 程序设计 > Java技术 >

Hyperledger Fabric 1.0 从零开始（十二）——fa…

2018-06-18 03:54:51来源：未知 阅读 ()

新老客户大回馈,云服务器低至5折

在 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的改良使用和调用方法应该就完成了，如果还有什么问题，可以留言讨论。

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：windows 安装 redis

下一篇：K：java中的安全模型(沙箱机制)

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签