溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

fabric go sdk是什么

發(fā)布時間:2021-12-28 17:18:14 來源:億速云 閱讀:317 作者:小新 欄目:互聯(lián)網(wǎng)科技

小編給大家分享一下fabric go sdk是什么,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

fabric go sdk是Hyperledger Fabric官方提供的Go語言開發(fā)包,應(yīng)用程序可以利用fabric go sdk與fabric網(wǎng)絡(luò)進(jìn)行交互并訪問鏈碼。本教程介紹如何使用fabric go sdk實現(xiàn)鏈碼的安裝、實例化、交易提交 和狀態(tài)查詢等操作。

本文把與Hyperledger fabric網(wǎng)絡(luò)交互的baas、應(yīng)用程序、客戶端統(tǒng)稱成為客戶端,它們可以使用fabric go sdk和fabric區(qū)塊鏈網(wǎng)絡(luò)進(jìn)行交互,fabric go sdk調(diào)用grpc可以與指定的peer和orderer進(jìn)行通信,本文的目的是在BYFN搭建的fabric網(wǎng)絡(luò)的基礎(chǔ)之上,展示如何使用fabric go sdk操作鏈碼:

fabric go sdk是什么

1、fabric go sdk簡介

fabric go sdk是Fabric官方的Go語言SDK,它的目錄結(jié)構(gòu)如下:

fabric go sdk是什么

有2個目錄需要注意一下,internal和third_party,它們兩個包含了fabric go sdk依賴的一些代碼,來自于fabric、fabric-ca,當(dāng)使用到fabric的一些類型時,應(yīng)當(dāng)使用以下的方式,而不是直接導(dǎo)入fabric或者fabric-ca:

import "github.com/hyperledger/fabric go sdk/third_party/github.com/hyperledger/fabric/xxx"

pkg目錄是fabric go sdk的主要實現(xiàn),doc文檔介紹了不同目錄所提供的功能,以及給出了接口調(diào)用樣例:

  • pkg/fabsdk:主package,主要用來生成fabsdk以及fabric go sdk中其他pkg使用的option context。

  • pkg/client/channel:主要用來調(diào)用、查詢Fabric鏈碼,或者注冊鏈碼事件。

  • pkg/client/resmgmt:主要用來Hyperledger fabric網(wǎng)絡(luò)的管理,比如創(chuàng)建通道、加入通道,安裝、實例化和升級鏈碼。

  • pkg/client/event:配合channel模塊來進(jìn)行Fabric鏈碼事件的注冊和過濾。

  • pkg/client/ledger:主要用來實現(xiàn)Fabric賬本的查詢,查詢區(qū)塊、交易、配置等。

  • pkg/client/msp:主要用來管理fabric網(wǎng)絡(luò)中的成員關(guān)系。

3、使用fabric go sdk的一般步驟

  • 為client編寫配置文件config.yaml

  • 為client創(chuàng)建fabric sdk實例fabsdk

  • 為client創(chuàng)建resource manage client,簡稱RC,RC用來進(jìn)行管理操作的client, 比如通道的創(chuàng)建,鏈碼的安裝、實例化和升級等

  • 為client創(chuàng)建channel client,簡稱CC,CC用來鏈碼的調(diào)用、查詢以及鏈碼事件 的注冊和取消注冊

4、fabric go sdk配置文件config.yaml概述

client使用sdk與fabric網(wǎng)絡(luò)交互,需要告訴sdk兩類信息:

  • 我是誰:即當(dāng)前client的信息,包含所屬組織、密鑰和證書文件的路徑等, 這是每個client專用的信息。

  • 對方是誰:即fabric網(wǎng)絡(luò)結(jié)構(gòu)的信息,channel、org、orderer和peer等 的怎么組合起當(dāng)前fabric網(wǎng)絡(luò)的,這些結(jié)構(gòu)信息應(yīng)當(dāng)與configytx.yaml中是一致的。這是通用配置,每個客戶端都可以拿來使用。另外,這部分信息并不需要是完整fabric網(wǎng)絡(luò)信息,如果當(dāng)前client只和部分節(jié)點交互,那配置文件中只需要包含所使用到的網(wǎng)絡(luò)信息。

fabric go sdk是什么

5、使用go mod管理fabric go sdk項目的依賴

fabric go sdk目前本身使用go modules管理依賴,從go.mod可知,依賴的一些包指定了具體的版本, 如果你的項目依賴的版本和fabric go sdk依賴的版本不同,會產(chǎn)生編譯問題。

因此建議項目也使用go moudles管理依賴,然后相同的軟件包可以使用相同的版本,可以這樣操作:

  • go mod init初始化好項目的go.mod文件。

  • 編寫代碼,完成后運行g(shù)o mod run,會自動下載依賴的項目,但版本可能與 fabric go sdk中的依賴版本不同,編譯存在問題。

  • 把go.mod中的內(nèi)容復(fù)制到項目的go.mod中,然后保存,go mod會自動合并相同的依賴, 運行g(shù)o mod tidy,會自動添加新的依賴或刪除不需要的依賴。

6、創(chuàng)建fabric go sdk的入口實例

通過config.FromFile解析配置文件,然后通過fabsdk.New創(chuàng)建fabric go sdk的入口實例。

import "github.com/hyperledger/fabric go sdk/pkg/core/config"
import "github.com/hyperledger/fabric go sdk/pkg/fabsdk"

sdk, err := fabsdk.New(config.FromFile(c.ConfigPath))
if err != nil {
  log.Panicf("failed to create fabric sdk: %s", err)
}

7、創(chuàng)建fabric go sdk的資源管理客戶端

管理員賬號才能進(jìn)行Hyperledger fabric網(wǎng)絡(luò)的管理操作,所以創(chuàng)建資源管理客戶端一定要使用管理員賬號。

通過fabsdk.WithOrg("Org1")和fabsdk.WithUser("Admin")指定Org1的Admin賬戶,使用sdk.Context創(chuàng)建clientProvider,然后通過resmgmt.New創(chuàng)建fabric go sdk資源管理客戶端。

import 	"github.com/hyperledger/fabric go sdk/pkg/client/resmgmt"

rcp := sdk.Context(fabsdk.WithUser("Admin"), fabsdk.WithOrg("Org1"))
rc, err := resmgmt.New(rcp)
if err != nil {
  log.Panicf("failed to create resource client: %s", err)
}

8、創(chuàng)建fabric go sdk的通道客戶端

使用用戶賬號創(chuàng)建fabric go sdk的通道客戶端,以便進(jìn)行fabric鏈碼的調(diào)用和查詢。使用sdk.ChannelContext創(chuàng)建channelProvider,需要指定channelID和用戶User1,然后通過channel.New創(chuàng)建通道客戶端,這個通道客戶端就是調(diào)用channelID對應(yīng)channel上鏈碼的channel client。

import 	"github.com/hyperledger/fabric go sdk/pkg/client/channel"

ccp := sdk.ChannelContext(ChannelID, fabsdk.WithUser("User1"))
cc, err := channel.New(ccp)
if err != nil {
  log.Panicf("failed to create channel client: %s", err)
}

9、使用fabric go sdk的資源管理客戶端安裝鏈碼

安裝Fabric鏈碼使用資源管理客戶端的InstallCC接口,需要指定resmgmt.InstallCCRequest以及在哪些peers上面安裝。resmgmt.InstallCCRequest指明了鏈碼ID、鏈碼路徑、鏈碼版本以及打包后的鏈碼。

打包鏈碼需要使用到鏈碼路徑CCPath和GoPath,GoPath即本機的$GOPATH,CCPath是相對于GoPath的相對路徑,如果路徑設(shè)置不對,會造成sdk找不到鏈碼。

// pack the chaincode
ccPkg, err := gopackager.NewCCPackage("github.com/hyperledger/fabric-samples/chaincode/chaincode_example02/go/", "/Users/shitaibin/go")
if err != nil {
  return errors.WithMessage(err, "pack chaincode error")
}

// new request of installing chaincode
req := resmgmt.InstallCCRequest{
  Name:    c.CCID,
  Path:    c.CCPath,
  Version: v,
  Package: ccPkg,
}

reqPeers := resmgmt.WithTargetEndpoints("peer0.org1.example.com")
resps, err := rc.InstallCC(req, reqPeers)
if err != nil {
  return errors.WithMessage(err, "installCC error")
}

10、使用fabric go sdk的資源管理客戶端實例化鏈碼

實例化鏈碼需要使用fabric go sdk的資源管理客戶端的InstantiateCC接口,需要通過ChannelID、 resmgmt.InstantiateCCRequest和peers,指明在哪個channel上實例化鏈碼,請求包含了鏈碼的ID、路徑、版本,以及初始化參數(shù)和背書策略,背書策略可以通過cauthdsl.FromString生成。

// endorser policy
org1OrOrg2 := "OR('Org1MSP.member','Org2MSP.member')"
ccPolicy, err := cauthdsl.FromString(org1OrOrg2)
if err != nil {
  return errors.WithMessage(err, "gen policy from string error")
}

// new request
args := packArgs([]string{"init", "a", "100", "b", "200"})
req := resmgmt.InstantiateCCRequest{
  Name:    c.CCID,
  Path:    c.CCPath,
  Version: v,
  Args:    args,
  Policy:  ccPolicy,
}

// send request and handle response
reqPeers := resmgmt.WithTargetEndpoints("peer0.org1.example.com")
resp, err := rc.InstantiateCC(ChannelID, req, reqPeers)
if err != nil {
  return errors.WithMessage(err, "instantiate chaincode error")
}

11、使用fabric go sdk的資源管理客戶端升級鏈碼

再fabric go sdk中,升級鏈碼和實例化鏈碼是非常相似的,不同點只在請求是resmgmt.UpgradeCCRequest,調(diào)用的接口是rc.UpgradeCC:

// endorser policy
org1AndOrg2 := "AND('Org1MSP.member','Org2MSP.member')"
ccPolicy, err := c.genPolicy(org1AndOrg2)
if err != nil {
  return errors.WithMessage(err, "gen policy from string error")
}

// new request
args := packArgs([]string{"init", "a", "100", "b", "200"})
req := resmgmt.UpgradeCCRequest{
  Name:    c.CCID,
  Path:    c.CCPath,
  Version: v,
  Args:    args,
  Policy:  ccPolicy,
}

// send request and handle response
reqPeers := resmgmt.WithTargetEndpoints("peer0.org1.example.com")
resp, err := rc.UpgradeCC(ChannelID, req, reqPeers)
if err != nil {
  return errors.WithMessage(err, "instantiate chaincode error")
}

12、使用fabric go sdk的通道客戶端調(diào)用鏈碼

在fabric go sdk中,使用通道客戶端的Execute接口調(diào)用鏈碼,使用入?yún)hannel.Request和peers指明要讓哪些peer上執(zhí)行鏈碼,進(jìn)行背書。channel.Request指明了要調(diào)用的鏈碼,以及鏈碼內(nèi)要Invoke的函數(shù)args,args是序列化的結(jié)果,序列化是自定義的,只要鏈碼能夠按相同的規(guī)則進(jìn)行反序列化即可。

// new channel request for invoke
args := packArgs([]string{"a", "b", "10"})
req := channel.Request{
  ChaincodeID: c.CCID,
  Fcn:         "invoke",
  Args:        args,
}

// send request and handle response
// peers is needed
reqPeers := channel.WithTargetEndpoints("peer0.org1.example.com")
resp, err := cc.Execute(req, reqPeers)
if err != nil {
  return errors.WithMessage(err, "invoke chaincode error")
}
log.Printf("invoke chaincode tx: %s", resp.TransactionID)

13、使用fabric go sdk的通道客戶端查詢鏈碼

在fabric go sdk中,查詢和調(diào)用鏈碼是非常相似的,使用相同的channel.Request,指明了Invoke鏈碼中的query函數(shù),然后調(diào)用cc.Query進(jìn)行查詢操作,這樣節(jié)點不會對請求進(jìn)行背書:

// new channel request for query
req := channel.Request{
  ChaincodeID: c.CCID,
  Fcn:         "query",
  Args:        packArgs([]string{keys}),
}

// send request and handle response
reqPeers := channel.WithTargetEndpoints(peer)
resp, err := cc.Query(req, reqPeers)
if err != nil {
  return errors.WithMessage(err, "query chaincode error")
}

log.Printf("query chaincode tx: %s", resp.TransactionID)
log.Printf("result: %v", string(resp.Payload))

以上是“fabric go sdk是什么”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學(xué)習(xí)更多知識,歡迎關(guān)注億速云行業(yè)資訊頻道!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI