我的开源
RocketMQ简介
RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。
RocketMQ的安装
点击官方下载链接，会看到RocketMQ的各个版本，目前最新的发行版是4.5.2，点击下载二进制文件进行安装。
。
下载完后，将其放到要安装的服务器或虚拟机上，这里以linux系统为例。
使用命令将其剪切到 /usr/local/ mv rocketmq-all-4.5.2-bin-release.zip /usr/local/,然后进行解压 unzip rocketmq-all-4.5.2-bin-release.zip。
安装完成！## 启动RocketMQ
- 启动NameServer
进入安装目录的bin文件夹下，执行命令nohup sh mqnamesrv &启动NameServer。使用tail -f ~/logs/rocketmqlogs/namesrv.log查看启动日志。
表示启动成功。如果启动失败就先修改两个配置文件 runbroker.sh 和runserver.sh，这两个文件都在bin目录，先说明怎样改第一个配置文件 vim runbroker.sh，将里面的这三个JVM参数调低，-Xms256m -Xmx256m -Xmn128m。然后对于 runserver.sh 配置文件也做同样的更改。下图所示是更改位置。
- 启动Broker
执行nohup sh mqbroker autoCreateTopicEnable=true -n localhost:9876 &启动Broker，tail -f ~/logs/rocketmqlogs/broker.log
启动成功！## 测试RocketMQ
1、打开两个终端，分别进入MQ的bin目录，一个发消息，一个收消息。
2、发消息端配置
先设置环境变量，export NAMESRV_ADDR=localhost:9876，使用安装包的Demo发送消息 sh tools.sh org.apache.rocketmq.example.quickstart.Producer
正在发送消息ing。
3、接受消息端配置
先设置环境变量，export NAMESRV_ADDR=localhost:9876，接受消息 sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
成功！此时发送端再执行发送消息命令，接受端就会自动打印第二次发送端发送的消息了。