接口 com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy
的使用

使用 LoadBalanceStrategy 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.metaslave

com.taobao.metamorphosis.client 中 LoadBalanceStrategy 的使用

返回 LoadBalanceStrategy 的 com.taobao.metamorphosis.client 中的方法

protected LoadBalanceStrategy

MetaMessageSessionFactory.createLoadBalanceStrategy(ConsumerConfig consumerConfig)

com.taobao.metamorphosis.client.consumer 中 LoadBalanceStrategy 的使用

实现 LoadBalanceStrategy 的 com.taobao.metamorphosis.client.consumer 中的类

class	ConsisHashStrategy 基于一致性哈希的负载均衡策略： 将所有consumer组织成一个环 将所有分区根据hash值插入到环上 获取指定consumer前面，前一个consumer之后的分区列表作为结果
class	DefaultLoadBalanceStrategy 默认的负载均衡策略，尽量使得负载在所有consumer之间平均分配，consumer之间分配的分区数差距不大于1

参数类型为 LoadBalanceStrategy 的 com.taobao.metamorphosis.client.consumer 中的方法

void	ConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy) 注册订阅者

参数类型为 LoadBalanceStrategy 的 com.taobao.metamorphosis.client.consumer 中的构造方法

ConsumerZooKeeper.ZKLoadRebalanceListener(FetchManager fetchManager, MetaZookeeper.ZKGroupDirs dirs, String consumerIdString, ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, LoadBalanceStrategy loadBalanceStrategy)

SimpleMessageConsumer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, ConsumerConfig consumerConfig, ConsumerZooKeeper consumerZooKeeper, ProducerZooKeeper producerZooKeeper, SubscribeInfoManager subscribeInfoManager, RecoverManager recoverManager, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)

com.taobao.metamorphosis.metaslave 中 LoadBalanceStrategy 的使用

参数类型为 LoadBalanceStrategy 的 com.taobao.metamorphosis.metaslave 中的方法

void	SlaveConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)