请选择 进入手机版 | 继续访问电脑版

window系统搭建RocketMQ 4.8.0版本 伪集群

[复制链接]
云韵 发表于 2021-1-3 11:59:03 | 显示全部楼层 |阅读模式 打印 上一主题 下一主题
Apache RocketMQ发布4.8.0,DLedger模式全面提升!
RocketMQ中两个重要的组成部门就是NameServer和Broker
NameServer:相当于是Broker的注册中心,可以或许管理Broker节点,为生产者和消费者提供路由信息。
Broker:则是背后真正的消息服务器。Broker在启动时向NameServer注册,消息生产者(Producer)在发送消息之前先从NameServer获取Broker服务器列表,然后根据负载从列表中选择一台Broker举行消息发送。
NameServer和Broker分别运行在各自独立的jvm进程中,有着各自差别的集群模式。
NameServer集群只需要摆设多个节点即可,各节点之间无需信息同步。
Broker集群则分为多种模式:主从模式,双主模式,双主双从模式,多主多从模式,Broker又有同步刷盘和异步刷盘模式。
如下是RocketMQ的集群摆设图:

本文主要解说如安在windows系统搭建RocketMQ集群模式。
主要搭建两个节点的NameServer集群,和一主一从的Broker集群。
1、到RocketMQ官网下载二进制压缩包并解压
http://rocketmq.apache.org/dowloading/releases/

conf 文件夹中目次及文件如下:

2、搭建NameServer集群
为了不污染解压后的目次和文件,我们可以在conf文件夹的同级目次下创建myconf目次,用于存在自界说的设置文件。
NameServer默认的端口是9876,在同一台呆板启动两个差别实例,我们需要使用的端标语,
在myconf目次新建两个namesrv1.properties,和namesrv2.properties,用于指定差别的服务端口。
namesrv1.properties指定端口为9876
namesrv2.properties指定端口为9877
设置项如下:
  1. listenPort=9877
复制代码


启动时指定相应的设置文件即可,运行效果如下说明启动乐成

到此NameServer集群搭建乐成。
3、搭建一主一从异步落盘的Broker集群
从/conf/2m-2s-async目次将broker-a.properties(主节点设置文件),broker-a-s.properties(从节点设置文件)两个设置文件复制到myconf目次,并做如下修改。
主节点设置broker-a.properties 内容如下
  1. brokerClusterName=DefaultClusterbrokerName=broker-a#0表现是一个主节点, >0表现SlavebrokerId=0deleteWhen=04fileReservedTime=48brokerRole=ASYNC_MASTERflushDiskType=ASYNC_FLUSH#nameServer所在,分号分割namesrvAddr=127.0.0.1:9876;127.0.0.1:9877#允许自动创建主题autoCreateTopicEnable=true#存储路径storePathRootDir=D:\\rocketmq\\store_master#commitLog存储路径storePathCommitLog=D:\\rocketmq\\store_master\\commitLog#消费队列存储路径storePathConsumerQueue=D:\\rocketmq\\store_master\\consumerqueue#消息索引存储路径storePathIndex=D:\\rocketmq\\store_master\\index#checkpoint 文件存储路径storeCheckpoint=D:\\rocketmq\\store_master\\checkpoint#abort 文件存储路径abortFile=D:\\rocketmq\\store_master\\abort
复制代码
从节点设置broker-a-s.properties 内容如下
  1. brokerClusterName=DefaultCluster#从节点的brokerName必须和主节点一样brokerName=broker-a#0表现是一个主节点, >0表现SlavebrokerId=1deleteWhen=04fileReservedTime=48brokerRole=SLAVEflushDiskType=ASYNC_FLUSH#nameServer所在,分号分割namesrvAddr=127.0.0.1:9876;127.0.0.1:9877#允许自动创建主题autoCreateTopicEnable=true#注意需改端口,而且要和默认的10911相差5以上listenPort=10921#存储路径storePathRootDir=D:\\rocketmq\\store_slave#commitLog存储路径storePathCommitLog=D:\\rocketmq\\store_slave\\commitLog#消费队列存储路径storePathConsumerQueue=D:\\rocketmq\\store_slave\\consumerqueue#消息索引存储路径storePathIndex=D:\\rocketmq\\store_slave\\index#checkpoint 文件存储路径storeCheckpoint=D:\\rocketmq\\store_slave\\checkpoint#abort 文件存储路径abortFile=D:\\rocketmq\\store_slave\\abort
复制代码
修改好设置之后,按照如下方式启动,如果打印相同的信息则表现乐成!!!

4、可以通过RocketMQ的扩展工具查察集群信息
GitHub所在:https://github.com/apache/rocketmq-externals.git
下载后需要修改rocketmq-console模块的application.properties设置文件
  1. rocketmq.config.namesrvAddr=127.0.0.1:9876;127.0.0.1:9876
复制代码
启动org.apache.rocketmq.console.App启动类,欣赏器访问http://127.0.0.1:8080/即可看到如下信息。

5、RocketMQ根据设置生成的数据存储目次


6 注意
在同一台集群摆设多个实例的情况下,两个实例日志打印到的是同一个位置,大概造成日志杂乱,需要对启动脚本更改,使用不消的情况目次才华修改。有需要相识的可以留言相互交换!

来源:https://blog.csdn.net/u013202238/article/details/105881073
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则


专注素材教程免费分享
全国免费热线电话

18768367769

周一至周日9:00-23:00

反馈建议

27428564@qq.com 在线QQ咨询

扫描二维码关注我们

Powered by Discuz! X3.4© 2001-2013 Comsenz Inc.( 蜀ICP备2021001884号-1 )