渔业管理系统智能合约编写

1. 代码准备

创建文件夹

mkdir fish 
cd fish 
mkdir chaincode 
cd chaincode
mkdir fishcc
cd fishcc
npm init

修改package.json，将"test"键值对改成“start”

npm install -save fabric-shim
vi index.js

chiancode基本框架

"use strict";
const shim = require('fabric-shim');
const util = require('util');
let Chaincode = class {
 //初始化智能合约的方法
 async Init(stub) {
 console.info('=========== Instantiated fabcar chaincode ===========');
 return shim.success();
 }
shim.start(new Chaincode());

Invoke函数

 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);
     }
 }

queryFish函数

 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;
 }

initLedger方法

// 根据官方建议,最好的初始化区块链账本的方法是单独编写一个intLedger的方法.

async initLedger(stub, args) {
 console.info('============= 开始 : 初始化账本 ===========');
 let fishes = [];
 fishes.push({
 vessel: "奋进号38A", 
 location: "67.0006, -70.5476", 
 timestamp: "1504054225",
 holder: "王大壮"
 });
 fishes.push({
 vessel: "光明号66B", 
 location: "57.9006, -78.3478", 
 timestamp: "1504054666",
 holder: "高大壮"
 });
 fishes.push({
 vessel: "钓鱼岛58B", 
 location: "77.9034, -75.3455", 
 timestamp: "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('============= 结束 :初始化账本 ===========');
 }

recordFish方法

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

queryAllFish方法

 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.value.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));
         }
     }
 }

changeFishHolder方法

更改小黄鱼的归属人

 async changeFishHolder(stub, args) {
 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 stub.putState(args[0], Buffer.from(JSON.stringify(fish)));
 console.info('============= END : changeFishHolder ===========');
 }
 }

2. 环境准备

配置msp信息crypto-config.yaml

在fish目录下操作

mkdir fisnetwork
cd fishnetwork
mkdir basic-network
cd basic-network
vi crypto-config.yaml

OrdererOrgs:
  - Name: Orderer
    Domain: example.com
    Specs:
      - Hostname: orderer
PeerOrgs:
  - Name: Org1
    Domain: org1.example.com 
    Template:
      Count: 1     
    Users:
      Count: 1

配置组织和排序节点 configtx.yaml

Profiles:
    OneOrgOrdererGenesis:
        Orderer:
            <<: *OrdererDefaults
            Organizations:
                - *OrdererOrg
        Consortiums:
            SampleConsortium:
                Organizations:
                    - *Org1
    OneOrgChannel:
        Consortium: SampleConsortium
        Application:
            <<: *ApplicationDefaults
            Organizations:
                - *Org1
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
Orderer: &OrdererDefaults
    OrdererType: solo
    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:

创建证书目录结构

export PATH=/home/jinyzhi/fabric-samples/bin:${PWD}:$PATH
cryptogen generate --config=./crypto-config.yaml

生成创世区块

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

编写docker-compose.yml配置文件

注意ca的默认密码是adminpw

#
# Copyright IBM Corp All Rights Reserved
#
# SPDX-License-Identifier: Apache-2.0
#
version: '2'

networks:
  basic:

services:
  ca.example.com:
    image: hyperledger/fabric-ca
    environment:
      - FABRIC_CA_HOME=/etc/hyperledger/fabric-ca-server
      - FABRIC_CA_SERVER_CA_NAME=ca.example.com
      - FABRIC_CA_SERVER_CA_CERTFILE=/etc/hyperledger/fabric-ca-server-config/ca.org1.example.com-cert.pem
      - FABRIC_CA_SERVER_CA_KEYFILE=/etc/hyperledger/fabric-ca-server-config/4239aa0dcd76daeeb8ba0cda701851d14504d31aad1b2ddddbac6a57365e497c_sk
    ports:
      - "7054:7054"
    command: sh -c 'fabric-ca-server start -b admin:adminpw -d'
    volumes:
      - ./crypto-config/peerOrganizations/org1.example.com/ca/:/etc/hyperledger/fabric-ca-server-config
    container_name: ca.example.com
    networks:
      - basic

  orderer.example.com:
    container_name: orderer.example.com
    image: hyperledger/fabric-orderer
    environment:
      - ORDERER_GENERAL_LOGLEVEL=debug
      - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
      - ORDERER_GENERAL_GENESISMETHOD=file
      - ORDERER_GENERAL_GENESISFILE=/etc/hyperledger/configtx/genesis.block
      - ORDERER_GENERAL_LOCALMSPID=OrdererMSP
      - ORDERER_GENERAL_LOCALMSPDIR=/etc/hyperledger/msp/orderer/msp
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric/orderer
    command: orderer
    ports:
      - 7050:7050
    volumes:
        - ./config/:/etc/hyperledger/configtx
        - ./crypto-config/ordererOrganizations/example.com/orderers/orderer.example.com/:/etc/hyperledger/msp/orderer
        - ./crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/:/etc/hyperledger/msp/peerOrg1
    networks:
      - basic

  peer0.org1.example.com:
    container_name: peer0.org1.example.com
    image: hyperledger/fabric-peer
    environment:
      - CORE_VM_ENDPOINT=unix:///host/var/run/docker.sock
      - CORE_PEER_ID=peer0.org1.example.com
      - CORE_LOGGING_PEER=debug
      - CORE_CHAINCODE_LOGGING_LEVEL=DEBUG
      - CORE_PEER_LOCALMSPID=Org1MSP
      - CORE_PEER_MSPCONFIGPATH=/etc/hyperledger/msp/peer/
      - CORE_PEER_ADDRESS=peer0.org1.example.com:7051
      # # 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}_basic      
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric
   #  command: peer node start
    command: peer node start --peer-chaincodedev=true
    ports:
      - 7051:7051
      - 7052:7052
      - 7053:7053
    volumes:
        - /var/run/:/host/var/run/
        - ./crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/msp:/etc/hyperledger/msp/peer
        - ./crypto-config/peerOrganizations/org1.example.com/users:/etc/hyperledger/msp/users
        - ./config:/etc/hyperledger/configtx
    depends_on:
      - orderer.example.com
    networks:
      - basic 

  cli:
    container_name: cli
    image: hyperledger/fabric-tools
    tty: true
    environment:
      - GOPATH=/opt/gopath
      - CORE_VM_ENDPOINT=unix:///host/var/run/docker.sock
      - CORE_LOGGING_LEVEL=DEBUG
      - CORE_PEER_ID=cli
      - CORE_PEER_ADDRESS=peer0.org1.example.com:7051
      - CORE_PEER_LOCALMSPID=Org1MSP
      - CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp
      - CORE_CHAINCODE_KEEPALIVE=10
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric/peer
    command: /bin/bash
    volumes:
        - /var/run/:/host/var/run/
        - ./../chaincode/:/opt/gopath/src/github.com/
        - ./crypto-config:/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/
    networks:
        - basic
    #depends_on:
    #  - orderer.example.com
    #  - peer0.org1.example.com
    #  - couchdb

编写启动脚本 start.sh

#!/bin/bash
set -ev
# don't rewrite paths for Windows Git Bash users
export MSYS_NO_PATHCONV=1​
docker-compose -f docker-compose.yml down​
docker-compose -f docker-compose.yml up -d ca.example.com orderer.example.com peer0.org1.example.com ​
export FABRIC_START_TIMEOUT=30
sleep ${FABRIC_START_TIMEOUT}​
# Create the channel
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/etc/hyperledger/msp/users/Admin@org1.example.com/msp" peer0.org1.example.com peer channel create -o orderer.example.com:7050 -c mychannel -f /etc/hyperledger/configtx/channel.tx
# Join peer0.org1.example.com to the channel.
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/etc/hyperledger/msp/users/Admin@org1.example.com/msp" peer0.org1.example.com peer channel join -b mychannel.block

编写startFabirc.sh脚本（在/fish/fishnetwork/webapp目录下）

#!/bin/bash
set -e
# don't rewrite paths for Windows Git Bash users
export MSYS_NO_PATHCONV=1
starttime=$(date +%s)
LANGUAGE=node
CC_SRC_PATH=/opt/gopath/src/github.com/fishcc
# clean the keystore
rm -rf ./hfc-key-store
# launch network; create channel and join peer to channel
cd ../basic-network
./start.sh
# Now launch the CLI container in order to install, instantiate chaincode
docker-compose -f ./docker-compose.yml up -d cli
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode install -n fishcc -v 1.0 -p "$CC_SRC_PATH" -l node
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode instantiate -o orderer.example.com:7050 -C mychannel -n fishcc -l node -v 1.0 -c '{"Args":[""]}' -P "OR ('Org1MSP.member','Org2MSP.member')"
sleep 20
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode invoke -o orderer.example.com:7050 -C mychannel -n fishcc -c '{"function":"initLedger","Args":[""]}'
printf "\n脚本启动时间 : $(($(date +%s) - starttime)) 秒 ...\n\n\n"
printf "执行'npm install' 安装依赖文件\n"
printf "执行 'node enrollAdmin.js', 创建管理员, 然后执行 'node registerUser'创建用户\n\n"
printf "执行 'node invoke.js' 调用函数\n"
printf "执行 'node query.js' 查询记录\n\n"

打开执行权限

chmod 777 startFabric.sh
cd ../basic-network
chmod 777 start.sh

环境变量赋值、启动
将channel-artifacts文件夹中的文件复制到config文件夹中

cd  ../webapp
export COMPOSE_PROJECT_NAME=net
./startFabric.sh

手动启动chaincode
进入chaincode文件夹

CORE_CHAINCODE_ID_NAME="fishcc:1.0"  npm start -- --peer.address grpc://172.17.0.1:7052
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。