RocketMQ集群配置

这篇具有很好参考价值的文章主要介绍了RocketMQ集群配置。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

RocketMQ默认的端口号如下:

  1. Namesrv:9876
  2. Broker:10911

请注意,这些是默认的端口,你可以在RocketMQ的配置文件中修改这些端口。同时,如果你运行了多个broker实例或namesrv实例,那么每个实例需要使用不同的端口。

两个Namesrv实例,还有2对 Broker实例主和备,该怎么配置?
在这种情况下,你可以分别为每个Broker实例创建一个配置文件,并在每个文件中指定相应的Namesrv地址、Broker名称和角色(Master或Slave)。

以下是具体步骤:

1. Namesrv实例

Namesrv没有特定的配置文件,所有配置都是在启动命令中指定的。如果你想要运行多个Namesrv实例,你只需要为每个实例指定不同的端口号。例如:

nohup sh mqnamesrv -n localhost:9876 > namesrv1.log 2>&1 &
nohup sh mqnamesrv -n localhost:9877 > namesrv2.log 2>&1 &

在这个例子中,我们启动了两个Namesrv实例,分别监听9876和9877端口。

2. Broker实例

对于Broker实例,你可以在RocketMQ的conf目录下创建4个新的配置文件,例如:

  • broker-a-master.properties
  • broker-a-slave.properties
  • broker-b-master.properties
  • broker-b-slave.properties

然后在每个配置文件中添加相应的内容。

例如,在broker-a-master.properties中:

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
autoCreateTopicEnable=true
namesrvAddr=localhost:9876;localhost:9877

broker-a-slave.properties中:

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
autoCreateTopicEnable=true
namesrvAddr=localhost:9876;localhost:9877

同样的,你也需要为broker-b配置对应的master和slave配置。

然后,你可以使用以下命令分别启动这4个Broker实例:

nohup sh mqbroker -c ../conf/broker-a-master.properties > broker-a-master.log 2>&1 &
nohup sh mqbroker -c ../conf/broker-a-slave.properties > broker-a-slave.log 2>&1 &
nohup sh mqbroker -c ../conf/broker-b-master.properties > broker-b-master.log 2>&1 &
nohup sh mqbroker -c ../conf/broker-b-slave.properties > broker-b-slave.log 2>&1 &

注意,每个Broker实例都需要一个独立的配置文件,且brokerNamebrokerId应该是唯一的。在每对Master和Slave中,brokerName应该相同,而brokerId在Master中应为0,在Slave中应为1。

以上命令假定你在RocketMQ的bin目录中运行。如果你在其他位置运行,你可能需要修改命令中的路径。

另外,如果你想要在后台运行这些命令,你可以使用nohup命令,并将输出重定向到一个日志文件,如上面命令中的namesrv1.lognamesrv2.logbroker-a-master.log,`broker-a-slave

在Linux系统中,你可以使用ps命令查看正在运行的RocketMQ Namesrv和Broker实例。以下是如何使用这个命令:

  1. 打开命令行窗口。

  2. 输入以下命令来查看正在运行的Namesrv实例:

ps -ef | grep mqnamesrv

如果Namesrv实例正在运行,你将看到类似以下的输出:

root     12345     1  0 Jun21 ?        00:00:00 sh mqnamesrv
  1. 输入以下命令来查看正在运行的Broker实例:
ps -ef | grep mqbroker

如果Broker实例正在运行,你将看到类似以下的输出:

root     23456     1  0 Jun21 ?        00:00:00 sh mqbroker -c ../conf/2m-noslave.properties

在这些命令的输出中,你可以看到启动Namesrv和Broker的命令,以及关联的进程ID。

对于你的特定情况,你需要看到两个Namesrv实例和四个Broker实例(每个Broker一对主从)。

请注意,你可能需要根据实际的Namesrv和Broker配置调整这些命令。例如,如果你使用了不同的配置文件或者命令选项,那么你需要在grep命令中指定相应的文本。文章来源地址https://www.toymoban.com/news/detail-529848.html

到了这里,关于RocketMQ集群配置的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • RocketMQ快速实战以及集群架构详解

    MQ:MessageQueue,消息队列。是在互联网中使用非常广泛的一系列服务中间件。 这个词可以分两个部分来看,一是Message:消息。消息是在不同进程之间传递的数据。这些进程可以部署在同一台机器上,也可以分布在不同机器上。二是Queue:队列。队列原意是指一种具有FIFO(先进

    2024年02月03日
    浏览(47)
  • 使用 KubeSphere 部署高可用 RocketMQ 集群

    作者:老Z,云原生爱好者,目前专注于云原生运维,KubeSphere Ambassador。 Spring Cloud Alibaba 全家桶之 RocketMQ 是一款典型的分布式架构下的消息中间件产品,使用异步通信方式和发布订阅的消息传输模型。 很多基于 Spring Cloud 开发的项目都喜欢采用 RocketMQ 作为消息中间件。 Rock

    2023年04月15日
    浏览(47)
  • RocketMQ双主双从同步集群部署

    🎈 作者: 互联网-小啊宇 🎈 简介: CSDN 运维领域创作者、阿里云专家博主。目前从事 Kubernetes运维相关工作,擅长Linux系统运维、开源监控软件维护、Kubernetes容器技术、CI/CD持续集成、自动化运维、开源软件部署维护等领域。 🎈 博客首页:CSDN【互联网-小阿宇】 、阿里云

    2024年02月12日
    浏览(42)
  • RocketMQ第一课-快速实战以及集群架构搭建

    ​ RocketMQ是阿里巴巴开源的一个消息中间件,在阿里内部历经了双十一等很多高并发场景的考验,能够处理亿万级别的消息。2016年开源后捐赠给Apache,现在是Apache的一个顶级项目。 ​ 早期阿里使用ActiveMQ,但是,当消息开始逐渐增多后,ActiveMQ的IO性能很快达到了瓶颈。于是

    2024年02月15日
    浏览(45)
  • 【RocketMQ专题】快速实战及集群架构原理详解

    基本介绍 MQ:即MessageQueue,消息队列。是在互联网中使用非常广泛的一系列服务中间件。 这个词可以分两个部分来看: Message:消息。消息是在不同进程之间传递的数据。这些进程可以部署在同一台机器上,也可以分布在不同机器上 Queue:队列。队列原意是指一种具有FIFO(先

    2024年02月07日
    浏览(29)
  • RocketMQ主从集群broker无法启动,日志报错

    使用vmWare安装的centOS7.9虚拟机,RocketMQ5.1.3 在rocketMQ的bin目录里使用相对路径的方式启动broker,jps查询显示没有启动,日志报错如下 排查配置文件没有问题,nameServer也已经正常启动 更换绝对路径,启动broker,就可以正常启动  

    2024年02月16日
    浏览(47)
  • 使用docker搭建RocketMQ(非集群搭建官方镜像)

    之前在使用 RocketMQ 官方的包在搭建的时候,发现好多问题,什么修改内存大小,然后启动 broker 报错,类似 service not available now, maybe disk full 等等… 最后决定还是重新用 docker 搭建下,感觉这样子玩坏了,可以直接把容器干掉,重新启动一个新的容器,毕竟是在学习阶段,这

    2024年02月13日
    浏览(56)
  • RocketMQ集群4.9.2升级4.9.6版本

    本文主要记录生产环境短暂停机升级RocketMQ版本的过程         1.将生产环境MQ4.9.2集群同步到测试环境,并启动,确保正常运行。         2.参照4.9.2配置4.9.6集群         3.停掉4.9.2集群,启动4.9.6集群,测试确保正常运行。         4.停掉4.9.6集群,复制4.9.2集群的store存

    2024年02月15日
    浏览(73)
  • 阿里云主机安装RocketMQ 集群支持外网访问

    背景:因公司迁移机房,需要在云主机上部署一套和本地一样的rocketMQ,原本计划直接购买云rocketMQ,云rocketMQ仅支持5.0.0,本地rocketMQ 是3.4.6,公司多个服务都使用本地的3.4.6版本的RocketMQ,所以需要再云上搭建一套简易版RocketMQ集群,并支持外网访问。 准备:两台开通外网的

    2024年01月21日
    浏览(42)
  • Springbootg整合RocketMQ ——使用 rocketmq-spring-boot-starter 来配置发送和消费 RocketMQ 消息

           本文解析将 RocketMQ Client 端集成为 spring-boot-starter 框架的开发细节,然后通过一个简单的示例来一步一步的讲解如何使用这个 spring-boot-starter 工具包来配置,发送和消费 RocketMQ 消息。 添加maven依赖: 修改application.properties 注意: 请将上述示例配置中的 127.0.0.1:9876 替换

    2024年03月22日
    浏览(45)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包