在本地 Kubernetes 上快速部署 Hyperledger Fabric 網路

Hyperledger (or the Hyperledger project) is an umbrella project of open source blockchains and related tools, started in December 2015 by the Linux Foundation, to support the collaborative development of blockchain-based distributed ledgers.

brew cask install docker

kubectl create -f https://raw.githubusercontent.com/kubernetes/dashboard/master/src/deploy/recommended/kubernetes-dashboard.yaml

#获取token，复制一条即可
kubectl -n kube-system describe secret `kubectl -n kube-system get secret|grep admin-token|cut -d " " -f1`|grep "token:"|tr -s " "|cut -d " " -f2
#启动一个代理
kubectl proxy

git clone git@github.com:IBM/blockchain-network-on-kubernetes.git
chmod +x setup_blockchainNetwork.sh
chmod +x deleteNetwork.sh
./setup_blockchainNetwork.sh

$ kubectl get pods
NAME                                    READY     STATUS      RESTARTS   AGE
blockchain-ca-77459f9b84-zd8qt          1/1       Running     0          2m
blockchain-orderer-5c88f8cf95-25862     1/1       Running     0          2m
blockchain-org1peer1-7d95cbfd64-wcvz6   1/1       Running     0          2m
blockchain-org2peer1-d85dfcfc7-4kpmz    1/1       Running     0          2m
blockchain-org3peer1-6cffb6cbc7-stnj5   1/1       Running     0          2m
blockchain-org4peer1-84486f557c-pmvq8   1/1       Running     0          2m
chaincodeinstall-skd26                  0/4       Completed   0          1m
chaincodeinstantiate-jm85m              0/1       Completed   0          1m
copyartifacts-kmcp9                     0/1       Completed   0          3m
createchannel-p6ggq                     0/2       Completed   0          2m
joinchannel-lhqnx                       0/4       Completed   0          2m
utils-vr8fr                             0/2       Completed   0          2m

kubectl exec -it blockchain-org1peer1-7d95cbfd64-wcvz6 bash #进入org1节点的bash
root@blockchain-org1peer1-7d95cbfd64-wcvz6:/# peer chaincode query -C channel1 -n cc -c '{"Args":["query","a"]}'

peer chaincode invoke -o blockchain-orderer:31010 -C channel1 -n cc -c '{"Args":["invoke","b","a","51"]}'

command: ["sh", "-c", "echo $GOPATH; cp -r /shared/artifacts/chaincode $GOPATH/src/; ls $GOPATH/src; peer chaincode install -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -p chaincode_example02/"]

peer chaincode instantiate -o blockchain-orderer:31010 -C ${CHANNEL_NAME} -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -c '{\"Args\":[\"init\",\"a\",\"100\",\"b\",\"200\"]}'

func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response;
func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response;
func main()；

./deleteNetwork.sh

package main

import (
	"errors"
	"fmt"
	"strconv"

	"github.com/hyperledger/fabric/core/chaincode/shim"
	pb "github.com/hyperledger/fabric/protos/peer"
)

type GameChainCode struct {
}

func (cc *GameChainCode) Init(stub shim.ChaincodeStubInterface) pb.Response {

	var sum string // Sum of asset holdings across accounts. Initially 0
	var sumVal int // Sum of holdings
	var err error
	_, args := stub.GetFunctionAndParameters()
	if len(args) != 1 {
		return shim.Error("Incorrect number of arguments. Expecting 1")
	}
	// Initialize the chaincode
	sum = args[0]
	sumVal, err = strconv.Atoi(sum)
	if err != nil {
		return shim.Error("Expecting integer value for sum")
	}
	fmt.Printf("sumVal = %d\n", sumVal)
	if sumVal < 100 {
		return shim.Error("init value must bigger than 100")
	}
	// Write the state to the ledger
	err = stub.PutState("total", []byte(strconv.Itoa(sumVal)))
	if err != nil {
		return shim.Error(err.Error())
	}
	return shim.Success(nil)
}

func (cc *GameChainCode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
	function, args := stub.GetFunctionAndParameters()
	if function == "query" {
		return cc.query(stub, args)
	} else if function == "lottery" {
		return cc.lottery(stub, args)
	} else if function == "create_user" {
		return cc.create_user(stub, args)
	}
	return shim.Error("Invalid invoke function name. Expecting query uid,lottery uid token,create_user uid")
}

func (cc *GameChainCode) create_user(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) != 1 {
		return shim.Error("params error")
	}
	uId := args[0]
	balance, err := cc.getBalance(stub, uId)
	if balance < 0 || err != nil {
		stub.PutState(uId, []byte("1000"))
		return shim.Success([]byte("1000"))
	} else {
		return shim.Error("uid has been registed")
	}
}

func (cc *GameChainCode) query(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) == 0 {
		t, err := cc.getTotal(stub)
		if err != nil {
			return shim.Error("get total error!")
		}
		if t < 100 {
			return shim.Success([]byte("false"))
		} else {
			return shim.Success([]byte("true"))
		}
	} else {
		t, err := cc.getBalance(stub, args[0])
		if err != nil {
			return shim.Error("get balance error!")
		} else {
			return shim.Success([]byte(strconv.Itoa(t)))
		}
	}

}

func (cc *GameChainCode) lottery(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) != 2 {
		return shim.Error("params error")
	}
	t, err := cc.getTotal(stub)
	if err != nil {
		return shim.Error("get total error!")
	}
	uId := args[0]
	uWager, err := strconv.Atoi(args[1])
	if err != nil {
		return shim.Error("wager error!")
	}
	err = cc.plus(stub, uId, -uWager)
	if err != nil {
		return shim.Error("balance not enough")
	}

	if (uWager - t) == 0 {
		//hit
		err = cc.plus(stub, uId, uWager+t)
		return shim.Success([]byte("you win! game over!"))
	} else if ((t - uWager) > t>>2) && ((t - uWager) < t>>2+t>>3) {
		err = cc.plus(stub, uId, uWager>>1)
		return shim.Success([]byte("congratulation!!!!"))
	} else {
		err = cc.plus(stub, "total", uWager)
		return shim.Success([]byte("Good Luck Next Time!"))
	}
	return shim.Error("bet error")

}

//plus or minus value of key
func (cc *GameChainCode) plus(stub shim.ChaincodeStubInterface, k string, v int) error {
	Avalbytes, err := stub.GetState(k)
	if err != nil {
		return err
	}
	TotalV, err := strconv.Atoi(string(Avalbytes))
	if err != nil {
		return err
	}
	TotalV += v
	if TotalV < 0 {
		return errors.New("balance not enough")
	}
	stub.PutState(k, []byte(strconv.Itoa(TotalV)))
	return nil
}

func (cc *GameChainCode) getBalance(stub shim.ChaincodeStubInterface, k string) (int, error) {
	Avalbytes, err := stub.GetState(k)
	if err != nil {
		return -1, err
	}
	TotalV, err := strconv.Atoi(string(Avalbytes))
	if err != nil {
		return -1, err
	}
	return TotalV, nil
}

func (cc *GameChainCode) getTotal(stub shim.ChaincodeStubInterface) (int, error) {
	return cc.getBalance(stub, "total")
}

func main() {
	err := shim.Start(new(GameChainCode))
	if err != nil {
		fmt.Printf("Error starting game chaincode: %s", err)
	}
}

peer chaincode instantiate -o blockchain-orderer:31010 -C ${CHANNEL_NAME} -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -c '{\"Args\":[\"init\",\"1024\"]}'

kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["create_user","paper"]}'
#查询余额，看看是不是1000块
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["query","paper"]}'
#投资50，猜一猜
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["lottery","paper","50"]}'
#获得结果 result: status:200 payload:"Good Luck Next Time!"

#再来一次，赌大一点800
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["lottery","paper","800"]}'
#result: status:200 payload:"congratulation!!!!"
#哈哈，中奖了