首页 > 其他分享 >rocketmq集群配置

rocketmq集群配置

时间:2023-02-26 14:24:36浏览次数:61  
标签:bin 配置 11.0 broker 集群 usr local rocketmq

rocketmq 2m-2s-sync部署

1、下载

jdk-8u361-linux-x64.tar.gz

rocketmq-all-5.1.0-bin-release.zip

#/etc/profile 环境变量:

export JAVA_HOME=/usr/local/jdk1.8.0_361 export CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar export PATH=$JAVA_HOME/bin:$PATH

2、规划

名称IP
nameserver 11.0.1.141:9876,11.0.1.142:9876,11.0.1.143:9876
master 11.0.1.142,11.0.1.143
slave 11.0.1.142,11.0.1.143

3、nameserver配置文件修改

#JAVA_OPT参数修改

/usr/local/rocketmq/bin/runserver.sh

/usr/local/rocketmq/bin/runbroker.sh

#启动nameserver

nohup /usr/local/rocketmq/bin/mqnamesrv >/usr/local/rocketmq/logs/rocketmq-namesrv.log 2>&1 &

nohup sh mqnamesrv &

 

4、broker-m配置

mkdir /data/rocketmq-m/commitlog -p

#/usr/local/rocketmq/conf/broker-a.properties

#所属集群名字 brokerClusterName=rocketmq_cluster #通过配置文件指定机器的集群和broker归属,比如brokerName一样的属于同一个broker,一个broker只能有一个master,可以有多个slave,brokerId为0的为master,其他的为slave。 brokerName=broker-a #0表示Master,>0表示Slave brokerId=0 #删除文件时间点,默认凌晨 4点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=48 #Broker 的角色 brokerRole=SYNC_MASTER #异步刷新ASYNC_FLUSH /同步刷新SYNC_FLUSH flushDiskType=ASYNC_FLUSH

#nameServer地址,分号分割 namesrvAddr=11.0.1.141:9876;11.0.1.142:9876;11.0.1.143:9876 #在发送消息时,自动创建服务器不存在的topic,默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 listenPort=6888 #ConsumeQueue每个文件默认存30W条,根据业务情况调整 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/data/rocketmq-m #commitLog 存储路径 storePathCommitLog=/data/rocketmq-m/commitlog

 

nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker-a.properties >/usr/local/rocketmq/logs/rocketmq-broker-m.log 2>&1 &

 

5、broker-s配置

mkdir /data/rocketmq-s/commitlog -p

#Broker 的角色 brokerRole=SLAVE

brokerId=1

nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker-as.properties >/usr/local/rocketmq/logs/rocketmq-broker-s.log 2>&1 &

 

6、mqadmin

/usr/local/rocketmq/bin/mqadmin clusterList -n 11.0.1.141:9876

标签:bin,配置,11.0,broker,集群,usr,local,rocketmq
From: https://www.cnblogs.com/52shaidan/p/17156606.html

相关文章

  • Mysql中关于查询日志的配置详解
    查询日志MySQL中的查询日志保存在文本文件中,能够记录MySQL中的所有数据操作。开启查询日志MySQL默认情况下没有开启查询日志,如果需要开启查询日志,则需要在​​my.cnf​​​......
  • stm32f407探索者开发板(十七)——串口寄存器库函数配置方法
    文章目录​​一、STM32串口常用寄存器和库函数​​​​1.1常用的串口寄存器​​​​1.2串口相关的库函数​​​​1.3状态寄存器(USART_SR)​​​​1.4数据寄存器(USART_D......
  • VUEX getters 配置项
      获取bigSum<template><divid="app"><h1>当前总数为:{{$store.state.nbr}}</h1><h2>放大十倍总数为:{{$store.getters.bigSum}}</h2><select......
  • 配置PHP7环境
    1.准备好安装包wampserver和PhpStorm2.先点击wampserver3.1.9_x64.exe    点击install 进度条满了   选择你想用的浏览器和文本  完成后......
  • Golang基于Mysql分布式锁实现集群主备
    背景集群中如果需要主备,可以基于Redis、zk的分布式锁等实现,本文将介绍如何利用Mysql分布式锁进行实现。原理数据库中包含数据字段(此处为Master的主机名)、版本号和上......
  • maven plugin配置说明
    例子如下:1、maven-clean-plugin插件执行mvnclean或mvnclean:clean来调用这个插件清理项目。注意下面日志:DeletingD:\selfProjects\common-project-spring-boot\c......
  • zk单机集群安装
    参考:https://www.cnblogs.com/leeSmall/p/9563547.htmlzk单机集群安装cd/usr/local下载wgethttp://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-......
  • 【Mybatis】【配置文件解析】【二】Mybatis源码解析-别名、环境变量、插件、ObjectFac
    1 前言在上一节我们分析了properties和settings,这节我们分析下别名、环境变量、插件以及ObjectFactory的解析。2 源码分析2.1 解析typeAliasestypeAliases标签......
  • 全局配置-tabBar
           ......
  • 全局配置
                  ......