ChannelSupportRegistrar 只是某个chanel的

[yfhk]

// ChannelSupportRegistrar provides a way for the Handler to look up the Support for a channel type ChannelSupportRegistrar interface { // BroadcastChannelSupport returns the message channel header, whether the message is a config update // and the channel resources for a message or an error if the message is not a message which can // be processed directly (like CONFIG and ORDERER_TRANSACTION messages) BroadcastChannelSupport(msg cb.Envelope) (cb.ChannelHeader, bool, ChannelSupport, error) }

type handlerImpl struct { sm ChannelSupportRegistrar }

// Handle starts a service thread for a given gRPC connection and services the broadcast connection func (bh *handlerImpl) Handle(srv ab.AtomicBroadcast_BroadcastServer) error { addr := util.ExtractRemoteAddress(srv.Context()) logger.Debugf("Starting new broadcast loop for %s", addr) for { msg, err := srv.Recv() if err == io.EOF { logger.Debugf("Received EOF from %s, hangup", addr) return nil } if err != nil { logger.Warningf("Error reading from %s: %s", addr, err) return err }

[yfhk]

其他的channel上面也会有一个systemchannel

[yfhk]

创建channel的命令只发给一个orderer还是所有的orderer都要执行？

[yfhk]

orderer之间广播？还是由sdk来广播给所有的orderer？

[yfhk]

// Channel gives read only access to the channel configuration type Channel interface { // HashingAlgorithm returns the default algorithm to be used when hashing // such as computing block hashes, and CreationPolicy digests HashingAlgorithm() func(input []byte) []byte

// BlockDataHashingStructureWidth returns the width to use when constructing the
// Merkle tree to compute the BlockData hash
BlockDataHashingStructureWidth() uint32

// OrdererAddresses returns the list of valid orderer addresses to connect to to invoke Broadcast/Deliver
OrdererAddresses() []string

// Capabilities defines the capabilities for a channel
Capabilities() ChannelCapabilities

}

[yfhk]

if isOrdererRequired {
    if len(common.OrderingEndpoint) == 0 {
        orderingEndpoints, err := common.GetOrdererEndpointOfChainFnc(channelID, signer, endorserClient)
        if err != nil {
            return nil, fmt.Errorf("Error getting (%s) orderer endpoint: %s", channelID, err)
        }
        if len(orderingEndpoints) == 0 {
            return nil, fmt.Errorf("Error no orderer endpoint got for %s", channelID)
        }
        logger.Infof("Get chain(%s) orderer endpoint: %s", channelID, orderingEndpoints[0])
        // override viper env
        viper.Set("orderer.address", orderingEndpoints[0])
    }

    broadcastClient, err = common.GetBroadcastClientFnc(channelID)

[yfhk]

从上面看出，只需要一个ip就可以了