AI 助理
备案控制台
开发者社区 大数据 文章 正文

兄弟连区块链教程Fabric1.0源代码分析configupdate处理通道配置更新

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

　　区块链教程Fabric1.0源代码分析configupdate处理通道配置更新，2018年下半年，区块链行业正逐渐褪去发展之初的浮躁、回归理性，表面上看相关人才需求与身价似乎正在回落。但事实上，正是初期泡沫的渐退，让人们更多的关注点放在了区块链真正的技术之上。

Fabric 1.0源代码笔记 之 Orderer #configupdate（处理通道配置更新）

1、configupdate概述

configupdate，用于接收配置交易，并处理通道配置更新。
相关代码在orderer/configupdate目录。

2、SupportManager接口定义及实现

2.1、SupportManager接口定义

type SupportManager interface {
    GetChain(chainID string) (Support, bool)
    NewChannelConfig(envConfigUpdate *cb.Envelope) (configtxapi.Manager, error)
}
//代码在orderer/configupdate/configupdate.go

2.2、SupportManager接口实现

SupportManager接口实现，即configUpdateSupport结构体及方法。

type configUpdateSupport struct {
    multichain.Manager //type multiLedger struct
}

func (cus configUpdateSupport) GetChain(chainID string) (configupdate.Support, bool) {
    return cus.Manager.GetChain(chainID)
}
//代码在orderer/server.go

multichain.Manager接口及实现multiLedger，见Fabric 1.0源代码笔记 之 Orderer #multichain（多链支持包）

3、Support接口定义及实现

3.1、Support接口定义

type Support interface {
    ProposeConfigUpdate(env *cb.Envelope) (*cb.ConfigEnvelope, error)
}
//代码在orderer/configupdate/configupdate.go

3.2、Support接口实现

Support接口实现，即configManager结构体及方法。

type configManager struct {
    api.Resources
    callOnUpdate []func(api.Manager)
    initializer  api.Initializer
    current      *configSet
}

func (cm *configManager) processConfig(channelGroup *cb.ConfigGroup) (*configResult, error) //./config.go
func (cm *configManager) commitCallbacks() //./manager.go
func (cm *configManager) ProposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error) //./manager.go
func (cm *configManager) proposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error) //./manager.go
func (cm *configManager) prepareApply(configEnv *cb.ConfigEnvelope) (*configResult, error) //./manager.go
func (cm *configManager) Validate(configEnv *cb.ConfigEnvelope) error //./manager.go
func (cm *configManager) Apply(configEnv *cb.ConfigEnvelope) error //./manager.go
func (cm *configManager) ChainID() string //./manager.go
func (cm *configManager) Sequence() uint64 //./manager.go
func (cm *configManager) ConfigEnvelope() *cb.ConfigEnvelope //./manager.go
func (cm *configManager) verifyDeltaSet(deltaSet map[string]comparable, signedData []*cb.SignedData) error //./update.go
func (cm *configManager) authorizeUpdate(configUpdateEnv *cb.ConfigUpdateEnvelope) (map[string]comparable, error) //./update.go
func (cm *configManager) policyForItem(item comparable) (policies.Policy, bool) //./update.go
func (cm *configManager) computeUpdateResult(updatedConfig map[string]comparable) map[string]comparable //./update.go
//代码在common/configtx/manager.go

4、ConfigUpdateProcessor接口定义及实现

4.1、ConfigUpdateProcessor接口定义

type ConfigUpdateProcessor interface {
    Process(envConfigUpdate *cb.Envelope) (*cb.Envelope, error)
}
//代码在orderer/common/broadcast/broadcast.go

4.2、ConfigUpdateProcessor接口实现

ConfigUpdateProcessor接口实现，即Processor结构体及方法。

type Processor struct {
    signer               crypto.LocalSigner
    manager              SupportManager //即type configUpdateSupport struct，或者即multichain.multiLedger
    systemChannelID      string
    systemChannelSupport Support
}

//构造Processor
func New(systemChannelID string, supportManager SupportManager, signer crypto.LocalSigner) *Processor
//获取channelID
func channelID(env *cb.Envelope) (string, error) 
//处理通道配置更新
func (p *Processor) Process(envConfigUpdate *cb.Envelope) (*cb.Envelope, error)
func (p *Processor) existingChannelConfig(envConfigUpdate *cb.Envelope, channelID string, support Support) (*cb.Envelope, error)
func (p *Processor) proposeNewChannelToSystemChannel(newChannelEnvConfig *cb.Envelope) (*cb.Envelope, error)
func (p *Processor) newChannelConfig(channelID string, envConfigUpdate *cb.Envelope) (*cb.Envelope, error)
//代码在orderer/configupdate/configupdate.go

4.2.1、func New(systemChannelID string, supportManager SupportManager, signer crypto.LocalSigner) *Processor

func New(systemChannelID string, supportManager SupportManager, signer crypto.LocalSigner) *Processor {
    support, ok := supportManager.GetChain(systemChannelID)
    return &Processor{
        systemChannelID:      systemChannelID,
        manager:              supportManager,
        signer:               signer,
        systemChannelSupport: support,
    }
}
//代码在orderer/configupdate/configupdate.go

4.2.2、func (p Processor) Process(envConfigUpdate cb.Envelope) (*cb.Envelope, error)

func (p *Processor) Process(envConfigUpdate *cb.Envelope) (*cb.Envelope, error) {
    channelID, err := channelID(envConfigUpdate)
    support, ok := p.manager.GetChain(channelID) //存在
    if ok {
        return p.existingChannelConfig(envConfigUpdate, channelID, support)
    }
    return p.newChannelConfig(channelID, envConfigUpdate) //不存在
}
//代码在orderer/configupdate/configupdate.go

4.2.3、func (p Processor) existingChannelConfig(envConfigUpdate cb.Envelope, channelID string, support Support) (*cb.Envelope, error)

func (p *Processor) existingChannelConfig(envConfigUpdate *cb.Envelope, channelID string, support Support) (*cb.Envelope, error) {
    configEnvelope, err := support.ProposeConfigUpdate(envConfigUpdate)
    return utils.CreateSignedEnvelope(cb.HeaderType_CONFIG, channelID, p.signer, configEnvelope, msgVersion, epoch)
}
//代码在orderer/configupdate/configupdate.go

4.2.4、func (p Processor) newChannelConfig(channelID string, envConfigUpdate cb.Envelope) (*cb.Envelope, error)

func (p *Processor) newChannelConfig(channelID string, envConfigUpdate *cb.Envelope) (*cb.Envelope, error) {
    ctxm, err := p.manager.NewChannelConfig(envConfigUpdate) //创建新的通道
    newChannelConfigEnv, err := ctxm.ProposeConfigUpdate(envConfigUpdate) //创建新的通道后处理通道配置
    newChannelEnvConfig, err := utils.CreateSignedEnvelope(cb.HeaderType_CONFIG, channelID, p.signer, newChannelConfigEnv, msgVersion, epoch)
    return p.proposeNewChannelToSystemChannel(newChannelEnvConfig)
}
//代码在orderer/configupdate/configupdate.go

5、详解configManager结构体

5.1、configManager结构体定义及方法

type configManager struct {
    api.Resources
    callOnUpdate []func(api.Manager)
    initializer  api.Initializer
    current      *configSet
}

func validateConfigID(configID string) error
func validateChannelID(channelID string) error
func NewManagerImpl(envConfig *cb.Envelope, initializer api.Initializer, callOnUpdate []func(api.Manager)) (api.Manager, error)
func (cm *configManager) commitCallbacks()
func (cm *configManager) ProposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error)
func (cm *configManager) proposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error)
func (cm *configManager) prepareApply(configEnv *cb.ConfigEnvelope) (*configResult, error)
func (cm *configManager) Validate(configEnv *cb.ConfigEnvelope) error
func (cm *configManager) Apply(configEnv *cb.ConfigEnvelope) error
func (cm *configManager) ChainID() string
func (cm *configManager) Sequence() uint64
func (cm *configManager) ConfigEnvelope() *cb.ConfigEnvelope

func proposeGroup(result *configResult) error
func processConfig(channelGroup *cb.ConfigGroup, proposer api.Proposer) (*configResult, error)
func (cm *configManager) processConfig(channelGroup *cb.ConfigGroup) (*configResult, error)

func (c *configSet) verifyReadSet(readSet map[string]comparable) error
func ComputeDeltaSet(readSet, writeSet map[string]comparable) map[string]comparable
func validateModPolicy(modPolicy string) error
func (cm *configManager) verifyDeltaSet(deltaSet map[string]comparable, signedData []*cb.SignedData) error
func verifyFullProposedConfig(writeSet, fullProposedConfig map[string]comparable) error
//验证所有修改的配置都有相应的修改策略，返回修改过的配置的映射map[string]comparable
func (cm *configManager) authorizeUpdate(configUpdateEnv *cb.ConfigUpdateEnvelope) (map[string]comparable, error)
func (cm *configManager) policyForItem(item comparable) (policies.Policy, bool)
func (cm *configManager) computeUpdateResult(updatedConfig map[string]comparable) map[string]comparable
//Envelope转换为ConfigUpdateEnvelope
func envelopeToConfigUpdate(configtx *cb.Envelope) (*cb.ConfigUpdateEnvelope, error)
//代码在common/configtx/manager.go

5.2、func (cm configManager) ProposeConfigUpdate(configtx cb.Envelope) (*cb.ConfigEnvelope, error)

func (cm *configManager) ProposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error) {
    return cm.proposeConfigUpdate(configtx)
}

func (cm *configManager) proposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error) {
    //Envelope转换为ConfigUpdateEnvelope
    configUpdateEnv, err := envelopeToConfigUpdate(configtx)
    //验证所有修改的配置都有相应的修改策略，返回修改过的配置的映射map[string]comparable
    configMap, err := cm.authorizeUpdate(configUpdateEnv)
    channelGroup, err := configMapToConfig(configMap) //ConfigGroup
    //实际调用processConfig(channelGroup, cm.initializer)，并最终调用proposeGroup(configResult)
    result, err := cm.processConfig(channelGroup)
    result.rollback()
    return &cb.ConfigEnvelope{
        Config: &cb.Config{
            Sequence:     cm.current.sequence + 1,
            ChannelGroup: channelGroup,
        },
        LastUpdate: configtx,
    }, nil
}
//代码在common/configtx/manager.go

补充ConfigUpdateEnvelope:

type ConfigUpdateEnvelope struct {
    ConfigUpdate []byte //type ConfigUpdate struct
    Signatures   []*ConfigSignature
}

type ConfigUpdate struct {
    ChannelId string
    ReadSet   *ConfigGroup
    WriteSet  *ConfigGroup
}

type ConfigGroup struct {
    Version   uint64
    Groups    map[string]*ConfigGroup
    Values    map[string]*ConfigValue
    Policies  map[string]*ConfigPolicy
    ModPolicy string
}
//代码在protos/common/configtx.pb.go

补充ConfigGroup:



### 5.3、func (cm *configManager) authorizeUpdate(configUpdateEnv *cb.ConfigUpdateEnvelope) (map[string]comparable, error)

func (cm configManager) authorizeUpdate(configUpdateEnv cb.ConfigUpdateEnvelope) (map[string]comparable, error) {
    //反序列化configUpdateEnv.ConfigUpdate
    configUpdate, err := UnmarshalConfigUpdate(configUpdateEnv.ConfigUpdate)

    readSet, err := MapConfig(configUpdate.ReadSet) //map[string]comparable
    err = cm.current.verifyReadSet(readSet)

    writeSet, err := MapConfig(configUpdate.WriteSet) //map[string]comparable

    //从writeSet中逐一对比readSet，去除没有发生变更的
    deltaSet := ComputeDeltaSet(readSet, writeSet)
    signedData, err := configUpdateEnv.AsSignedData() //转换为SignedData

    err = cm.verifyDeltaSet(deltaSet, signedData) //校验deltaSet

    fullProposedConfig := cm.computeUpdateResult(deltaSet) //合并为fullProposedConfig
    err := verifyFullProposedConfig(writeSet, fullProposedConfig)
    return fullProposedConfig, nil
}
//代码在common/configtx/update.go


补充comparable:

type comparable struct {
    *cb.ConfigGroup
    *cb.ConfigValue
    *cb.ConfigPolicy
    key string
    path []string
}
//代码在common/configtx/compare.go


### 5.4、func (cm *configManager) processConfig(channelGroup *cb.ConfigGroup) (*configResult, error)

func (cm configManager) processConfig(channelGroup cb.ConfigGroup) (*configResult, error) {
    configResult, err := processConfig(channelGroup, cm.initializer)
    err = configResult.preCommit()
    return configResult, nil
}
//代码在common/configtx/config.go


补充configResult：

type configResult struct {
    tx interface{}
    groupName string
    groupKey string
    group *cb.ConfigGroup
    valueHandler config.ValueProposer
    policyHandler policies.Proposer
    subResults []*configResult
    deserializedValues map[string]proto.Message
    deserializedPolicies map[string]proto.Message
}

func NewConfigResult(config *cb.ConfigGroup, proposer api.Proposer) (ConfigResult, error)
func (cr *configResult) JSON() string
func (cr configResult) bufferJSON(buffer bytes.Buffer)
//cr.valueHandler.PreCommit(cr.tx)
func (cr *configResult) preCommit() error
//cr.valueHandler.CommitProposals(cr.tx)
//cr.policyHandler.CommitProposals(cr.tx)
func (cr *configResult) commit()
//cr.valueHandler.RollbackProposals(cr.tx)
//cr.policyHandler.RollbackProposals(cr.tx)
func (cr *configResult) rollback()
func proposeGroup(result *configResult) error
func processConfig(channelGroup cb.ConfigGroup, proposer api.Proposer) (configResult, error)
//代码在common/configtx/config.go


#### 5.4.1、func processConfig(channelGroup *cb.ConfigGroup, proposer api.Proposer) (*configResult, error)

func processConfig(channelGroup cb.ConfigGroup, proposer api.Proposer) (configResult, error) {
    helperGroup := cb.NewConfigGroup()
    helperGroup.Groups[RootGroupKey] = channelGroup

    configResult := &configResult{
        group: helperGroup,
        valueHandler: proposer.ValueProposer(),
        policyHandler: proposer.PolicyProposer(),
    }
    err := proposeGroup(configResult)
    return configResult, nil
}
//代码在common/configtx/config.go


#### 5.4.2、func proposeGroup(result *configResult) error

func proposeGroup(result *configResult) error {
    subGroups := make([]string, len(result.group.Groups))
    i := 0
    for subGroup := range result.group.Groups {
        subGroups[i] = subGroup
        i++
    }

    valueDeserializer, subValueHandlers, err := result.valueHandler.BeginValueProposals(result.tx, subGroups)
    subPolicyHandlers, err := result.policyHandler.BeginPolicyProposals(result.tx, subGroups)

    for key, value := range result.group.Values {
        msg, err := valueDeserializer.Deserialize(key, value.Value)
        result.deserializedValues[key] = msg
    }

    for key, policy := range result.group.Policies {
        policy, err := result.policyHandler.ProposePolicy(result.tx, key, policy)
        result.deserializedPolicies[key] = policy
    }

    result.subResults = make([]*configResult, 0, len(subGroups))

    for i, subGroup := range subGroups {
        result.subResults = append(result.subResults, &configResult{
            tx: result.tx,
            groupKey: subGroup,
            groupName: result.groupName + "/" + subGroup,
            group: result.group.Groups[subGroup],
            valueHandler: subValueHandlers[i],
            policyHandler: subPolicyHandlers[i],
            deserializedValues: make(map[string]proto.Message),
            deserializedPolicies: make(map[string]proto.Message),
        })
        err := proposeGroup(result.subResults[i])
    }
    return nil
}
//代码在common/configtx/config.go

文章标签：
区块链
数据格式
JSON
关键词：
区块链分析
Fabric配置
区块链教程
Fabric通道
区块链源代码
区块链教程
目录
相关文章
游客vsgxb64qlj7cg
|
6月前
|
存储 供应链 监控
区块链技术在供应链管理中的应用与前景分析
随着信息化时代的到来，供应链管理面临着越来越多的挑战和机遇。本文主要探讨了区块链技术在供应链管理中的应用，以及未来的发展前景。通过对区块链技术的特点和优势进行分析，结合实际案例和趋势展望，展示了区块链技术在提升供应链透明度、效率和安全性方面的潜力，以及未来发展的可能方向。
游客vsgxb64qlj7cg
274 2
FeelTouchLabs
|
3月前
|
安全 区块链
Massa Layer 1区块链 POS 安全性分析
Massa Labs 回应 Certik 的挑战，通过严格的数学分析证明了其权益证明系统的安全性，抵抗了潜在攻击者试图操纵随机抽签的企图。
FeelTouchLabs
59 0
Massa Layer 1区块链 POS 安全性分析
路边两盏灯
|
3月前
|
网络协议 微服务
【Azure 微服务】基于已经存在的虚拟网络(VNET)及子网创建新的Service Fabric并且为所有节点配置自定义DNS服务
【Azure 微服务】基于已经存在的虚拟网络(VNET)及子网创建新的Service Fabric并且为所有节点配置自定义DNS服务
路边两盏灯
33 0
肥猪肥猪-17824
|
6月前
|
存储 供应链 安全
基于区块链技术的智能合约安全性分析
【5月更文挑战第31天】本文深入探讨了区块链技术中智能合约的安全性问题，通过分析现有智能合约的安全漏洞和攻击手段，提出了一系列增强智能合约安全性的策略。文章首先介绍了区块链和智能合约的基本概念，随后详细讨论了智能合约面临的安全挑战，包括代码漏洞、重入攻击等问题，并对比分析了不同平台下智能合约的安全性差异。最后，文章提出了一系列提高智能合约安全性的建议，旨在为区块链应用的健康发展提供参考。
肥猪肥猪-17824
114 1
区块链WEB3技术团队
|
5月前
|
存储 安全 区块链
元宇宙与区块链技术的关系可以从多个角度进行阐述。以下是对这两者之间关系的详细分析
**元宇宙：虚拟世界融合现实元素，强调交互与沉浸；区块链：去中心化、安全的分布式账本。两者结合，区块链确保元宇宙中虚拟资产安全、支付高效、身份验证私密、治理透明，支撑其经济体系与用户信任，驱动未来发展。**
区块链WEB3技术团队
48 0
开发V|TG_ch3nguang
|
6月前
|
存储 算法 安全
区块链系统开发技术规则分析
区块链核心技术包括：1) 哈希算法，利用单向函数将任意数据转化为固定长度代码，确保安全验证；2) 非对称加密，使用公钥和私钥一对进行加密解密，保证信息安全；3) 共识机制，如PoW、PoS、DPoS等，实现快速交易验证和确认；4) 智能合约，自动执行的可信代码，一旦编写即不可更改，用于自动化交易；5) 分布式存储，将数据分散存储在网络各处，涵盖结构化、非结构化和半结构化数据。
开发V|TG_ch3nguang
67 1
区块链WEB3技术团队
|
5月前
|
区块链
近期区块链市场趋势分析
**区块链市场趋势摘要:** - 跨链技术成熟，提升互操作性，助力区块链网络融合。 - DeFi持续繁荣，智能合约与AMM创新活跃，市场竞争驱动市场壮大。 - NFT市场多样化，拓展至游戏、音乐等领域，实用性增强。 - 区块链寻求绿色转型，通过PoS共识与绿色能源减少能耗。 - 技术模块化、可组合性提升，降低成本，增强系统灵活性。 这些趋势展现区块链潜力，带来机遇与挑战，促进行业创新。
区块链WEB3技术团队
29 0
叫个什么名字
|
6月前
|
供应链 区块链 数据安全/隐私保护
探索区块链技术在金融领域的应用与前景分析
本文将深入探讨区块链技术在金融领域的具体应用场景，分析其优势与挑战，并展望未来发展趋势。通过案例分析和技术解析，揭示区块链技术在金融行业中的革新意义及前景。
叫个什么名字
678 15
Enaium
Minecraft Fabric 教程 #8 添加附魔书
这就创建了一个FireBoom附魔书 onTargetDamaged //当目标被攻击 在mc FireballEntity类有一个 方法就是当火球碰撞了就创建一个火焰爆炸的效果
Enaium
74 0
开发V|TG_ch3nguang
|
区块链
区块链的发币流程技术分析
区块链现在是发展的如火如荼，很多人都想趁着这个风口，投入区块链创业的浪潮中。 那么我们该怎么做才能抓住这个机会呢？ 进行区块链发币要求是很多的，主要有以下几个步骤。
开发V|TG_ch3nguang
508 0

热门文章

最新文章

  • 1
    Data Fabric：一站式数据管理与服务
  • 2
    IBM技术专家：Hyperleger Fabric 架构与部署实例解析
  • 3
    区块链Hyperledger Fabric在阿里云容器服务Kubernetes中的进阶使用技巧（一）
  • 4
    Minecraft开服教程（官方服务器/fabric服务器）
  • 5
    阿里云容器服务区块链解决方案全新升级 支持Hyperledger Fabric v1.1
  • 6
    超级账本Fabric的架构与设计
  • 7
    fabric的state统计（或设置环境——系统的和fabric本身的）
  • 8
    Hyperledger Fabric 1.0 从零开始（九）——Fabric多节点集群生产启动
  • 9
    fabric装饰器类
  • 10
    Hyperledger Fabric 2.x Java区块链应用
  • 1
    新技术浪潮：区块链、物联网与虚拟现实的发展趋势与应用探讨
    55
  • 2
    新兴科技探索：区块链、物联网、虚拟现实的未来应用前景
    137
  • 3
    探索区块链技术在金融领域的应用与前景分析
    678
  • 4
    新兴科技驱动未来发展：区块链、物联网和虚拟现实的趋势与应用探讨
    41
  • 5
    新兴科技引领未来发展：探索区块链、物联网、虚拟现实的趋势与应用
    63
  • 6
    新技术驱动未来：区块链、物联网、虚拟现实的蓬勃发展与创新应用
    60
  • 7
    未来技术浪潮：区块链、物联网与虚拟现实的融合与创新
    108
  • 8
    未来技术的融合潮流：区块链、物联网与虚拟现实的交汇点
    110
  • 9
    未来技术纵横谈：区块链、物联网与虚拟现实的融合革新
    84
  • 10
    未来交织：探索区块链、物联网和虚拟现实的融合革新
    32

    • 相关课程

    更多
  • 机器阅读技术与应用
  • 软件供应商发布服务实操

    • 相关电子书

    更多
  • 区块链开启可问责服务新时代
  • 区块链在当前实际金融业务应用中的关键技术实施和解决方案
  • IBM区块链技之道

    • 相关实验场景

    更多
  • 语言入门-1：环境构建
  • 搭建IoT小程序开发环境，创建一个应用
  • 制作开放场景
  • 基于函数计算快速搭建Zblog等传统应用框架
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月