hyperledgerfabric1.0部署实操一

2019独角兽企业重金招聘Python工程师标准>>>

我操作的系统环境是ubuntu16.04&＃xff0c;如果你的系统是windows&＃xff0c;先安装一个virtualbox。

1 oracle virtual Box 5.1.26安装配置

1.1 虚拟机安装

1、新建&＃xff5b;名字&＃xff1a;超级账本1.0&＃xff1b;linux&＃xff1b;ubuntu桌面版16&＃xff0c;0.4 64bit&＃xff5d; --64位需要更改bios以支持虚拟化&＃xff0c;事先下好ubuntu镜像&＃xff1b;

2、分内存2G&＃xff0c;创建虚拟硬盘&＃xff0c;文件类型选VDI模式&＃xff0c;把文件设置为保存在E盘&＃xff0c;分上20G以上&＃xff1b;

3、开始安装ubuntu&＃xff0c;我用到版本是16.4桌面版&＃xff0c;选中文简体&＃xff0c;勾选“安装ubuntu是下载更新”&＃xff0c;选择“其他选项”&＃xff0c;自己手工设置分区&＃xff1b;

4、分区的设置&＃xff1a;分给交换分区500m&＃xff0c;分给/boot300m&＃xff0c;其他的都分给/根目录&＃xff0c;其中根目录是主分区&＃xff0c;其他逻辑分区&＃xff1b;

5、时区选上海&＃xff0c;语言默认汉语即可&＃xff1b;

1.2 共享粘贴板、共享文件夹的设置

1&＃xff09;运行设备-安装增强功能

2&＃xff09;设备-共享粘帖板&＃xff0c;选择双向

---重启系统&＃xff0c;增强功能生效

3&＃xff09;设备-共享文件夹&＃xff0c;点选右侧增加按钮添加共享文件夹&＃xff0c;在弹出框设置如下&＃xff1a;

l 共享文件夹路径&＃xff0c;选“其他”&＃xff0c;然后选择你本机的共享文件夹&＃xff08;例如我的D:\share&＃xff09;;

l 勾选“固定分配”&＃xff1b;

mkdir /mnt/share/ sudo mount -t vboxsf share /mnt/share/

1.3 ssh配置

sudo apt-get install openssh-server 2 hyperdeger fabric1.0安装

登陆你刚装好的virtualbox&＃xff0c;先配置环境&＃xff1a;

lsb_release -a &＃xff08;查询自己系统的版本号&＃xff0c;我的是xenial&＃xff0c;下面找源的时候要对应上&＃xff09; cp /etc/apt/sources.list /etc/apt/sources.list.bak vim /etc/apt/sources.list

修改源内容&＃xff08;完全替换掉就内容&＃xff09;&＃xff1a;

先清空旧的内容&＃xff0c;在命令模式下输入&＃xff1a;

ggdG

然后切换到插入模式拷贝以下内容粘贴过去&＃xff08;输入i即可切换到输入模式&＃xff0c;按esc键切换回命令模式&＃xff0c;在命令模式输入:wq进行保存&＃xff09;&＃xff1a;

#deb包 deb http://mirrors.aliyun.com/ubuntu/ xenial main restricted universe multiverse deb http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted universe multiverse deb http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted universe multiverse deb http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse ##测试版源 deb http://mirrors.aliyun.com/ubuntu/ xenial-proposed main restricted universe multiverse # 源码 deb-src http://mirrors.aliyun.com/ubuntu/ xenial main restricted universe multiverse deb-src http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted universe multiverse deb-src http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted universe multiverse deb-src http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse ##测试版源 deb-src http://mirrors.aliyun.com/ubuntu/ xenial-proposed main restricted universe multiverse

修改DNS&＃xff1a;

sudo vim /etc/resolvconf/resolv.conf.d/base nameserver 202.96.134.133 nameserver 8.8.8.8 sudo resolvconf -u

更新源:

sudo apt update

安装crul:

sudo apt install curl

如果git默认没有安装也执行安装&＃xff1a;

sudo apt install git

设置git参数&＃xff1a;

git config --global http.postBuffer 524288000

2.1 配置docker

从daocloud安装docker:

curl -sSL https://get.daocloud.io/docker | sh

添加当前用户到docker:

sudo usermod -aG docker zpc sudo gpasswd -a zpc docker newgrp - docker

修改 Docker 服务配置:

sudo vim /etc/default/docker 添加 DOCKER_OPTS&＃61;"$DOCKER_OPTS -H tcp://0.0.0.0:2375 -H unix:///var/run/docker.sock --api-cors-header&＃61;&＃39;*&＃39;"

设置国内Daocloud的Docker加速器地址&＃xff1a;

curl -sSL https://get.daocloud.io/daotools/set_mirror.sh | sh -s http://8d37c888.m.daocloud.io 重启dockersudo service docker restart

测试&＃xff1a;

docker -v docker pull hello-world docker run hello-world

2.2 配置docker-compse

安装pip:

sudo apt-get install python-pip

修改权限&＃xff1a;

su - zpc sudo chmod &＃43;x /usr/local/bin/docker-compose

查看安装的版本&＃xff1a;

docker-compose -v

2.3 安装配置GO

查看本地源中go的版本 apt-cache madison golang 如果版本低则手动从官网下载安装&＃xff08;当前是1.9&＃xff09; wget --no-check-certificate https://studygolang.com/dl/golang/go1.9.2.linux-amd64.tar.gz ##如果此链接地址不好用换这个https://dl.gocn.io/golang/1.9.2/go1.9.2.linux-amd64.tar.gz sudo tar -C /usr/local -xzf go1.9.2.linux-amd64.tar.gz vi ~/.profile export PATH&＃61;$PATH:/usr/local/go/bin export GOROOT&＃61;/usr/local/go export GOPATH&＃61;$HOME/go export PATH&＃61;$PATH:$HOME/go/binsource ~/.profile cd ~ mkdir gogo version

2.4 安装配置node、npm、cnpm

用nvm安装node与npm

curl -o- https://raw.githubusercontent.com/creationix/nvm/v0.33.6/install.sh | bash 关闭重启终端 nvm ls-remote nvm install v9.1.0

cnpm配置&＃xff1a;

npm install -g cnpm --registry&＃61;https://registry.npm.taobao.org

2.5 下载fabric

mkdir -p ~/go/src/github.com/hyperledger cd ~/go/src/github.com/hyperledger git clone https://github.com/hyperledger/fabric.git cd ~/go/src/github.com/hyperledger/fabric git init git checkout -b v1.0.0 3 e2e_cli样例实操

e2e_cli是fabric下面的一个独立样例&＃xff1a;与e2e_cli同级的还有

cd ~/go/src/github.com/hyperledger/fabric/examples/e2e_cli/ 下载fabric相关镜像&＃xff1a; source download-dockerimages.sh -c x86_64-1.0.0 -f x86_64-1.0.0

启动fabric

./network_setup.sh up

OK了之后&＃xff0c;以下尝试一些简单操作&＃xff1a;

另行打开一个命令行

docker exec -it cli bash

查询A账户余额

peer chaincode query -C mychannel -n mycc -c &＃39;{"Args":["query","a"]}&＃39;

查询结果应该有90

把a账户的余额再转20元给b账户

peer chaincode invoke -o orderer.example.com:7050 --tls true --cafile /opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/ordererOrganizations/example.com/orderers/orderer.example.com/msp/tlscacerts/tlsca.example.com-cert.pem -C mychannel -n mycc -c &＃39;{"Args":["invoke","a","b","20"]}&＃39;

再查询a账户看是否剩下70了

退出cli容器 exit cd ~/go/src/github.com/hyperledger/fabric/examples/e2e_cli 关闭fabric ./network_setup.sh down

用node客户端sdk在节点本地连接操作区块链

mkdir ~/nodeTest cd ~/nodeTest vi package.json{ "name": "nodeTest", "version": "1.0.0", "description": "Hyperledger Fabric Node SDK Test Application", "scripts": { "test": "echo \"Error: no test specified\" && exit 1" }, "dependencies": { "fabric-ca-client": "^1.0.0", "fabric-client": "^1.0.0" }, "author": "zpc", "license": "Apache-2.0", "keywords": [ "Hyperledger", "Fabric", "Test", "Application" ] }

npm install --registry&＃61;https://registry.npm.taobao.org &＃xff08;走国内淘宝的镜像&＃xff09;

vi query.js

&＃39;use strict&＃39;;var hfc &＃61; require(&＃39;fabric-client&＃39;); var path &＃61; require(&＃39;path&＃39;); var sdkUtils &＃61; require(&＃39;fabric-client/lib/utils&＃39;) var fs &＃61; require(&＃39;fs&＃39;); var options &＃61; { user_id: &＃39;Admin&＃64;org1.example.com&＃39;, msp_id:&＃39;Org1MSP&＃39;, channel_id: &＃39;mychannel&＃39;, chaincode_id: &＃39;mycc&＃39;, network_url: &＃39;grpcs://localhost:7051&＃39;,//因为启用了TLS&＃xff0c;所以是grpcs,如果没有启用TLS&＃xff0c;那么就是grpc privateKeyFolder:&＃39;/home/zpc/go/src/github.com/hyperledger/fabric/examples/e2e_cli/crypto-config/peerOrganizations/org1.example.com/users/Admin&＃64;org1.example.com/msp/keystore&＃39;, signedCert:&＃39;/home/zpc/go/src/github.com/hyperledger/fabric/examples/e2e_cli/crypto-config/peerOrganizations/org1.example.com/users/Admin&＃64;org1.example.com/msp/signcerts/Admin&＃64;org1.example.com-cert.pem&＃39;, tls_cacerts:&＃39;/home/zpc/go/src/github.com/hyperledger/fabric/examples/e2e_cli/crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/tls/ca.crt&＃39;, server_hostname: "peer0.org1.example.com" };var channel &＃61; {}; var client &＃61; null; const getKeyFilesInDir &＃61; (dir) &＃61;> { //该函数用于找到keystore目录下的私钥文件的路径 var files &＃61; fs.readdirSync(dir) var keyFiles &＃61; [] files.forEach((file_name) &＃61;> { let filePath &＃61; path.join(dir, file_name) if (file_name.endsWith(&＃39;_sk&＃39;)) { keyFiles.push(filePath) } }) return keyFiles } Promise.resolve().then(() &＃61;> { console.log("Load privateKey and signedCert"); client &＃61; new hfc(); var createUserOpt &＃61; { username: options.user_id, mspid: options.msp_id, cryptoContent: { privateKey: getKeyFilesInDir(options.privateKeyFolder)[0], signedCert: options.signedCert } } //以上代码指定了当前用户的私钥&＃xff0c;证书等基本信息 return sdkUtils.newKeyValueStore({ path: "/tmp/fabric-client-stateStore/" }).then((store) &＃61;> { client.setStateStore(store) return client.createUser(createUserOpt) }) }).then((user) &＃61;> { channel &＃61; client.newChannel(options.channel_id); let data &＃61; fs.readFileSync(options.tls_cacerts); let peer &＃61; client.newPeer(options.network_url, { pem: Buffer.from(data).toString(), &＃39;ssl-target-name-override&＃39;: options.server_hostname } ); peer.setName("peer0"); //因为启用了TLS&＃xff0c;所以上面的代码就是指定TLS的CA证书 channel.addPeer(peer); return; }).then(() &＃61;> { console.log("Make query"); var transaction_id &＃61; client.newTransactionID(); console.log("Assigning transaction_id: ", transaction_id._transaction_id); //构造查询request参数 const request &＃61; { chaincodeId: options.chaincode_id, txId: transaction_id, fcn: &＃39;query&＃39;, args: [&＃39;a&＃39;] }; return channel.queryByChaincode(request); }).then((query_responses) &＃61;> { console.log("returned from query"); if (!query_responses.length) { console.log("No payloads were returned from query"); } else { console.log("Query result count &＃61; ", query_responses.length) } if (query_responses[0] instanceof Error) { console.error("error from query &＃61; ", query_responses[0]); } console.log("Response is ", query_responses[0].toString());//打印返回的结果 }).catch((err) &＃61;> { console.error("Caught Error", err); });