路漫漫，水迢迢

使用背景RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点 1、能够保证严格的消息顺序 2、提供丰富的消息拉取模式 3、高效的订阅者水平扩展能力 4、实时的消息订阅机制 5、亿级消息堆积能力 为什么使用RocketMQ 1、强调集群无单点，可扩展，任意一点高可用、水平可扩展 2、海量消息堆积能力，消息堆积后写入低延迟 3、支持上万个队列 4、消息失败重试机制 5、

版本:        <dependency>        <groupId>org.apache.rocketmq</groupId>        <artifactId>rocketmq-client</artifactId>        <version>4.3.0</v...

【为什么使用RocketMq】1、应用解耦2、流量削峰3、消息分发4、保证最终一致性5、方便动态扩容【RocketMq的角色】producerconsumerBrokerNameServerbroker配置文件：#nameServer 地址，分号分割namesrvAddr=192.168.100.131:9876;192.168.100.132:...

上一节我们已经把DefaultMQPushConsumer的大体流程分析了一下，从这节开始我们分析一部分消息处理的细节问题。继续在DefaultMQPushConsumerImpl的pullMessage方法中有个ProcessQueue，待会我们来分析这个队列的作用。 public void pullMessage(final PullRequest pullRequest) { ...

我们首先看下DefaultMQPullConsumer使用例子：package com.swk.springboot.rocketmq;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Set;import org.apache.rocketmq.client...