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
成功!此时发送端再执行发送消息命令,接受端就会自动打印第二次发送端发送的消息了。