一,下载安装包
1.官网地址:http://rocketmq.apache.org/dowloading/releases/
2.网盘下载:
链接:https://pan.baidu.com/s/1pir1iAVkAhhaTrT-6Jx2-w
提取码:m281
二、安装及启动
1、将zip文件上传到linux的~下,然后解压:
我的安装包放在了/home/RocketMQ 解压:unzip 压缩包名称
2、移动 执行 mv rocketmq-all-4.3.0-bin-release /usr/local/rocketmq
看一下该文件的目录:
启动NameServer命令(bin目录下)
启动:nohup sh mqnamesrv &
查看日志:tail -f ~/logs/rocketmqlogs/namesrv.log
启动Broker命令(bin目录下)
启动:nohup sh mqbroker -n localhost:9876 &
查看日志:tail -f ~/logs/rocketmqlogs/broker.log
关闭RocketMQ命令:(bin目录下)
关闭NameServer:sh mqshutdown namesrv
关闭Borker:sh mqshutdown broker
注意:RocketMQ默认的虚拟机内存比较大,启动Broker如果因为内存不许而失败,需要编辑两个配置文件,修改JVM内存大小。
编辑runbroker.sh和runserver.sh修改默认JVM的大小
vim runbroker.sh
vim runserver.sh
3.启动nameserver,在bin目录下执行:nohup sh mqnamesrv & 查看启动是否成功的日志命令:tail -f ~/logs/rocketmqlogs/namesrv.log 打印如下表示启动成功:
4.启动broker,在bin目录下执行:nohup sh mqbroker -n localhost:9876 & 查看日志命令:tail -f ~/logs/rocketmqlogs/broker.log,打印如下表示启动成功:
三。测试RocketMQ
这里我用的是putty来测试,连接两台,一个发送消息,一个接收消息
putty:
链接:https://pan.baidu.com/s/16huhWIZ7wm9P8Q0t1emcdQ
提取码:q4j5
1.发送消息<bin目录>
设置环境变量:export NAME SRV_ADDR=localhost:9876
使用安装包demo发送消息:sh tools.sh org.apache.rocketmq.example.quickstart.Producer
2.接收消息<bin目录>
设置环境变量:export NAME SRV_ADDR=localhost:9876
使用安装包demo接收消息:sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
到此,RocketMQ初步完成。。。。。。。。。。。。。