RocketMQ 安装以及测试

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

1. 启动 NameServer
   进入安装目录的 bin 文件夹下，执行命令 nohup sh mqnamesrv & 启动 NameServer。使用 tail -f ~/logs/rocketmqlogs/broker.log 查看启动日志。

表示启动成功。如果启动失败就先修改两个配置文件 runbroker.sh 和 runserver.sh，这两个文件都在 bin 目录，先说明怎样改第一个配置文件 vim runbroker.sh，将里面的这三个 JVM 参数调低，-Xms256m -Xmx256m -Xmn128m。然后对于 runserver.sh 配置文件也做同样的更改。下图所示是更改位置。

2. 启动 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

成功！此时发送端再执行发送消息命令，接受端就会自动打印第二次发送端发送的消息了。