上一篇 <<<RocketMQ集群环境程序启用相关知识点
下一篇 >>>RocketMQ所有配置说明
1.单机要做主备,需要在broker.conf中增加配置
a.同一个集群的主备brokerName是相同的,
b.listenPort不能重复,
c.brokerId=0为主,其他都是备
d.设置brokerIP1=IP,不然客户端连接超时
listenPort=10911
brokerIP1=10.211.55.16
#存储路径
storePathRootDir=/temp/store
#commitLog 存储路径
storePathCommitLog=/temp/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/temp/store/consumequeue
#消息索引|存储路径
storePathindex=/temp/store/index
#checkpoint 文件存储路径
storeCheckpoint=/temp/store/checkpoint
abortFile=/temp/store/abort
nohup sh bin/mqnamesrv &
nohup sh bin/mqbroker -n 10.211.55.16:9876 -c conf/broker-a.conf &
nohup sh bin/mqbroker -n 10.211.55.16:9876 -c conf/broker-a-s.conf &
nohup sh bin/mqbroker -n 10.211.55.16:9876 -c conf/broker-b.conf &
nohup sh bin/mqbroker -n 10.211.55.16:9876 -c conf/broker-b-s.conf &
验证集群情况:sh bin/mqadmin clusterList -n 10.211.55.16:9876
2.其他相关说明
#集群名称,可以区分不同集群,不同的业务可以建多个集群
brokerClusterName=jarye
# Broker 的名称, Master 和Slave 通过使用相同的Broker 名称来表明相互关系,以说明某个Slave 是哪个Master 的Slave 。
brokerName=broker-a
# 一个Master Barker 可以有多个Slave, 0 表示Master ,大于0 表示不同Slave 的ID 。
brokerId=0
#与fileReservedTim巳参数呼应,表明在几点做消息删除动作,默认值04 表示凌晨4 点。
deleteWhen=04
namesrvAddr=mqnameserver1:9876;mqnameserver2:9876
autoCreateTopicEnable=true
#topic默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker自动创建订阅组,建议线下开启,线上关闭,默认【true】
autoCreateSubscriptionGroup=true
#Broker 监听的端口号,如果一台机器上启动了多个Broker , 则要设置不同的端口号,避免冲突。
listenPort=10911
brokerIp=192.168.1.1
推荐阅读:
<<<消息中间件的核心思想
<<<消息中间件常见问题汇总
<<<基于Netty简单手写消息中间件思路
<<<消息队列常用名词与中间件对比
<<<Rabbitmq基础知识
<<<Rabbitmq示例之点对点简单队列
<<<Rabbitmq示例之工作(公平)队列
<<<Rabbitmq示例之发布订阅模式
<<<Rabbitmq示例之路由模式Routing
<<<Rabbitmq示例之通配符模式Topics
<<<Rabbitmq示例之RPC模式
<<<Rabbitmq队列模式总结
<<<Rabbitmq如何保证消息不丢失
<<<Springboot利用AmqpTemplate整合Rabbitmq
<<<Rabbitmq如何保证幂等性
<<<Rabbitmq的重试策略
<<<Rabbitmq通过死信队列实现过期监听
<<<Rabbitmq解决分布式事务思路
<<<Rabbitmq解决分布式事务demo
<<<Rabbitmq环境安装
<<<Kafka中的专业术语都有哪些
<<<Kafka的设计原理介绍
<<<Kafka集群如何实现相互感知
<<<Kafka如何实现分区及指定分区消费
<<<Kafka如何保证消息顺序消费
<<<Kafka如何保证高吞吐量
<<<Kafka集群环境搭建
<<<RocketMQ架构原理
<<<RocketMQ、RabbitMQ和Kafka的对比
<<<SpringBoot整合RocketMQ示例
<<<RocketMQ保证顺序消费demo
<<<RocketMQ如何动态扩容和缩容
<<<RocketMQ如何解决分布式事务
<<<RocketMQ单机版本安装
<<<RocketMQ集群环境程序启用相关知识点
<<<RocketMQ所有配置说明