河源市企业网站seo价格,河北邯郸信息港,绵阳商城网站建设,wordpress安全环境准备#xff1a;Linux安装Java环境#xff08;OracleJDK#xff09; 在当今分布式架构的开发中#xff0c;消息队列成为了一种常见的解决方案。RocketMQ是阿里巴巴开源的分布式消息中间件#xff0c;具有高吞吐量、高可用性和强大的扩展性#xff0c;因此在构建大规模… 环境准备Linux安装Java环境OracleJDK 在当今分布式架构的开发中消息队列成为了一种常见的解决方案。RocketMQ是阿里巴巴开源的分布式消息中间件具有高吞吐量、高可用性和强大的扩展性因此在构建大规模、高可靠性的应用系统时备受推崇。而在使用RocketMQ时为了更好地了解消息的流动和监控RocketMQ Dashboard成为了一个不可或缺的可视化工具。
本篇博客将带大家一步步在Linux系统中安装RocketMQ并介绍如何配置和使用RocketMQ Dashboard。我们将深入探讨这两者的安装与集成过程帮助大家快速上手并运用于实际项目中。无论是初次接触Spring Cloud Alibaba还是对RocketMQ和Dashboard感兴趣本文都将为大家提供详尽的指导与实例。 文章目录 rocketmq第一步下载第二步解压第三步启动NameServer第四步启动Broker第五步关闭服务 rocketmq-dashboard第一步下载rocketmq-dashboard第二步解压打包启动 rocketmq
第一步下载 https://archive.apache.org/dist/rocketmq/4.9.1/ ROCKETMQ下载 RocketMQ 的安装包分为两种二进制包和源码包。 二进制包是已经编译完成后可以直接运行的源码包是需要编译后运行的 下载二进制包 第二步解压
unzip rocketmq-all-4.9.1-bin-release.zip 第三步启动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; errorCannot allocate memory (errno12)
#
# 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 vim runserver.sh修改为
-Xms256m -Xmx256m -Xmn125m 出现下面语句则启动成功
The Name Server boot success. serializeTypeJSON编写启动脚本后台运行
vim startup.sh添加内容如下
nohup sh bin/mqnamesrv 运行启动脚本即可 上面启动的NameServer在rocketmq中的位置如下 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
brokerIP1xx.xx.xx.xx # 你的公网IPnohup sh bin/mqbroker -c conf/broker.conf -n localhost:9876 -n localhost:9876的意思就是指定nameserver地址为localhost:9876可以通过-h查看配置信息
如果出现了以下的报错信息则情况和nameserver一样需要修改启动脚本
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; errorCannot allocate memory (errno12)
#
# 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.logvim bin/runbroker.sh -Xms256m -Xmx256m再次启动即可出现如下则成功
The broker[VM-12-4-centos, 10.0.12.4:10911] boot success. serializeTypeJSON and name server is localhost:9876至此一个单Master的RocketMQ集群已经部署起来了 通过ps命令可以看到有两个服务启动成功 之后云服务器开放端口 第五步关闭服务
$ 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) OKrocketmq-dashboard
第一步下载rocketmq-dashboard https://github.com/apache/rocketmq-dashboard 第二步解压打包启动
mvn clean package -Dmaven.test.skiptrue之后会打成一个jar包 运行起来即可
nohup java -jar -Drocketmq.namesrv.addr127.0.0.1:9876 rocketmq-dashboard-1.0.0.jar 访问ip:8080 即可 通过本文的介绍和指导大家应该已经成功地在Linux系统上安装了RocketMQ并且了解了RocketMQ Dashboard的配置和使用方法。RocketMQ作为一款高性能、高可靠性的分布式消息中间件在现代分布式架构的开发中发挥着不可或缺的作用。而RocketMQ Dashboard则为我们提供了一个直观、方便的可视化界面让我们更加轻松地监控和管理消息队列。
