懂哪写哪，随时补充
链码结构 链码API链码在开发过程中需要实现链码接口，交易的类型决定了哪个接口函数将会被调用，链码的接口定义如下：
type Chaincode interface {
Init(stub ChaincodeStubInterface) pb.Response
Invoke(stub ChaincodeStubInterface) pb.Response
}
链码的必要结构如下：
package main
//引入必要的包
import(
"github.com/hyperledger/fabric/core/chaincode/shim"
pb"github.com/hyperledger/fabric/protos/peer"
)
//声明一个结构体
type SimpleChaincode struct {}
//为结构体添加Init方法
func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response{
//在该方法中实现链码初始化或升级时的处理逻辑
//编写时可灵活使用stub中的API
}
//为结构体添加Invoke方法
func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response{
//在该方法中实现链码运行中被调用或查询时的处理逻辑
//编写时可灵活使用stub中的API
}
//主函数，需要调用shim.Start（ ）方法
func main() {
err:=shim.Start(new(SimpleChaincode))
if err != nil {
fmt.Printf("Error starting Simple chaincode: %s", err)
}
}
shim.ChaincodeStubInterface接口
参数读取APIGetArgs() [][]byte
//以byte数组的数组的形式获得传入的参数列表
GetStringArgs() []string
//以字符串数组的形式获得传入的参数列表
GetFunctionAndParameters() (string, []string)
//将字符串数组的参数分为两部分，第一个参数作为被调用的函数名称，剩下的参数作为函数的执行参数（若交易只有一个参数，则为空列表）
GetArgsSlice() ([]byte, error)
//以byte切片的形式获得参数列表
eg:
function, args := stub.GetFunctionAndParameters()
1、Init方法
Init方法中，首先通过stub的GetFunctionAndParameters（）方法提取本次调用的交易中所指定的参数：
_, args := stub.GetFunctionAndParameters()
//本例中，用下划线忽略了返回的function值，用args变量记录其他参数。
接下来检查args参数数量，必须为4，否则会通过shim.Error（）函数创建并返回一个状态为ERROR的Response消息：
if len(args) != 4 {
return shim.Error("Incorrect number of arguments. Expecting 4")
}
分别读取4个参数。设用该链码实现转账的两个实体分别为a和b，则A、Aval、B、Bval的值分别表示a的名称、a的初始余额、b的名称、b的初始余额：
A = args[0]
Aval, err = strconv.Atoi(args[1])//strconv.Atoi()将string类型转为int类型
if err != nil {
return shim.Error("Expecting integer value for asset holding")
}
B = args[2]
Bval, err = strconv.Atoi(args[3])
if err != nil {
return shim.Error("Expecting integer value for asset holding")
}
之后，最为关键的是将必要的状态值记录到分布式账本中。stub的PutState（）函数可以尝试在账本中添加或更新一对键值（需要等待Committer节点验证通过，才真正写入账本得到确认）。
Pustate（）方法格式为PutState（key string，value[]byte）error，其中key为键，类型是string；value为值，类型是字节数组。以下代码向账本中存入了两对键值，分别记录了a和b的余额：
err = stub.PutState(A, []byte(strconv.Itoa(Aval)))
if err != nil {
return shim.Error(err.Error())
}
err = stub.PutState(B, []byte(strconv.Itoa(Bval)))
//strconv.Itoa函数的参数是一个整型数字，它可以将数字转换成对应的字符串类型的数字。
if err != nil {
return shim.Error(err.Error())
}
最后，通过shim.Success（nil）创建并返回状态为OK的Response消息。
2、Invoke方法
Invoke方法中，同样通过stub的GetFunctionAndParameters（）方法提取本次调用的交易中所指定的参数：
unction, args := stub.GetFunctionAndParameters()
之后根据function值的不同，执行不同的分支处理逻辑。
本例在Invoke中实现了三个分支处理逻辑：query、invoke和delete。由代码可见，为每个分支的处理逻辑都编写了一个方法：
if function == "invoke" {
return t.invoke(stub, args)
} else if function == "delete" {
return t.delete(stub, args)
} else if function == "query" {
return t.query(stub, args)
}
链码代码可参考examples/chaincode/go/marbles02/marbles_chaincode.go。
1、链码结构：
package main
// 引入必要的包
import (
"bytes"
"encoding/json"
"fmt"
"strconv"
"strings"
"time"
"github.com/hyperledger/fabric/core/chaincode/shim"
pb "github.com/hyperledger/fabric/protos/peer"
)
// 声明名为SimpleChaincode的结构体
type SimpleChaincode struct {
}
// 声明大理石（marble）结构体
type marble struct {
ObjectType string `json:"docType"`
Name string `json:"name"`
Color string `json:"color"`
Size int `json:"size"`
Owner string `json:"owner"`
}
// 主函数，需要调用shim.Start()方法
func main() {
err := shim.Start(new(SimpleChaincode))
if err != nil {
fmt.Printf("Error starting Simple chaincode: %s", err)
}
}
// 为SimpleChaincode添加Init方法
func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response {
// 不做具体处理
return shim.Success(nil)
}
// 为SimpleChaincode添加Invoke方法
func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
function, args := stub.GetFunctionAndParameters()
fmt.Println("invoke is running " + function)
// 定位到不同的分支处理逻辑
if function == "initMarble" {
return t.initMarble(stub, args)
} else if function == "transferMarble" {
return t.transferMarble(stub, args)
} else if function == "transferMarblesBasedOnColor" {
return t.transferMarblesBasedOnColor(stub, args)
} else if function == "delete" {
return t.delete(stub, args)
} else if function == "readMarble" {
return t.readMarble(stub, args)
} else if function == "queryMarblesByOwner" {
return t.queryMarblesByOwner(stub, args)
} else if function == "queryMarbles" {
return t.queryMarbles(stub, args)
} else if function == "getHistoryForMarble" {
return t.getHistoryForMarble(stub, args)
} else if function == "getMarblesByRange" {
return t.getMarblesByRange(stub, args)
}
fmt.Println("invoke did not find func: " + function) // error
return shim.Error("Received unknown function invocation")
}
在链码中，可以自定义结构体类型来表示一种资产，并设定资产的各种属性。本例中定义了大理石（marble）资产，其属性包括类型、名称、颜色、尺寸、拥有者。具体映射到代码中，对marble类型的声明如下：
type marble struct {
ObjectType string `json:"docType"`
Name string `json:"name"`
Color string `json:"color"`
Size int `json:"size"`
Owner string `json:"owner"`
}
2、Invoke方法
链码的Init方法中未进行任何处理，Invoke方法中则包含了9个分支方法。
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xDANxHBW-1652562140847)(D:\阿童学习笔记大全\Hyperledger\插图\案例二invoke分支.png)]
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-EDmLLLL0-1652562140849)(D:\阿童学习笔记大全\Hyperledger\插图\案例二invoke分支2.png)]
下面对分支方法逐一进行介绍。
initMarble方法initMarble方法根据输入参数创建一个大理石，并写入账本。
方法接受4个参数，依次表示大理石名称、颜色、尺寸、拥有者名称。例如，如果调用链码时指定参数**{“Args”： [“initMarble”，“marble1”，“blue”，“35”，“tom”]}**，则功能为创建并记录一个名称为marble1、蓝色、尺寸为 35的大理石，拥有者为tom。
读取参数后，首先使用stub.GetState（）进行查重。如果同样名称的大理石在账本中已经存在，则返回error的Response：
// 检查大理石是否已经存在
marbleAsBytes, err := stub.GetState(marbleName)
if err != nil {
return shim.Error("Failed to get marble: " + err.Error())
} else if marbleAsBytes != nil {
fmt.Println("This marble already exists: " + marbleName)
return shim.Error("This marble already exists: " + marbleName)
}
创建相应的marble类型变量，并用json.Marshal（）方法将其序列化到JSON对象中。自定义类型的变量序列化之后才可以写入账本，同理，对于从账本中读取出的信息需要反序列化后才便于进行 *** 作：
// 创建marble，并序列化为JSON对象
objectType := "marble"
marble := &marble{objectType, marbleName, color, size, owner}
marbleJSONasBytes, err := json.Marshal(marble)
if err != nil {
return shim.Error(err.Error())
}
之后，用stub.PutState（）将序列化后的内容写入账本，以大理石名称marbleName为键：
// 将marbleJSONasBytes存入状态
err = stub.PutState(marbleName, marbleJSONasBytes)
if err != nil {
return shim.Error(err.Error())
}
在initMarble中，为了支持之后针对某一特定颜色的大理石进行范围查找，需要将该大理石的颜色与名称这两个属性组合起来创建一个复合键，并记录在账本中。这里，复合键的意义是将一部分属性也构造为了索引的一部分，使得针对这部分属性做查询时，可以直接根据索引返回查询结果，而不需要具体提取完整信息来作比对：
indexName := "color~name"
colorNameIndexKey, err := stub.CreateCompositeKey(indexName, []string
{marble.Color, marble.Name})
if err != nil {
return shim.Error(err.Error())
}
这里调用了stub的CreateCompositeKey方法来创建复合键。该方法格式为 CreateCompositeKey（objectType string，attributes[]string）（string，error），实际上会将objectType和attributes中的每个 string串联起来，中间用U+0000分割；同时在开头加上\x00，标明该键为复合键。
最后，以复合键为键，以0x00为值，将复合键记录入账本中：
value := []byte{0x00}
stub.PutState(colorNameIndexKey, value)
根据大理石名称，readMarble方法会在账本中查询并返回大理石信息。
方法接受1个参数，即大理石名称。例如，如果调用链码时指定参数**{“Args”：[“readMarble”，“marble1”]}**，则功能为查找名称为marble1的大理石，如果找到，返回其信息：
valAsbytes, err := stub.GetState(name)
if err != nil {
jsonResp = "{\"Error\":\"Failed to get state for " + name + "\"}"
return shim.Error(jsonResp)
} else if valAsbytes == nil {
jsonResp = "{\"Error\":\"Marble does not exist: " + name + "\"}"
return shim.Error(jsonResp)
}
return shim.Success(valAsbytes)
根据大理石名称，delete方法会在账本中删除大理石信息。
方法接受1个参数，即大理石名称。例如，如果调用链码时指定参数**{“Args”：[“delete”，“marble1”]}**，则功能为删除名称为marble1的大理石的信息。
**除了删除以大理石名称为键的状态，还需删除该大理石的颜色与名称复合键。**所以方法中第一步需要读取该大理石的颜色：
var marbleJSON marble
valAsbytes, err := stub.GetState(marbleName)
if err != nil {
jsonResp = "{\"Error\":\"Failed to get state for " + marbleName + "\"}"
return shim.Error(jsonResp)
} else if valAsbytes == nil {
jsonResp = "{\"Error\":\"Marble does not exist: " + marbleName + "\"}"
return shim.Error(jsonResp)
}
err = json.Unmarshal([]byte(valAsbytes), &marbleJSON)
if err != nil {
jsonResp = "{\"Error\":\"Failed to decode JSON of: " + marbleName + "\"}"
return shim.Error(jsonResp)
}
其中**用json.Unmarshal方法将从账本中读取到的值反序列化为marble类型变量marbleJSON。**则大理石颜色为marbleJSON.Color。
删除以大理石名称为键的状态：
err = stub.DelState(marbleName)
if err != nil {
return shim.Error("Failed to delete state:" + err.Error())
}
删除以大理石的颜色与名称复合键为键的状态：
indexName := "color~name"
colorNameIndexKey, err := stub.CreateCompositeKey(indexName, []string{marbleJSON.Color, marbleJSON.Name})
if err != nil {
return shim.Error(err.Error())
}
err = stub.DelState(colorNameIndexKey)
if err != nil {
return shim.Error("Failed to delete state:" + err.Error())
}
transferMarble方法用于更改一个大理石的拥有者。
方法接受两个参数，依次为大理石名称和新拥有者名称。例如，如果调用链码时指定参数**{“Args”：[“transferMarble”，“marble2”，“jerry”]}**，则功能是将名称为marble2的大理石的拥有者改为jerry。
首先用stub.GetState（）方法从账本中取得信息，再用json.Unmarshal（）方法将其反序列化为marble类型：
marbleAsBytes, err := stub.GetState(marbleName)
if err != nil {
return shim.Error("Failed to get marble:" + err.Error())
} else if marbleAsBytes == nil {
return shim.Error("Marble does not exist")
}
marbleToTransfer := marble{}
err = json.Unmarshal(marbleAsBytes, &marbleToTransfer)
if err != nil {
return shim.Error(err.Error())
}
更改大理石的拥有者：
marbleToTransfer.Owner = newOwner
最后将更改后的状态写入账本：
marbleJSONasBytes, _ := json.Marshal(marbleToTransfer)
err = stub.PutState(marbleName, marbleJSONasBytes)
if err != nil {
return shim.Error(err.Error())
}
给定大理石名称的起始和终止，getMarblesByRange可以进行范围查询，返回所有名称在指定范围内的大理石信息。
方法接受两个参数，依次为字典序范围的起始（包括）和终止（不包括）。例如，调用链码时可以指定参数**{“Args”：[“getMarblesByRange”，“marble1”，“marble3”]}**进行范围查询，返回查找到的结果的键值。
方法中调用了stub.GetStateByRange（startKey，endKey）进行范围查询，其返回结果是一个迭代器StateQueryIteratorInterface结构，可以按照字典序迭代每个键值对，最后需调用Close（）方法关闭：
resultsIterator, err := stub.GetStateByRange(startKey, endKey)
if err != nil {
return shim.Error(err.Error())
}
defer resultsIterator.Close()
通过迭代器的迭代构造出查询结果的JSON数组，最后通过shim.Success（）方法来返回结果：
var buffer bytes.Buffer
buffer.WriteString("[")
bArrayMemberAlreadyWritten := false
for resultsIterator.HasNext() {
queryResponse, err := resultsIterator.Next()
if err != nil {
return shim.Error(err.Error())
}
if bArrayMemberAlreadyWritten == true {
buffer.WriteString(",")
}
buffer.WriteString("{\"Key\":")
buffer.WriteString("\"")
buffer.WriteString(queryResponse.Key)
buffer.WriteString("\"" )
buffer.WriteString(", \"Record\":")
// 记录本身就是一个 JSON 对象
buffer.WriteString(string(queryResponse.Value))
buffer.WriteString("}")
bArrayMemberAlreadyWritten = true
}
buffer.WriteString("]")
fmt.Printf("- getMarblesByRange queryResult:\n%s\n", buffer.String())
return shim.Success(buffer.Bytes())
Go 语言拼接字符串有五种方法，分别是：使用+号拼接、使用 sprintf 拼接、使用 join 函数拼接、使用 buffer.WriteString 函数拼接、使用 buffer.Builder 拼接。
使用 join 函数拼接：
var str []string = []string{s1, s2}
s := strings.Join(str, "")
使用 buffer.WriteString 函数拼接：
var bt bytes.Buffer
bt.WriteString(s1)
bt.WriteString(s2)
//获得拼接后的字符串
s3 := bt.String()
使用 buffer.Builder 拼接：
var build strings.Builder
build.WriteString(s1)
build.WriteString(s2)
s3 := build.String()
Go言拼接字符串有五种方法，分别是：使用+号拼接、使用 sprintf 拼接、使用 join 函数拼接、使用 buffer.WriteString 函数拼接、使用 buffer.Builder 拼接。
使用 join 函数拼接：
var str []string = []string{s1, s2}
s := strings.Join(str, "")
使用 buffer.WriteString 函数拼接：
var bt bytes.Buffer
bt.WriteString(s1)
bt.WriteString(s2)
//获得拼接后的字符串
s3 := bt.String()
使用 buffer.Builder 拼接：
var build strings.Builder
build.WriteString(s1)
build.WriteString(s2)
s3 := build.String()
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）