Hyperledger Fabric 消息协议

Fabric 中大量采用了 gRPC 消息在不同组件之间进行通信交互,主要包括如下几种情况:客户端访问 Peer 节点,客户端和 Peer 节点访问排序节点,链码容器与 Peer 节点交互,以及多个 Peer 节点之间的 Gossip 交互。

消息结构

除了 Peer 节点之间的 Gossip 通信外,大多都采用了信封(Envelope)结构来对消息进行封装.

普通信封结构并不复杂,包括一个载荷(Payload)域存放数据,以及对载荷域中内容进行签名的签名(Signature)域。载荷域中又包括头部(Header)域记录类型、版本、签名者信息等元数据,以及数据(Data)域,记录消息内容。

头部域是一个通用的结构。包括两种头部:通道头(ChannelHeader)和签名头(Signature-Header)。通道头中记录了如下与通道和交易相关的很多信息。

●Type:int32 类型,代表了结构体(如 Envelope)的类型。结构体消息根据类型不同,其 Payload 可以解码为不同的结构。类型可以为 MESSAGE、CONFIG、CONFIG_UPDATE、ENDORSER_TRANSACTION、ORDERER_TRANSACTION、DELIVER_SEEK_INFO、CHAINCODE_PACKAGE、PEER_ADMIN_OPERATION 等。

●Version:int32 类型,版本号记录了消息协议的版本,一般为 0。

●Timestamp:*google_protobuf.Timestamp 类型,消息创建的时间。

●ChannelID:string 类型,消息所关联的通道 ID。

●TxID:string 类型,交易的 ID,由交易发起者创建。

●Epoch:uint64 类型,所属的世代,目前指定为所属区块的高度。

●Extension:[] byte 类型,扩展域。

●TlsCertHash:[] byte 类型。如果启用了双向 TLS 认证,则此处为客户端 TLS 证书的 Hash 值。

签名头中主要记录签名者的身份信息。


客户端访问 Peer 节点

客户端通过 SDK 和 Endorser Peer 进行交互,执行链码相关操作(安装、实例化、升级链码以及调用),加入、列出应用通道和监听事件操作等。

除监听事件外,大部分消息都采用了 SignedProposal 结构(定义在 fabric-protos-go 项目的 peer/chaincode.pb.go 文件),消息中 ChannelHeader.Type 为 ENDORSER_TRANSACTION 或 CONFIG,发往的 gRPC 服务地址为 /protos.Endorser/ProcessProposal。监听事件则通过 DeliverClient 接口类型来实现,包括 Deliver、DeliverFiltered、DeliverWithPrivateData 三种方法。

SignedProposal 消息结构中包括 Proposal 和对其的签名。Proposal 消息结构中同样包括 Header 域、Payload 域,以及扩展域。其中,Payload 域和扩展域如何解码都取决于 Channel-Header 中的 Type 指定的类型。


客户端、Peer 节点访问 Orderer

客户端通过 SDK 和 Orderer 进行交互,执行链码实例化、调用和升级,应用通道创建和更新,以及区块结构获取等操作。Peer 节点可以直接向 Orderer 请求获取区块结构。两者采用了同样的获取接口。

请求消息都采用了 Envelope 结构,并且都发往 /orderer.AtomicBroadcast/Broadcast gRPC 服务地址。从 Orderer 获取信息时,则发往 /orderer.AtomicBroadcast/Deliver gRPC 服务地址。


链码和 Peer 节点交互

对于原生链码,在链码容器启动后,会向 Peer 节点进行注册,gRPC 地址为 /protos.ChaincodeSupport/Register。对于外部链码,在其启动后,Peer 节点会主动发起连接请求,gRPC 地址为 /protos.Chaincode/Connect。

链码和 Peer 之间的交互消息为 ChaincodeMessage 结构其中,Payload 域中可以包括各种 Chaincode 操作消息,如 GetHistoryForKey、GetQueryResult、PutStateInfo、GetStateByRange 等。

注册完成后,双方建立起双工通道,通过更多消息类型实现多种交互.


Peer 节点之间 Gossip 交互

Peer 之间可以通过 Gossip 协议来完成邻居探测、Leader 选举、区块分发、私密数据同步等过程,主要原理为通过 GossipClient 客户端的 GossipStream 双向流进行通信,发送 Signed-GossipMessage 消息结构,gRPC 服务地址主要为 /gossip.Gossip/GossipStream。

此外,Peer 可通过单独的 Ping 服务对远端节点在线状态进行探测,gRPC 服务地址为 /gossip.Gossip/Ping。

Gossip 交互过程

总结 Gossip 交互过程如图 14-16 所示。利用不同的消息体,完成 Peer 之间的信息同步。


Gossip 消息结构

Gossip 采用签名信封结构(SignedGossipMessage)用来封装 Gossip 消息(GossipMessage)和对应的信封结构(Envelope)。


Gossip 消息标签

GossipMessage 为核心的数据结构。其可能的标签值(GossipMessage_Tag)如下所示,这些标签默认带有 GossipMessage 前缀。

●UNDEFINED:标签未定义,当标签为空时返回该值。

●EMPTY:空标签,用于建立连接、心跳、请求和响应成员消息。

●ORG_ONLY:仅限组织内消息,如私密数据。

●CHAN_ONLY:仅限通道内消息。

●CHAN_AND_ORG:限通道内同一组织内,如获取区块数据。

●CHAN_OR_ORG:限通道内或限组织内,如状态信息。


Gossip 消息内容结构

GossipMessage 通过消息内容类型来应用到不同场景。合法的消息内容结构(isGossipMessage_Content)下面详细介绍,这些结构默认带有 GossipMessage 前缀。

(1)成员消息适用于邻居发现场景,定期维护存活的邻居信息,不局限在通道内,主要由 gossip/discovery 模块实现。

(2)拉取消息

适用于从远程节点拉取身份或区块数据,主要数据结构为:gossip/gossip/pull/pullstore.go#Mediator 和 gossip/gossip/algo/pull.go#PullEngine。包括如下两种消息类型:

●PullMsgType_IDENTITY_MSG,获取对方的身份信息,消息标签为 EMPTY,不局限在通道内。

●PullMsgType_BLOCK_MSG,获取区块数据。消息标签为 CHAN_AND_ORG,局限在通道内的同一组织内。

(3)数据消息

适用于从远程节点同步区块或私密数据。

(4)状态消息

适用于与远程节点同步账本状态。

(5)其他消息

其他消息包括连接消息、选举 Leader 消息和空消息。

grpcgo

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/334167.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

AI交互数字人怎么应用在展览展厅?

随着AIGC的迅速发展,AI交互数字人成为展览展厅的新流量密码。越来越多文旅品牌、博物馆展馆等通过部署AI交互数字人,开创全新的交互模式。 如山西博物馆上线的主题云展览《且听凤鸣》中,打破了常态展示模式,以“数字人小程序”的方…

项目知识—SSM及之后02

1、resultMap写的Base内容必须保证select都使用上 2、VALUE单个 ,VALUES多个 3、一对多,两张表,多的表加外键 比如班级和学生就是一对多,查就是按照学生表去查询 多对多,三张表,关系表加外键 4、数据库…

论文阅读 Attention is all u need - transformer

文章目录 1 摘要1.1 核心 2 模型架构2.1 概览2.2 理解encoder-decoder架构2.2.1 对比seq2seq,RNN2.2.2 我的理解 3. Sublayer3.1 多头注意力 multi-head self-attention3.1.1 缩放点乘注意力 Scaled Dot-Product Attention3.1.2 QKV3.1.3 multi-head3.1.4 masked 3.…

中国IT产经新闻:新能源汽车发展前景与燃油车的利弊之争

随着科技的进步和环保意识的提高,新能源汽车在全球范围内逐渐受到重视。然而,在新能源汽车迅速发展的同时,燃油车仍然占据着主导地位。本文将从新能源与燃油车的利弊、新能源汽车的发展前景两个方面进行分析,以期为读者提供全面的…

婚恋/社交娱乐/同城相亲/红娘相亲交友软件开发小程序

需求分析:首先明确小程序的目标、功能和用户需求。确定小程序的主要功能,例如用户注册、登录、个人资料编辑、浏览其他用户资料、发送消息等。 技术选型:选择适合的开发框架和技术工具。在小程序开发中,可以使用微信小程序原生开…

kubernetes 容器运行环境安全 POLP AppArmor Seccomp

开头语 写在前面:如有问题,以你为准, 目前24年应届生,各位大佬轻喷,部分资料与图片来自网络 内容较长,页面右上角目录方便跳转 最小特权原则 POLP 最小特权原则 (Principle of least privilege,POLP)&…

机器人技能学习-robosuite-0-入门介绍

文章目录 前言模块介绍实战案例1:从 demo 中创建自己的 env案例2:更换属于自己的物体 前言 资料太少、资料太少、资料太少,重要的事说三边,想根据自己实际场景自定义下机器人,结果发现无路可走,鉴于缺少参…

网络协议与攻击模拟_01winshark工具简介

一、TCP/IP协议簇 网络接口层(没有特定的协议) 物理层:PPPOE宽带拨号(应用场景:宽带拨号,运营商切网过来没有固定IP就需要拨号,家庭带宽一般都采用的是拨号方式)数据链路层网络层…

【办公自动化】Window电脑如何设置定时任务计划

在Windows系统中,我们可以使用任务计划程序来创建和管理定时任务。任务计划程序是Windows操作系统自带的一个功能,可以帮助我们自动执行一些重复性的任务,例如备份文件、更新软件等。 一、打开任务计划程序 首先,我们需要打开任…

Linux安装JDK和Maven并配置环境变量

文章目录 一、安装JDK并配置环境变量二、安装maven并配置环境变量 一、安装JDK并配置环境变量 将JDK的安装包上传到Linux系统的usr/local目录 使用xftp上传文件 解压JDK的压缩包 xshell连接到云主机 [roottheo ~]# cd /usr/local[roottheo local]# ls aegis apache-tomcat-…

LitJson-Json字符串转对像时:整型与字符串或字符串转:整型进的类型不一致的处理

目录 问题描述上代码测试代码各位看官,打赏个1元吧 Json数据格式是大家在游戏开中常量用的一种数据格式,某种程度上可以说是必备的。对unity开发来说,LitJson这个json库应该是被使用最多的json库了。 问题描述 今天说要的其中的这个api: Jso…

【精通C语言】:深入解析for循环,从基础到进阶应用

🎥 屿小夏 : 个人主页 🔥个人专栏 : C语言详解 🌄 莫道桑榆晚,为霞尚满天! 文章目录 📑前言一、for循环基础1.1 语法1.2 示例1.3 流程图1.4 for与while的对比 二、for循环进阶2.1 fo…