區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer chaincode命令及子命令實現(xiàn)

gghyoo 發(fā)布于2019-06-27 18:50 / 3484人閱讀

摘要：兄弟連區(qū)塊鏈教程源代碼分析命令及子命令實現(xiàn)，年下半年，區(qū)塊鏈行業(yè)正逐漸褪去發(fā)展之初的浮躁回歸理性，表面上看相關(guān)人才需求與身價似乎正在回落。

　　兄弟連區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer chaincode命令及子命令實現(xiàn)，2018年下半年，區(qū)塊鏈行業(yè)正逐漸褪去發(fā)展之初的浮躁、回歸理性，表面上看相關(guān)人才需求與身價似乎正在回落。但事實上，正是初期泡沫的漸退，讓人們更多的關(guān)注點放在了區(qū)塊鏈真正的技術(shù)之上。

Fabric 1.0源代碼筆記之 Peer #peer chaincode命令及子命令實現(xiàn) 1、peer chaincode install子命令實現(xiàn)（安裝鏈碼） 1.0、peer chaincode install子命令概述

peer chaincode install，將鏈碼的源碼和環(huán)境封裝為一個鏈碼安裝打包文件，并傳輸?shù)奖硶?jié)點。

peer chaincode install支持如下兩種方式：

指定代碼方式，peer chaincode install -n <鏈碼名稱> -v <鏈碼版本> -p <鏈碼路徑>

基于鏈碼打包文件方式，peer chaincode install <鏈碼打包文件>

有個圖3

1.1、初始化Endorser客戶端

cf, err = InitCmdFactory(true, false)
//代碼在peer/chaincode/install.go

cf, err = InitCmdFactory(true, false)代碼如下：

func InitCmdFactory(isEndorserRequired, isOrdererRequired bool) (*ChaincodeCmdFactory, error) {
????var err error
????var endorserClient pb.EndorserClient
????if isEndorserRequired {
????????//獲取Endorser客戶端
????????endorserClient, err = common.GetEndorserClientFnc() //func GetEndorserClient() (pb.EndorserClient, error)
????}
????//獲取簽名
????signer, err := common.GetDefaultSignerFnc()
????var broadcastClient common.BroadcastClient
????if isOrdererRequired {
????????//此處未用到，暫略
????}
????//構(gòu)造ChaincodeCmdFactory
????return &ChaincodeCmdFactory{
????????EndorserClient:  endorserClient,
????????Signer:          signer,
????????BroadcastClient: broadcastClient,
????}, nil
}
//代碼在peer/chaincode/common.go

1.2、構(gòu)造ChaincodeDeploymentSpec消息（鏈碼信息及鏈碼文件打包）

if ccpackfile == "" { //指定代碼方式，重新構(gòu)造構(gòu)造ChaincodeDeploymentSpec消息
????ccpackmsg, err = genChaincodeDeploymentSpec(cmd, chaincodeName, chaincodeVersion)
} else { //基于鏈碼打包文件方式，直接讀取ChaincodeDeploymentSpec消息
????var cds *pb.ChaincodeDeploymentSpec
????ccpackmsg, cds, err = getPackageFromFile(ccpackfile)
}
//代碼在peer/chaincode/install.go

ccpackmsg, err = genChaincodeDeploymentSpec(cmd, chaincodeName, chaincodeVersion)代碼如下：

func genChaincodeDeploymentSpec(cmd *cobra.Command, chaincodeName, chaincodeVersion string) (*pb.ChaincodeDeploymentSpec, error) {
????//已經(jīng)存在，直接報錯
????if existed, _ := ccprovider.ChaincodePackageExists(chaincodeName, chaincodeVersion); existed {
????????return nil, fmt.Errorf("chaincode %s:%s already exists", chaincodeName, chaincodeVersion)
????}
????spec, err := getChaincodeSpec(cmd)
????cds, err := getChaincodeDeploymentSpec(spec, true)
????return cds, nil
}
//代碼在peer/chaincode/install.go

spec, err := getChaincodeSpec(cmd)代碼如下：

func getChaincodeSpec(cmd *cobra.Command) (*pb.ChaincodeSpec, error) {
????spec := &pb.ChaincodeSpec{}
????err := checkChaincodeCmdParams(cmd) //檢查參數(shù)合法性
????input := &pb.ChaincodeInput{}
????//flags.StringVarP(&chaincodeCtorJSON, "ctor", "c", "{}"，ctor為鏈碼具體執(zhí)行參數(shù)信息，默認為{}
????err := json.Unmarshal([]byte(chaincodeCtorJSON), &input)
????//flags.StringVarP(&chaincodeLang, "lang", "l", "golang"，lang為鏈碼的編寫語言，默認為golang
????chaincodeLang = strings.ToUpper(chaincodeLang)
????spec = &pb.ChaincodeSpec{
????????Type:        pb.ChaincodeSpec_Type(pb.ChaincodeSpec_Type_value[chaincodeLang]),
????????ChaincodeId: &pb.ChaincodeID{Path: chaincodePath, Name: chaincodeName, Version: chaincodeVersion},
????????Input:       input,
????}
????return spec, nil
}
//代碼在peer/chaincode/common.go

cds, err := getChaincodeDeploymentSpec(spec, true)代碼如下：

func getChaincodeDeploymentSpec(spec *pb.ChaincodeSpec, crtPkg bool) (*pb.ChaincodeDeploymentSpec, error) {
????var codePackageBytes []byte
????if chaincode.IsDevMode() == false && crtPkg {
????????var err error
????????err = checkSpec(spec) //檢查spec合法性
????????codePackageBytes, err = container.GetChaincodePackageBytes(spec) //打包鏈碼文件及依賴文件
????}
????//構(gòu)造ChaincodeDeploymentSpec
????chaincodeDeploymentSpec := &pb.ChaincodeDeploymentSpec{ChaincodeSpec: spec, CodePackage: codePackageBytes}
????return chaincodeDeploymentSpec, nil
//代碼在peer/chaincode/common.go

1.3、創(chuàng)建lscc Proposal并簽名

creator, err := cf.Signer.Serialize() //獲取簽名者
//按ChaincodeDeploymentSpec構(gòu)造Proposal，即鏈碼ChaincodeDeploymentSpec消息作為參數(shù)傳遞給lscc系統(tǒng)鏈碼并調(diào)用
//調(diào)用createProposalFromCDS(chainID, cds, creator, policy, escc, vscc, "deploy")
prop, _, err := utils.CreateInstallProposalFromCDS(msg, creator) 
var signedProp *pb.SignedProposal
signedProp, err = utils.GetSignedProposal(prop, cf.Signer) //簽名提案
//代碼在peer/chaincode/install.go

createProposalFromCDS(chainID, cds, creator, policy, escc, vscc, "deploy")代碼如下：

func createProposalFromCDS(chainID string, msg proto.Message, creator []byte, policy []byte, escc []byte, vscc []byte, propType string) (*peer.Proposal, string, error) {
????var ccinp *peer.ChaincodeInput
????var b []byte
????var err error
????b, err = proto.Marshal(msg)
????switch propType {
????case "deploy":
????????fallthrough
????case "upgrade": 
????????cds, ok := msg.(*peer.ChaincodeDeploymentSpec)
????????ccinp = &peer.ChaincodeInput{Args: [][]byte{[]byte(propType), []byte(chainID), b, policy, escc, vscc}}
????case "install": 
????????ccinp = &peer.ChaincodeInput{Args: [][]byte{[]byte(propType), b}}
????}
????lsccSpec := &peer.ChaincodeInvocationSpec{ //構(gòu)造lscc ChaincodeInvocationSpec
????????ChaincodeSpec: &peer.ChaincodeSpec{
????????????Type:        peer.ChaincodeSpec_GOLANG,
????????????ChaincodeId: &peer.ChaincodeID{Name: "lscc"},
????????????Input:       ccinp}}

????return CreateProposalFromCIS(common.HeaderType_ENDORSER_TRANSACTION, chainID, lsccSpec, creator)
}
//代碼在protos/utils/proputils.go

1.4、提交并處理Proposal

proposalResponse, err := cf.EndorserClient.ProcessProposal(context.Background(), signedProp)
//代碼在peer/chaincode/install.go

2、peer chaincode instantiate子命令實現(xiàn)（實例化鏈碼） 2.0、peer chaincode instantiate概述

peer chaincode instantiate命令通過構(gòu)造生命周期管理系統(tǒng)鏈碼（LSCC）的交易，將安裝過的鏈碼在指定通道上進行實例化調(diào)用。
在peer上創(chuàng)建容器啟動，并執(zhí)行初始化操作。

2.1、初始化EndorserClient、Signer、及BroadcastClient

與2.1接近，附BroadcastClient初始化代碼如下：

cf, err = InitCmdFactory(true, true)
//代碼在peer/chaincode/instantiate.go

func InitCmdFactory(isEndorserRequired, isOrdererRequired bool) (*ChaincodeCmdFactory, error) {
????//初始化EndorserClient、Signer
????var broadcastClient common.BroadcastClient
????if isOrdererRequired {
????????//flags.StringVarP(&orderingEndpoint, "orderer", "o", "", "Ordering service endpoint")
????????//orderingEndpoint為orderer服務地址
????????broadcastClient, err = common.GetBroadcastClientFnc(orderingEndpoint, tls, caFile)
????}
}
//代碼在peer/chaincode/common.go

BroadcastClient更詳細內(nèi)容，參考Fabric 1.0源代碼筆記之 Peer #BroadcastClient（Broadcast客戶端）

2.2、構(gòu)造ChaincodeDeploymentSpec消息

spec, err := getChaincodeSpec(cmd) //構(gòu)造ChaincodeSpec，參考本文1.2
//構(gòu)造ChaincodeDeploymentSpec，參考本文1.2，但無法打包鏈碼文件
cds, err := getChaincodeDeploymentSpec(spec, false)
//代碼在peer/chaincode/instantiate.go

2.3、創(chuàng)建lscc Proposal并簽名

creator, err := cf.Signer.Serialize() //獲取簽名者
//policyMarhsalled為flags.StringVarP(&policy, "policy", "P", common.UndefinedParamValue,即鏈碼關(guān)聯(lián)的背書策略
//即調(diào)用 createProposalFromCDS(chainID, cds, creator, policy, escc, vscc, "deploy")，參考本文1.3
prop, _, err := utils.CreateDeployProposalFromCDS(chainID, cds, creator, policyMarhsalled, []byte(escc), []byte(vscc))
var signedProp *pb.SignedProposal
signedProp, err = utils.GetSignedProposal(prop, cf.Signer) //簽名提案
//代碼在peer/chaincode/instantiate.go

2.4、提交并處理Proposal、獲取Proposal響應并創(chuàng)建簽名交易Envelope

proposalResponse, err := cf.EndorserClient.ProcessProposal(context.Background(), signedProp)
if proposalResponse != nil {
????env, err := utils.CreateSignedTx(prop, cf.Signer, proposalResponse) //由Proposal創(chuàng)建簽名交易Envelope
????return env, nil
}
//代碼在peer/chaincode/instantiate.go

env, err := utils.CreateSignedTx(prop, cf.Signer, proposalResponse)代碼如下：

func CreateSignedTx(proposal *peer.Proposal, signer msp.SigningIdentity, resps ...*peer.ProposalResponse) (*common.Envelope, error) {
????hdr, err := GetHeader(proposal.Header) //反序列化為common.Header
????pPayl, err := GetChaincodeProposalPayload(proposal.Payload) //反序列化為peer.ChaincodeProposalPayload
????signerBytes, err := signer.Serialize() //signer序列化
????shdr, err := GetSignatureHeader(hdr.SignatureHeader) //反序列化為common.SignatureHeader
????if bytes.Compare(signerBytes, shdr.Creator) != 0 { //Proposal創(chuàng)建者需與當前簽名者相同
????????return nil, fmt.Errorf("The signer needs to be the same as the one referenced in the header")
????}
????hdrExt, err := GetChaincodeHeaderExtension(hdr) //Header.ChannelHeader反序列化為peer.ChaincodeHeaderExtension

????var a1 []byte
????for n, r := range resps {
????????if n == 0 {
????????????a1 = r.Payload
????????????if r.Response.Status != 200 { //檢查Response.Status是否為200
????????????????return nil, fmt.Errorf("Proposal response was not successful, error code %d, msg %s", r.Response.Status, r.Response.Message)
????????????}
????????????continue
????????}
????????if bytes.Compare(a1, r.Payload) != 0 { //檢查所有ProposalResponse.Payload是否相同
????????????return nil, fmt.Errorf("ProposalResponsePayloads do not match")
????????}
????}

????endorsements := make([]*peer.Endorsement, len(resps))
????for n, r := range resps {
????????endorsements[n] = r.Endorsement
????}

????//如下為逐層構(gòu)建common.Envelope
????cea := &peer.ChaincodeEndorsedAction{ProposalResponsePayload: resps[0].Payload, Endorsements: endorsements}
????propPayloadBytes, err := GetBytesProposalPayloadForTx(pPayl, hdrExt.PayloadVisibility)
????cap := &peer.ChaincodeActionPayload{ChaincodeProposalPayload: propPayloadBytes, Action: cea}
????capBytes, err := GetBytesChaincodeActionPayload(cap)
????taa := &peer.TransactionAction{Header: hdr.SignatureHeader, Payload: capBytes}
????taas := make([]*peer.TransactionAction, 1)
????taas[0] = taa
????tx := &peer.Transaction{Actions: taas}
????txBytes, err := GetBytesTransaction(tx)
????payl := &common.Payload{Header: hdr, Data: txBytes}
????paylBytes, err := GetBytesPayload(payl)
????sig, err := signer.Sign(paylBytes)
????return &common.Envelope{Payload: paylBytes, Signature: sig}, nil
}

//代碼在protos/utils/txutils.go

common.Envelope更詳細內(nèi)容，參考：Fabric 1.0源代碼筆記之附錄-關(guān)鍵數(shù)據(jù)結(jié)構(gòu)

2.5、向orderer廣播交易Envelope

err = cf.BroadcastClient.Send(env)
//代碼在peer/chaincode/instantiate.go

3、peer chaincode invoke子命令實現(xiàn)（調(diào)用鏈碼） 3.0、peer chaincode invoke概述

通過invoke命令可以調(diào)用運行中的鏈碼的方法。
.png)

3.1、初始化EndorserClient、Signer、及BroadcastClient

參考本文1.1和2.1。

cf, err = InitCmdFactory(true, true)
//代碼在peer/chaincode/invoke.go

3.2、構(gòu)造ChaincodeInvocationSpec

spec, err := getChaincodeSpec(cmd) //構(gòu)造ChaincodeSpec
invocation := &pb.ChaincodeInvocationSpec{ChaincodeSpec: spec} //構(gòu)造ChaincodeInvocationSpec
//代碼在peer/chaincode/common.go

3.3、創(chuàng)建Chaincode Proposal并簽名

creator, err := signer.Serialize()
var prop *pb.Proposal
prop, _, err = putils.CreateProposalFromCIS(pcommon.HeaderType_ENDORSER_TRANSACTION, cID, invocation, creator)
var signedProp *pb.SignedProposal
signedProp, err = putils.GetSignedProposal(prop, signer) //Proposal簽名
//代碼在peer/chaincode/common.go

3.4、提交并處理Proposal、獲取Proposal響應

var proposalResp *pb.ProposalResponse
proposalResp, err = endorserClient.ProcessProposal(context.Background(), signedProp)
//代碼在peer/chaincode/common.go

3.5、創(chuàng)建簽名交易Envelope并向orderer廣播交易Envelope

if invoke {
????env, err := putils.CreateSignedTx(prop, signer, proposalResp) //創(chuàng)建簽名交易
????err = bc.Send(env) //廣播交易
}
//代碼在peer/chaincode/common.go

4、peer chaincode query子命令實現(xiàn)（查詢鏈碼）

與3、peer chaincode invoke子命令實現(xiàn)（調(diào)用鏈碼）基本相同，區(qū)別在于提交并處理Proposal后，不再創(chuàng)建交易以及廣播交易。

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/24371.html

發(fā)表評論

登陸后可評論

0條評論

gghyoo

男|高級講師

我要關(guān)注我要私信

TA的文章

tensorflow查看版本

閱讀 2099·2023-04-25 17:57
史上最詳細Python學習路線-從入門到精通，只需90天

閱讀 1298·2021-11-24 09:39
css3變形動畫的一些基礎(chǔ)知識

閱讀 2497·2019-08-29 16:39
js輕松實現(xiàn)折疊面板

閱讀 3323·2019-08-29 13:44
CSS美化上傳按鈕、checkbox和radio樣式

閱讀 3140·2019-08-29 13:14
JavaScript到底是解釋型語言還是編譯型語言?

閱讀 2331·2019-08-26 11:36
走進身份管理-IAM/IDaaS

閱讀 3827·2019-08-26 11:00
原型圖/補充

閱讀 956·2019-08-26 10:14

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer chaincode命令及子命令實現(xiàn)

相關(guān)文章

**兄弟連區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer根命令入口及加載子命令一**

區(qū)塊鏈教程Fabric1.0源代碼分析Peer（Endorser服務端）

區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer根命令入口及加載子命令二

區(qū)塊鏈教程Fabric1.0源代碼分析Peer EndorserClient（Endorser客戶端

**基于ubuntu16.04部署IBM開源區(qū)塊鏈項目-彈珠資產(chǎn)管理(Marbles)**

發(fā)表評論

0條評論

gghyoo

男|高級講師

TA的文章

tensorflow查看版本

史上最詳細Python學習路線-從入門到精通，只需90天

css3變形動畫的一些基礎(chǔ)知識

js輕松實現(xiàn)折疊面板

CSS美化上傳按鈕、checkbox和radio樣式

JavaScript到底是解釋型語言還是編譯型語言?

走進身份管理-IAM/IDaaS

原型圖/補充

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

區(qū)塊鏈教程Fabric1.0源代碼分析Peer peer chaincode命令及子命令實現(xiàn)

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！