目录
一、准备工作
软硬件需求
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
评论记录：
回复评论：