Spring Boot消息队列系统：RocketMQ初入门
前言
来啦老铁！
笔者学习Spring Boot有一段时间了，截至目前已实践、总结了26篇Spring Boot系列学习文章，感兴趣的同学可以关注专题一起学习吧！
Spring Boot全家桶
在上一篇文章中，我们一起敲开了消息队列的大门，今天继续造！
生命有限，今天我们先学习RocketMQ！
RocketMQ学习路径
- RocketMQ简介；
- RocketMQ下载；
- RocketMQ安装；
- 安装RocketMQ可视化插件；
- RocketMQ初尝鲜；
1. RocketMQ简介；
RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。
Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Consumer 实例构成。
接下来我将在windows环境下（笔者也没别的机器呀，哭~）与各位一起来入入门，学习学习RocketMQ！
2. RocketMQ下载；
1). RocketMQ官网地址：
2). Apache RocketMQ开发者指南（中文）：
3). RocketMQ下载地址：
下载入口
下载链接
这里有几个注意点：
- 需要安装java 1.8以上版本；
java
-
由于下载地址的目标服务器在国外，下载过程有点漫长，朋友需耐心：
国外服务器
3. RocketMQ安装；
1). 下载完成后，解压;
RocketMQ
2). 设置系统环境变量（非必须）
设置系统环境变量 1
设置系统环境变量 2
3). 启动nameserver
- 命令行执行命令
mqnamesrv
- 第一次启动，容易遇到以下错误：
启动nameserver报错
- 解决办法：
(1). 找到bin目录下的runserver.cmd文件：
runserver.cmd文件
(2). 修改runserver.cmd文件中关于VM内存的配置：
过大的VM内存配置
合理的VM内存配置
保存后，重新执行mqnamesrv命令：
成功启动mqnamesrv
启动成功后，不要关闭窗口；
4). 启动broker
- 命令行执行命令：
mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
同样的，您也许也会遇到类似的错误：
启动broker报错
找到bin目录下的runbroker.cmd文件：
runbroker.cmd
修改runbroker.cmd文件：
修改runbroker.cmd文件
-XX:MaxDirectMemorySize为所有直接字节缓冲区保留的内存的限制。如果为此选项设置了值，那么所有直接字节缓冲区的大小总和不得超过此限制，即与jvm垃圾回收有关。
保存后，重新执行命令：
启动broker
如果遇到啥反应也没有就直接结束命令，则删除C:\Users\当前系统用户名\store下的所有文件，重新执行命令即可！
至此，RocketMQ就算启动成功了，但是却仍然感觉RocketMQ很遥远，接下来我们来进一步使用RocketMQ！
4. 安装RocketMQ可视化插件；
在进一步使用RocketMQ之前，我们先来安装一款RocketMQ可视化插件，通过这款插件，我们对RocketMQ会有更为直观的感受！
1). 下载rocketmq-externals（存放位置任意）：
git clone https://github.com/apache/rocketmq-externals.git
2). 使用IntelliJ打开rocketmq-externals项目下的rocketmq-console子项目；
我们会发现，其为Spring Boot项目哟，是不是很熟悉！
3). 安装maven依赖（安装依赖可能会比较久）；
4). 启动项目；
检查src/main/resources/application.properties文件中的配置项：
server.port=18080
...
rocketmq.config.namesrvAddr=127.0.0.1:9876
...
其中server.port是可视化插件的站点端口，可自己修改，我们此处使用18080；
rocketmq.config.namesrvAddr就是mqbroker的地址，注意端口号要完全正确；
执行mvn clean package -Dmaven.test.skip=true后，打开target/start_rocketmq.bat文件(也可直接启动App.java，你懂的)，即可启动可视化插件：
启动可视化插件
浏览器访问可视化插件：http://127.0.0.1:18080/#/
浏览器访问可视化插件
这个可视化插件看起来还是蛮高大上的，里头可对RocketMQ运维、聚合了消息系统的数据、可进行topic管理、消费者的管理、生产者的管理、消息追踪等，功能十分丰富，有机会我们可以深入详细实践一下！
5. RocketMQ初尝鲜；
我们将在命令行窗口，完成topic创建、启动测试消费者、启动测试生产者，初步了解RocketMQ消息产生与消费！
1). 我们可以通过命令行，创建我们自己的topic，如：
mqadmin updateTopic -t DylanTopicTest -c DefaultCluster -n 127.0.0.1:9876
命令行创建topic
可视化插件中查看新创建的topic
2). 启动测试消费者；
命令1：
set NAMESRV_ADDR=127.0.0.1:9876
命令2：
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
启动测试消费者
3). 启动测试生产者；
命令1：
set NAMESRV_ADDR=127.0.0.1:9876
命令2：
tools.cmd org.apache.rocketmq.example.quickstart.Producer
启动测试生产者
据说测试生产者启动后，生产者会发送1000个消息，然后自动退出，不过笔者启动生产者后，遇到报错：
...
[REJECTREQUEST]system busy, start flow control for a while
...
这个我一时半会没搞定，咱们下一期继续探索，也欢迎有知道如何解决的朋友，给我留言哦，感谢！
下一期，我预计会尝试从代码侧完成消息的生产、消费等这些基础过程！敬请期待！
如果本文对您有帮助，麻烦点赞、关注！
谢谢！
