geth-pbft-book
  • Introduction
  • Chapter1 Geth
    • Section1.1 start & configure
    • Section1.2 engine
    • Section1.3 event-receive
    • Section1.4 event-send&mine
    • Section1.5 mining process
    • Section1.6 communication
    • Section1.7 code analysis
  • Chapter2 fabric
    • Section2.1 fabric v0.6 startup
    • Section2.2 Event
      • Section2.2.1 stream to consenter
      • Section2.2.2 consenter to pbft
      • Section2.2.3 pbft to network
    • Section2.3 Consensus
      • Section2.3.1 event
      • Section2.3.2 network
      • Section2.3.3 crypto
      • Section2.3.4 blockchain
      • Section2.3.5 stack
      • Section2.3.6 others
      • Section2.3.7 summary
    • Section2.4 fabric message structure
    • Section2.5 fabric protocol
    • Section2.6 fabric v0.6 实际入口serve()函数
    • Section2.7 接口与实现
    • Section2.8 prePrepare、prepare-and-commit
  • Chapter3 clique
  • Chapter4 development notes
    • Section4.1 plan
    • Section4.2 notes
      • Section4.2.1 zhiguo's notes
      • Section4.2.2 xiaobei's notes
        • geth-pbft开发笔记
        • geth-pbft消息传递机制
        • checkpoint部分的恢复与修改
        • stateUpdateEvent、stateUpdatedEvent的接收和处理
        • viewchange struct
        • mine test-遇到的问题（1）
        • mine test-遇到的问题（2）
        • mine test-遇到的问题（3）
        • viewchange test-遇到的问题（1）
        • viewchange test-遇到的问题（2）
        • viewchange test-遇到的问题（3）
        • 操作步骤
      • Section4.2.3 Agzs's notes
        • 搭建编译环境
        • 解析addPeer操作
        • 11.12_15 配置文件问题
        • 11.15_20 peer共享连接问题
        • 11.20_21 pbft的API问题
        • 11.21_22 pbft投票选举新的signer
        • 数据结构功能汇总
        • 修改文件汇总(push)
        • 编译运行问题汇总
        • 想到的bug
        • 交易测试
  • env
    • geth and smart contract
    • Git merge
    • Git pull撤销误操作
    • 循环导包问题
    • git上传大文件
    • librocksdb.so.4.1共享库问题
  • Tips
    • Comma-ok断言
    • golang 安装使用 protobuf
    • golang interface
    • go语言-与-JSON
    • Terminal Lantern
    • 内置函数append()
Powered by GitBook
On this page
  • Event
  • ExecutionConsumer
  • Consenter 接收事件
  • coordinator
  • Network
  • Inquirer 获取网络信息
  • Communicator 发送消息
  • NetworkStack
  • Stack
  • Crypto
  • SecurityUtils 加密消息
  • secHelper
  • Blockchain
  • ReadOnlyLedger
  • LegacyExecutor
  • Executor 执行Tx
  • LedgerManager

Was this helpful?

  1. Chapter2 fabric

Section2.7 接口与实现

Event

ExecutionConsumer

  • Usage

    • consensus.Consenter接口的一部分.

    • consensus/executor.coordinatorImpl的成员变量consumer

  • Implement

    • 没有单独实现的ExecutionConsumer

    • Consenter对ExecutionConsumer进行了实现

Consenter 接收事件

  • Usage

    • consensus/helper.EngineImpl的成员变量，pbft只会生成一个consensus.Consenter作为engine的成员变量

    • consensus/helper.Helper的成员变量

  • Implement

    • Helper的Consenter来自于engine, engine的Consenter来自controller, controller的来自于pbft.

    • Consenter接口的实现为obcBatch，但obcBatch并没有自己实现这些函数, 而是继承自consensus/pbft/external.go中的externalEventReceiver；externalEventReceiver通过和event.Manager的直接交互来对接口进行了实现.

coordinator

  • Helper的成员变量coordinator，类型为peer.MessageHandlerCoordinator, 定义在peer中, 是初始化engine时的唯一参数, 也可以说是和节点联系的途径.

  • engine使用它获得PeerEndpoint(本节点), 然后将它传给Helper用于初始化, 自己并不保存这个变量. Helper会保存该变量, 并用它来实现了NetworkStack里的功能, 包括获取节点信息, 广播, 单播, 另外还包括获取区块链长度.

Network

Inquirer 获取网络信息

  • Usage

    • consensus.NetworkStack接口的一部分

    • consensus/pbft.communicator接口的一部分.

  • Implement

    • Inquirer的引用都是通过NetworkStack实现的

Communicator 发送消息

  • Usage

    • consensus.NetworkStack接口的一部分

    • consensus/pbft.communicator接口的一部分.

    • broadcaster结构体的成员变量

  • Implement

    • Communicator通过NetworkStack实现的

NetworkStack

  • NetworkStack只是作为Stack的一部分被使用, 并没有单独实现NetworkStack接口的结构体.

  • 对于Stack, 由Helper来实现, Helper对NetworkStack部分的实现是依赖于core/peer中定义的MessageHandlerCoordinator. 该参数在程序启动时会初始化.

Stack

  • 在pbft内部, 也定义了一个与此对应的接口innerStack, 用于内部使用.

  • 只有consensus/helper/helper.go中定义的Helper实现了Stack.

Crypto

SecurityUtils 加密消息

  • SecurityUtils接口仅作为Stack的一部分使用, Stack是由Helper实现的, 对于SecurityUtils部分, Helper通过调用secHelper来实现, secHelper类型为crypto.Peer，实际由nodeImpl实现。

secHelper

  • 用于实现SecurityUtils接口, 类型为crypto.Peer, 通过调用coordinator.GetSecHelper()生成. 在消息传递前会进行加密, 接收后进行解密.

  • 实际上, 在pbft中并没有直接使用SecurityUtils接口, 而是进行了封装.

Blockchain

ReadOnlyLedger

  • blockchain被封装在了Ledger内, ReadOnlyLedger定义了对Blockchain的读操作, Helper使用Ledger对其进行了实现, 而Ledger内部则是调用了blockchain的对应方法, blockchain则是通过使用db进行了实现.

LegacyExecutor

  • LegacyExecutor用来对blockchain进行写操作, 实际实现只有一处, 在Helper中, 另一处在executor里虽作为一部分定义了一个新的接口, 但该接口仍是通过Helper来初始化的.

  • 在Helper中, 除func ExecTxs()是和chaincode交互实现的, 其他仍是和Ledger交互. executor的存在, 主要是为了方便收集来自obcBatch关于对blockchain写操作的消息, 集中调用Helper进行执行.

Executor 执行Tx

  • Executor作为Stack的一部分以Helper实现, Helper用executor来实现的, 本质上是由executor.coordinatorImpl来实现的.

LedgerManager

  • LedgerManager也是Stack的一部分, 用于设置Ledger的状态是否最新/合法, 会在状态转换前或检测到失效后置false, 收到stateUpdatedEvent后重新置true.

PreviousSection2.6 fabric v0.6 实际入口serve()函数NextSection2.8 prePrepare、prepare-and-commit

Last updated 4 years ago

Was this helpful?