RocketMQ(Linux版本5.1.4)

2024-01-01 08:16:18

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

成功!!!

文章来源:https://blog.csdn.net/weixin_53029881/article/details/135316201
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。