一、智能合约构成
Go 语言的智能合约代码主要由以下接口构成：
·接口 Init 主要用于智能合约初始化和升级智能合约时调用此接口，初始化相关的数据。
·接口 Invoke 主要用于实现智能合约中的内部业务逻辑。用户可以根据实际需求，实现相关的业务。
·在实现过程中，用户可以调用 ChaincodeStubInterface 的 API 接口和链上进行交互。
二、基本示例
本示例以一个基本的智能合约用例为例，只包含智能合约的必须部分，没有实现任何业务逻辑。
package mainimport ( "github.com/hyperledger/fabric/core/chaincode/shim" "github.com/hyperledger/fabric/protos/peer")// SimpleAssetDemo implements a simple chaincode to manage an assettype SimpleAssetDemo struct {}// Init is called during chaincode instantiation to initialize any data.func (t *SimpleAssetDemo) Init(stub shim.ChaincodeStubInterface) peer.Response { return shim.Success(nil)}// Invoke is called per transaction on the chaincode. Each transaction is// either a 'get' or a 'set' on the asset created by Init function. The 'set'// method may create a new asset by specifying a new key-value pair.func (t *SimpleAssetDemo) Invoke(stub shim.ChaincodeStubInterface) peer.Response { return shim.Success(nil)}func main() { err := shim.Start(new(SimpleAssetDemo)) if err != nil { fmt.Printf("Error starting SimpleAssetDemo chaincode: %s", err) }}
三、示例
Hyperledger Fabric 提供了很多智能合约样例，具体请参考 fabric 示例。本示例以 Hyperledger Fabric 提供的 example02 样例为例。该示例的 Init 函数用于初始化两个 key/value 键值对，Invoke 函数用于根据不同业务逻辑进行细分调用，最终调用以下业务逻辑接口：
·invoke：用于 key 之间的 value 转移。
·delete：用于删除一个键值对。
·query：用于查询 key 所对应的值。
四、Init 函数示例
Init 函数在智能合约实例化以及升级的时候会被调用。在实现 Init 函数的过程中，可使用 Go 语言版本的合约 API 列表 来对参数和账本进行操作。本例通过调用 API GetFunctionAndParameters 获取到用户输入参数。在获取用户输入参数后，通过调用 API PutState 将数据写到账本中。具体代码如下：
// Init用于初始化两个键值对，用户输入的参数为KEY1_NAME, VALUE1, KEY2_NAME, VALUE2func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response { fmt.Println("ex02 Init") // 调用API GetFunctionAndParameters 获取用户输入参数 _, args := stub.GetFunctionAndParameters() var A, B string // Entities var Aval, Bval int // Asset holdings var err error if len(args) != 4 { return shim.Error("Incorrect number of arguments. Expecting 4") } // Initialize the chaincode A = args[0] Aval, err = strconv.Atoi(args[1]) 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") } fmt.Printf("Aval = %d, Bval = %d\\n", Aval, Bval) // 调用API PutState把数据写入账本 err = stub.PutState(A, []byte(strconv.Itoa(Aval))) if err != nil { return shim.Error(err.Error()) } err = stub.PutState(B, []byte(strconv.Itoa(Bval))) if err != nil { return shim.Error(err.Error()) } return shim.Success(nil)}
五、Invoke 函数示例
Invoke 函数对用户的不同的智能合约业务逻辑进行拆分。本例通过调用 API GetFunctionAndParameters 获取到用户的具体业务类型和参数，根据用户的不同业务类型，分别调用不同的业务函数，如 invoke，delete 和 query 函数。具体代码如下：
// Invoke把用户调用的function细分到几个子function, 包含invoke,delete和queryfunc (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response { fmt.Println("ex02 Invoke") // 调用API GetFunctionAndParameters获取用户输入的业务类型和参数 function, args := stub.GetFunctionAndParameters() if function == "invoke" { // Make payment of X units from A to B return t.invoke(stub, args) } else if function == "delete" { // Deletes an entity from its state return t.delete(stub, args) } else if function == "query" { // the old "Query" is now implemtned in invoke return t.query(stub, args) } return shim.Error("Invalid invoke function name. Expecting \\"invoke\\" \\"delete\\" \\"query\\"")}
六、invoke 函数示例
业务逻辑 invoke 函数主要用于实现业务逻辑中的资产转移。本例中通过调用 API GetState 获取到 KEY 对应的资产总值，通过调用用户业务逻辑实现资产转移，通过调用 API PutState 将用户最终资产写入账本。具体代码如下：
// invoke实现两个键之间的value转移，输入为KEY1_NAME, KEY2_NAME，VALUE// Transaction makes payment of X units from A to Bfunc (t *SimpleChaincode) invoke(stub shim.ChaincodeStubInterface, args []string) pb.Response { var A, B string // Entities var Aval, Bval int // Asset holdings var X int // Transaction value var err error if len(args) != 3 { return shim.Error("Incorrect number of arguments. Expecting 3") } A = args[0] B = args[1] // API GetState获取对应账户的资产 Avalbytes, err := stub.GetState(A) if err != nil { return shim.Error("Failed to get state") } if Avalbytes == nil { return shim.Error("Entity not found") } Aval, _ = strconv.Atoi(string(Avalbytes)) Bvalbytes, err := stub.GetState(B) if err != nil { return shim.Error("Failed to get state") } if Bvalbytes == nil { return shim.Error("Entity not found") } Bval, _ = strconv.Atoi(string(Bvalbytes)) // 执行具体业务逻辑，这里是对应资产进行转移 // Perform the execution X, err = strconv.Atoi(args[2]) if err != nil { return shim.Error("Invalid transaction amount, expecting a integer value") } Aval = Aval – X Bval = Bval + X fmt.Printf("Aval = %d, Bval = %d\\n", Aval, Bval) // API PutState将对应资产写入账本 // Write the state back to the ledger err = stub.PutState(A, []byte(strconv.Itoa(Aval))) if err != nil { return shim.Error(err.Error()) } err = stub.PutState(B, []byte(strconv.Itoa(Bval))) if err != nil { return shim.Error(err.Error()) } return shim.Success(nil)}
七、delete 函数示例
业务逻辑 delete 函数主要用于实现业务逻辑中的账户删除功能，本例通过调用 API DelState 删除对应账户。具体代码如下：
// delete用于从账本中删除指定的键，输入为KEY_NAME// Deletes an entity from statefunc (t *SimpleChaincode) delete(stub shim.ChaincodeStubInterface, args []string) pb.Response { if len(args) != 1 { return shim.Error("Incorrect number of arguments. Expecting 1") } A := args[0] // API DelState删除特定的账户 // Delete the key from the state in ledger err := stub.DelState(A) if err != nil { return shim.Error("Failed to delete state") } return shim.Success(nil)}
八、query 函数示例
业务逻辑 query 函数主要用于实现业务逻辑中的账户查询功能，本例通过调用 API GetState 查询对应账户的资产。具体代码如下：
// query主要是查询键对应的值，输入为KEY_NAME// query callback representing the query of a chaincodefunc (t *SimpleChaincode) query(stub shim.ChaincodeStubInterface, args []string) pb.Response { var A string // Entities var err error if len(args) != 1 { return shim.Error("Incorrect number of arguments. Expecting name of the person to query") } A = args[0] // API GetState查询特定的账户 // Get the state from the ledger Avalbytes, err := stub.GetState(A) if err != nil { jsonResp := "{\\"Error\\":\\"Failed to get state for " + A + "\\"}" return shim.Error(jsonResp) } if Avalbytes == nil { jsonResp := "{\\"Error\\":\\"Nil amount for " + A + "\\"}" return shim.Error(jsonResp) } jsonResp := "{\\"Name\\":\\"" + A + "\\",\\"Amount\\":\\"" + string(Avalbytes) + "\\"}" fmt.Printf("Query Response:%s\\n", jsonResp) return shim.Success(Avalbytes)}