• windows RocketMQ与可视化监控平台安装


    windows RocketMQ与可视化监控平台安装

    安装日期2023.09.21 最新版

    RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件,搭建RocketMQ需要先配置JAVA环境变量,需要有JAVA_HOME。

    下载安装包

    进入官网选择需要的版本下载安装包(以下以5.1.3为例)。官网下载地址:官网
    下载编译好的二进制文件,也可以自己选择源文件。这边主要以二进制包的方式来进行安装。
    进入下载也如下图:

    image-20230921225723007.png

    安装RocketMQ

    1、解压安装包,进入安装目录的bin文件夹,这里包含MQ启动脚本,包括sh和cmd脚本;
    2、修改虚拟机内存,RocketMQ 默认的虚拟机内存较大,启动 Broker 或者 NameServer 可能会因为内存不足而导致失败,需要根据实际情况修改Broker和NameServer的虚拟机内存。编译runbroker和runserver文件(win环境下修改cmd脚本,linux环境下修改sh脚本即可),以下是参考设置:

    # 以windows环境下为例,编辑 runbroker.cmd 和 runserver.cmd 修改默认 JVM 大小
    $ vi bin/runbroker.cmd
    # 修改-server参数
    set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"
    
    $ vi bin/runserver.cmd
    # 修改-server参数
    set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    启动RocketMQ

    在RocketMQ安装路径的bin目录下,执行以下两个命令

    1、启动NameServer

    # windows环境下启动
    .\mqnamesrv
    
    • 1
    • 2

    image-20230921230146851.png

    2、启动Broker

    # windows环境下启动
    .\mqbroker -n 127.0.0.1:9876 
    
    • 1
    • 2

    启动成功如下图所示
    image-20230921230157742.png

    如果 MQ 处于开启成功后,会有四个端口,其中,一个 namesrv 端口,默认是 9876,还有三个 broker 端口(10909、10911、10912)
    如果需要本地开发环境连接到rocketmq的服务器进行消息推送,需要开启修改对应的配置文件实现。配置文件再mq根目录下的conf文件夹中;

    安装并启动mq可视化监控平台

    rocketmq-dashboard是RocketMQ的一个拓展开源项目,可以对MQ进行可视化监控。
    下载地址:https://github.com/apache/rocketmq-dashboard
    1、下载项目并将配置文件中的namesrv地址改成自己的NameServer地址;
    2、配置完成后进行编译打包,然后启动打包完成的jar就可以了;
    启动成功后就可以通过浏览器访问 http://ip地址:端口 进入控制台页面,可视化查询MQ服务的相关信息,如下图所示:

    推荐使用docker来安装,目前最新的可用 docker 镜像是 apacherocketmq/rocketmq-console:2.0.0

    docker pull apacherocketmq/rocketmq-console:2.0.0
    
    • 1

    运行它(自己更改名称vrAddr和端口)

    docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t apacherocketmq/rocketmq-console:2.0.0
    
    • 1

    浏览器访问:http://ip:8080

    在下面修改成宿主机的ip地址,不能用127.0.0.1,因为是docker容器。

    image-20230921230635385.png

    image-20230921230412192.png

    参考博客:

    https://blog.csdn.net/xianren95/article/details/121924194 “十分钟搞懂RocketMQ,从部署到灵活使用(附示例demo)”
    https://blog.csdn.net/qq_36737803/article/details/112261352 “RocketMQ与Springboot整合(rocketmq-spring-boot-starter)实战教程”
    https://blog.csdn.net/qq435265116/article/details/123994458 “windows搭建RocketMQ踩的坑之Please set the ROCKETMQ_HOME variable in your environment”
    https://blog.csdn.net/abu935009066/article/details/120828337 “RocketMQ Web控制台监控界面介绍+部署”

  • 相关阅读:
    WIN2012远程桌面授权过期
    【C++】从零开始的CS:GO逆向分析1——寻找偏移与基址的方法
    【WPF系列】- XAML语法规范
    Java多线程
    数据结构考研第五章——树与二叉树(内含动图)
    Python基于机器视觉的图像风格迁移
    双指针法 ( 三数之和 )
    深入理解Java虚拟机(第3版)学习笔记——虚拟机字节码执行引擎(超详细)
    吊打面试官系列之---吃透MySQL mvcc机制--锁模块
    python---字符串
  • 原文地址:https://blog.csdn.net/qq_43757282/article/details/133151629