一：顺序发送 通过一定算法，将一组顺序消息发送到同一个broker下面的同一个队列，消费者进行顺序监听即可。 例如：一条信息的唯一标识 通过一定算法 路由到 同一个 broker 下到 某一个队列下 ...

tag 的使用场景：不同的消费组，订阅同一 topic 不同的 tag，拉取不同的消息并消费。在 topic 内部对消息进行隔离。 producer 发送消息，指定 tag cons ...

rocketMQ 为了保证 consumer 顺序消费，做了很多工作。 MQClientManager 在 jvm 进程中是单例，其内部维护一个 map，键是 clientId，值是 MQClien ...

附加：如果有多个master，那么每个master配置的名字应该一样，要不然识别不了对方，不知道是一个集群内部的 所属集群名字：brokerClusterName=rocketmq-c ...

1:基础知识梳理 Message对象 topic: 主题名称 tag: 标签，用于过滤 key: 消息唯一标示，可以是业务字段组合 body: 消息体,字节数组 注意 发送消息到 ...

命令行主类：org.apache.rocketmq.tools.command.MQAdminStartup 客户端创建 topic 程序参数：updateTopic -n localhost:9 ...

1、导入依赖 2、配置生产者 3、发送消息Controller 4、客户端 5、测试 注意：一定要创建to ...

rocketMQ 重置消息 offset，有两种情形：一种是有消费者在线，另一种则是无消费者在线。 命令行 首先描述存在在线消费者的情况： 1. 命令行程序和 nameserver ...

问题 Rocketmq 重试是否有超时问题，假如超时了如何解决，是重新发送消息呢？还是一直等待 假如某个 msg 进入了重试队列（%RETRY_XXX%），然后成功消费了 概述 ...

一、rocketMQ安装 　　（一）安装NameSrv 　　1、创建nameSrv数据挂载文件夹 　　2、拉取镜像 　　3、运行NameSrv新容器 ...