以前都是听说MQ，或者在别人搭建好的基础上去使用，没有自己动手搭建过，就没有更深入去理解。现在机会来啦.啦啦.啦啦啦......
引用自己的CSDN文章
href="https://blog.csdn.net/chenzhong2010/article/details/106699590
或点击左下角“阅读原文”来支持我...φ(0￣*)啦啦啦_φ(*￣0￣)>
一、安装配置
1.1、下载
下载地址是http://rocketmq.apache.org/release_notes/release-notes-4.2.0/
打开后显示如图：
点击上图zip进行下载。1.2、安装下载完成后解压该zip文件，并移动到对应的目录下，如：
1.3、配置环境变量
右键“我的电脑”->“属性”->“高级属性”->“环境变量”，新增环境变量
ROCKETMQ_HOME
D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release
二、启动NAMESERVER
打开cmd命令窗口，输入命令：
start mqnamesrv.cmd
如上图所述，说明环境变量是正确的，并且NAMESERVER启动成功，此框请不要关闭。
三、启动BROKER
另外打开一个cmd命令窗口，输入命令：
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true后续查询broker名称是tiannanIT，名称就是本地电脑名称：
或者
启动带有配置文件的，启动broker时需要加载配置文件，执行命令：
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true -c D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf后续查询broker名称是broker-a，名称就是broker.conf里面配置的：
配置文件broker.conf默认内容如：
brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType = ASYNC_FLUSHcmd运行brocker后：
奇怪，只是弹出了个框，却没有成功提示，不过这样已经是启动broker成功了，此框勿关闭。
【备注】如果光标没有闪烁，而是回到命令行，那意思就是brocker启动失败，需要把c:/user/你的用户名/store文件夹里面的所有文件全部删除，再启动，成功。
四、查看连接到nameserver上的broker
mqadmin clusterList -n localhost:9876
五、下载RocketMQ插件(管理控制台)
通过git命令下载以下链接对应的源码
git clone https://gitee.com/mirrors/RocketMQ-Externals.git进入D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals**rocketmq-console**目录，清除并打包(如果有自己的maven私服，最好启动)：
mvn clean package -Dmaven.test.skip=true
进入到编译包下cd D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals\rocketmq-console\target\
执行启动该jar：
java -jar rocketmq-console-ng-1.0.1.jar应用访问：http://127.0.0.1:9980
六、创建主题topic
mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t tx-mq-TOPIC
mqadmin updateTopic -c DefaultCluster -n localhost:9876 -t threezto-test -r 12 -w 12
显示刚刚已经创建的两个topic：
然后可以查看一些自定义主题、系统主题等等：
七、控制台创建主题
通过菜单：主题->新增/更新，就弹出框来填写对应的信息，并提交。
八、启动消费者
打开cmd命令窗口，执行以下命令：
set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Consumer
以上，消费者启动成功。
九、启动生产者
打开cmd命令窗口，执行以下命令：
set NAMESRV_ADDR=127.0.0.1:9876tools.cmd org.apache.rocketmq.example.quickstart.Producer
使用topic是TopicTest。
这时候消费者窗口正在消费消息：
十、查看控制台
查看消费者：
查看集群：
查看主题TopicTest的各项信息：
状态：
路由：
CONSUMER管理：
TOPIC配置：
查看消息：
可以查到，
Topic：TopicTest
Tag：TagA
consumerGroup：please_rename_unique_group_name_4
十一、其他命令
1)删除主题
mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t zto-example十二、数据文件配置
12.1 查看数据存储
rocketmq的数据默认都是存放到该目录下
查询属性，发现文件实在太大了，想迁移该文件到其他地方，为c盘腾空间
打开broker.conf配置文件，增加以下配置(注意：需要使用 \\，\是无效的)：
#存储路径storePathRootDir=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store#commitLog 存储路径storePathCommitLog=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\commitlog#消费队列存储路径存储路径storePathConsumeQueue=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\consumequeue#消息索引存储路径storePathIndex=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\index#checkpoint 文件存储路径storeCheckpoint=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\checkpoint#abort 文件存储路径abortFile=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\abort首先将C:\Users\tiannan\store里所有文件迁移出来(否则brocker运行失败)，然后重新运行：
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true -c D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf运行成功后，你会发现rocketmq安装目录下生成store文件夹，里面还有生成一些文件，如：
关闭broker后，再将之前的备份拷贝回来：
最好重新重启broker，打开rocketmq控制台，又可以看见之前生成的topic等信息了。
在上述配置的内容来看，rocketmq的各端配置、以及消息都是存储在store里面的，需要保护好该目录数据。
12.2 查看日志存储
默认存储在C:\Users\tiannan\logs\rocketmqlogs文件夹里面，这个日志文件夹以及里面的日志文件，是以下日志配置进行配置的：
xml文件里面都是设置父目录是 ${user.home}/logs/rocketmqlogs ，所以可以在对应的xml文件里面修改日志存储位置。
十三、修改mqnamesrv和mqbroker的jvm内存
mqnamesrv.cmd -> runserver.cmd
打开runserver.cmd文件，找到以下内容修改：
set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"##修改为set "JAVA_OPT=%JAVA_OPT% -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"mqbroker.cmd -> runbroker.cmd打开runbroker.cmd文件，找到以下内容修改：
set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"##修改为set "JAVA_OPT=%JAVA_OPT% -server -Xms512m -Xmx512m -Xmn256m"或者修改成你需要的内存大小即可。
挺简单的，对你来说，已经学会了拉
。
关注我，下期继续！！！
