1、准备工作
1.1、软硬件需求
系统要求是64位的,JDK要求是1.8及其以上版本的。
1.2、下载RocketMQ安装包
将下载的安装包上传到Linux,并解压
[root@test001 mysoft]# ls
rocketmq-all-4.8.0-bin-release.zip
[root@test001 mysoft]# unzip rocketmq-all-4.8.0-bin-release.zip
[root@test001 mysoft]# ls
rocketmq-all-4.8.0-bin-release rocketmq-all-4.8.0-bin-release.zip
[root@test001 mysoft]# cd rocketmq-all-4.8.0-bin-release/
[root@test001 rocketmq-all-4.8.0-bin-release]# ll
总用量 40
drwxr-xr-x. 2 root root 102 12月 9 2020 benchmark
drwxr-xr-x. 3 root root 4096 12月 4 2020 bin
drwxr-xr-x. 6 root root 211 12月 4 2020 conf
drwxr-xr-x. 2 root root 4096 12月 9 2020 lib
-rw-r--r--. 1 root root 17336 10月 23 2020 LICENSE
-rw-r--r--. 1 root root 1338 12月 4 2020 NOTICE
-rw-r--r--. 1 root root 5132 12月 4 2020 README.md
2、修改初始内存
2.1、修改runserver.sh
这里修改jvm参数,目前我们是做测试,机器没有这么多内存,所以调小点。
使用vim命令打开bin/runserver.sh文件,现将这些值修改为如下
2.2、修改runbroker.sh
使用vim命令打开bin/runbroker.sh文件。现将这些值修改为如下
3、启动
3.1、启动NameServer
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
3.2、启动broker
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
4、发送/接收消息测试
4.1、发送消息
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
4.2、接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
5、关闭Server
无论是关闭name server还是broker,都是使用bin/mqshutdown命令
sh bin/mqshutdown namesrv
sh bin/mqshutdown broker