1 准备工作
软硬件需求
系统要求是64位的，JDK要求是1.8及其以上版本的。
下载RocketMQ安装包
将下载的安装包上传到Linux。
解压。
2、修改初始内存
修改runserver.sh
使用vim命令打开bin/runserver.sh文件。现将这些值修改为如下：
修改runbroker.sh
使用vim命令打开bin/runbroker.sh文件。现将这些值修改为如下：
3、启动
启动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
4、发送/接收消息测试
发送消息
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
接收消息
sh bin/tools.sh org.apache.rocketmq.example.1 quickstart.Consumer
5、关闭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
版权声明：本文不是「本站」原创文章，版权归原作者所有 | 原文地址: