概念回顾

Hyperledger的工作流程

解决双花问题：将并行的事情变成串行

fabric架构图

数据库

前后端开发环境搭建

Chaincode实战

![在这里插入图片描述](https://img-blog.csdnimg.cn/20201128213144697.png?x-oss-process=image/watermark,type_ZmF

渔业管理系统只智能合约使用nodejs的编写

1. 初始化nodejs项目

npm init

2. 安装智能合约所用到的库

npm install --save fibric-shim

3.创建index.js文件

'use strict';
const shim = require('fabric-shim');
const util = require('util');

let Chaincode = class {
        //初始化智能合约的方法
        async Init(stub){
                console.info('=============Instantiated fish chaincode===============');
                return shim.success();
        }

        async Invoke(stub){
                let ret = stub.getFunctionAndParameters();
                console.info(ret);

                let method = this[ret.fcn];
                if(!method){
                        console.error('找不到要调用的函数和函数,函数名:'+ret.fcn);
                        throw new Error('找不到要调用的函数,函数名:'+ret.fcn);
                }
                try{
                        let payload = await method(stub, ret.params);//直接调用函数，获取返回值
                        return shim.success(payload);
                } catch(err){
                        console.log(err);
                        return shim.error(err);
                }
        }

        //查询账本中的世界状态
        async queryFish(stub, args){
                if(args.length != 1){
                        throw new Error('错误的调用参数,实例:FISH01');
                }
                let fishNumber = args[0];
                let fishAsBytes = await stub.getState(fishNumber);//从账本中获取fish的信息，账本是二进制存储的
                if(!fishAsBytes !! fishAsBytes.toString().length <= 0){
                        throw new Error(fishAsBytes + '不存在：');
                }
                console.log(fishAsBytes.toString());
                return fishAsBytes;
        }

        //初始化账本
        async initLedger(stub, args) {
        console.info('=========开始: 初始化账本========');
        let fishes = [ ];
        fishes.push({
                vessel: "奋进号38A",
                location: "67.0086, -70. 5476",
                timestamp: "1584054225",
                holder: "王大杜"
        });
        fishes.push({
                vessel: "光明号668",
                location: "57.9086, -78. 3478",
                timestamp: "1504054666",
                holder: "高大壮"
        });
        fishes.push({
                vessel: "钓鱼岛58B",
                location: "77.9034, -75.3455",
                tinestamp: "1504054888",
                holder: "刘胡兰"
        });
        for (let i = 0; i < fishes.length; i++) {
                await stub.putState('Fish'+i,Buffer.from(JSON.stringify(fishes[i])));
                console.info( 'Added <---->', fishes[i]);
        }
        console.info('===============结束：初始化账本============');
        }

        //记录捕捞的鱼
        async recordFish(stub,args){
                console.info('============START : record fish===========');
                if(args.length != 5){
                        throw new Error('需要5个参数，第0个参数是id，后面四个参数，vessel,location,timestamp,holder');
                }
                var fish = {
                        vessel: args[0],
                        location: args[2],
                        timestamp: args[3],
                        holder: args[4]
                }
                await stub.putState(args[0],Buffer.from(JSON.stringify(fish)));
                console.info('==================END : record fish===============');

        }

        //查询所有的鱼
        async queryAllFish(stub, args) {
        let startKey ="FISH0';
        let endkey = 'FISH999';
        let iterator = await stub. getStateByRange(startKey, endKey);

        let allResults = [];
        while (true) {
                let res = await iterator.next();

                if (res.value && res.value.value.tostring()) {
                        let jsonRes = {};
                        console.log(res.value.value.toString('utf8'));
                        jsonRes.Key = res.value.key;
                        try{
                                jsonRes.Record = JSON. parse(res.value.value.toString('utf8'));
                        }catch (err) {
                                console.log(err);
                                jsonRes.Record = res.value.valve.tostring('utf8' );
                        }
                        allResults.push(jsonRes);
                }
                if (res.done) {
                        console.log('end of data');
                        await iterator.close();
                        console. info(allResults);
                        return Buffer.from(JSON.stringify(allResults));
                }
        }
        }

        //更改小黄鱼的归属人
        async changeFishHolder(){
                console.info('==================START : changeFishHolder============');
                if(args.length != 2){
                        throw new Error('参数数量错误，需要两个参数');
                }

                let fishAsBytes = await stub.getState(args[0]);
                let fish  = JSON.parse(fishAsBytes);
                fish.holder = args[1];

                await syub.putState(args[0], Buffer.from(JSON.stringify(fish)));
                conlose.info('=========END: changeFishHolder============');


        }

}

shim.start(new Chaincode);

4. 创建first-network网络，在firstnetwork文件配置相关的配置文件。
   配置MSP信息，crypto-config.yaml文件，生成证书信息。
   
   

配置组织和排序节点configtx.yaml文件，配置节点如何工作等等，节点信息和创始区块等。

5. 配置文件的规则已经设置好，需要工具去生成相应的区块等初始信息。
生成证书的目录结构：执行以下命令

cryptogen generate --config ./crypto-config.yaml
#cryptogen 命令的使用是fabric二进制文件提供的，需要将cryptogen 需要配置到环境变量中去，该二进制文件在
/opt/gopath/src/text_demo/fabric-samples/bin目录下
执行以下命令
export PATH=/opt/gopath/src/text_demo/fabric-samples/bin:$PATH

执行完显示

执行以下命令指定四级目录

tree -L 4

创始区块的配置的生成

mkdir channel-artifacts
configtxgen -profile OneOrgOrdererGenesis -outputBlock ./channel-artifacts/genesis.block 
configtxgen -profile OneOrgChannel -outputCreateChannelTx ./channel-artifacts/channel.tx -channelID mychannel
tree -L 4

编写docker-compose.yml配置文件 执行docker容器

具体步骤

具体步骤看一下链接