下载控制台
生产者
指定任意队列个数
消费者
MessageListenerConcurrently和MessageListenerOrderly的区别
消息发送到哪个队列？
RocketMq提供的队列选择器
三种发送模式
发送超时设置
消费者设置拉取消息数量
MessageListenerOrderly的返回值
MessageListenerConcurrently的返回值
集群消费
集群消费策略
自定义消费策略
广播消费
两个消费者组，模拟广播消费
同一个消费者组监听不同的Topic会发生什么？
集群搭建双master，没有salve
集群搭建双master，双salve
salve节点只能读，不能写
实现顺序消息
消费者如果有异常，不会抛出！！！
延迟消息
消息去重
保证消息的绝对不丢失
单机搭建
http://rocketmq.apache.org/ 官网下载zip包。unzip 命令解压。
修改 bin 目录下的 runserver和runbroker （元空间）
./mqnamesrv ./mqbroker -n localhost:9876 autoCreateTopicEnable=true 注意：需要先启动nameServer。启动broker时后缀参数必须带上，否则无法找到对应的nameServer，无法自动创建Topic
下载控制台
https://github.com/apache/rocketmq-externals 从GitHup下载源代码。找到rocketmq-console，先编辑一下rocketmq-console里面的application.properties文件，将项目使用的rocketmq.config.namesrvAddr配置上去。
使用maven打包这个项目。进入项目目录使用命令。mvn clean package -Dmaven.test.skip=true
可能时间有点长，等待结束后找到target目录找到jar，java -jar xxx.jar 启动。
浏览器输入 http://localhost:8080 即可进入。
生产者
导入jar包我这里没有使用Springboot整合，但其实使用的API是同一套。
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.3.2</version>
</dependency>