区块链教程Fabric1.0源代码分析Orderer multichain
区块链教程Fabric1.0源代码分析Orderer multichain,2018年下半年,区块链行业正逐渐褪去发展之初的浮躁、回归理性,表面上看相关人才需求与身价似乎正在回落。但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上。
Fabric 1.0源代码笔记 之 Orderer #multichain(多链支持包)
1、multichain概述
multichain代码集中在orderer/multichain目录下,目录结构如下:
- manager.go,Manager接口定义及实现。
- chainsupport.go,ChainSupport接口定义及实现。
- systemchain.go,system chain。
2、Manager接口定义及实现
2.1、Manager接口定义
用于链的创建和访问。
type Manager interface { //获取ChainSupport,以及判断链是否存在 GetChain(chainID string) (ChainSupport, bool) //获取系统通道的通道ID SystemChannelID() string //支持通道创建请求 NewChannelConfig(envConfigUpdate *cb.Envelope) (configtxapi.Manager, error) } //代码在orderer/multichain/manager.go
2.2、Manager接口实现
Manager接口实现,即multiLedger结构体及方法。
type multiLedger struct { chains map[string]*chainSupport consenters map[string]Consenter ledgerFactory ledger.Factory signer crypto.LocalSigner systemChannelID string systemChannel *chainSupport } type configResources struct { configtxapi.Manager } type ledgerResources struct { *configResources ledger ledger.ReadWriter } //代码在orderer/multichain/manager.go
涉及方法如下:
func (cr *configResources) SharedConfig() config.Orderer //获取配置交易Envelope func getConfigTx(reader ledger.Reader) *cb.Envelope //构造multiLedger func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager //获取系统链ID func (ml *multiLedger) SystemChannelID() string //按chainID获取ChainSupport func (ml *multiLedger) GetChain(chainID string) (ChainSupport, bool) //构造ledgerResources func (ml *multiLedger) newLedgerResources(configTx *cb.Envelope) *ledgerResources //创建新链 func (ml *multiLedger) newChain(configtx *cb.Envelope) //通道或链的个数 func (ml *multiLedger) channelsCount() int //支持创建新的通道 func (ml *multiLedger) NewChannelConfig(envConfigUpdate *cb.Envelope) (configtxapi.Manager, error) //代码在orderer/multichain/manager.go
func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager代码如下:
func NewManagerImpl(ledgerFactory ledger.Factory, consenters map[string]Consenter, signer crypto.LocalSigner) Manager { ml := &multiLedger{ chains: make(map[string]*chainSupport), ledgerFactory: ledgerFactory, consenters: consenters, signer: signer, } existingChains := ledgerFactory.ChainIDs() for _, chainID := range existingChains { rl, err := ledgerFactory.GetOrCreate(chainID) configTx := getConfigTx(rl) ledgerResources := ml.newLedgerResources(configTx) chainID := ledgerResources.ChainID() if _, ok := ledgerResources.ConsortiumsConfig(); ok { //系统链 chain := newChainSupport(createSystemChainFilters(ml, ledgerResources), ledgerResources, consenters, signer) ml.chains[chainID] = chain ml.systemChannelID = chainID ml.systemChannel = chain defer chain.start() } else { //普通链 chain := newChainSupport(createStandardFilters(ledgerResources), ledgerResources, consenters, signer) ml.chains[chainID] = chain chain.start() } } return ml } //代码在orderer/multichain/manager.go
3、ChainSupport接口定义及实现
3.1、ChainSupport接口定义
type ChainSupport interface { PolicyManager() policies.Manager //策略管理 Reader() ledger.Reader Errored() <-chan struct{} broadcast.Support ConsenterSupport //嵌入ConsenterSupport接口 Sequence() uint64 //支持通道更新 ProposeConfigUpdate(env *cb.Envelope) (*cb.ConfigEnvelope, error) } type ConsenterSupport interface { crypto.LocalSigner BlockCutter() blockcutter.Receiver SharedConfig() config.Orderer CreateNextBlock(messages []*cb.Envelope) *cb.Block WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block ChainID() string Height() uint64 } type Consenter interface { //定义支持排序机制 HandleChain(support ConsenterSupport, metadata *cb.Metadata) (Chain, error) } type Chain interface { //接受消息 Enqueue(env *cb.Envelope) bool Errored() <-chan struct{} Start() //开始 Halt() //挂起 } //代码在orderer/multichain/chainsupport.go
3.2、ChainSupport和ConsenterSupport接口实现
ChainSupport接口实现,即chainSupport结构体及方法。
type chainSupport struct { *ledgerResources chain Chain cutter blockcutter.Receiver filters *filter.RuleSet signer crypto.LocalSigner lastConfig uint64 lastConfigSeq uint64 } //代码在orderer/multichain/chainsupport.go
涉及方法如下:
//构造chainSupport func newChainSupport(filters *filter.RuleSet,ledgerResources *ledgerResources,consenters map[string]Consenter,signer crypto.LocalSigner,) *chainSupport func createStandardFilters(ledgerResources *ledgerResources) *filter.RuleSet func createSystemChainFilters(ml *multiLedger, ledgerResources *ledgerResources) *filter.RuleSet func (cs *chainSupport) start() func (cs *chainSupport) NewSignatureHeader() (*cb.SignatureHeader, error) func (cs *chainSupport) Sign(message []byte) ([]byte, error) func (cs *chainSupport) Filters() *filter.RuleSet func (cs *chainSupport) BlockCutter() blockcutter.Receiver func (cs *chainSupport) Reader() ledger.Reader func (cs *chainSupport) Enqueue(env *cb.Envelope) bool func (cs *chainSupport) Errored() <-chan struct{} //创建块,调取ledger.CreateNextBlock(cs.ledger, messages) func (cs *chainSupport) CreateNextBlock(messages []*cb.Envelope) *cb.Block func (cs *chainSupport) addBlockSignature(block *cb.Block) func (cs *chainSupport) addLastConfigSignature(block *cb.Block) //写入块 func (cs *chainSupport) WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block func (cs *chainSupport) Height() uint64 //代码在orderer/multichain/chainsupport.go
func (cs chainSupport) WriteBlock(block cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block 代码如下:
func (cs *chainSupport) WriteBlock(block *cb.Block, committers []filter.Committer, encodedMetadataValue []byte) *cb.Block { for _, committer := range committers { committer.Commit() } cs.addBlockSignature(block) cs.addLastConfigSignature(block) err := cs.ledger.Append(block)//账本追加块 return block } //代码在orderer/multichain/chainsupport.go
感谢关注兄弟连区块链教程分享!
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
一线互联网常见的14个Java面试题,你颤抖了吗程序员
跳槽不算频繁,但参加过不少面试(电话面试、face to face面试),面过大/小公司、互联网/传统软件公司,面糊过(眼高手低,缺乏实战经验,挂掉),也面过人,所幸未因失败而气馁,在此过程中不断查缺补漏,养成了踏实、追本溯源、持续改进的习惯,特此将自己经历过、构思过的一些面试题记录下来,如果答案有问题,欢迎拍砖讨论,希望能对找工作或者感兴趣的同学有所帮助,陆续整理中。 1. synchronized和reentrantlock异同 相同点 都实现了多线程同步和内存可见性语义 都是可重入锁 不同点 实现机制不同 synchronized通过java对象头锁标记和Monitor对象实现 reentrantlock通过CAS、ASQ(AbstractQueuedSynchronizer)和locksupport(用于阻塞和解除阻塞)实现 synchronized依赖jvm内存模型保证包含共享变量的多线程内存可见性 reentrantlock通过ASQ的volatile state保证包含共享变量的多线程内存可见性 使用方式不同 synchronized可以修饰实例方法(锁住实例对象)、静态...
- 下一篇
5分钟了解分页的那些事?
写在前面 最近面试,我问了一个非常通用的问题,题目是什么呢? 题目就是,谈谈你对分页里面逻辑的理解以及如何实现的?面试题目不难,但是90%的人讲不清楚分页逻辑,对分页的一些细节问题更是回答的很模糊。不是很清晰。下面借此机会给大家讲讲分页有哪些逻辑。 分页的那些事 如上图所示: 分页包含很多小细节, 每页展示10条,多余的下一页展示,这里就涉及的知识点有,是否采取逻辑分页还是物理分页,物理分页的实现方式有哪些,各位自行百度,这里主要讲前台页面如何编写分页的逻辑 <#– 是否上一页–> <#if page.hasPreviousPage> <li><a class=”pointer” data-page=”1″>首页</i></a></li> <li><a class=”pointer” data-page=”${page.prePage}”>上一页</i></a></li> </#if> <#–处理开头部分逻辑 开头省略号实现逻...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- Hadoop3单机部署,实现最简伪集群
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- CentOS7,CentOS8安装Elasticsearch6.8.6