1. 每日区块链首页
  2. 独家专栏

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

兄弟连区块链教程Fabric1.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.Config
func UnmarshalConfigUpdate(data []byte) (*cb.ConfigUpdate, error)
func UnmarshalConfigUpdateOrPanic(data []byte) *cb.ConfigUpdate
func UnmarshalConfigUpdateEnvelope(data []byte) (*cb.ConfigUpdateEnvelope, error)
func UnmarshalConfigUpdateEnvelopeOrPanic(data []byte) *cb.ConfigUpdateEnvelope
func 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.policyManager
func (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.mspConfigHandler
func (r *resources) MSPManager() msp.MSPManager
//构造resources
func newResources() *resources
//代码在common/configtx/initializer.go

原创文章,作者:兄弟连区块链学院,如若转载,请注明出处:http://www.dayqkl.com/54021.html

发表评论

登录后才能评论
QR code