java

rocketmq5.xx版本安装

1.下载二进制包

https://rocketmq.apache.org/zh/download

5.xx版本架构: https://juejin.cn/post/7293788137662758946

2.安装启动

  1. 解压 unzip xxx.zip

  2. 启动nameserver

cd bin目录
nohup sh mqnamesrv >/dev/null 2>&1 &

//执行 jps 查看进程

jps

//查看日志确保服务已正常启动

tail -f ~/logs/rocketmqlogs/namesrv.log The Name Server boot success…

  1. 启动broker
nohup sh mqbroker -n localhost:9876 >/dev/null 2>&1 &
(ip换成实际的或127.0.0.1)

//执行 jps 查看进程

jps

25954 BrokerStartup //查看日志确保服务已正常启动

tail -f ~/logs/rocketmqlogs/broker.log The broker[broker-a, 10.1.54.121:10911] boot success…

  1. 启动proxy(5.xx版本)
nohup sh mqproxy -n localhost:9876 >/dev/null 2>&1 &

默认端口:Proxy 的 8080 端口提供 Remoting 协议的接入,8081 端口提供 gRPC 协议的接入
  1. 关闭服务

sh mqshutdown proxy sh mqshutdown broker sh mqshutdown namesrv

The mqnamesrv(36664) is running… Send shutdown request to mqnamesrv(36664) OK 创建topic: sh mqadmin updatetopic -b localhost:10911 -n localhost:9876 -t Topic_1

3.可视化界面

https://github.com/apache/rocketmq-dashboard

jdk1.8

修改配置: application.yml

打包:
mvn clean package -D maven.test.skip=true



启动:
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

浏览器访问: ip

docker安装

sudo docker pull apacherocketmq/rocketmq-dashboard:latest

docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.18.144.40:9876" -p 8180:8080 -t apacherocketmq/rocketmq-dashboard:latest

访问:8180端口

关于作者

程序员,软件工程师,java, golang, rust, c, python,vue, Springboot, mybatis, mysql,elasticsearch, docker, maven, gcc, linux, ubuntu, centos, axum,llm, paddlepaddle, onlyoffice,minio,银河麒麟,中科方德,rpm