咨询干货

了解优化推广技术相关资讯

使用Hyperledger Fabric和Composer实现区块链应用程序

2021-01-19来自网络作者: 开源中国

目前无法绕过技术领域的是区块链话题。但除了加密货币之外,还有更多有趣的应用程序可以带来许多激动人心的软件生态系统。这也适用于Hyperledger项目,该项目提供了一个非常模块化的区块链框架。让我们看看使用Hyperledger Fabric和Composer实现区块链应用程序是多么容易。

关于项目Hyperledger

Hyperledger是一个umbrella项目的名称,在该项目下开源区块链方法和工具是协同开发的。它由Linux基金会于2015年推出,并享有IBM,英特尔和富士通等软件巨头以及大型社区的热烈参与。Hyperledger的GitHub存储库目前比以往更加活跃。任何人都可以参与开发。

在Hyperledger中,不仅开发了单个区块链框架(或平台)。相反,重点是并行采用多种方法,创造协同效应,可重复使用的组件和灵活性。从Hyperledger概念的角度来看,区块链网络与比特币或以太网等加密货币的代表无法比较。相反,Hyperledger网络的节点分布在参与组织中,这使得私有,许可或联盟区块链网络特别有趣。首先,我们可以忘记公共区块链的工作证明,股权证明和其他共识机制。所涉及的组织从应用程序业务价值和所涉及的信任中作为联合体验证彼此的交易和利益。这也很大程度上解决了可扩展性问题(我们从比特币网络中了解到)并且可以实现高交易吞吐量。

项目Hyperledger的不同区块链方法是Fabric,Burrow,Iroha,Indy和Sawtooth。私有,许可和联合区块链可以与所有这些区块链一起开发,但每种实现都遵循不同的方法。

我们将在本文中详细介绍Fabric,因为它拥有最活跃的社区,并且是最灵活的变体。由于其强大的模块化,fabric是普遍可用的。 “你可以将Hyperledger Fabric视为类似于Apache Web Server”,Linux基金会Hyperledger执行董事Brian Behlendorf说。其他方法更多用于在有限的环境中实施特殊情况。

Hyperledger Fabric ——灵活的区块链应用平台

使用Fabric作为平台,可以开发完全独立的分布式分类帐解决方案。Fabric包含可以尽可能自由实现的概念。区块链网络的基础是对所需组织结构的建模。每个参与者都有固定的身份,可以通过颁发的证书来识别自己。除了身份验证之外,还包括授权。使用这种基于角色的系统,可以获得许可区块链中隐私和机密性的灵活方面。对于证书和参与者的管理,可以使用结构证书颁发机构(1.0版之前的成员服务提供者)。

资产的定义(要在区块链上管理的项目)完全取决于区块链应用程序。这些资产,例如来自汽车行业的引擎块由JSON和/或二进制格式的键值对模型定义。

链代码的概念旨在基于资产及其所有者实现业务逻辑。这可用于实现Go,Java或Node.js等语言中的规则,这些规则定义读取权限或资产修改。执行链代码功能可以读取和返回资产和/或创建和修改资产并将它们存储在本地分类帐数据库中。在节点上的本地持久性更改之后,将更改提交给网络(“认可”)并在其他组织接受后插入到区块链中。在以太坊或其他公共区块链平台的背景下,可以将链码与智能合约进行比较。

通道用于实现隐私领域。在最简单的场景中,整个链代码部署在所有参与者加入的单个通道上。但是,为了创建封装区域并仅允许选定的参与者在其中进行通信,可以配置具有受限参与者组的通道。每个通道可以部署不同的链代码,从而可以实现功能隔离。此外,可以使用AES部分或完全加密通道中的通信。

结果,在每个通道中维护一个分布式分类帐,这可以被想象为链接交易的现金簿。每个参与者为他们所属的每个通道保留一份分类帐副本。这为网络中的每个现有信道创建了区块链数据结构。与区块链一样,交易存储在块中,这些块在单个连接列表中成为加密链。

但是,为了向客户端应用程序提供分类帐数据的单独视图,甚至可以执行针对网络的复杂读取请求。由于使用了像CouchDB这样的面向文档的数据库,这是可能的。这为连接到Fabric网络的客户端提供了灵活的数据访问。

使用Composer添加更简单的概念

Hyperledger-Composer是Hyperledger生态系统中的工具之一。你可以将其视为Fabric的框架。如果你想开发,构建和管理Fabric网络,那么即使不是强制性的,也是实用的。它引入了基于Fabric的进一步概念,以提供精美的抽象概念。

除资产外,还可以在Composer建模语言中定义网络参与者,交易和事件的方案。每种交易类型的流都通过JavaScript代码在简单的API上实现。访问控制文件可用于限制参与者对某些资源的访问权限。可以在Composer Query Language中定义对分类帐中数据的常用查询,这是一种类似SQL的语言。

然后,必须将所有必需文件打包到.bna文件中的BND(业务网络定义)。然后,可以将此存档安装在现有Fabric网络上。BND的源代码当然可以在我们首选的编辑器中进行本地开发和测试,因此可以通过Git进行版本控制。对于原型设计和演示目的,有Composer Playground。这提供了一个现代,清晰且直观可用的Web界面,可访问Composer CLI的本地配置。使用Playground,你可以轻松创建,安装,测试,编辑,导入和导出BND。

在Composer Playground中,你可以以用户友好的方式安装,修改和测试新的业务网络,而无需先前的样本区块链应用知识(例如车辆生命周期,汽车拍卖或农场动物跟踪)。在设置工具之后,可以在本地完成相同的操作,这样我们就可以在短时间玩游戏后离开托管游乐场。这个游乐场非常适合使用原型验证想法并了解底层的Composer和Fabric模型。

使用案例:引擎块的供应链跟踪

为了使用Hyperledger-Fabric和Composer实现私有区块链网络,以汽车行业的发动机组跟踪为例。在这种情况下,有制造商和经销商作为网络参与者。发动机及其安装的车辆显示为资产。制造商和经销商的公司被引入并被识别为网络中的组织。

Fabric链代码应提供以下功能:

  • 1.生产具有唯一序列号的发动机缸体。
  • 2.生产后将发动机缸体传送给经销商。
  • 3.跟踪车辆的序列号。
  • 4.将发动机缸体安装到注册车辆中。

下一步是安装所需的工具和设置项目。

开发环境设置和项目创建

首先,需要安装文档中列出的Fabric的所有要求。然后我们安装Composer和Composer及其相关工具本身的要求。

然后,最好让自己熟悉新环境。如果我们完全按照上一个链接的说明操作,则fabric-tools现在位于我们的主目录中。通过描述的脚本,我们可以在Docker-Compose中启动一个简单的Fabric网络,获得对等管理员访问权限并停止并再次删除它。首先,我们下载1.1版的Docker镜像并启动网络:

  1. export FABRIC_VERSION=hlfv11 && ./downloadFabric.sh && ./startFabric.sh 

在网络运行时,composer-playground web-UI可以通过composer-playground启动。它使用composer-cli的所有托管配置并访问正在运行的Fabric网络。从现在开始,我们将Fabric视为可配置的平台/基础架构,其状态通过合适的工具进行更改。我们不直接使用Fabric概念开发链代码,权限或任何模型,因为Composer提供了更多优势。

实施功能

现在我们在我们选择的目录中创建我们的BND项目。对于Yeoman(使用模板设置项目的代码生成器,如Maven Archtypes),有一个模板(hyperledger-composer:businessnetwork。但是,我已经准备了一个存储库,我们现在也可以使用JavaScript ES6和一些很好的工具。我们应该从开始分支“初始”开始。master分支具有最终版本和工作版本。我们首先克隆存储库的初始分支。

git clone -b initial git@github.com:jverhoelen/fabric-composer-engine-supplychain.git

现在我们在我们选择的编辑器中打开文件夹。Visual Studio Code非常适合Composer,因为它具有可安装的语法高亮扩展。稍作修改后你会发现它是一个NPM项目,所以我们从npm install开始安装所有依赖项。使用npm test我们可以运行单元测试,使用npm run lint我们可以测试代码样式,并且使用npm run createArchive我们可以创建the.bna文件,我们以打包格式完成业务网络定义。让我们马上试试看是否一切正常。

然后我们熟悉项目结构。lib文件夹包含实现交易处理器功能的JS文件。当然,我们想测试这个业务逻辑并将我们的单元测试存储在test/文件夹中。模型定义(参与者,资产,交易等)在models/中。

我们想首先为所需的区块链网络建模。为此,我们删除模型文件的内容,并在第一行为其指定一个新的命名空间

  1. namespace org.acme.enginesupplychain 

我们为参与者制造商和经销商建模,并使用Composer建模语言的继承。我们还希望每个参与者除了姓名外还有一个可选地址。我们将这些属性放入一个概念中:

  1. participant Member identified by memberId { 
  2.     o String memberId 
  3.     o String name 
  4.     o Address address optional 
  5.   
  6. participant Manufacturer extends Member { 
  7.   
  8. participant Merchant extends Member { 
  9.   
  10. concept Address { 
  11.     o String country 
  12.     o String city 
  13.     o String street 
  14.     o String streetNo 

然后我们介绍我们网络的资产:引擎块和稍后安装引擎的汽车。在这里,我们了解资产和参与者可以互相参考。引用始终指向任何类型的现有资源。我们以小“o”开头的属性总是存在于资源本身中。

  1. asset Engine identified by engineId { 
  2.     o String engineId 
  3.     o EngineProperties data 
  4.   
  5.     --> Manufacturer manufacturer 
  6.     --> Car currentCar optional 
  7.     --> Merchant merchant optional 
  8.   
  9. asset Car identified by carId { 
  10.     o String carId 
  11.     o String legalDocumentId 
  12.   
  13. concept EngineProperties { 
  14.     o String brand 
  15.     o String model 
  16.     o Double horsePower 
  17.     o Double cubicCapacity 
  18.     o Integer cylindersAmount 

在对系统建模之后,我们定义了可以在现有资产和参与者之上执行的所有可用操作。这些是交易资源。之后,我们为以下每个交易模型测试并实现基础交易逻辑。

  1. transaction EngineMerchantTransfer { 
  2.     --> Engine engine 
  3.     --> Merchant merchant 
  4.   
  5. transaction EngineCarInstallation { 
  6.     --> Engine engine 
  7.     --> Car car 
  8.   
  9. transaction EngineCreation { 
  10.     --> Manufacturer manufacturer 
  11.     o EngineProperties data 
  12.   
  13. transaction CarCreation { 
  14.     o String legalIdDocument 

现在我们已经定义了可能发生的事情,我们可以在提交交易时开始实现它如何影响分类帐状态。首先,我们致力于创建引擎资产。引擎应该以UUID格式获得随机生成的ID,并且应该从一开始就始终属于制造商。所以我们清空logic.js文件并从头开始。我们定义常量modelsNamespace和函数uuid,因为我们将更频繁地需要它们。接下来是createEngineAsset函数。函数上方的文档块非常重要,以便Composer可以识别打包代码时实现的交易类型。

  1. /* global getAssetRegistry getFactory */ 
  2.   
  3. const modelsNamespace = 'org.acme.enginesupplychain' 
  4. function uuid() { 
  5.     const s4 = () => Math.floor((1 + Math.random()) * 0x10000).toString(16).substring(1) 
  6.     return `${s4()}${s4()}-${s4()}-${s4()}-${s4()}-${s4()}${s4()}${s4()}` 
  7.   
  8. /** 
  9. * Creation of a Engine asset triggered by physical production. 
  10. * @param {org.acme.enginesupplychain.EngineCreation} tx - the transaction to create an engine 
  11. * @transaction 
  12. */ 
  13. async function createEngineAsset(tx) { // eslint-disable-line no-unused-vars 
  14.     const engineRegistry = await getAssetRegistry(modelsNamespace + '.Engine'
  15.     const engine = getFactory().newResource(modelsNamespace, 'Engine', uuid()) 
  16.     const engineData = getFactory().newConcept(modelsNamespace, 'EngineProperties'
  17.   
  18.     engine.data = Object.assign(engineData, tx.data) 
  19.     engine.manufacturer = tx.manufacturer 
  20.   
  21.     await engineRegistry.add(engine) 

通过这种方式,我们还实现了其他交易类型EngineMerchantTransfer,EngineCarInstallation和CarCreation。

  1. /** 
  2. * An engine is transfered to a merchant. 
  3. * @param {org.acme.enginesupplychain.EngineMerchantTransfer} tx - the engine transfer transaction 
  4. * @transaction 
  5. */ 
  6. async function transferEngineToMerchant(tx) { // eslint-disable-line no-unused-vars 
  7.     const engineRegistry = await getAssetRegistry(modelsNamespace + '.Engine'
  8.     tx.engine.merchant = tx.merchant 
  9.   
  10.     await engineRegistry.update(tx.engine) 
  11.   
  12. /** 
  13. * An engine is installed in a car. 
  14. * @param {org.acme.enginesupplychain.EngineCarInstallation} tx - the engine into car installation transaction 
  15. * @transaction 
  16. */ 
  17. async function installEngineToCar(tx) { // eslint-disable-line no-unused-vars 
  18.     const engineRegistry = await getAssetRegistry(modelsNamespace + '.Engine'
  19.     if (tx.car) { 
  20.         tx.engine.currentCar = tx.car 
  21.         await engineRegistry.update(tx.engine) 
  22.     } else { 
  23.         return Promise.reject('No target car was set on the transaction!'
  24.     } 
  25.   
  26. /** 
  27. * A car is created. 
  28. * @param {org.acme.enginesupplychain.CarCreation} tx - transaction to create a new car 
  29. * @transaction 
  30. */ 
  31. async function createCar(tx) { // eslint-disable-line no-unused-vars 
  32.     const carRegistry = await getAssetRegistry(modelsNamespace + '.Car'
  33.     const factory = getFactory() 
  34.     const carId = uuid() 
  35.     const car = factory.newResource(modelsNamespace, 'Car', carId) 
  36.     car.legalDocumentId = tx.legalIdDocument 
  37.   
  38.     await carRegistry.add(car) 

功能本身的单元测试相对简单,如果我们有经验,我们不需要了解更多。只有对此所需的对象的boostrapping仍然有点超载样板代码。测试首先启动内存中的Fabric网络,在其上安装业务网络,然后以默认管理员身份对其进行身份验证。因为这个Composer提供了库composer-admin,composer-client,composer-common和composer-connector-embedded。在测试设置之后,我们现在可以针对嵌入式网络编写测试用例。由于其长度,设置代码未包含在列表中,但可以在test/EngineSupplychainSpec.js中的主分支上查看和测试。

用于测试交易类型的单元测试用例通常具有类似的模式。他们使用其属性和关系重新创建交易,针对网络执行交易,然后检查所涉及的资产和参与者的数据状态。我们来看看createEngineAsset的现有测试用例。

  1. describe(‘EngineSupplychainSpec’, () => { 
  2.   
  3.    // setup is done in the before and beforeEach hook 
  4.    // results are the bnc (BusinessNetworkConnection), target namespace 
  5.    // as well as test assets, participants and required registries 
  6.    describe('createEngineAsset', () => { 
  7.        it('should create an Engine by submitting a valid EngineCreation transaction', async () => { 
  8.            const factory = bnc.getBusinessNetwork().getFactory() 
  9.   
  10.            const engineCreationTrans = factory.newTransaction(namespace, 'EngineCreation'
  11.            engineCreationTrans.data = factory.newConcept(namespace, 'EngineProperties'
  12.            engineCreationTrans.data.brand = 'Audi' 
  13.            engineCreationTrans.data.model = 'Fancy engine model' 
  14.            engineCreationTrans.data.horsePower = 400 
  15.            engineCreationTrans.data.cubicCapacity = 4000 
  16.            engineCreationTrans.data.cylindersAmount = 10 
  17.   
  18.            const manufacturerRegistry = await bnc.getParticipantRegistry(namespace + '.Manufacturer'
  19.            await manufacturerRegistry.addAll([]) 
  20.            engineCreationTrans.manufacturer = factory.newRelationship(namespace, 'Manufacturer', testManufacturer.$identifier) 
  21.   
  22.            await bnc.submitTransaction(engineCreationTrans) 
  23.   
  24.            const allEngines = await engineRegistry.getAll() 
  25.            allEngines.length.should.equal(2) 
  26.        }) 
  27.    }) 
  28. }) 

在Hyperledger Composer中实现业务网络定义的方法应该通过这些见解变得清晰。此外,BND可以为我们定义更多的东西。在permissions.acl中,你可以使用访问控制语言为给定简单条件的参与者定义访问限制。对于许多应用程序,事件和查询功能也非常有用和有趣。

最后,我们来看看主分支上的解决方案。所有这些要求都已在其中实施和测试。我们现在用npm run createArchive生成完成的.bna文件,然后在dist/文件夹中。我们现在可以将它导入到我们在控制台中启动的Composer Playground中,以便在我们的本地Fabric网络上进行尝试。通过Web UI的方式应该是不言自明的,但它也是正式记录的。

总结和展望

我们已经了解了Hyperledger项目的重要部分。具体来说,我们现在知道Fabric作为具有基本概念的区块链平台。Composer添加了许多重要概念,使开发人员可以非常方便地实施和管理区块链网络。通过实施的关于发动机缸体生产和跟踪的区块链应用案例,我们了解了一个简单但功能强大的私人/联盟区块链用例。

最终的区块链网络最初只在本地执行。我们还没有扩展同行组织和订购服务的配置。但我们可以轻松添加更多组织并通过多个主机分发对等节点。对于由真正的组织联盟跨越的区块链网络,我们仍然有一些问题需要解决:

我们如何管理组织和对等节点?组织如何自动将新的对等节点添加到网络中?我们如何获得一个可以抵御失败的公平和同质的网络?客户如何与网络通信?

这个仍然年轻的平台已经提供了很多功能和舒适性。但是,仍有许多任务需要完成。从开发人员的角度来看,单元测试代码看起来仍然非常臃肿。很快就会出现库,通过它可以更容易地实现通常的测试模式。我们迫切希望看到Hyperledger等项目将如何继续推动业务中分布式账本技术的适应性。

故障排除

确保所有工具都与Fabric 1.1兼容。这意味着必须下载此版本的所有docker镜像。应安装最新版本的Composer和Composer Playground。目前是v0.19.1。本文中Fabric和Composer文档的所有链接都是故意修复到Fabric 1.1和最新的Composer版本。

声明:本站发布的内容以原创、转载、分享网络内容为主,如有侵权,请联系电话:021-51697771-8029,邮箱:mj@cndns.com,我们将会在第一时间删除。文章观点不代表本站立场,如需处理请联系我们。