com.taobao.metamorphosis.client.consumer
类 ConsisHashStrategy

java.lang.Object
  继承者 com.taobao.metamorphosis.client.consumer.ConsisHashStrategy
所有已实现的接口:
LoadBalanceStrategy

public class ConsisHashStrategy
extends Object
implements LoadBalanceStrategy

基于一致性哈希的负载均衡策略:

作者:
boyan(boyan@taobao.com)

嵌套类摘要
 
从接口 com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy 继承的嵌套类/接口
LoadBalanceStrategy.Type
 
构造方法摘要
ConsisHashStrategy()
           
 
方法摘要
static byte[] computeMd5(String k)
          Get the md5 of the given key.
 List<String> getPartitions(String topic, String consumerId, List<String> curConsumers, List<String> curPartitions)
          根据consumer id查找对应的分区列表
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

构造方法详细信息

ConsisHashStrategy

public ConsisHashStrategy()
方法详细信息

computeMd5

public static byte[] computeMd5(String k)
Get the md5 of the given key.


getPartitions

public List<String> getPartitions(String topic,
                                  String consumerId,
                                  List<String> curConsumers,
                                  List<String> curPartitions)
从接口 LoadBalanceStrategy 复制的描述
根据consumer id查找对应的分区列表

指定者:
接口 LoadBalanceStrategy 中的 getPartitions
参数:
topic - 分区topic
consumerId - consumerId
curConsumers - 当前所有的consumer列表
curPartitions - 当前的分区列表
返回:


Copyright © 2010–2013. All rights reserved.