likes
comments
collection
share

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

作者站长头像
站长
· 阅读数 54

环境准备:Linux安装Java环境(OracleJDK)

在当今分布式架构的开发中,消息队列成为了一种常见的解决方案。RocketMQ是阿里巴巴开源的分布式消息中间件,具有高吞吐量、高可用性和强大的扩展性,因此在构建大规模、高可靠性的应用系统时备受推崇。而在使用RocketMQ时,为了更好地了解消息的流动和监控,RocketMQ Dashboard成为了一个不可或缺的可视化工具。

本篇博客将带大家一步步在Linux系统中安装RocketMQ,并介绍如何配置和使用RocketMQ Dashboard。我们将深入探讨这两者的安装与集成过程,帮助大家快速上手并运用于实际项目中。无论是初次接触Spring Cloud Alibaba,还是对RocketMQ和Dashboard感兴趣,本文都将为大家提供详尽的指导与实例。

💽 rocketmq

💽第一步,下载

https://archive.apache.org/dist/rocketmq/4.9.1/

ROCKETMQ下载 RocketMQ 的安装包分为两种,二进制包和源码包。 二进制包是已经编译完成后可以直接运行的,源码包是需要编译后运行的

下载二进制包

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

💽第二步,解压

unzip rocketmq-all-4.9.1-bin-release.zip 

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

💽第三步,启动NameServer

运行bin文件夹里面的mqnamesrv脚本

sh mqnamesrv

如果启动不成功,报错如下

Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000006ec800000, 2147483648, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 2147483648 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /opt/rocketmq/rocketmq-all-4.9.1-bin-release/bin/hs_err_pid19004.log

那就是jvm内存不足,修改runserver.sh,原因是mqnamesrv实际运行的是runserver.sh脚本

mqnamesrv:

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

vim runserver.sh

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

修改为

-Xms256m -Xmx256m -Xmn125m 

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

出现下面语句则启动成功

The Name Server boot success. serializeType=JSON

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

编写启动脚本后台运行

vim startup.sh

添加内容如下

nohup sh bin/mqnamesrv &

运行启动脚本即可

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

上面启动的NameServer在rocketmq中的位置如下

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

NameServer是一个简单的 Topic 路由注册中心,支持 Topic、Broker 的动态注册与发现。 主要包括两个功能: Broker管理,NameServer接受Broker集群的注册信息并且保存下来作为路由信息的基本数据。然后提供心跳检测机制,检查Broker是否还存活; 路由信息管理,每个NameServer将保存关于 Broker 集群的整个路由信息和用于客户端查询的队列信息。Producer和Consumer通过NameServer就可以知道整个Broker集群的路由信息,从而进行消息的投递和消费。 NameServer通常会有多个实例部署,各实例间相互不进行信息通讯。Broker是向每一台NameServer注册自己的路由信息,所以每一个NameServer实例上面都保存一份完整的路由信息。当某个NameServer因某种原因下线了,客户端仍然可以向其它NameServer获取路由信息。

💽第四步,启动Broker

如果你的mq部署在公网上面,例如阿里云

vim conf/broker.conf

修改broker配置文件,否则别的应用连接不上 新增两行:

namesrvAddr = xx.xx.xx.xx:9876
brokerIP1=xx.xx.xx.xx  # 你的公网IP

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

nohup sh bin/mqbroker -c conf/broker.conf -n localhost:9876 &

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

-n localhost:9876的意思就是指定nameserver地址为localhost:9876,可以通过-h查看配置信息

如果出现了以下的报错信息,则情况和nameserver一样需要修改启动脚本

Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /opt/rocketmq/rocketmq-all-4.9.1-bin-release/hs_err_pid24331.log
vim bin/runbroker.sh 

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

-Xms256m -Xmx256m

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

再次启动即可,出现如下则成功

The broker[VM-12-4-centos, 10.0.12.4:10911] boot success. serializeType=JSON and name server is localhost:9876

至此,一个单Master的RocketMQ集群已经部署起来了 通过ps命令可以看到有两个服务启动成功

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

之后云服务器开放端口

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

💽第五步,关闭服务

$ sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK

$ sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

💽rocketmq-dashboard

💽第一步,下载rocketmq-dashboard

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

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

💽第二步,解压打包启动

mvn clean package -Dmaven.test.skip=true

之后会打成一个jar包

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

运行起来即可

nohup java -jar -Drocketmq.namesrv.addr=127.0.0.1:9876 rocketmq-dashboard-1.0.0.jar &

访问ip:8080 即可

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

通过本文的介绍和指导,大家应该已经成功地在Linux系统上安装了RocketMQ,并且了解了RocketMQ Dashboard的配置和使用方法。RocketMQ作为一款高性能、高可靠性的分布式消息中间件,在现代分布式架构的开发中发挥着不可或缺的作用。而RocketMQ Dashboard则为我们提供了一个直观、方便的可视化界面,让我们更加轻松地监控和管理消息队列。

【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具

转载自:https://juejin.cn/post/7265251127071735849
评论
请登录