peer.go - Hyperledger 源码分析之 Fabric

返回介绍

peer.go

发布于 2019-11-11 字数4714 浏览 852 评论 0

peer.go

peer 相关

比较核心的数据结构。

Peer 接口,两个方法:包括获取一个 peer 端点和发送探测 hello 消息。

type Peer interface {    GetPeerEndpoint() (*pb.PeerEndpoint, error)    NewOpenchainDiscoveryHello() (*pb.Message, error)}

具体实现的数据结构为 PeerImpl。

type PeerImpl struct {    handlerFactory HandlerFactory  // 生成一个 MessageHandler    handlerMap     *handlerMap     // 所有注册上来的消息处理器    ledgerWrapper  *ledgerWrapper  // ledger 操作句柄    secHelper      crypto.Peer     // 处理身份验证和安全相关    engine         Engine          // handler 工厂 + 本地交易处理的引擎    isValidator    bool    reconnectOnce  sync.Once    discHelper     discovery.Discovery //探测任务句柄    discPersist    bool}

核心方法,包括:

  • ExecuteTransaction:准备执行一个交易,发送给本地的引擎(VP 节点),或给远端的 peer;
  • Broadcast:向所有注册的消息句柄发送消息;
  • Unicast:向指定的 peer 发送消息;
  • 一系列 Get 方法:包括获取 Block 内容、获取当前链的大小、当前状态的 hash、获取已注册的 peer 端点、远端 ledger 等等,很多功能实际上都是通过其它包来完成。
  • sendTransactionsToLocalEngine:交易发给本地的引擎处理;
  • SendTransactionsToPeer:交易发给其它 peer 处理;

消息相关

两个基础接口 MessageHandler 和 MessageHandlerCoordinator。

type MessageHandler interface {    RemoteLedger    // 获取远端的 ledger    HandleMessage(msg *pb.Message) error // 接收到某个消息进行处理    SendMessage(msg *pb.Message) error //发送消息到对端    To() (pb.PeerEndpoint, error) // 对端是哪个节点    Stop() error}
type MessageHandlerCoordinator interface {    Peer    SecurityAccessor    BlockChainAccessor    BlockChainModifier    BlockChainUtil    StateAccessor    RegisterHandler(messageHandler MessageHandler) error    DeregisterHandler(messageHandler MessageHandler) error    Broadcast(*pb.Message, pb.PeerEndpoint_Type) []error    Unicast(*pb.Message, *pb.PeerID) error    GetPeers() (*pb.PeersMessage, error)    GetRemoteLedger(receiver *pb.PeerID) (RemoteLedger, error)    PeersDiscovered(*pb.PeersMessage) error    ExecuteTransaction(transaction *pb.Transaction) *pb.Response    Discoverer}

上一篇:errors.go

下一篇:scc

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

目前还没有任何评论,快来抢沙发吧!