Hyperledger Fabric 链码开发-常用函数_fabric中invokechaincode函数

目前，Fabric的开发主要分为两部分，一是链码及智能合约的开发，二是基于SDK的应用开发。我们一般提到区块链都会关注智能合约的开发，因为它是区块链与外部连接的触手，同时，也是区块链实现自动执行，减少人为干预的重要手段。但是区块链要实现与业务系统的对接，仅仅靠智能合约是无法实现的，它还需要SDK以及相关应用的开发。

Blockchain结构

除了header指向下一个block的hash value外，block是由一组transaction构成, Transactions --> Blocks --> Ledger。

1. Chaincode是生成transacton的唯一方式，是外界与区块链系统交互的唯一渠道，开发Fabric区块链应用就是编写Chaincode, Chaincode就是业务逻辑实现

2. Fabric预先定义了Chaincode接口，Chaincode实际上是一种接口的实现（理论上编程语言都可以去实现这些接口，目前支持go, java）,以下是必须要实现的接口

type Chaincode interface {
   
    // deploy transaction被调用，一般只调用一次
    Init(stub ChaincodeStubInterface) pb.Response

    // 查询或更新账本，可多次调用
    Invoke(stub ChaincodeStubInterface) pb.Response
}
1
2
3
4
5
6
7
8

3. Chaincode编写好后，需要部署在Fabric的节点上, 运行在Docker容器中（开发chaincode的时候建议本地调试）

Chaincode 结构

shim.ChaincodeStubInterface 接口有三个方法，分别是：Init、Query 和 Invoke

包

package main
1

导入库

import (
	"fmt"
	"strconv"

	"github.com/hyperledger/fabric/core/chaincode/shim"
	pb "github.com/hyperledger/fabric/protos/peer"
)
1
2
3
4
5
6
7

定义类

type SimpleChaincode struct {
   
}
1
2
3

Init 方法

负责初始化工作，链码首次部署到区块链网络时调用，将由部署自己的链代码实例的每个对等节点执行。此方法可用于任何与初始化、引导或设置相关的任务。

func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response {
   
}
1
2
3

Query

只要在区块链状态上执行任何读取/获取/查询操作，就需要调用 Query 方法。如果尝试在 Query 方法内修改区块链的状态，将会抛出异常。

Invoke

此方法主要是做修改操作，但是很多例子中一些用户也在 Invoke 做查询。

put, get, del 等操作都在可以在 Invoke 中运行

func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
   
}
1
2
3

参考例子

func (s *SmartContract) Invoke(stub shim.ChaincodeStubInterface) sc.Response {
   

	// Retrieve the requested Smart Contract function and arguments
	function, args := stub.GetFunctionAndParameters()
	// Route to the appropriate handler function to interact with the ledger appropriately
	if function == "balanceToken" {
   
		return s.balanceToken(stub, args)
	} else if function == "initLedger" {
   
		return s.initLedger(stub)
	} else if function == "transferToken" {
   
		return s.transferToken(stub, args)
	}

	return shim.Error("Invalid Smart Contract function name.")
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

在 Invoke 函数中，首先使用 stub.GetFunctionAndParameters() 获取合约函数 function, args := stub.GetFunctionAndParameters() 然后判断函数名称，实现对应的逻辑关系。 if function == “balanceToken” { return s.balanceToken(stub, args) } else if function == “initLedger” { return s.initLedger(stub) } else if function == “transferToken” { return s.transferToken(stub, args) }

func main()

任何 Go 程序的都需要 main 函数，他是程序的入口，因此该函数被用于引导/启动链代码。当对peer节点部署chaincode并实例化时，就会执行 main 函数。

func main() {
   
	err := shim.Start(new(SimpleChaincode))
	if err != nil {
   
		fmt.Printf("Error starting Simple chaincode: %s", err)
	}
}
shim.Start(new(SampleChaincode)) 启动链代码并注册到peer 节点。

 
1
2
3
4
5
6
7
8
9
10
11
12

shim.ChaincodeStubInterface 接口

Hyperledger提供基于key/value的数据存储，其中key是字符串，value则是二进制字节数组，Hyperledger的Go API提供了三个方法用于数据存取：PutState（key, value）用于向Hyperledger中存储数据， GetState(key)用于从Hyperledger中提取数据，而DelState(key)则从Hyperledger中删除数据。

写入数据如果是 struct 结构体，需要序列化，通常使用 json,其他形式的序列化也可以，只要能反序列化即可。

增，删，查 操作

PutState（key, value）写入区块

写入区块联系

func (s *SmartContract) initLedger(stub shim.ChaincodeStubInterface) sc.Response {
   
	
	token := &Token{
   
		Owner: "netkiller",
		TotalSupply: 10000,
		TokenName: 
1
2
3
4
5
6
7
8