Skip to content

Latest commit

 

History

History
143 lines (102 loc) · 4.4 KB

join_channel.md

File metadata and controls

143 lines (102 loc) · 4.4 KB

加入通道

客户端发起请求

在BYFN使用的命令如下:

peer channel join -b mychannel.block

  • 加入channel的请求是发往Peer的

  • 请求的类型 HeaderType_CONFIG,

  • 客户端首先创建一个ChaincodeSpec结构

  • 其input中的Args第一个参数是CSCC.JoinChain（指定调用配置链码的操作），

  • 第二个参数为所加入通道的初始区块(创建通道时, 从orderer获取的)

如下图:

利用ChaincodeSpec,构造ChaincodeInvocationSpec, 然后创建Proposal, 最后客户端通过gRPC(/protos.Endorser/ProcessProposal)把这个Proposal签名后发送给peer节点.

客户端和背书节点,只有ProcessProposal这一个接口

Peer节点处理流程

Peer 接收Proposal

节点加入链的JoinChain请求是由系统链码CSCC处理的:

block, err := utils.GetBlockFromBlockBytes(args[1])
func (e *PeerConfiger) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
    //args[0]为JoinChain或GetChannels
    args := stub.GetArgs()
    fname := string(args[0]) //Invoke function
    sp, err := stub.GetSignedProposal() //获取SignedProposal

    switch fname {
    case JoinChain: //加入通道
        //从args[1]里获取创世区块, 
        block, err := utils.GetBlockFromBlockBytes(args[1])
        // 获取chainID
        cid, err := utils.GetChainIDFromBlock(block)
        // 验证区块内容
        err := validateConfigBlock(block)
        // 检查本地的 MSP Admins 策略
        err = e.policyChecker.CheckPolicyNoChannel(mgmt.Admins, sp)
        // 加入Chain
        return joinChain(cid, block)
    ............
    }
}
//代码在core/scc/cscc/configure.go

合法性和权限检查

由下面两个函数完成

// 验证区块内容
err := validateConfigBlock(block) 
//代码在core/scc/cscc/configure.go

// 检查本地的 MSP Admins 策略
err = e.policyChecker.CheckPolicyNoChannel(mgmt.Admins, sp)
//代码在core/policy/policy.go

它们会校验创世区块的合法性（包括内容完整性），比如是否包含应用相关的配置项，还会对提交者的身份进行认证和权限检查.

配置交易是需要应用程序用提交者的私钥进行签名的，身份认证需要确认请求Header是否包含有效的提交者身份信息，再验证配置交易请求是否是该提交者签名的。

然后是权限检查，包括两个方面。

1）是否有权限向节点提交请求：即检查提交者的MSP是否与本地MSP相同。

2）是否满足加入通道请求的策略：提交加入通道请求是需要有管理员权限的.

加入Chain

func joinChain(chainID string, block *common.Block) pb.Response {
    //建mychannel的链（账本）和gossip服务
    err := peer.CreateChainFromBlock(block)
    // InitChain会调用DeploySysCCs, deploy 给定的系统链码列表.代码在core/scc/importsysccs.go. 每个channel都有自己的系统链码.配置文件中可以指定安装哪些系统chaincode.
    peer.InitChain(chainID)
    // 发送创建区块的event
    err := producer.SendProducerBlockEvent(block)
    return shim.Success(nil)
}
//代码在core/scc/cscc/configure.go

创建peer结点 mychannel的Chain 账本和gossip服务

func CreateChainFromBlock(cb *common.Block) error {
    // 从block中获取chainIID
    cid, err := utils.GetChainIDFromBlock(cb)
    var l ledger.PeerLedger
    // 根据区块创建属于mychannel的账本
    l, err = ledgermgmt.CreateLedger(cb)
    // 创建新的Chain, 初始化Gossip服务, Leader选举,必要时与Orderer连接.
    return createChain(cid, l, cb)
}

createChain会在这个peer里, 为这个通道创建一个struct chain:

type chain struct {
	cs        *chainSupport
	cb        *common.Block //应该是config block
	committer committer.Committer // 
}
type chainSupport struct {
	configtxapi.Manager // 查询或更新config
    config.Application   // 保存了Application的config: anchor节点, 组织名等
	ledger ledger.PeerLedger //对账本的操作接口
}

Peer本地创建账本有两个操作:

  • 往本地链的数据库idStore添加记录
  • 把创世区块写到本地文件系统里

因为Peer节点可以随时加入, 加入晚的可能会缺失很多区块, 通过Gossip向别的节点拉取区块.

返回结果

从Peer节点的joinChain返回后, 客户端会收到ProposalResp, 整个join工作结束.