区块链教程Fabric1.0源代码分析Peer DeliverClient(Deliver客户端)
兄弟连区块链教程Fabric1.0源代码分析Peer DeliverClient(Deliver客户端),2018年下半年,区块链行业正逐渐褪去发展之初的浮躁、回归理性,表面上看相关人才需求与身价似乎正在回落。但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上。
Fabric1.0源代码笔记之Peer DeliverClient(Deliver客户端)
1、DeliverClient概述
DeliverClient代码分布如下:
- peer/channel/deliverclient.go,deliverClientIntf接口定义及实现,以及DeliverClient工具函数。
- protos/orderer/ab.pb.go,AtomicBroadcast_DeliverClient接口定义和实现。
2、deliverClientIntf接口定义及实现
2.1、DeliverClient工具函数
//构造deliverClient func newDeliverClient(conn *grpc.ClientConn, client ab.AtomicBroadcast_DeliverClient, chainID string) *deliverClient //代码在peer/channel/deliverclient.go
2.2、deliverClientIntf接口定义及实现
type deliverClientIntf interface { getSpecifiedBlock(num uint64) (*common.Block, error) getOldestBlock() (*common.Block, error) getNewestBlock() (*common.Block, error) Close() error } type deliverClient struct { conn *grpc.ClientConn client ab.AtomicBroadcast_DeliverClient chainID string } //构造查询Envelope func seekHelper(chainID string, position *ab.SeekPosition) *common.Envelope //r.client.Send(seekHelper(r.chainID, &ab.SeekPosition{Type: &ab.SeekPosition_Specified{Specified: &ab.SeekSpecified{Number: blockNumber}}})) func (r *deliverClient) seekSpecified(blockNumber uint64) error //r.client.Send(seekHelper(r.chainID, &ab.SeekPosition{Type: &ab.SeekPosition_Oldest{Oldest: &ab.SeekOldest{}}})) func (r *deliverClient) seekOldest() error //return r.client.Send(seekHelper(r.chainID, &ab.SeekPosition{Type: &ab.SeekPosition_Newest{Newest: &ab.SeekNewest{}}})) func (r *deliverClient) seekNewest() error //r.client.Recv()读取块 func (r *deliverClient) readBlock() (*common.Block, error) //r.seekSpecified(num)和r.readBlock() func (r *deliverClient) getSpecifiedBlock(num uint64) (*common.Block, error) //r.seekOldest()和r.readBlock() func (r *deliverClient) getOldestBlock() (*common.Block, error) //r.seekNewest()和r.readBlock() func (r *deliverClient) getNewestBlock() (*common.Block, error) //r.conn.Close() func (r *deliverClient) Close() error //cf.DeliverClient.getSpecifiedBlock(0)获取创世区块 func getGenesisBlock(cf *ChannelCmdFactory) (*common.Block, error) //代码在peer/channel/deliverclient.go
func seekHelper(chainID string, position ab.SeekPosition) common.Envelope代码如下:
func seekHelper(chainID string, position *ab.SeekPosition) *common.Envelope { seekInfo := &ab.SeekInfo{ Start: position, Stop: position, Behavior: ab.SeekInfo_BLOCK_UNTIL_READY, } msgVersion := int32(0) epoch := uint64(0) env, err := utils.CreateSignedEnvelope(common.HeaderType_CONFIG_UPDATE, chainID, localmsp.NewSigner(), seekInfo, msgVersion, epoch) return env } //代码在peer/channel/deliverclient.go
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
区块链教程Fabric1.0源代码分析PeerBroadcastClient(Broadcast客户端)
兄弟连区块链教程Fabric1.0源代码分析PeerBroadcastClient(Broadcast客户端),2018年下半年,区块链行业正逐渐褪去发展之初的浮躁、回归理性,表面上看相关人才需求与身价似乎正在回落。但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上。 Fabric1.0源代码笔记之Peer DeliverClient(Deliver客户端) 1、DeliverClient概述 DeliverClient代码分布如下: peer/channel/deliverclient.go,deliverClientIntf接口定义及实现,以及DeliverClient工具函数。 protos/orderer/ab.pb.go,AtomicBroadcast_DeliverClient接口定义和实现。 2、deliverClientIntf接口定义及实现 2.1、DeliverClient工具函数 //构造deliverClient func newDeliverClient(conn *grpc.ClientConn, client ab.AtomicBr...
- 下一篇
区块链教程Fabric1.0源代码分析policy(背书策略)-兄弟连区块链
区块链教程Fabric1.0源代码分析policy(背书策略),2018年下半年,区块链行业正逐渐褪去发展之初的浮躁、回归理性,表面上看相关人才需求与身价似乎正在回落。但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上。 Fabric 1.0源代码笔记 之 policy(背书策略) 1、policy概述 policy代码分布在core/policy、core/policyprovider、common/policies目录下。目录结构如下: core/policy/policy.go,PolicyChecker接口定义及实现、PolicyCheckerFactory接口定义。 core/policyprovider/provider.go,PolicyChecker工厂默认实现。 common/policies目录* policy.go,ChannelPolicyManagerGetter接口及实现。 * implicitmeta_util.go,通道策略工具函数。 2、PolicyChecker工厂 2.1、PolicyCheckerFactory接口定义 t...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS关闭SELinux安全模块
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- Hadoop3单机部署,实现最简伪集群
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- CentOS6,CentOS7官方镜像安装Oracle11G
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS8编译安装MySQL8.0.19
- CentOS6,7,8上安装Nginx,支持https2.0的开启