ITPub博客

首页 > 区块链 > 区块链 > 区块链教程Fabric1.0源代码分析配置交易体系介绍

区块链教程Fabric1.0源代码分析配置交易体系介绍

原创 区块链 作者:兄弟连区块链入门教程 时间:2018-10-30 16:07:34 0 删除 编辑

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

Fabric 1.0源代码笔记 之 configtx(配置交易)

1、configtx概述

configtx代码分布在common/configtx目录,目录结构如下:

  • api目录,核心接口定义,如Manager、Resources、Transactional、PolicyHandler、Proposer、Initializer。

  • initializer.go,Resources和Initializer接口实现。

  • template.go,Template接口定义及实现。

  • config.go,ConfigResult接口定义及实现。

  • manager.go/update.go,Manager接口实现。

  • util.go,configtx工具函数。

2、Template接口定义及实现

2.1、Template接口定义

type Template interface {
    Envelope(chainID string) (*cb.ConfigUpdateEnvelope, error)}//代码在common/configtx/template.go

ConfigUpdateEnvelope定义:

type ConfigUpdateEnvelope struct {
    ConfigUpdate []byte //type ConfigUpdate struct
    Signatures   []*ConfigSignature //type ConfigSignature struct}type ConfigUpdate struct {
    ChannelId string
    ReadSet   *ConfigGroup //type ConfigGroup struct
    WriteSet  *ConfigGroup //type ConfigGroup struct}type ConfigSignature struct {
    SignatureHeader []byte
    Signature       []byte}type ConfigGroup struct {
    Version   uint64
    Groups    map[string]*ConfigGroup
    Values    map[string]*ConfigValue
    Policies  map[string]*ConfigPolicy
    ModPolicy string}//代码在protos/common/configtx.pb.go

2.2、Template接口实现(simpleTemplate)

type simpleTemplate struct {
    configGroup *cb.ConfigGroup}func NewSimpleTemplate(configGroups ...*cb.ConfigGroup) Template {
    sts := make([]Template, len(configGroups))
    for i, group := range configGroups {
        sts[i] = &simpleTemplate{
            configGroup: group,
        }
    }
    return NewCompositeTemplate(sts...)}func (st *simpleTemplate) Envelope(chainID string) (*cb.ConfigUpdateEnvelope, error) {
    config, err := proto.Marshal(&cb.ConfigUpdate{
        ChannelId: chainID,
        WriteSet:  st.configGroup,
    })
    return &cb.ConfigUpdateEnvelope{
        ConfigUpdate: config,
    }, nil}//代码在common/configtx/template.go

2.3、Template接口实现(compositeTemplate)

type compositeTemplate struct {
    templates []Template}func NewCompositeTemplate(templates ...Template) Template {
    return &compositeTemplate{templates: templates}}func (ct *compositeTemplate) Envelope(chainID string) (*cb.ConfigUpdateEnvelope, error) {
    channel := cb.NewConfigGroup()
    for i := range ct.templates {
        configEnv, err := ct.templates[i].Envelope(chainID)
        config, err := UnmarshalConfigUpdate(configEnv.ConfigUpdate)
        err = copyGroup(config.WriteSet, channel)
    }
    marshaledConfig, err := proto.Marshal(&cb.ConfigUpdate{
        ChannelId: chainID,
        WriteSet:  channel,
    })
    return &cb.ConfigUpdateEnvelope{ConfigUpdate: marshaledConfig}, nil}//代码在common/configtx/template.go

2.4、Template接口实现(modPolicySettingTemplate)

type modPolicySettingTemplate struct {
    modPolicy string
    template  Template}func NewModPolicySettingTemplate(modPolicy string, template Template) Template {
    return &modPolicySettingTemplate{
        modPolicy: modPolicy,
        template:  template,
    }}func (mpst *modPolicySettingTemplate) Envelope(channelID string) (*cb.ConfigUpdateEnvelope, error) {
    configUpdateEnv, err := mpst.template.Envelope(channelID)
    config, err := UnmarshalConfigUpdate(configUpdateEnv.ConfigUpdate)
    setGroupModPolicies(mpst.modPolicy, config.WriteSet)
    configUpdateEnv.ConfigUpdate = utils.MarshalOrPanic(config)
    return configUpdateEnv, nil}//代码在common/configtx/template.go

3、configtx工具函数

func UnmarshalConfig(data []byte) (*cb.Config, error)func UnmarshalConfigOrPanic(data []byte) *cb.Configfunc UnmarshalConfigUpdate(data []byte) (*cb.ConfigUpdate, error)func UnmarshalConfigUpdateOrPanic(data []byte) *cb.ConfigUpdatefunc UnmarshalConfigUpdateEnvelope(data []byte) (*cb.ConfigUpdateEnvelope, error)func UnmarshalConfigUpdateEnvelopeOrPanic(data []byte) *cb.ConfigUpdateEnvelopefunc UnmarshalConfigEnvelope(data []byte) (*cb.ConfigEnvelope, error)func UnmarshalConfigEnvelopeOrPanic(data []byte) *cb.ConfigEnvelope//代码在common/configtx/util.go

4、Resources接口定义及实现

4.1、Resources接口定义

type Resources interface {
    PolicyManager() policies.Manager //获取通道策略管理器,即policies.Manager
    ChannelConfig() config.Channel //获取通道配置
    OrdererConfig() (config.Orderer, bool) //获取Orderer配置
    ConsortiumsConfig() (config.Consortiums, bool) //获取config.Consortiums
    ApplicationConfig() (config.Application, bool) //获取config.Application
    MSPManager() msp.MSPManager //获取通道msp管理器,即msp.MSPManager}//代码在common/configtx/api/api.go

4.2、Resources接口实现

Resources接口实现,即resources结构体及方法。

type resources struct {
    policyManager    *policies.ManagerImpl
    configRoot       *config.Root
    mspConfigHandler *configtxmsp.MSPConfigHandler}//代码在common/configtx/initializer.go

涉及方法如下:

//获取r.policyManagerfunc (r *resources) PolicyManager() policies.Manager//获取r.configRoot.Channel()func (r *resources) ChannelConfig() config.Channel//获取r.configRoot.Orderer()func (r *resources) OrdererConfig() (config.Orderer, bool)//获取r.configRoot.Application()func (r *resources) ApplicationConfig() (config.Application, bool)//获取r.configRoot.Consortiums()func (r *resources) ConsortiumsConfig() (config.Consortiums, bool)//获取r.mspConfigHandlerfunc (r *resources) MSPManager() msp.MSPManager//构造resourcesfunc newResources() *resources//代码在common/configtx/initializer.go




来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/31557831/viewspace-2218092/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2018-10-11

  • 博文量
    79
  • 访问量
    45028