AllocateMessageQueueStrategy 是消息消费时对消息队列分配的策略接口AllocateMessageQueueConsistentHash则是一致性hash策略的实现

一致性Hash算法

有N台后台服务节点，通常我们会对请求的关键字做hash(key) % N 来进行负载均衡，将请求发送至某一个节点。对于一般情况可能无所谓，但对于Redis分布式集群缓存等分布式场景，这种方式会引起几乎所有key的重新映射，这影响是非常大的。

所以一致性hash就是为了解决这个问题，它的算法目的是每个key在稳定情况下每次只会映射到同一个节点，在节点数增减的情况下只会影响一部分的key发生重新映射。

链接：什么是一致性hash算法

RocketMQ实现

首先是hash环和服务节点的实现

ConsistentHashRouter

 使用TreeMap来存储节点hash值和节点的对应关系，hash函数默认使用MD5

 在构造函数中，将所有消费者ClientID作为节点，插入到环中

 考虑一致性hash算法的平衡性，采用多个虚拟节点来代替

路由消息队列routeNode

这里计算每个消息队列的hash值，获取环中比它大的第一个节点（利用TreeMap.tailMap视图）

 

AllocateMessageQueueConsistentHash

核心的环和路由代码由ConsistentHashRouter实现，策略类中就比较简单了，首先定义了环中一个物理节点对应10个虚拟节点

 然后将所有消费者节点添加到环，然后依次对消费队列进行hash和分配