欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

docker安装rocketmq、控制台

程序员文章站 2022-07-14 23:01:06
...

docker安装rocketmq

找个地方保存mq配置文件和日志文件(我是windows、linux操作一样)
mkdir rocketmq/namesrv/logs
mkdir rocketmq/broker/conf
mkdir rocketmq/broker/logs
mkdir rocketmq/broker/store
mkdir rocketmq/rocketmq-console-ng/logs

安装mqnamesrv

拉取镜像:docker pull rocketmqinc/rocketmq:4.4.0
启动镜像:docker run --name rmqnamesrv --restart=always -d -p 9876:9876 -v D:\docker\rocketmq\namesrv\logs:/home/rocketmq/logs -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq:4.4.0 sh mqnamesrv

说明:

  • -v 挂载宿主机,输入日志文件

安装broker 服务器(mqnamesrv同一镜像)

创建配置文件:broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = 10.199.251.157 #外网地址

外网地址获取方式:

  • windows:ipconfig
    docker安装rocketmq、控制台
  • linux 服务器对外ip
启动broker:docker run --name rmqbroker --restart=always -d -p 10911:10911 -p 10909:10909 -v  D:\docker\rocketmq\broker\logs:/home/rocketmq/logs -v  D:\docker\rocketmq\broker\store:/home/rocketmq/store -v  D:\docker\rocketmq\broker\conf\broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf --link rmqnamesrv:namesrv -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq:4.4.0 sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

说明:

  • -v: 挂载宿主机,输入日志文件和使用配置文件
  • –link: mqnamesrv为镜像,不能直接通信,可以通过该方法通信
  • -e:指定容器内的环境变量

安装控制台

拉取最新镜像:docker pull styletang/rocketmq-console-ng
启动镜像:docker run -d --restart=always --name rocketmq-console-ng -v D:\docker\rocketmq\rocketmq-console-ng\logs:/root/logs  -e "JAVA_OPTS=-Drocketmq.namesrv.addr=mqaddr:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 6080:8080 -t --link rmqnamesrv:mqaddr styletang/rocketmq-console-ng:1.0.0

说明:

  • rmqnamesrv:namesrv镜像地址
  • mqaddr:namesrv镜像地址别名,rocketmq-console-ng中使用
访问:外网地址:28080

控制台使用技巧

  • tipic(主题)

    查看注册到mq所有的topic
    docker安装rocketmq、控制台
    功能按钮:

    • status:队列及offset信息
    • consumer manage:当前topic订阅的消费者(多订阅时某个订阅者不能消费可查看是否订阅成功)
    • send message:测试订阅
  • message
    查看某个topic全部发送的信息
    docker安装rocketmq、控制台

相关标签: docker