linux安装
查看java版本
java -version
1.8正好，11要修改很多地方。
解压rocketmq
unzip rocketmq-all-4.5.1-bin-release.zip
移动到opt目录下，并重命名文件夹为rocketmq。
修改配置文件
/etc/profile文件下加上
ROCKET_HOME=/opt/rocketmq
PATH=$PATH:$ROCKET_HOME/bin
生效命令（需要在rocketmq目录中？）
. /etc/profile （有空格）
启动
Please set the JAVA_HOME variable in your environment, We need java(x64)! !!
修改bin/runserver.sh，bin/runbroker.sh，bin/tools.sh文件，改成自己的jdk地址
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java/jdk1.8.0_321
继续报错 VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
内存溢出。
还是刚才的三个文件，把内存改小
-server -Xms1g -Xmx1g -Xmn256m（自己合适就行）
mqnamesrv 启动成功
# 1.启动Broker ，内存还要改小，和namesrv不是共用内存的。
mqbroker -n localhost:9876
日志位置
root/logs/rocketmqlogs
关闭
mqshutdown broker
mqshutdown namesrv
可视化工具rocketmq-externals-rocketmq-console-1.0.0
导入idea后，换成jdk1.8，然后通过命令打包
mvn clean package -DskipTests
然后target目录下cmd，运行jar包
java -jar rocketmq-console-ng-1.0.0.jar
跑不起来就直接idea运行吧，懒得改jdk版本了。
连接失败
修改broker.conf，增加
namesrvAddr = 121.196.1.1:9876
brokerIP1 = 121.196.1.1
重新运行
mqbroker -n localhost:9876 -c conf/broker.conf
还是不行，RocketMQ默认使用3个端口：9876 、10911 、11011
端口打开，连接成功。
windows安装
先下载rocketmq，解压，配置环境变量
ROCKETMQ_HOME
E:\Program\rocketmq-all-4.5.1-bin-release\rocketmq-all-4.5.1-bin-release
在bin文件夹中
启动cmd start mqnamesrv.cmd
等到有success
启动broker
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
autoCreateTopicEnable=true？自动创建主题
没有linux碰到的麻烦多，可能自己电脑内存比云服务器大
可视化工具下载
https://github.com/apache/rocketmq-externals/archive/rocketmq-console-1.0.0.zip
或
https://github.com/apache/rocketmq-externals.git
编译E:\WorkSpace\rocketmq-externals-rocketmq-console-1.0.0\rocketmq-externals-rocketmq-console-1.0.0\rocketmq-console
mvn clean package -Dmaven.test.skip=true 直接双击打包会出问题
clean package -DskipTests
运行target
java -jar rocketmq-console-ng-1.0.0.jar
报错javax/xml/bind/ValidationException 猜测是默认JDK版本过高，怎么使用JDK8启动？
过时版本，先凑合用；
解决办法：直接idea中运行
RocketMQ使用
导入maven包
<rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${rocketmq-spring-boot-starter-version}</version>
</dependency>
spring项目创建监听类
监听主题和分组
主题topic就是这个监听只会监听这个主题的消息
分组consumerGroup是消费者的分组，如果有多个消费者都是这个分组，那他们就会分工合作，保证不会重复读取消息。（消费端自己协调，和生产端没关系）
