本文共 1945 字，大约阅读时间需要 6 分钟。
Rroducer负载均衡
Producer端，每个实例在发消息的时候，默认会轮询所有的message queue发送，以达到让消息平均落在不同的queue上。而由于queue可以散落在不同的brocker，所以消息会发送到不同的brocker下
图中箭头线条上的标号代表顺序，发布方会把第一条消息发送至Queue 0,然后第二条消息发送至Queue1,以此类推。Consumer负载均衡
集群模式
在集群消费模式下，每条消息只需要投递到订阅这个topic的Consumer Group下的一个实例即可。RocketMQ采用主动拉取的方式拉取并消费消息，在拉取的时候需要明确拉取哪一条message queue而每当实例的数量有更变，都会触发一次所有实例的负载均衡，这时候会按照queue的数量和实例的数量平均分配queue给每个实例
默认的分配算法是AllocateMessageQueueAvergely,如下图
还有另外一种平均非大算法是AllocateMessageQueueAveragelyByCircle，也就是平均分摊每一条queue,只是以换装轮流分queue的形式，如下图 需要注意的是，集群模式下，queue都是只允许分配只一个实例，这是由于如果多个实例同时消费一个queue的消息，由于拉取哪些消息是consumer主动空指的，那样会导致同一个消息在不同的实例下被消费多次，所以算法上都是一个queue之分给一个consumer实例，一个consumer实例可以允许同时分到不用的queue通过增加consumer实例去分摊queue消费，可以起到水平扩展的消费能力的作用。而有实例下线的时候，会重新触发负载均衡，这时候员来分配到的queue将分配到其他实例上继续消费
但是如果consumer实例的数量比message queue的数量总数量还多的化，多出来的consumer实例将无法分到queue，也就是无法消费到消息，也就无法起到分摊负载的作用了，所以需要控制让queue的总数量大于等于consumer的数量
广播模式
由于广播莫i是下要求一条消息需要投递到一个消费组下面所有的消费者实例，所以也就没有消息被分摊消费的说法。在现实上，其中一个不同就是在consumer分配queue的时候，所有的consumer都分到所有的queue顺序消息的重试
对于顺序消息，当消费者消费消息失败后，消息队列RocketMQ会自动不断进行消息重试（每次间隔时间为1秒），这时，应用会出现消息消费被阻塞的情况。因此，在使用顺序消息时，务必保证应用能够即时监控并处理消费失败的情况，避免阻塞现象的发生
无序消息的重试
对于无序消息（普通，定时，延时，事务消息），当消费者消费消息失败时，你可以通过设置返回状态达到消息重试的结果。无序消息的重试只针对集群消费方式生效；广播方式不提供失败重试特性，即消费失败后，失败消息不再重试，继续消费新的消息
重试次数
消息队列RocketMQ默认允许每条消息最多重试16次，每次重试的间隔时间如下 如果消息重试16次后仍然失败，消息将不再投递。如果严格按照上述重试时间间隔计算，某条消息在一直消费失败的前提下，将会在接下来的4小时46分钟之内进行16次重试，超过这个时间范围消息将不再重试投递注意：一条消息无论重试多少次，这些重试消息的MessageID不会改变
配置方式
消费失败后，重试配置方式 集群消费方式下，消息消费失败后期望消息重试，需要在消息监听器接口的视线中明确进行配置（三种方式任选一种）获取消息重试次数
消费者收到消息后，可按照如下方式获取消息的重试次数转载地址：http://xhxzb.baihongyu.com/