目录

一、准备工作

软硬件需求

下载RocketMQ安装包

​ 二、修改启动参数

修改runserver.sh

修改runbroker.sh

三、启动

启动NameServer

 启动broker

四、发送/接收消息测试

发送消息

五、关闭Server

一、准备工作

软硬件需求

linux系统要求是 64 位的， JDK 要求是 1.8 及其以上版本的。

下载RocketMQ安装包

 

 将下载的安装包上传到Linux。

unzip命令解压。

 二、修改启动参数

修改runserver.sh 使用 vim 命令打开 bin/runserver.sh 文件。现将这些值修改为如下：

 

修改runbroker.sh 使用 vim 命令打开 bin/runbroker.sh 文件。现将这些值修改为如下：

 

三、启动

启动NameServer

nohup sh bin/mqnamesrv & 
tail -f ~/logs/rocketmqlogs/namesrv.log

 

 启动broker

nohup sh bin/mqbroker -n localhost:9876 & 
tail -f ~/logs/rocketmqlogs/broker.log

 

四、发送/接收消息测试

发送消息

export NAMESRV_ADDR=localhost:9876 
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

五、关闭Server 无论是关闭 name server 还是 broker ，都是使用 bin/mqshutdown 命令。

[root@mqOS rocketmq]# sh bin/mqshutdown broker 
The mqbroker(1740) is running... 
Send shutdown request to mqbroker(1740) OK 

[root@mqOS rocketmq]# sh bin/mqshutdown namesrv 
The mqnamesrv(1692) is running... 
Send shutdown request to mqnamesrv(1692) OK 
[2]+ 退出 143 nohup sh bin/mqbroker -n localhost:9876