RocketMQ中消息消费以消费组的模式开展，一个消费组内可以包含多个消费者，每一个消费者组可订阅多个主题，消费组内消费者之间有集群模式和广播模式两种
前面已经将RocketMQ的相关知识与应用进行了记录，这一章就来整合SpringBoot，这也是一个重头戏，因为在我们的实际运用中不可能还去向前面那样
RocketMQ是阿里巴巴旗下一款开源的MQ框架，经历过双十一考验、Java编程语言实现，有非常好完整生态系统。RocketMQ作为一款纯java、分
RocketMQ存储的文件主要包括Commitlog文件、ConsumeQueue文件、Index文件。RocketMQ将所有主题的消息存储在同一个文
今天我们通过一篇文章来认识一下常见消息队列RabbitMQ、RocketMQ、Kafka。
经过上面的讲解，延时消息的处理流程如下：最后，延时消息的延时时间并不精确，这个时间是 Broker 调度线程把消息重新投递到原始的 MessageQu
/ 消息列表分割器：其只会处理每条消息的大小不超4M的情况。// 若存在某条消息，其本身大小大于4M，这个分割器无法处理， // 其直接将这条消息构成
