开发者社区> 区块链教程> 正文

区块链教程Fabric1.0源代码分析Orderer multichain多链支持包

简介:
+关注继续查看

Fabric 1.0源代码笔记 之 Orderer #multichain(多链支持包)

兄弟连区块链教程Fabric1.0源代码分析Orderer multichain多链支持包

1、multichain概述

multichain代码集中在orderer/multichain目录下,目录结构如下:

  • manager.go,Manager接口定义及实现。
  • chainsupport.go,ChainSupport接口定义及实现。
  • systemchain.go,system chain。

2、Manager接口定义及实现

2.1、Manager接口定义

用于链的创建和访问。

type Manager interface {
    //获取ChainSupport,以及判断链是否存在
    GetChain(chainID string) (ChainSupport, bool)
    //获取系统通道的通道ID
    SystemChannelID() string
    //支持通道创建请求
    NewChannelConfig(envConfigUpdate *cb.Envelope) (configtxapi.Manager, error)
}
//代码在orderer/multichain/manager.go

2.2、Manager接口实现

Manager接口实现,即multiLedger结构体及方法。

type multiLedger struct {
    chains          map[string]*chainSupport
    consenters      map[string]Consenter
    ledgerFactory   ledger.Factory
    signer          crypto.LocalSigner
    systemChannelID string
    systemChannel   *chainSupport
}

type configResources struct {
    configtxapi.Manager
}

type ledgerResources struct {
    *configResources
    ledger ledger.ReadWriter
}
//代码在orderer/multichain/manager.go

涉及方法如下:

func (cr *configResources) SharedConfig() config.Orderer
//获取配置交易Envelope
func getConfigTx(reader ledger.Reader) *cb.Envelope
//构造multiLedger
func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager
//获取系统链ID
func (ml *multiLedger) SystemChannelID() string
//按chainID获取ChainSupport
func (ml *multiLedger) GetChain(chainID string) (ChainSupport, bool)
//构造ledgerResources
func (ml *multiLedger) newLedgerResources(configTx *cb.Envelope) *ledgerResources
//创建新链
func (ml *multiLedger) newChain(configtx *cb.Envelope)
//通道或链的个数
func (ml *multiLedger) channelsCount() int
//支持创建新的通道
func (ml *multiLedger) NewChannelConfig(envConfigUpdate *cb.Envelope) (configtxapi.Manager, error)
//代码在orderer/multichain/manager.go

func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager代码如下:

func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager {
    ml := &multiLedger{
        chains:        make(map[string]*chainSupport),
        ledgerFactory: ledgerFactory,
        consenters:    consenters,
        signer:        signer,
    }

    existingChains := ledgerFactory.ChainIDs()
    for _, chainID := range existingChains {
        rl, err := ledgerFactory.GetOrCreate(chainID)
        configTx := getConfigTx(rl)
        ledgerResources := ml.newLedgerResources(configTx)
        chainID := ledgerResources.ChainID()

        if _, ok := ledgerResources.ConsortiumsConfig(); ok { //系统链
            chain := newChainSupport(createSystemChainFilters(ml, ledgerResources), ledgerResources, consenters, signer)
            ml.chains[chainID] = chain
            ml.systemChannelID = chainID
            ml.systemChannel = chain
            defer chain.start()
        } else { //普通链
            chain := newChainSupport(createStandardFilters(ledgerResources), ledgerResources, consenters, signer)
            ml.chains[chainID] = chain
            chain.start()
        }
    }
    return ml
}
//代码在orderer/multichain/manager.go

3、ChainSupport接口定义及实现

3.1、ChainSupport接口定义

type ChainSupport interface {
    PolicyManager() policies.Manager //策略管理
    Reader() ledger.Reader
    Errored() <-chan struct{}
    broadcast.Support
    ConsenterSupport //嵌入ConsenterSupport接口
    Sequence() uint64
    //支持通道更新
    ProposeConfigUpdate(env *cb.Envelope) (*cb.ConfigEnvelope, error)
}

type ConsenterSupport interface {
    crypto.LocalSigner
    BlockCutter() blockcutter.Receiver
    SharedConfig() config.Orderer
    CreateNextBlock(messages []*cb.Envelope) *cb.Block
    WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block
    ChainID() string
    Height() uint64
}

type Consenter interface { //定义支持排序机制
    HandleChain(support ConsenterSupport, metadata *cb.Metadata) (Chain, error)
}

type Chain interface {
    //接受消息
    Enqueue(env *cb.Envelope) bool
    Errored() <-chan struct{}
    Start() //开始
    Halt() //挂起
}
//代码在orderer/multichain/chainsupport.go

3.2、ChainSupport和ConsenterSupport接口实现

ChainSupport接口实现,即chainSupport结构体及方法。

type chainSupport struct {
    *ledgerResources
    chain         Chain
    cutter        blockcutter.Receiver
    filters       *filter.RuleSet
    signer        crypto.LocalSigner
    lastConfig    uint64
    lastConfigSeq uint64
}
//代码在orderer/multichain/chainsupport.go

涉及方法如下:

//构造chainSupport
func newChainSupport(filters *filter.RuleSet,ledgerResources *ledgerResources,consenters map[string]Consenter,signer crypto.LocalSigner,) *chainSupport
func createStandardFilters(ledgerResources *ledgerResources) *filter.RuleSet
func createSystemChainFilters(ml *multiLedger, ledgerResources *ledgerResources) *filter.RuleSet
func (cs *chainSupport) start()
func (cs *chainSupport) NewSignatureHeader() (*cb.SignatureHeader, error)
func (cs *chainSupport) Sign(message []byte) ([]byte, error)
func (cs *chainSupport) Filters() *filter.RuleSet
func (cs *chainSupport) BlockCutter() blockcutter.Receiver
func (cs *chainSupport) Reader() ledger.Reader
func (cs *chainSupport) Enqueue(env *cb.Envelope) bool
func (cs *chainSupport) Errored() <-chan struct{}
//创建块,调取ledger.CreateNextBlock(cs.ledger, messages)
func (cs *chainSupport) CreateNextBlock(messages []*cb.Envelope) *cb.Block
func (cs *chainSupport) addBlockSignature(block *cb.Block)
func (cs *chainSupport) addLastConfigSignature(block *cb.Block)
//写入块
func (cs *chainSupport) WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block 
func (cs *chainSupport) Height() uint64
//代码在orderer/multichain/chainsupport.go

func (cs chainSupport) WriteBlock(block cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block 代码如下:

func (cs *chainSupport) WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block {
    for _, committer := range committers {
        committer.Commit()
    }
    cs.addBlockSignature(block)
    cs.addLastConfigSignature(block)
    err := cs.ledger.Append(block)//账本追加块
    return block
}
//代码在orderer/multichain/chainsupport.go

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
五分钟搞定Docker安装ElasticSearch
五分钟搞定Docker安装ElasticSearch
6 0
Apache APISIX Summit ASIA 2022 拉开帷幕,首日精彩内容回顾
2022 年 5 月 20 日,Apache APISIX Summit ASIA 2022 在线上拉开帷幕,为开发者们带来了关于 APISIX 基础架构与应用实践、开源生态和开源项目的多角度分享与讨论。
10 0
解决研发数据分析瓶颈,开源项目 DevLake 加入 Apache 软件基金会孵化器 | InfoQ 专访
每一位开源参与者、每一个开源项目都可以成为舞台上的主角。
6 0
pypy真的能让python比c还快?
最近 “pypy为什么能让python比c还快” 刷屏了,原文讲的内容偏理论,干货比较少。我们可以再深入一点点,了解pypy的真相。
9 0
再聊我的源码阅读方法-xml-rpc源码慢读
之前介绍我的源码阅读方法,有粉丝朋友说很有帮助,认为是授人予鱼。这是过誉了,也让我很受鼓舞,这次带来另外一种阅读方法,希望对大家也有帮助。
9 0
2020你应该有自己的知识库
2020你应该有自己的知识库
6 0
谁是虽好的语言 ?- 语言选型闲聊(上)
谁是最好的语言?当然是php了 :) 先说一声抱歉,最近工作上有个里程碑要交付,比较忙, 本周的celery源码系列又又要延期了。为了避免大家误以为停更,今天简单聊点别的内容吧。近期我们公司做架构升级,调研了一下各种语言, 包括TypeScript,c#,rust, 还有java和go。这个过程中有一些个人看法,可能会有些偏颇或者不正确的地方,我就简单一说,大家一乐,无意引战。
9 0
谁是虽好的语言 ?- 语言选型闲聊(下)
近期我们公司做架构升级,调研了一下各种语言, 包括TypeScript,c#,rust, 还有java和go。这个过程中有一些个人看法,可能会有些偏颇或者不正确的地方,我就简单一说,大家一乐,无意引战。
6 0
Vite 与 Vue Cli 对比 - 尤雨溪: Vite 会取代 vue-cli 吗?
尤雨溪在发布 Vite 之后写了一条推,感觉不会在用 webpack 了(Vue-cli 基于 Webpack 开发,并配置了 Webpack 打包规则),Sean 是 Webpack 核心开发者,会一些中文,在尤大这条下面直接感叹。Vue-cli 一直是 Vue 2 默认官方脚手架工具,Vue-cli 基于 Webpack 开发。Vue 3 发布后,尤大同时发布了 Vite ,那么 Vue 3 同时有两个前端打包工具 Vite 和 Vue CLI,那么他们俩应该怎么选呢?
9 0
56
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
OceanBase 入门到实战教程
立即下载
阿里云图数据库GDB,加速开启“图智”未来.ppt
立即下载
实时数仓Hologres技术实战一本通2.0版(下)
立即下载