RocketMQ消息拉取功能如何实现长尾词优化？

本文共计9167个文字，预计阅读时间需要37分钟。

RocketMQ消息的消费以组为单位，包含两种消费模式：广播模式：同一消息队列可以分配给组内每个消费者，每条消息可被组内消费者消费一次。集群模式：同一消息队列下，一个消费者组内消费者可以消费不同消息队列中的消息。

RocketMQ消息的消费以组为单位，有两种消费模式：

广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。

集群模式：同一个消费组下，一个消息队列同一时间只能分配给组内的一个消费者，也就是一条消息只能被组内的一个消费者进行消费。（一般情况下都使用的是集群模式）

消息的获取也有两种模式：

拉模式：消费者主动发起拉取消息的请求，获取消息进行消费。

推模式：消息到达Broker后推送给消费者。RocketMQ对拉模式进行了包装去实现推模式，本质还是需要消费者去拉取，一个拉取任务完成后继续下一次拉取。