1、停止之前的运行服务
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# sh bin/mqshutdown namesrv
No mqnamesrv running.
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]#
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]#
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# sh bin/mqshutdown broker
No mqbroker running.
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]#
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# pwd
/usr/local/rocketmq-all-4.7.0-bin-release
2、删除之前的RocketMQ
rm -rf rocketmq-all-4.7.0-bin-release
unzip rocketmq-all-5.1.4-bin-release.zip
它的目录结构:
-
benchmark:这里面就是一些可以直接运行,进行测试的 sh 文件
-
bean:该目录是比较常用的,里面是一些可执行文件
-
conf:这里面就是一些配置文件
-
lib:就是 mq 所依赖的第三方 jar 包
4、启动RocketMQ
(1)启动 NameServer 进入 bin 目录 cd bin/ 后台启动 nohup sh mqnamesrv & 或者 nohup ./mqnamesrv &
可以查看日志,看 mq 是否启动成功: tail -f ~/logs/rocketmqlogs/namesrv.log
或者通过端口号查看
netstat -an | grep 9876
(2)启动 Broker 在启动之前先修改两个配置 vim runserver.sh
将原先注释掉,mq 默认需要的内存是比较大的,根据自己 Linux 的内存大小去设置,我这里就改成 256 256 128 了。
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
vim runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"
启动 broker
nohup ./mqbroker -n localhost:9876 &
查看日志检测是否启动成功
tail -f ~/logs/rocketmqlogs/broker.log
又看到日志打印这个就说明启动成功了,注意:不要把它给关了。
5、测试
(1)发送消息
# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Producer
(2)接收消息
# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Consumer
成功!!!