备案控制台
开发者社区 微服务 文章 正文

区块链教程Fabric1.0源代码分析配置交易-生成通道配置二

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

　　兄弟连区块链教程Fabric1.0源代码分析配置交易-生成通道配置二。Generator接口实现，即bootstrapper。

type bootstrapper struct {
    channelGroups     []*cb.ConfigGroup
    ordererGroups     []*cb.ConfigGroup
    applicationGroups []*cb.ConfigGroup
    consortiumsGroups []*cb.ConfigGroup
}

func New(conf *genesisconfig.Profile) Generator
func (bs *bootstrapper) ChannelTemplate() configtx.Template
func (bs *bootstrapper) GenesisBlock() *cb.Block
func (bs *bootstrapper) GenesisBlockForChannel(channelID string) *cb.Block
//代码在common/configtx/tool/provisional/provisional.go

func New(conf *genesisconfig.Profile) Generator代码如下：

func New(conf *genesisconfig.Profile) Generator {
    bs := &bootstrapper{
        channelGroups: []*cb.ConfigGroup{
            config.DefaultHashingAlgorithm(), //默认哈希函数
            config.DefaultBlockDataHashingStructure(), //默认块数据哈希结构
            
            //默认通道策略，包括读策略、写策略和管理策略
            //ReadersPolicyKey = "Readers"，ImplicitMetaPolicy_ANY，任意
            policies.TemplateImplicitMetaAnyPolicy([]string{}, configvaluesmsp.ReadersPolicyKey),
            //WritersPolicyKey = "Writers"，ImplicitMetaPolicy_ANY，任意
            policies.TemplateImplicitMetaAnyPolicy([]string{}, configvaluesmsp.WritersPolicyKey),
            //AdminsPolicyKey = "Admins"，ImplicitMetaPolicy_MAJORITY，大多数
            policies.TemplateImplicitMetaMajorityPolicy([]string{}, configvaluesmsp.AdminsPolicyKey),
        },
    }

    if conf.Orderer != nil { //系统通道配置
        oa := config.TemplateOrdererAddresses(conf.Orderer.Addresses) //设置Orderer地址
        oa.Values[config.OrdererAddressesKey].ModPolicy = OrdererAdminsPolicy //OrdererAdminsPolicy = "/Channel/Orderer/Admins"

        bs.ordererGroups = []*cb.ConfigGroup{
            oa,
            config.TemplateConsensusType(conf.Orderer.OrdererType), //设置共识插件类型
            config.TemplateBatchSize(&ab.BatchSize{ //设置批处理大小
                MaxMessageCount:   conf.Orderer.BatchSize.MaxMessageCount,
                AbsoluteMaxBytes:  conf.Orderer.BatchSize.AbsoluteMaxBytes,
                PreferredMaxBytes: conf.Orderer.BatchSize.PreferredMaxBytes,
            }),
            config.TemplateBatchTimeout(conf.Orderer.BatchTimeout.String()), //设置批处理超时
            config.TemplateChannelRestrictions(conf.Orderer.MaxChannels), //设置最大通道数

            //初始化Orderer读、写、管理策略
            policies.TemplateImplicitMetaPolicyWithSubPolicy([]string{config.OrdererGroupKey}, BlockValidationPolicyKey, configvaluesmsp.WritersPolicyKey, cb.ImplicitMetaPolicy_ANY),
            policies.TemplateImplicitMetaAnyPolicy([]string{config.OrdererGroupKey}, configvaluesmsp.ReadersPolicyKey),
            policies.TemplateImplicitMetaAnyPolicy([]string{config.OrdererGroupKey}, configvaluesmsp.WritersPolicyKey),
            policies.TemplateImplicitMetaMajorityPolicy([]string{config.OrdererGroupKey}, configvaluesmsp.AdminsPolicyKey),
        }

        for _, org := range conf.Orderer.Organizations {
            mspConfig, err := msp.GetVerifyingMspConfig(org.MSPDir, org.ID)
            bs.ordererGroups = append(bs.ordererGroups,
                configvaluesmsp.TemplateGroupMSPWithAdminRolePrincipal([]string{config.OrdererGroupKey, org.Name},
                    mspConfig, org.AdminPrincipal == genesisconfig.AdminRoleAdminPrincipal,
                ),
            )
        }

        switch conf.Orderer.OrdererType {
        case ConsensusTypeSolo:
        case ConsensusTypeKafka:
            bs.ordererGroups = append(bs.ordererGroups, config.TemplateKafkaBrokers(conf.Orderer.Kafka.Brokers)) //设置Kafka
        default:
        }
    }

    if conf.Application != nil { //应用通道配置
        bs.applicationGroups = []*cb.ConfigGroup{
            policies.TemplateImplicitMetaAnyPolicy([]string{config.ApplicationGroupKey}, configvaluesmsp.ReadersPolicyKey),
            policies.TemplateImplicitMetaAnyPolicy([]string{config.ApplicationGroupKey}, configvaluesmsp.WritersPolicyKey),
            policies.TemplateImplicitMetaMajorityPolicy([]string{config.ApplicationGroupKey}, configvaluesmsp.AdminsPolicyKey),
        }
        for _, org := range conf.Application.Organizations {
            mspConfig, err := msp.GetVerifyingMspConfig(org.MSPDir, org.ID)
            bs.applicationGroups = append(bs.applicationGroups,
                configvaluesmsp.TemplateGroupMSPWithAdminRolePrincipal([]string{config.ApplicationGroupKey, org.Name},
                    mspConfig, org.AdminPrincipal == genesisconfig.AdminRoleAdminPrincipal,
                ),
            )
            var anchorProtos []*pb.AnchorPeer
            for _, anchorPeer := range org.AnchorPeers {
                anchorProtos = append(anchorProtos, &pb.AnchorPeer{
                    Host: anchorPeer.Host,
                    Port: int32(anchorPeer.Port),
                })
            }
            bs.applicationGroups = append(bs.applicationGroups, config.TemplateAnchorPeers(org.Name, anchorProtos))
        }

    }

    if conf.Consortiums != nil { //联盟相关
        tcg := config.TemplateConsortiumsGroup()
        tcg.Groups[config.ConsortiumsGroupKey].ModPolicy = OrdererAdminsPolicy
        tcg.Groups[config.ConsortiumsGroupKey].Policies[configvaluesmsp.AdminsPolicyKey] = &cb.ConfigPolicy{
            Policy: &cb.Policy{
                Type:  int32(cb.Policy_SIGNATURE),
                Value: utils.MarshalOrPanic(cauthdsl.AcceptAllPolicy),
            },
            ModPolicy: OrdererAdminsPolicy,
        }
        bs.consortiumsGroups = append(bs.consortiumsGroups, tcg)
        for consortiumName, consortium := range conf.Consortiums {
            cg := config.TemplateConsortiumChannelCreationPolicy(consortiumName, policies.ImplicitMetaPolicyWithSubPolicy(
                configvaluesmsp.AdminsPolicyKey,
                cb.ImplicitMetaPolicy_ANY,
            ).Policy)

            cg.Groups[config.ConsortiumsGroupKey].Groups[consortiumName].ModPolicy = OrdererAdminsPolicy
            cg.Groups[config.ConsortiumsGroupKey].Groups[consortiumName].Values[config.ChannelCreationPolicyKey].ModPolicy = OrdererAdminsPolicy
            bs.consortiumsGroups = append(bs.consortiumsGroups, cg)

            for _, org := range consortium.Organizations {
                mspConfig, err := msp.GetVerifyingMspConfig(org.MSPDir, org.ID)
                bs.consortiumsGroups = append(bs.consortiumsGroups,
                    configvaluesmsp.TemplateGroupMSPWithAdminRolePrincipal(
                        []string{config.ConsortiumsGroupKey, consortiumName, org.Name},
                        mspConfig, org.AdminPrincipal == genesisconfig.AdminRoleAdminPrincipal,
                    ),
                )
            }
        }
    }

    return bs
}
//代码在common/configtx/tool/provisional/provisional.go

func (bs bootstrapper) GenesisBlockForChannel(channelID string) cb.Block代码如下：

func (bs *bootstrapper) GenesisBlockForChannel(channelID string) *cb.Block {
    block, err := genesis.NewFactoryImpl(
        configtx.NewModPolicySettingTemplate(
            configvaluesmsp.AdminsPolicyKey,
            configtx.NewCompositeTemplate(
                configtx.NewSimpleTemplate(bs.consortiumsGroups...),
                bs.ChannelTemplate(),
            ),
        ),
    ).Block(channelID)
    return block
}

//代码在common/configtx/tool/provisional/provisional.go

5、configtxgen命令

5.1、main函数

func main() {
    var outputBlock, outputChannelCreateTx, profile, channelID, inspectBlock, inspectChannelCreateTx, outputAnchorPeersUpdate, asOrg string

    //-outputBlock，初始区块写入指定文件
    flag.StringVar(&outputBlock, "outputBlock", "", "The path to write the genesis block to (if set)")
    //-channelID，指定通道名称
    flag.StringVar(&channelID, "channelID", provisional.TestChainID, "The channel ID to use in the configtx")
    //-outputCreateChannelTx，将通道创建交易写入指定文件
    flag.StringVar(&outputChannelCreateTx, "outputCreateChannelTx", "", "The path to write a channel creation configtx to (if set)")
    //-profile，指定profile
    flag.StringVar(&profile, "profile", genesisconfig.SampleInsecureProfile, "The profile from configtx.yaml to use for generation.")
    //-inspectBlock，打印指定区块的配置信息
    flag.StringVar(&inspectBlock, "inspectBlock", "", "Prints the configuration contained in the block at the specified path")
    //-inspectChannelCreateTx，打印通道创建交易文件中的配置更新信息
    flag.StringVar(&inspectChannelCreateTx, "inspectChannelCreateTx", "", "Prints the configuration contained in the transaction at the specified path")
    //-outputAnchorPeersUpdate，生成锚节点配置更新文件，需同时指定-asOrg
    flag.StringVar(&outputAnchorPeersUpdate, "outputAnchorPeersUpdate", "", "Creates an config update to update an anchor peer (works only with the default channel creation, and only for the first update)")
    //-asOrg，以指定身份执行更新配置交易，如更新锚节点配置信息
    flag.StringVar(&asOrg, "asOrg", "", "Performs the config generation as a particular organization (by name), only including values in the write set that org (likely) has privilege to set")
    flag.Parse()

    factory.InitFactories(nil)
    config := genesisconfig.Load(profile) //读取指定配置

    if outputBlock != "" { //生成Orderer服务启动的初始区块
        err := doOutputBlock(config, channelID, outputBlock)
    }
    if outputChannelCreateTx != "" { //生成新建应用通道的配置交易
        err := doOutputChannelCreateTx(config, channelID, outputChannelCreateTx)
    }
    if outputAnchorPeersUpdate != "" { //生成锚节点配置更新文件
        err := doOutputAnchorPeersUpdate(config, channelID, outputAnchorPeersUpdate, asOrg)
    }
}
//代码在common/configtx/tool/configtxgen/main.go

5.2、doOutputBlock（生成Orderer服务启动的初始区块，即系统通道的初始区块文件）

func doOutputBlock(config *genesisconfig.Profile, channelID string, outputBlock string) error {
    pgen := provisional.New(config) //构建Generator实例
    genesisBlock := pgen.GenesisBlockForChannel(channelID) //生成创世区块
    err := ioutil.WriteFile(outputBlock, utils.MarshalOrPanic(genesisBlock), 0644) //创世区块写入文件
    return nil
}
//代码在common/configtx/tool/configtxgen/main.go

genesis更详细内容，参考：Fabric 1.0源代码笔记 之 configtx（配置交易） #genesis（系统通道创世区块）

5.3、doOutputChannelCreateTx（生成新建应用通道的配置交易）

func doOutputChannelCreateTx(conf *genesisconfig.Profile, channelID string, outputChannelCreateTx string) error {
    var orgNames []string
    for _, org := range conf.Application.Organizations {
        orgNames = append(orgNames, org.Name)
    }
    configtx, err := configtx.MakeChainCreationTransaction(channelID, conf.Consortium, nil, orgNames...)
    err = ioutil.WriteFile(outputChannelCreateTx, utils.MarshalOrPanic(configtx), 0644)
    return nil
}
//代码在common/configtx/tool/configtxgen/main.go

5.4、doOutputAnchorPeersUpdate（生成锚节点配置更新文件）

func doOutputAnchorPeersUpdate(conf *genesisconfig.Profile, channelID string, outputAnchorPeersUpdate string, asOrg string) error {
    var org *genesisconfig.Organization
    for _, iorg := range conf.Application.Organizations {
        if iorg.Name == asOrg {
            org = iorg
        }
    }
    anchorPeers := make([]*pb.AnchorPeer, len(org.AnchorPeers))
    for i, anchorPeer := range org.AnchorPeers {
        anchorPeers[i] = &pb.AnchorPeer{
            Host: anchorPeer.Host,
            Port: int32(anchorPeer.Port),
        }
    }

    configGroup := config.TemplateAnchorPeers(org.Name, anchorPeers)
    configGroup.Groups[config.ApplicationGroupKey].Groups[org.Name].Values[config.AnchorPeersKey].ModPolicy = mspconfig.AdminsPolicyKey
    configUpdate := &cb.ConfigUpdate{
        ChannelId: channelID,
        WriteSet:  configGroup,
        ReadSet:   cb.NewConfigGroup(),
    }

    configUpdate.ReadSet.Groups[config.ApplicationGroupKey] = cb.NewConfigGroup()
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Version = 1
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].ModPolicy = mspconfig.AdminsPolicyKey
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Groups[org.Name] = cb.NewConfigGroup()
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Values[config.MSPKey] = &cb.ConfigValue{}
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.ReadersPolicyKey] = &cb.ConfigPolicy{}
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.WritersPolicyKey] = &cb.ConfigPolicy{}
    configUpdate.ReadSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.AdminsPolicyKey] = &cb.ConfigPolicy{}

    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Version = 1
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].ModPolicy = mspconfig.AdminsPolicyKey
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Version = 1
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].ModPolicy = mspconfig.AdminsPolicyKey
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Values[config.MSPKey] = &cb.ConfigValue{}
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.ReadersPolicyKey] = &cb.ConfigPolicy{}
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.WritersPolicyKey] = &cb.ConfigPolicy{}
    configUpdate.WriteSet.Groups[config.ApplicationGroupKey].Groups[org.Name].Policies[mspconfig.AdminsPolicyKey] = &cb.ConfigPolicy{}

    configUpdateEnvelope := &cb.ConfigUpdateEnvelope{
        ConfigUpdate: utils.MarshalOrPanic(configUpdate),
    }

    update := &cb.Envelope{
        Payload: utils.MarshalOrPanic(&cb.Payload{
            Header: &cb.Header{
                ChannelHeader: utils.MarshalOrPanic(&cb.ChannelHeader{
                    ChannelId: channelID,
                    Type:      int32(cb.HeaderType_CONFIG_UPDATE),
                }),
            },
            Data: utils.MarshalOrPanic(configUpdateEnvelope),
        }),
    }

    err := ioutil.WriteFile(outputAnchorPeersUpdate, utils.MarshalOrPanic(update), 0644)
    return nil
}

//代码在common/configtx/tool/configtxgen/main.go

欢迎继续关注兄弟连区块链教程分享!

文章标签：
云消息队列 Kafka 版
区块链
消息中间件
Kafka
关键词：
区块链分析
区块链交易
区块链教程
Fabric通道
区块链源代码
区块链教程
目录
相关文章
游客vsgxb64qlj7cg
|
2月前
|
存储 供应链 监控
区块链技术在供应链管理中的应用与前景分析
随着信息化时代的到来，供应链管理面临着越来越多的挑战和机遇。本文主要探讨了区块链技术在供应链管理中的应用，以及未来的发展前景。通过对区块链技术的特点和优势进行分析，结合实际案例和趋势展望，展示了区块链技术在提升供应链透明度、效率和安全性方面的潜力，以及未来发展的可能方向。
游客vsgxb64qlj7cg
188 2
开发V_I357O98O7I8
|
2月前
|
安全 区块链
区块链积分商城系统开发详细指南//需求功能/指南教程/源码流程
Developing a blockchain points mall system involves multiple aspects such as blockchain technology, smart contracts, front-end development, and business logic design. The following is the general process for developing a blockchain points mall system
开发V_I357O98O7I8
62 1
芯在这
|
2月前
|
存储 算法 API
面向企业的区块链教程（一）（2）
面向企业的区块链教程（一）
芯在这
58 6
区块链WEB3技术团队
|
8天前
|
存储 安全 区块链
元宇宙与区块链技术的关系可以从多个角度进行阐述。以下是对这两者之间关系的详细分析
**元宇宙：虚拟世界融合现实元素，强调交互与沉浸；区块链：去中心化、安全的分布式账本。两者结合，区块链确保元宇宙中虚拟资产安全、支付高效、身份验证私密、治理透明，支撑其经济体系与用户信任，驱动未来发展。**
区块链WEB3技术团队
11 0
肥猪肥猪-17824
|
2月前
|
存储 供应链 安全
基于区块链技术的智能合约安全性分析
【5月更文挑战第31天】本文深入探讨了区块链技术中智能合约的安全性问题，通过分析现有智能合约的安全漏洞和攻击手段，提出了一系列增强智能合约安全性的策略。文章首先介绍了区块链和智能合约的基本概念，随后详细讨论了智能合约面临的安全挑战，包括代码漏洞、重入攻击等问题，并对比分析了不同平台下智能合约的安全性差异。最后，文章提出了一系列提高智能合约安全性的建议，旨在为区块链应用的健康发展提供参考。
肥猪肥猪-17824
33 1
区块链WEB3技术团队
|
15天前
|
区块链
近期区块链市场趋势分析
**区块链市场趋势摘要:** - 跨链技术成熟，提升互操作性，助力区块链网络融合。 - DeFi持续繁荣，智能合约与AMM创新活跃，市场竞争驱动市场壮大。 - NFT市场多样化，拓展至游戏、音乐等领域，实用性增强。 - 区块链寻求绿色转型，通过PoS共识与绿色能源减少能耗。 - 技术模块化、可组合性提升，降低成本，增强系统灵活性。 这些趋势展现区块链潜力，带来机遇与挑战，促进行业创新。
区块链WEB3技术团队
6 0
开发V|TG_ch3nguang
|
2月前
|
存储 算法 安全
区块链系统开发技术规则分析
区块链核心技术包括：1) 哈希算法，利用单向函数将任意数据转化为固定长度代码，确保安全验证；2) 非对称加密，使用公钥和私钥一对进行加密解密，保证信息安全；3) 共识机制，如PoW、PoS、DPoS等，实现快速交易验证和确认；4) 智能合约，自动执行的可信代码，一旦编写即不可更改，用于自动化交易；5) 分布式存储，将数据分散存储在网络各处，涵盖结构化、非结构化和半结构化数据。
开发V|TG_ch3nguang
31 1
叫个什么名字
|
2月前
|
供应链 区块链 数据安全/隐私保护
探索区块链技术在金融领域的应用与前景分析
本文将深入探讨区块链技术在金融领域的具体应用场景，分析其优势与挑战，并展望未来发展趋势。通过案例分析和技术解析，揭示区块链技术在金融行业中的革新意义及前景。
叫个什么名字
272 15
开发V_I357O98O7I8
|
2月前
|
安全 区块链
区块链游戏系统开发步骤需求丨功能逻辑丨规则玩法丨指南教程丨源码详细
Developing blockchain game systems has been a highly anticipated field in recent years. By combining blockchain technology and game mechanics, players can enjoy a brand new gaming experience and higher game credibility.
开发V_I357O98O7I8
54 0
开发V|TG_ch3nguang
|
10月前
|
区块链
区块链的发币流程技术分析
区块链现在是发展的如火如荼，很多人都想趁着这个风口，投入区块链创业的浪潮中。 那么我们该怎么做才能抓住这个机会呢？ 进行区块链发币要求是很多的，主要有以下几个步骤。
开发V|TG_ch3nguang
407 0

热门文章

最新文章

  • 1
    未来技术纵横谈：区块链、物联网及虚拟现实的新进展与应用探索
  • 2
    未来技术纵横谈：区块链、物联网与虚拟现实的融合革新
  • 3
    区块链系统开发|（成熟技术）/区块链系统开发介绍方案
  • 4
    未来技术的融合潮流：区块链、物联网与虚拟现实的交汇点
  • 5
    未来技术纵横谈：区块链、物联网与虚拟现实的融合革新
  • 6
    swap开发/区块链跨链技术系统开发规则
  • 7
    新技术趋势与应用：区块链、物联网和虚拟现实的未来展望
  • 8
    构建未来：区块链在供应链管理中的应用
  • 9
    未来交织：区块链、物联网与虚拟现实的技术融合与应用革新
  • 10
    未来技术纵横谈：区块链、物联网与虚拟现实的融合与创新
  • 1
    区块链游戏系统开发（开发详细）/案例开发/设计功能/逻辑方案/源码平台
    238
  • 2
    swap区块链交易所质押LP系统开发（模式介绍）方案部署
    91
  • 3
    区块链游戏链游系统开发功能详情丨方案逻辑丨开发项目丨案例分析丨源码规则
    97
  • 4
    区块链SWAP博饼交易所去中心化项目系统开发|DAPP技术开发
    100
  • 5
    【Web3探索】节点提供商：简化区块链访问流程
    197
  • 6
    区块链金融模式DeFI游戏开发搭建部署源码示例
    393
  • 7
    区块链交易所系统开发（海外版）丨交易所系统开发详细规则/方案介绍/项目逻辑/源码平台
    156
  • 8
    区块链分红代理系统开发逻辑部署-附源码规则示例
    336
  • 9
    区块链NFT系统开发|DAPP技术开发
    93
  • 10
    区块链代币支付钱包(trx/trc20代币/usdt)对接开发
    423

    • 相关电子书

    更多
  • 区块链开启可问责服务新时代
  • 区块链在当前实际金融业务应用中的关键技术实施和解决方案
  • IBM区块链技之道
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）