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

2018-11-04 470

　　区块链教程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

微信关注我们

原文链接：https://yq.aliyun.com/articles/664677

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

c# 与java base64 不一致解决方案

不一致的问题不是编码的问题而是json字符串的问题通常我们会json嵌套我们先来看连个字符串 {"contentType":"","httpMethod":"POST","paramMap":"{\"keyword\":\"华为\"}","url":"https:\/\/bizapi.jd.com\/api\/search\/search"} --第一条 {"contentType":"","httpMethod":"POST","paramMap":{"keyword":"华为"},"url":"https://bizapi.jd.com/api/search/search"} ----第二条 -----接下来我们看一下效果看第二条的第一条情况：我们将json字符串转换为对象直接使用但是paramMap的值是一个字符串我们又要将该值转换为json在使用的过程中我们转换了两次第二条情况:直接转换为json对象我们分别取不同key的value来使用发生错误的问题应该是有反斜杠转移符我们上一下代码 using Newtonsoft.Json; using Sys...

2018-11-05

599

引言委托和事件在 .Net Framework中的应用非常广泛，然而，较好地理解委托和事件对很多接触C#时间不长的人来说并不容易。它们就像是一道槛儿，过了这个槛的人，觉得真是太容易了，而没有过去的人每次见到委托和事件就觉得心里别（biè）得慌，混身不自在。本文中，我将通过两个范例由浅入深地讲述什么是委托、为什么要使用委托、事件的由来、.Net Framework中的委托和事件、委托和事件对Observer设计模式的意义，对它们的中间代码也做了讨论。将方法作为方法的参数我们先不管这个标题如何的绕口，也不管委托究竟是个什么东西，来看下面这两个最简单的方法，它们不过是在屏幕上输出一句问候的话语： 1 public void GreetPeople(string name) {2 // 做某些额外的事情，比如初始化之类，此处略3 EnglishGreeting(name);4 }1 public void EnglishGreeting(string name) {2 Console.WriteLine("Morning, " + name);3 }暂且不管这两个方法有没有什么实际意义。...

2018-11-05

594

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

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

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

1、configupdate概述

2、SupportManager接口定义及实现

2.1、SupportManager接口定义

2.2、SupportManager接口实现

3、Support接口定义及实现

3.1、Support接口定义

3.2、Support接口实现

4、ConfigUpdateProcessor接口定义及实现

4.1、ConfigUpdateProcessor接口定义

4.2、ConfigUpdateProcessor接口实现

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

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

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

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

5、详解configManager结构体

5.1、configManager结构体定义及方法

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

c# 与java base64 不一致解决方案

C# 中的委托

相关文章

发表评论

资源下载

Mario

腾讯云软件源

Spring

Rocky Linux

欢迎您来访！

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

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

1、configupdate概述

2、SupportManager接口定义及实现

2.1、SupportManager接口定义

2.2、SupportManager接口实现

3、Support接口定义及实现

3.1、Support接口定义

3.2、Support接口实现

4、ConfigUpdateProcessor接口定义及实现

4.1、ConfigUpdateProcessor接口定义

4.2、ConfigUpdateProcessor接口实现

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

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

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

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

5、详解configManager结构体

5.1、configManager结构体定义及方法

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

c# 与java base64 不一致解决方案

C# 中的委托

相关文章

发表评论

资源下载

Mario

腾讯云软件源

Spring

Rocky Linux

欢迎您来访！

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