超级账本HyperLedger: Fabric的基本概念与基础用法

Tags: HyperLedger 

目录

说明

超级账本HyperLedger视频教程:HyperLedger Fabric全手动、多服务器部署与进阶教程–“主页”中可领优惠券

Hyperledger是Linux基金会在2015年发起的项目,目的是推进区块链技术的开发应用。Hyperledger收录了多个区块链项目。

区块链技术平台:

Sawtooth
Iroha
Fabric 
Burrow
Indy

区块链工具:

Cello
Composer
Explorer
Quilt

相关笔记

视频演示:

文字介绍:

问题汇总:

Farbric

Fabric是一个支持智能合约(smart contracts)的分布式账本(ledger)系统。

Fabric是私有的,只有通过MSP(Membership Service Provider)认证的成员才可以进入到系统,参与合约的缔造与执行。

Fabric是插件式设计,账本数据有多种存放方式,共识机制(consensus mechanisms)可以切换,支持不同类型的MSP。

Fabric开发了channel功能,一个channel对应一个账本,只有加入channel的成员可见,可以防止竞争对手知晓交易的细节。

账本由两部分组成:全局状态(word state)和交易日志(transaction log)。 全局状态中记录的是当前状态,交易日志中记录了所有的交易记录,全局状态是这些交易记录的执行结果。

智能合约(Smart Contracts)用chaincode编写,由区块链外部的应用调用执行,chaincode通常是用来更新账本的。

Farbric的chaincode目前(2018-02-23 15:08:54)只支持Go语言,以后会支持Java和其它的语言。

达成共识的过程中,交易需要严格按照发生的顺序记录到账本中,Farbric提供了多种共识机制(SOLO、Kafka、SBFT…),建立交易网络的时候根据实际需要选用共识机制。

概念

Fabric的模型主要由以下几个概念组成:

Assets:           交易的资产
ChainCode:        描述交易逻辑的代码 
Ledger Features:  账本功能
Privacy through Channels: channel的私密性,可以对全网开发,也可以只对部分成员开放
                          包含交易逻辑的ChainCode可以只部署在特定用户端,实现部分公开的效果
                          还可以在ChainCode中对数据进行加密
Security & Membership Services: 参与交易的用户都经过认证的可信用户
Consensus:  交易从发起到被提交到账本的过程中的检验

部署示例

下面使用的fabric提供的一个部署示例,这个例子中会创建一个由4个peer组成的fabric网络。

部署要求:

docker版本不低于17.06.2
docker-compose版本不低于1.14.0
go版本1.9.x
如果用node.js开发应用,node.js版本不低于8.9.x

下载示例:

git clone https://github.com/hyperledger/fabric-samples.git
cd fabric-samples/first-network/

下载fabric的命令文件,-s指定要安装的版本:

mkdir -p /opt/fabric/1.0.6 
cd /opt/fabric/1.0.6 
curl -sSL https://goo.gl/6wtTN5 | bash -s 1.0.6   #这个网址需要翻墙访问
export PATH=$PATH:/opt/fabric/1.0.6/bin

执行结束后,在/opt/fabr /1.0.6/bin目录中可以看到以下文件:

configtxgen             //用于生成配置文件,存放在channel-artifacts目录中
configtxlator
cryptogen               //用于为网络的参与者生成证书,存放在crypto-config目录中
get-byfn.sh
get-docker-images.sh
orderer
peer

上面的命令执行时还会下载9个镜像,这9个镜像构成了fabric系统。

hyperledger/fabric-tools    
hyperledger/fabric-orderer  
hyperledger/fabric-peer     
hyperledger/fabric-javaenv  
hyperledger/fabric-ca       
hyperledger/fabric-ccenv    
hyperledger/fabric-zookeeper
hyperledger/fabric-kafka    
hyperledger/fabric-couchdb  

到fabric-samples/first-network/目录中执行byfn.sh,byfn.sh脚本可以用来创建一个由4个peer(分属2个组织)组成的网络

$./byfn.sh -h
Usage:
  byfn.sh -m up|down|restart|generate [-c <channel name>] [-t <timeout>] [-d <delay>] [-f <docker-compose-file>] [-s <dbtype>] [-i <imagetag>]
  byfn.sh -h|--help (print this message)
    -m <mode> - one of 'up', 'down', 'restart' or 'generate'
      - 'up' - bring up the network with docker-compose up
      - 'down' - clear the network with docker-compose down
      - 'restart' - restart the network
      - 'generate' - generate required certificates and genesis block
    -c <channel name> - channel name to use (defaults to "mychannel")
    -t <timeout> - CLI timeout duration in microseconds (defaults to 10000)
    -d <delay> - delay duration in seconds (defaults to 3)
    -f <docker-compose-file> - specify which docker-compose file use (defaults to docker-compose-cli.yaml)
    -s <dbtype> - the database backend to use: goleveldb (default) or couchdb
    -i <imagetag> - pass the image tag to launch the network using the tag: 1.0.1, 1.0.2, 1.0.3, 1.0.4 (defaults to latest)

Typically, one would first generate the required certificates and
genesis block, then bring up the network. e.g.:

    byfn.sh -m generate -c mychannel
    byfn.sh -m up -c mychannel -s couchdb
    byfn.sh -m up -c mychannel -s couchdb -i 1.0.6
    byfn.sh -m down -c mychannel

Taking all defaults:
    byfn.sh -m generate
    byfn.sh -m up
    byfn.sh -m down

创建网络:

./byfn.sh -m generate      #准备证书文件等
./byfn.sh -m up            #启动网络

执行完成后,会启动8个容器,其中6个用first-network/docker-compose-cli.yaml启动的容器:

orderer.example.com         # 用于形成共识 
peer0.org1.example.com      # 成员org1.example.com的第一个peer
peer1.org1.example.com      # 成员org1.example.com的第二个peer
peer0.org2.example.com      # 成员org2.example.com的第一个peer
peer1.org2.example.com      # 成员org2.example.com的第二个peer
cli                         # 命令行工具,启动后sleep一段时间后退出

另外三个是运行智能合约的容器:

dev-peer1.org2.example.com-mycc-1.0
dev-peer0.org1.example.com-mycc-1.0
dev-peer0.org2.example.com-mycc-1.0

一个容器是在创建合约后,实例化时创建的,两个是指定peer进行查询、交易时,需要智能合约的时候创建的。

另外有一个名为cli的容器会在启动10秒钟后自动退出:

docker start cli

CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/[email protected]/msp
CORE_PEER_ADDRESS=peer0.org1.example.com:7051
CORE_PEER_LOCALMSPID="Org1MSP"
CORE_PEER_TLS_ROOTCERT_FILE=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/tls/ca.crt

fabric ca

fabric ca用来管理fabric的用户,即用户证书的签署和撤销等。

启动fabric ca server启动后,可以直接用fabirc-ca-client创建、撤销证书。

fabric-ca-server init -b admin:adminpw

详情参考hyperleader fabric-ca

编译:

git clone https://github.com/hyperledger/fabric-ca.git
cd fabric-ca
make

启动fabric-ca-server:

$ fabric-ca-server init -b  admin:pass
$ fabric-ca-server start -b  admin:pass
2018/04/02 10:09:58 [INFO] Configuration file location: /opt/app/fabric/ca/fabric-ca-server-config.yaml
2018/04/02 10:09:58 [INFO] Starting server in home directory: /opt/app/fabric/ca
2018/04/02 10:09:58 [INFO] Server Version: 1.1.1-snapshot-d536f5a
2018/04/02 10:09:58 [INFO] Server Levels: &{Identity:1 Affiliation:1 Certificate:1}
2018/04/02 10:09:58 [INFO] The CA key and certificate already exist
2018/04/02 10:09:58 [INFO] The key is stored by BCCSP provider 'SW'
2018/04/02 10:09:58 [INFO] The certificate is at: /opt/app/fabric/ca/ca-cert.pem
2018/04/02 10:09:58 [INFO] Initialized sqlite3 database at /opt/app/fabric/ca/fabric-ca-server.db
2018/04/02 10:09:58 [INFO] Home directory for default CA: /opt/app/fabric/ca
2018/04/02 10:09:58 [INFO] Listening on http://0.0.0.0:7054

注册用户admin,密码为pass:

export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/admin
mkdir -p $FABRIC_CA_CLIENT_HOME
fabric-ca-client enroll -u http://admin:pass@localhost:7054

用户注册后会在$FABRIC_CA_CLIENT_HOME目录中,生成该用户的msp文件。

登记一个新的管理员admin2:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/admin
$ fabric-ca-client register --id.name admin2 --id.affiliation org1.department1 --id.attrs 'hf.Revoker=true,admin=true:ecert'
2018/04/02 10:24:10 [INFO] Configuration file location: /opt/app/fabric-ca/clients/admin/fabric-ca-client-config.yaml
2018/04/02 10:24:11 [INFO] 127.0.0.1:37738 POST /register 201 0 "OK"
Password: yRPoQHgvRMfv

admin2的密码为yRPoQHgvRMfv,用该密码注册admin2:

export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/admin2
mkdir -p $FABRIC_CA_CLIENT_HOME
fabric-ca-client enroll -u http://admin2:yRPoQHgvRMfv@localhost:7054

登记peer节点:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/admin
$ fabric-ca-client register --id.name peer1 --id.type peer --id.affiliation org1.department1 --id.secret peer1pw
2018/04/02 10:29:19 [INFO] Configuration file location: /opt/app/fabric-ca/clients/admin/fabric-ca-client-config.yaml
2018/04/02 10:29:19 [INFO] 127.0.0.1:37742 POST /register 201 0 "OK"
Password: peerlpw

注册peer节点:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/peer1
$ mkdir -p $FABRIC_CA_CLIENT_HOME
$ fabric-ca-client enroll -u http://peer1:peer1pw@localhost:7054 
2018/04/02 10:31:33 [INFO] Created a default configuration file at /opt/app/fabric-ca/clients/peer1/fabric-ca-client-config.yaml
2018/04/02 10:31:33 [INFO] generating key: &{A:ecdsa S:256}
2018/04/02 10:31:33 [INFO] encoded CSR
2018/04/02 10:31:33 [INFO] signed certificate with serial number 466996778638269692226353529244210797413718475950
2018/04/02 10:31:33 [INFO] 127.0.0.1:37746 POST /enroll 201 0 "OK"
2018/04/02 10:31:33 [INFO] Stored client certificate at /opt/app/fabric-ca/clients/peer1/msp/signcerts/cert.pem
2018/04/02 10:31:33 [INFO] Stored root CA certificate at /opt/app/fabric-ca/clients/peer1/msp/cacerts/localhost-7054.pem
2018/04/02 10:31:33 [INFO] Stored intermediate CA certificates at /opt/app/fabric-ca/clients/peer1/msp/intermediatecerts/localhost-7054.pem

重新获取用户的注册证书:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/peer1
$ fabric-ca-client reenroll 
2018/04/02 10:32:45 [INFO] Configuration file location: /opt/app/fabric-ca/clients/peer1/fabric-ca-client-config.yaml
2018/04/02 10:32:45 [INFO] generating key: &{A:ecdsa S:256}
2018/04/02 10:32:45 [INFO] encoded CSR
2018/04/02 10:32:45 [INFO] signed certificate with serial number 597323218796588712462517843147119438988456740867
2018/04/02 10:32:45 [INFO] 127.0.0.1:37748 POST /reenroll 201 0 "OK"
2018/04/02 10:32:45 [INFO] Stored client certificate at /opt/app/fabric-ca/clients/peer1/msp/signcerts/cert.pem
2018/04/02 10:32:45 [INFO] Stored root CA certificate at /opt/app/fabric-ca/clients/peer1/msp/cacerts/localhost-7054.pem
2018/04/02 10:32:45 [INFO] Stored intermediate CA certificates at /opt/app/fabric-ca/clients/peer1/msp/intermediatecerts/localhost-7054.pem

注销用户:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/admin
$ fabric-ca-client revoke -e peer1
2018/04/02 10:34:23 [INFO] Configuration file location: /opt/app/fabric-ca/clients/admin/fabric-ca-client-config.yaml
2018/04/02 10:34:23 [INFO] 127.0.0.1:37750 POST /revoke 200 0 "OK"
2018/04/02 10:34:23 [INFO] Sucessfully revoked certificates: [{Serial:51ccdc1bda8e1aa36496fb7169864b44e932c4ae AKI:f32804a7210722c0d06a525f6f3b79cf4f4eba51} {Serial:68a0e64546a3e19a0654b7576c269be89b97c803 AKI:f32804a7210722c0d06a525f6f3b79cf4f4eba51}]

获取fabric-ca的根证书:

$ export FABRIC_CA_CLIENT_HOME=/opt/app/fabric-ca/clients/cacerts
$ mkdir $FABRIC_CA_CLIENT_HOME
$ fabric-ca-client getcacert -u http://localhost:7054 -M $FABRIC_CA_CLIENT_HOME/msp 
2018/04/02 10:40:13 [INFO] Configuration file location: /opt/app/fabric-ca/clients/cacerts/fabric-ca-client-config.yaml
2018/04/02 10:40:13 [INFO] 127.0.0.1:37756 POST /cainfo 200 0 "OK"
2018/04/02 10:40:13 [INFO] Stored root CA certificate at /opt/app/fabric-ca/clients/cacerts/msp/cacerts/localhost-7054.pem
2018/04/02 10:40:13 [INFO] Stored intermediate CA certificates at /opt/app/fabric-ca/clients/cacerts/msp/intermediatecerts/localhost-7054.pem

使用方法

上一节中通过byfn.sh脚本直接启动了一个fabric网络。这个过程隐藏了太多细节,需要有一个逐步说明的例子。

orderer的创世区块

首先在启动orderer的时候,需要传入一个创世区块。创世区块中包含了将要参与的组织。

configtxgen -profile TwoOrgsOrdererGenesis -outputBlock $output/genesisblock

下面是创世区块使用的profiles:

TwoOrgsOrdererGenesis:
    Orderer:
        <<: *OrdererDefaults
        Organizations:
            - *OrdererOrg
    Consortiums:
        SampleConsortium:
            Organizations:
                - *Org1
                - *Org2

创世区块传递给orderer的方式有多种,在orderer.yml中配置:

GenesisMethod: file
GenesisProfile: SampleInsecureSolo
GenesisFile: ./genesisblock

部署orderer和peer

有了创世区块之后,就可以部署order和peer,完成fabric的部署。

创建channel

在使用fabric之前,需要先创建channel:

configtxgen -profile TwoOrgsChannel -outputCreateChannelTx $output/channel.tx -channelID $CHANNEL_NAME

下面是channel的profile:

TwoOrgsChannel:
    Consortium: SampleConsortium
    Application:
        <<: *ApplicationDefaults
        Organizations:
            - *Org1
            - *Org2

通过一个peer,将channel.tx发送给order,完成channel创建:

peer channel create -o orderer.example.com:7050 -c $CHANNEL_NAME -f ./channel-artifacts/channel.tx --tls true --cafile ./tlsca.example.com-cert.pem

创建成功后,会在本地生成一个名为$CHANNEL_NAME.block的文件。

peer channel list可以看到已经创建的channel。

[root@10-39-0-121 Admin-peer0.org1.example.com]# ./peer.sh channel list
2018-03-29 12:23:34.438 CST [channelCmd] InitCmdFactory -> INFO 003 Endorser and orderer connections initialized
Channels peers has joined:
mychannel
2018-03-29 12:23:34.440 CST [main] main -> INFO 006 Exiting.....

将所有peer加入到channel

需要分别将所有需要交互的peer加入到channel中,加入时要用到上一步生成的${CHANNEL_NAME}.block文件:

export CORE_PEER_LOCALMSPID=Org1MSP
export CORE_PEER_ADDRESS=peer0.org1.example.com:7051
peer channel join -b $CHANNEL_NAME.block

peer channel list可以看到当前使用的peer已经加入的channel:

$ ./peer.sh  channel list
Channels peers has joined:
mychannel

指定每个组织的anchor peer

需要在每个组织中指定一个anchor peer,需要先用configtxgen生成一个文件:

configtxgen -profile TwoOrgsChannel -outputAnchorPeersUpdate $output/Org1MSPanchors.tx -channelID $CHANNEL_NAME -asOrg Org1MSP

然后用生成的文件更新peer:

peer channel update -o orderer.example.com:7050 -c $CHANNEL_NAME -f ./channel-artifacts/${CORE_PEER_LOCALMSPID}anchors.tx --tls true --cafile ./tlsca.example.com-cert.pem

开发合约

合约就是一段代码, fabirc samples chaincode中给出了几个例子。

安装合约

安装合约就是将合约代码提交到fabric中。

peer chaincode install -n $NAME -v $VERSION -p $CODEPATH

如果合约使用用Go语言开发的,CODEPATH应该是$GOPATH/src下的目录。安装时,会将所有依赖的文件打包。

可以用peer chaincode list --installed查看已经安装的合约。

#./peer.sh chaincode list  --installed
Get installed chaincodes on peer:
Name: mycc, Version: 1.0, Path: chaincode_example02, Id: f34984a229c76f470fa24b6ecad6dc1a4876440f7213181265bdfbe6ad129371
2018-03-29 12:32:05.549 CST [main] main -> INFO 005 Exiting.....

合约位于peer的data目录中一个名为chaincodes的子目录中:

$ ls /opt/app/fabric/peer/data/chaincodes/
mycc.1.0

同一个合约,需要在每个peer上都安装,因为实测中发现用下面的命令只能看到目标peer上已经安装的合约:

./peer.sh chaincode list --installed

合约分步安装

上面的安装步骤可以分成三步进行。

合约打包:

peer chaincode package ccpack.out -n $NAME -v $VERSION -s -S -p $CODEPATH

合约签署:

peer chaincode signpackage ccpack.out signedccpack.out

合约安装:

peer chaincode install ./signedccpack.out

合约实例化

合约实例化就是在指定的peer上启动一个docker容器,并调用合约的方法Init方法。

peer chaincode instantiate -o orderer.example.com:7050 --tls true --cafile ./tlsca.example.com-cert.pem -C $CHANNEL_NAME -n $NAME -v $VERSION -c '{"Args":["init","a","100","b","200"]}' -P "OR ('Org1MSP.member','Org2MSP.member')"

-c:  传入合约的数据,  
       '{"Args":["init","a","100","b","200"]}'
-P:  该合约的背书策略,The endorsement policy associated to this chaincode
       "OR ('Org1MSP.member','Org2MSP.member')"

上面-c的含义是初始化时,调用合约的init方法,传入参数是”a”、”100”、”b”、”200”。

func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response {
	fmt.Println("ex02 Init")
	_, args := stub.GetFunctionAndParameters()
	
	...
	
	//初始化
	A = args[0]
	Aval, err = strconv.Atoi(args[1])
	B = args[2]
	Bval, err = strconv.Atoi(args[3])
	
	...
	
	//写入账本
	err = stub.PutState(A, []byte(strconv.Itoa(Aval)))
	err = stub.PutState(B, []byte(strconv.Itoa(Bval)))

在其它的peer上,能够看到已经实例化的合约:

./peer.sh chaincode list -C mychannel --instantiated
Get instantiated chaincodes on channel mychannel:
Name: mycc, Version: 1.0, Escc: escc, Vscc: vscc
2018-03-29 12:58:08.135 CST [main] main -> INFO 005 Exiting.....

合约只需要实例化一次,当通过其它peer上使用合约时,会自动在目标peer上启动一个执行合约的容器。

调用合约

peer chaincode invoke用来调用合约的其它方法:

peer chaincode invoke -o orderer.example.com:7050  --tls true --cafile ./tlsca.example.com-cert.pem -C $CHANNEL_NAME -n $NAME -c '{"Args":["invoke","a","b","10"]}'

上面的例子是调用合约的invoke方法:

func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
	fmt.Println("ex02 Invoke")
	function, args := stub.GetFunctionAndParameters()
	if function == "invoke" {
		// Make payment of X units from A to B
		return t.invoke(stub, args)
	} else if function == "delete" {
		// Deletes an entity from its state
		return t.delete(stub, args)
	} else if function == "query" {
		// the old "Query" is now implemtned in invoke
		return t.query(stub, args)
	}
	return shim.Error("Invalid invoke function name. Expecting \"invoke\" \"delete\" \"query\"")
}

查询合约

peer chaincode query是用来直接从peer查询数据:

peer chaincode query -C $CHANNEL_NAME -n $NAME -c '{"Args":["query","a"]}'

注意,如果在query命令调用合约里会修改账本的方法,那么修改是不会生效的,例如:

peer chaincode query -C $CHANNEL_NAME -n $NAME -c '{"Args":["invoke","a","b","10"]}'

账本中的数据没有被修改。

更新合约

peer chaincode upgrade用来更新合约,更新合约相当于将合约重新实例化,并带有一个新的版本号。

更新合约之前,需要在所有的peer上安装最新的合约,并使用新的版本号:

VERSION=1.1
peer chaincode install -n $NAME -v $VERSION -p $CODEPATH

然后直接使用upgrade更新合约:

VERSION=1.1
peer chaincode upgrade -o orderer.example.com:7050 --tls true --cafile ./tlsca.example.com-cert.pem -C $CHANNEL_NAME -n $NAME -v $VERSION -c '{"Args":["init","a","1000","b","2000"]}' -P "OR ('Org1MSP.member','Org2MSP.member')"

合约更新之后,对查询、调用等操作都将使用最新合约,老版本的合约还会存在,但是不再起作用。

每个peer上安装的合约必须是相同的,否则

合约启动与暂停

目前,fabric不支持合约的启动与暂停。要暂停合约,只能到peer上手动删除容器。

fabric SDKs

当前(2018-03-30 14:59:11)正式的Hyperledger Fabric SDKs只有Node和java。

其它语言的sdk在开发中, 在github hyperleader中可以找到。

sdk分为两部分,fabric-client用来调用fabric,fabric-ca-client用来与fabric-ca交互,逐层、撤销用户等。

fabric编译

编译的过程会联网,需要翻墙。

编译前会用curl下载一个.jar文件,可以提前准备好:

curl -fL https://nexus.hyperledger.org/content/repositories/releases/org/hyperledger/fabric/hyperledger-fabric/chaintool-1.0.0/hyperledger-fabric-chaintool-1.0.0.jar > build/bin/chaintool

编译:

go get github.com/hyperledger/fabric
cd $GOPATH/src/github.com/hyperledger/fabric
make 

可以用GOARCH和GOOS指定目标平台,用CGO_FLAGS表示是否启用cgo:

GOARCH=adm64 GOOS=linux make 

如果提示找不到protoc-gen-go:

cp: build/docker/gotools/bin/protoc-gen-go: No such file or directory

将protoc-gen-go复制过去:

cp gotools/build/gopath/bin/protoc-gen-go   build/docker/gotools/bin/protoc-gen-go

如果还是找不到protoc-gen-go文件,到gotools目录下执行make:

cd gotools/
make         //需要翻墙,会从golang.org下载代码golang.org/x/lint

在linux上编译时如果报错找不到”ltdl.h”,需要安装ltdl。

# github.com/hyperledger/fabric/vendor/github.com/miekg/pkcs11
vendor/github.com/miekg/pkcs11/pkcs11.go:26:18: fatal error: ltdl.h: No such file or directory
 #include <ltdl.h>
				  ^
compilation terminated.

yum install libtool-ltdl-devel
apt install libltdl3-dev

如果在mac上遇到下面的错误:

Step 3/5 : ADD payload/goshim.tar.bz2 $GOPATH/src/
failed to copy files: Error processing tar file(bzip2 data invalid: bad magic value in continuation file):
make: [build/image/ccenv/.dummy-x86_64-1.0.7-snapshot-ac3fabd] Error 1

需要安装gnu-tar,用gnu-tar替换mac默认的bsdtar,可以用brew list gnu-tar找到gnu-tar的位置:

$ brew install gnu-tar --with-default-names
$ export PATH="/usr/local/Cellar/gnu-tar/1.30/libexec/gnubin/:$PATH"
$ which tar
/usr/local/Cellar/gnu-tar/1.30/libexec/gnubin//tar

编译过程中会生成多个镜像,以及联网下载多个文件,需要较长的时间。编译完成后,会得到下面的二进制文件:

$ ls build/bin/
chaintool     configtxgen   configtxlator cryptogen     orderer       peer

chaintool是编译过程中使用的工具,Farbic主要由下面的程序组成:

configtxgen             //用于生成配置文件、创世区块,存放在channel-artifacts目录中
configtxlator           //用于将fabric的数据在json和protobuf格式之间转换
cryptogen               //用于为网络的参与者生成证书,存放在crypto-config目录中
orderer                 //用于形成共识
peer                    //用于peer操作管理,包含5个不同用途的子命令

order(Hyperledger Fabric Ordering Service)是用来形成共识的,这里的共识就是交易的顺序。当前版本(1.0.6)支持三种共识方式:

Solo,只部署一个order,因为只有一个order,所以不需要进行共识协商,仅用于测试
Kafka-based,使用kafka的发布/订阅功能进行排序,存在拜占庭将军问题(Byzantine failures)
PBFT,正在开发中,能够应对拜占庭将军问题

每个order中都存放一份账本,当前版本(1.0.6)支持三种账本格式:

File Ledger,存放在本地的levelDB数据库文件中,可用于生产
RAM Ledger, 在内存中保留最近一端时间内的交易记录,可用于测试
JSON Ledger,以json文件的方式存放,正在开发中

peer是最常用的管理命令,Hyperledger Fabric: Peer Commands,包括5个子命令:

peer chaincode : 对链进行操作
peer channel   : channel相关操作
peer logging   : 设置日志级别
peer node      : 启动、管理节点
peer version   : 查看版本信息

Farbric的主体是由order和peer组成的,如下图所示:

hyperleader fabric arch

命令使用

fabric命令使用

cryptogen

cryptogen命令用来生成证书:

cryptogen generate --config=./crypto-config.yaml

运行结束后在当前目录下会生成一个crypto-config目录。

配置文件格式如下:

OrdererOrgs:    //order的证书
  - Name: Orderer
    Domain: example.com
    Specs:
      - Hostname: orderer
PeerOrgs:      //peer的证书
  - Name: Org1
    Domain: org1.example.com
    Template:   
      Count: 2
        Start: 0
        Hostname: {{.Prefix}}{{.Index}} # default
    Users:
      Count: 1
  - Name: Org2
    Domain: org2.example.com
    Template:
      Count: 2
    Users:
      Count: 1

每个组织都有配置了一个ca证书,每个组件向fabric发起的交易和通信用keystore签署,对方用公钥signcerts进行验证。

生成的文件目录结构如下:

crypto-config
├── ordererOrganizations
│   └── example.com
│       ├── ca
│       │   ├── ca.example.com-cert.pem
│       │   └── f9628f7288c14b291ff0ed13a30b63893e872e7a2f598fc012c8e8769edad25e_sk
│       ├── msp
│       │   ├── admincerts
│       │   │   └── [email protected]
│       │   ├── cacerts
│       │   │   └── ca.example.com-cert.pem
│       │   └── tlscacerts
│       │       └── tlsca.example.com-cert.pem
│       ├── orderers
│       │   └── orderer.example.com
│       │       ├── msp
│       │       │   ├── admincerts
│       │       │   │   └── [email protected]
│       │       │   ├── cacerts
│       │       │   │   └── ca.example.com-cert.pem
│       │       │   ├── keystore
│       │       │   │   └── b3d4dbe09aa4d4b3825201e73970ef80b09ec98d01c6203f6c70ad155f84e3f5_sk
│       │       │   ├── signcerts
│       │       │   │   └── orderer.example.com-cert.pem
│       │       │   └── tlscacerts
│       │       │       └── tlsca.example.com-cert.pem
│       │       └── tls
│       │           ├── ca.crt
│       │           ├── server.crt
│       │           └── server.key
│       ├── tlsca
│       │   ├── 7f92c812607da0cfa24eb774c234c90d81564cdcdc4de875fb8d529d912fbbc0_sk
│       │   └── tlsca.example.com-cert.pem
│       └── users
│           └── [email protected]
│               ├── msp
│               │   ├── admincerts
│               │   │   └── [email protected]
│               │   ├── cacerts
│               │   │   └── ca.example.com-cert.pem
│               │   ├── keystore
│               │   │   └── cb1531785ee203640940006a29452171cac011120d7928308881fdcb13d34d0b_sk
│               │   ├── signcerts
│               │   │   └── [email protected]
│               │   └── tlscacerts
│               │       └── tlsca.example.com-cert.pem
│               └── tls
│                   ├── ca.crt
│                   ├── server.crt
│                   └── server.key
└── peerOrganizations
...

configtxgen

configtxgen用来生成第一个区块,channel数据,以及anchorPeer。

configtxgen -profile TwoOrgsOrdererGenesis -outputBlock ./genesis.block
configtxgen -profile TwoOrgsChannel -outputCreateChannelTx ./channel.tx -channelID $CHANNEL_NAME
configtxgen -profile TwoOrgsChannel -outputAnchorPeersUpdate ./Org1MSPanchors.tx -channelID $CHANNEL_NAME -asOrg Org1MSP
configtxgen -profile TwoOrgsChannel -outputAnchorPeersUpdate ./Org2MSPanchors.tx -channelID $CHANNEL_NAME -asOrg Org2MSP

configtxgen默认从configtx.yaml读取配置,-profile指定将要从中读取的内容:

Profiles:
    TwoOrgsOrdererGenesis:
        Orderer:
            <<: *OrdererDefaults
            Organizations:
                - *OrdererOrg
        Consortiums:
            SampleConsortium:
                Organizations:
                    - *Org1
                    - *Org2
    TwoOrgsChannel:
        Consortium: SampleConsortium
        Application:
            <<: *ApplicationDefaults
            Organizations:
                - *Org1
                - *Org2
Organizations:
    - &OrdererOrg
        Name: OrdererOrg
        ID: OrdererMSP
        MSPDir: crypto-config/ordererOrganizations/example.com/msp
    - &Org1
        Name: Org1MSP
        ID: Org1MSP
        MSPDir: crypto-config/peerOrganizations/org1.example.com/msp
        AnchorPeers:
            - Host: peer0.org1.example.com   //用来进行流言发布的分布式协议
              Port: 7051
    - &Org2
        Name: Org2MSP
        ID: Org2MSP
        MSPDir: crypto-config/peerOrganizations/org2.example.com/msp
        AnchorPeers:
            - Host: peer0.org2.example.com
              Port: 7051
Orderer: &OrdererDefaults
    OrdererType: solo    //solo or kafka
    Addresses:
        - orderer.example.com:7050
    BatchTimeout: 2s
    BatchSize:
        MaxMessageCount: 10
        AbsoluteMaxBytes: 99 MB
        PreferredMaxBytes: 512 KB
    Kafka:
        Brokers:
            - 127.0.0.1:9092
    Organizations:
Application: &ApplicationDefaults
    Organizations:

orderer

order配置文件格式如下:

General:
    LedgerType: file       //账本类型
    ListenAddress: 0.0.0.0
    ListenPort: 7050
    TLS:
        Enabled: true
        PrivateKey: tls/server.key
        Certificate: tls/server.crt
        RootCAs:
          - tls/ca.crt
        ClientAuthEnabled: false
        ClientRootCAs:
    LogLevel: debug

    GenesisMethod: file                  //创世块获取方式
    GenesisProfile: SampleSingleMSPSolo  //如果从文件获取创世块,忽略
    GenesisFile: genesis.block           //创世块内容

    LocalMSPDir: msp
    LocalMSPID: OrdererMSP

    Profile:                     // go pprof
        Enabled: false
        Address: 0.0.0.0:6060

    BCCSP:                       // 区块加密设置
        Default: SW
        SW:
            Hash: SHA2
            Security: 256
            FileKeyStore:
                KeyStore:

FileLedger:    //文件账本配置
    Location: /var/hyperledger/fabric/orderer
    Prefix: hyperledger-fabric-ordererledger

RAMLedger:     //内存账本配置
    HistorySize: 1000

Kafka:        //如果基于kafka
    Retry:
        ShortInterval: 5s
        ShortTotal: 10m
        LongInterval: 5m
        LongTotal: 12h
        NetworkTimeouts:
            DialTimeout: 10s
            ReadTimeout: 10s
            WriteTimeout: 10s
        Metadata:
            RetryBackoff: 250ms
            RetryMax: 3
        Producer:
            RetryBackoff: 100ms
            RetryMax: 3
        Consumer:
            RetryBackoff: 2s
    Verbose: false
    TLS:
      Enabled: false
      PrivateKey:
        #File: path/to/PrivateKey
      Certificate:
        #File: path/to/Certificate
      RootCAs:
        #File: path/to/RootCAs
    Version:

环境变量可以覆盖配置文件中的相关配置,例如:

command: orderer
environment:
  - ORDERER_GENERAL_LOGLEVEL=debug
  - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
  - ORDERER_GENERAL_GENESISMETHOD=file
  - ORDERER_GENERAL_GENESISFILE=/var/hyperledger/orderer/orderer.genesis.block
  - ORDERER_GENERAL_LOCALMSPID=OrdererMSP
  - ORDERER_GENERAL_LOCALMSPDIR=/var/hyperledger/orderer/msp  //orderer.example.com目录下的msp
  # enabled TLS
  - ORDERER_GENERAL_TLS_ENABLED=true
  - ORDERER_GENERAL_TLS_PRIVATEKEY=/var/hyperledger/orderer/tls/server.key
  - ORDERER_GENERAL_TLS_CERTIFICATE=/var/hyperledger/orderer/tls/server.crt
  - ORDERER_GENERAL_TLS_ROOTCAS=[/var/hyperledger/orderer/tls/ca.crt]

peer node

Hyperledger Fabric: peer node

目前(2018-03-28 17:16:26),peer node只有两个子命令:

peer node start
peer node status

peer node start时默认使用配置文件$FABRIC_CFG_PATH/core.yaml

fabric中提供了两个配置示例:

$ find . -name "core.yaml"
./examples/cluster/config/core.yaml
./sampleconfig/core.yaml

core.yaml文件格式如下,下面摘取了主要的配置:

peer:

    id: jdoe                       //peer的id
    networkId: dev                 //peer隶属的网络的id
    listenAddress: 0.0.0.0:7051
    address: 0.0.0.0:7051          //向同组织内的其它peer暴露的接口
    addressAutoDetect: false       //是否自动发现地址,在docker中运行可以使用
    gomaxprocs: -1                 //设置GOMAXPROCS,<1时保留原状

    gossip:                        //流言协议配置
        bootstrap: 127.0.0.1:7051  //初始化地址
        useLeaderElection: true    //是否参与leader选举
        orgLeader: false           //是否手动指定leader
                                   //一个组织内的leader将与order通信获取账本
        endpoint:                  //ID
        maxBlockCountToStore: 100  //在内存中保留的区块数量
        maxPropagationBurstLatency: 10ms  //消息推送的最大时间间隔
        maxPropagationBurstSize: 10       //滞留发送的消息的最大数量
        propagateIterations: 1            //消息被向外发送的次数
        propagatePeerNum: 3               //消息被推送给另外3个peer
        pullInterval: 4s                  //拉取时间间隔
        pullPeerNum: 3                    //从3个peer中拉取消息
        requestStateInfoInterval: 4s
        publishStateInfoInterval: 4s
        stateInfoRetentionInterval:
        publishCertPeriod: 10s
        skipBlockVerification: false
        dialTimeout: 3s
        connTimeout: 2s
        recvBuffSize: 20
        sendBuffSize: 20
        digestWaitTime: 1s
        requestWaitTime: 1s
        responseWaitTime: 2s
        aliveTimeInterval: 5s
        aliveExpirationTimeout: 25s
        reconnectInterval: 25s
        externalEndpoint:         //向其它组织中的peer发布的id,如果为空其它组织不会感知到这个peer

        //选举相关配置
        election: 
            startupGracePeriod: 15s
            membershipSampleInterval: 1s
            leaderAliveThreshold: 10s
            leaderElectionDuration: 5s

    //数据同步配置
    sync:
        blocks:
            channelSize: 10
        state:
            snapshot:
                channelSize: 50
                writeTimeout: 60s
            deltas:
                channelSize: 20

    //如果peer被设置为validator(验证节点),则监听事件
    events:
        address: 0.0.0.0:7053
        buffersize: 100
        timeout: 10
    tls:                    //p2p加密通信
        enabled: true
        cert:
            file: tls/server.crt
        key:
            file: tls/server.key
        rootcert:
            file: tls/ca.crt
        serverhostoverride:    //验证tls证书中的hostname

    fileSystemPath: /var/hyperledger/fabric/peer      //文件存放地址

    BCCSP:                     //指定区块加密算法
        Default: SW
        SW:
            Hash: SHA2
            Security: 256
            FileKeyStore:
                KeyStore:    //默认是'mspConfigPath'/keystore

    mspConfigPath: msp       //msp配置文件地址
    localMspId: Org1MSP      //msp服务id

    profile:                 // go profiling
        enabled:     false
        listenAddress: 0.0.0.0:6060
vm:  //虚拟机或容器的api,以及配置等
     //peer需要以容器的方式启动链码
    endpoint: unix:///var/run/docker.sock
    docker:
        tls:
            enabled: false
            ca:
                file: docker/ca.crt
            cert:
                file: docker/tls.crt
            key:
                file: docker/tls.key
        attachStdout: false
        hostConfig:
            NetworkMode: host
            Dns:
               # - 192.168.0.1
            LogConfig:
                Type: json-file
                Config:
                    max-size: "50m"
                    max-file: "5"
            Memory: 2147483648
chaincode:  //链码配置
    id:
        path:
        name:
    builder: $(DOCKER_NS)/fabric-ccenv:$(ARCH)-$(PROJECT_VERSION)  //链码的编译环境
    golang:
        runtime: $(BASE_DOCKER_NS)/fabric-baseos:$(ARCH)-$(BASE_VERSION)
    car:
        runtime: $(BASE_DOCKER_NS)/fabric-baseos:$(ARCH)-$(BASE_VERSION)
    java:
        Dockerfile: 
            from $(DOCKER_NS)/fabric-javaenv:$(ARCH)-$(PROJECT_VERSION)
    startuptimeout: 300000   //容器启动的超时时间,毫秒
    executetimeout: 30000    //命令的初始化调用超时时间,毫秒
    deploytimeout:  30000    //链码部署的超时时间

    mode: net    //dev模式在本地运行链码,net在容器中运行链码
    keepalive: 0
    system:      //系统链码白名单
        cscc: enable
        lscc: enable
        escc: enable
        vscc: enable
        qscc: enable

    logLevel: warning
    logFormat: '%{color}%{time:2006-01-02 15:04:05.000 MST} [%{module}] %{shortfunc} -> %{level:.4s} %{id:03x}%{color:reset} %{message}'

ledger:   #账本配置
  blockchain:
  state:
    stateDatabase: goleveldb
    couchDBConfig:
       couchDBAddress: 127.0.0.1:5984
       username:
       password:
    historyDatabase: true
    queryLimit: 10000

一个peer的启动示例:

environment:
  - CORE_VM_ENDPOINT=unix:///host/var/run/docker.sock
  # the following setting starts chaincode containers on the same
  # bridge network as the peers
  # https://docs.docker.com/compose/networking/
  - CORE_VM_DOCKER_HOSTCONFIG_NETWORKMODE=${COMPOSE_PROJECT_NAME}_byfn
  - CORE_LOGGING_LEVEL=DEBUG
  - CORE_PEER_TLS_ENABLED=true
  - CORE_PEER_GOSSIP_USELEADERELECTION=true
  - CORE_PEER_GOSSIP_ORGLEADER=false
  - CORE_PEER_PROFILE_ENABLED=true
  - CORE_PEER_TLS_CERT_FILE=/etc/hyperledger/fabric/tls/server.crt
  - CORE_PEER_TLS_KEY_FILE=/etc/hyperledger/fabric/tls/server.key
  - CORE_PEER_TLS_ROOTCERT_FILE=/etc/hyperledger/fabric/tls/ca.crt
  - CORE_PEER_ID=peer0.org1.example.com
  - CORE_PEER_ADDRESS=peer0.org1.example.com:7051
  - CORE_PEER_GOSSIP_EXTERNALENDPOINT=peer0.org1.example.com:7051
  - CORE_PEER_LOCALMSPID=Org1MSP
command: peer node start

查看node的状态

peer channel

生成的channel.tx可以用下面的命令解析:

configtxlator proto_decode --type common.Envelope   --input=output/staging/channel-artifacts/channel.tx

查看channel:

./peer.sh  channel  getinfo -c mychannel

查看peer加入的channel:

./peer.sh  channel  list

peer chaincode

查看已经安装的chaincode:

./peer.sh chaincode  list --installed

查看已经实例化的chaincode:

./peer.sh chaincode  list  --instantiated

接下来…

HyperLedger Fabric全手动、多服务器部署与进阶教程–“主页”中可领优惠券

超级账本HyperLedger的fabric项目部署过程时遇到的问题

更多关于超级账本和区块链的文章

参考

  1. Hyperledger
  2. Fabric
  3. Fabric: Building Your First Network
  4. Hyperledger Fabric Ordering Service
  5. Hyperledger Fabric: Peer Commands
  6. Hyperledger Fabric: Architecture Explained
  7. Hyperledger Fabric: peer node
  8. peer channel creation fails in Hyperledger Fabric
  9. fabirc samples chaincode
  10. Hyperledger Fabric SDKs
  11. github hyperleader
  12. hyperleader fabric-ca
  13. hyperledger的fabric项目的手动部署教程

HyperLedger

  1. hyperledger fabric 1.3.0 多节点手动部署
  2. 【视频】超级账本HyperLedger: Fabric源码走读(一):项目构建与代码结构
  3. 【视频】超级账本HyperLedger: Fabric Go SDK的使用
  4. 【视频】超级账本HyperLedger: Fabric使用kafka进行区块排序(共识)
  5. 超级账本HyperLedger: Fabric 1.2.0使用时遇到的问题
  6. 超级账本HyperLedger: Fabric的Chaincode开发过程中遇到的问题
  7. 【视频】超级账本HyperLedger: 为Fabric的Peer节点配置CouchDB
  8. 【视频】超级账本HyperLedger: Fabric从1.1.0升级到1.2.0
  9. 【视频】超级账本HyperLedger: Fabric源码走读(零):源代码阅读环境准备
  10. 【视频】超级账本HyperLedger: Fabric的Chaincode(智能合约、链码)开发、使用演示
  11. 超级账本HyperLedger: Fabric Node.js SDK使用时遇到的问题
  12. 超级账本HyperLedger: Fabric Golang SDK使用时遇到的问题
  13. 超级账本HyperLedger: FabricCA的级联使用(InterMediateCA)
  14. 【视频】超级账本HyperLedger: 使用Ansible进行Fabric多节点分布式部署(实战)
  15. 超级账本HyperLedger: Fabric掰开揉碎,一文解惑
  16. 超级账本HyperLedger: Fabric Channel配置的读取转换
  17. 【视频】超级账本HyperLedger: Fabric进阶,在已有的Channel中添加新的组织
  18. 超级账本HyperLedger: 超级账本工作组旗下项目介绍
  19. 超级账本HyperLedger: Fabric Chaincode(智能合约、链码)开发方法
  20. 【视频】超级账本HyperLedger: Fabric-CA的使用演示(两个组织一个Orderer三个Peer)
  21. 超级账本HyperLedger: FabricCA的基本概念与用法讲解
  22. 【视频】超级账本HyperLedger: Fabric的全手动、多服务器部署教程
  23. 超级账本HyperLedger: Explorer安装使用
  24. 【视频】超级账本HyperLedger: Fabric nodejs SDK的使用
  25. 超级账本HyperLedger: Fabric部署过程时遇到的问题汇总
  26. 超级账本HyperLedger: Cello部署和使用
  27. 超级账本HyperLedger: Fabric的基本概念与基础用法

推荐阅读

Copyright @2011-2019 All rights reserved. 转载请添加原文连接,合作请加微信lijiaocn或者发送邮件: [email protected],备注网站合作

友情链接:  系统软件  程序语言  运营经验  水库文集  网络课程  微信网文  发现知识星球