确定好需要修改的配置项, 离线修改后, 通过SDK或CLI发送给Orderer.

通道配置通过一个交易的形式存储在通道的配置区块中, 并且能够直接被修改. 但是, 在Fabric v1.0.0中, 还不能使用SDK来直接修改配置. configtxlator工具提供了一个API, 可以让SDK用户能够与这个API交互来更新配置.

更新通道的流程:

1. SDK取出最新配置
2. configtxlator工具将配置转化成我们能看懂的JSON文件
3. 客户端编辑配置文件
4. 使用configtxlator工具计算原有配置文件与现有配置文件的差异
5. 客户端使用SDK提交配置和签名

注: 个人认为, 服务器与客户端的概念, 是相对的. 对于用户直接使用的程序来说, 服务器是使用SDK的应用程序, 对于使用SDK的应用程序来说, 服务器是Fabric.

configtxlator --help

使用该命令了解configtxlator工具的使用.

启动configtxlator:

configtxlator start

type Consenter interface {
    HandleChain(support ConsenterSupport, metadata *cb.Metadata) (Chain, error)
}

这个接口的作用是创建一个对链的引用, 用于提供资源. 其中, 第一个参数提供交易过滤, 交易切割, 区块签名等功能; 第二个参数是一个指针, 指针链账本中最后一个提交块ORDERER的存储元数据. 如果是创世区块(genesis.block), 由于没有存储元数据字段定义, 所以该值为nil.

当Orderer接收到创建通道的请求时, 会根据genesis.block中配置的通道类型来创建新的通道, 调用的是不同的通道的 HandleChain().

不同排序服务的区块元数据不同, 如对于Kafka服务, 元数据中要保存Kafka的最新偏移, 而Solo则不需要, 所以 排序服务不能动态切换.

排序服务接收到某个通道上的交易后, 会提交给链处理. 需要实现的接口如下:

type Chain interface {
    Enqueue(env *cb.Envelope) bool
    Errored() <- chan struct{}
    Halt()
}

Enqueue(): 成功接收消息时, 返回true, 否则返回false

Errored(): 发生错误时, 返回报错的channel, 终止客户端的等待

Halt(): 用于分配链的各种资源, 并保持相关的最新状态, 包括从排序服务中读取资源, 将消息传递给区块进行拆分, 将区块结果写入账本.

Chain接口: 接收交易请求, 进行排序, 生成最终的区块, 提供了可以提交消息进行排序的方法. 在实现这个接口时, 需要把排好的交易通过blockcutter.Receiver进行交易分割, 最后写到账本中. 交易的分割有两种模式:

1. 交易先进入消息流中, 它在消息流中是有序的, 消息流中的交易分割到不同的区块里, 最后写入到账本中, solo和kafka都是这种模式.
2. 交易分割到不同的区块中, 交易是有序的, 最后写入账本中, sbft是这种模式.

排序服务需要配置文件的支持和配置文件参数的识别.

配置文件支持: 生成genesis.block的配置文件configtx.yaml中, Orderer.OrdererType可以指定排序服务类型. 假设添加了newconsenter.

配置文件参数识别: 在initializeMulti ChainManager的consenters中增加映射. consenters["newconsenter"] = newconsenter.New(). 然后在newconsenter里实现新的排序和共识算法.

利用Golang的并发机制, 内部构建一个接收消息的通道sendChan, 然后返回处理交易信息的链multichain.Chain:

func newChain (support multichain.ConsenterSupport) *chain {
    return &chain {
        batchTimeout: support.SharedConfig().BatchTimeout(),
        support: support,
        sendChain: make(chan *cb.Envelope),
        exitChan: make(chan struct{}),
    }
}

其中, batchTimeout是最长区块生成间隔时间; support提供交易切割和生成区块的功能, exitChan是服务异常的终止信息.

创建链以后, 通过 Start() 启动链的处理过程. 在Solo中, 就是启动一个线程循环的接收发送到sendChan通道的数据, 然后进行交易的切割和区块的写入.

排序服务接收到交易请求以后, 根据不同的排序服务类型提交给不同的链进行处理, 入口函数是 Enqueue. Solo类型接收到消息以后, 发送给sendChan就结束了.

排序服务内部如果出现异常, 会给exitChan发送消息, 外部程序可以读取Errored返回的通道, 进行异常处理.

Kafka节点数至少4个; Zookeeper节点数选奇数个, 至少为3.

修改configtx.yaml文件. 主要是修改Orderer.OrdererType, Orderer.kafka.Brokers, Orderer.AbsoluteMaxBytes三个选项.