rocketmq集群安装
程序员文章站
2022-03-23 22:03:14
...
jps |awk '{print $1}'|xargs kill -9 cd /home/soft/rocketmq/bin/ mqnamesrv -c /home/soft/rocketmq/conf/namesrv.properties & nohup sh mqbroker -c /home/soft/rocketmq/conf/2m-2s-sync/broker-a.properties brokerIP1=192.168.1.120 >/dev/null 2>&1 & cd /home/soft/rocketmq2/bin/ nohup sh mqbroker -c /home/soft/rocketmq2/conf/2m-2s-sync/broker-b-s.properties brokerIP1=192.168.1.120 >/dev/null 2>&1 & jps |awk '{print $1}'|xargs kill -9 cd /home/soft/rocketmq/bin/ mqnamesrv -c /home/soft/rocketmq/conf/namesrv.properties & nohup sh mqbroker -c /home/soft/rocketmq/conf/2m-2s-sync/broker-b.properties brokerIP1=192.168.1.125 >/dev/null 2>&1 & cd /home/soft/rocketmq2/bin/ nohup sh mqbroker -c /home/soft/rocketmq2/conf/2m-2s-sync/broker-a-s.properties brokerIP1=192.168.1.125 >/dev/null 2>&1 &
# Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. #brokerClusterName=DefaultCluster #namesrvAddr=192.168.1.120:9876;192.168.1.125:9876; #brokerName=broker-a #brokerId=0 #deleteWhen=04 #fileReservedTime=48 #brokerRole=SYNC_MASTER #flushDiskType=ASYNC_FLUSH #所属集群名字 brokerClusterName=rocketmq-cluster #broker名字,注意此处不同的配置文件填写的不一样 例如:在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b brokerName=broker-a #0 表示 Master,>0 表示 Slave brokerId=0 #nameServer地址,这里nameserver是单台,如果nameserver是多台集群的话,就用分号分割(即namesrvAddr=ip1:port1;ip2:port2;ip3:port3) namesrvAddr=192.168.1.120:9876;192.168.1.125:9876 #在发送消息时,自动创建服务器不存在的topic,默认创建的队列数。由于是4个broker节点,所以设置为4 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 brokerIP1=192.168.1.120 brokerIP2=192.168.1.120 listenPort=10911 #删除文件时间点,默认凌晨 4点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条,根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/home/soft/rocketmq/store #commitLog 存储路径 storePathCommitLog=/home/soft/rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/home/soft/rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/home/soft/rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/home/soft/rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/home/soft/rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole=MASTER #要配置为MASTER或SLAVE的角色 #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128
# Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. #brokerClusterName=DefaultCluster #namesrvAddr=192.168.1.120:9876;192.168.1.125:9876; #brokerName=broker-a #brokerId=1 #deleteWhen=04 #fileReservedTime=48 #brokerRole=SLAVE #flushDiskType=ASYNC_FLUSH #所属集群名字 brokerClusterName=rocketmq-cluster #broker名字,注意此处不同的配置文件填写的不一样 例如:在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b brokerName=broker-a #0 表示 Master,>0 表示 Slave brokerId=1 #nameServer地址,这里nameserver是单台,如果nameserver是多台集群的话,就用分号分割(即namesrvAddr=ip1:port1;ip2:port2;ip3:port3) namesrvAddr=192.168.1.120:9876;192.168.1.125:9876 #在发送消息时,自动创建服务器不存在的topic,默认创建的队列数。由于是4个broker节点,所以设置为4 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 brokerIP1=192.168.1.125 brokerIP2=192.168.1.125 #Broker 对外服务的监听端口 listenPort=10921 #删除文件时间点,默认凌晨 4点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条,根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/home/soft/rocketmq2/store #commitLog 存储路径 storePathCommitLog=/home/soft/rocketmq2/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/home/soft/rocketmq2/store/consumequeue #消息索引存储路径 storePathIndex=/home/soft/rocketmq2/store/index #checkpoint 文件存储路径 storeCheckpoint=/home/soft/rocketmq2/store/checkpoint #abort 文件存储路径 abortFile=/home/soft/rocketmq2/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole=SLAVE #要配置为MASTER或SLAVE的角色 #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128
## # 名称:NamesrvConfig.rocketmqHome <String> # 默认值:(通过 sh mqnamesrv 设置 ROCKETMQ_HOME 环境变量,在源程序中获取环境变量得 # 到的目录) # 描述:RocketMQ 主目录 # 建议:不主动配置 ## rocketmqHome = /home/soft/rocketmq ## # 名称:NamesrvConfig.kvConfigPath <String> # 默认值:$user.home/namesrv/kvConfig.json <在源程序中获取用户环境变量后生成> # 描述:kv 配置文件路径,包含顺序消息主题的配置信息 # 建议:启用顺序消息时配置 ## kvConfigPath = /home/soft/rocketmq/conf/kvConfig.json ## # 名称:NamesrvConfig.configStorePath <String> # 默认值:$user.home/namesrv/namesrv.properties <在源程序中获取用户环境变量后生成> # 描述:NameServer 配置文件路径 # 建议:启动时通过 -c 指定 ## configStorePath = /home/soft/rocketmq/conf/namesrv.properties ## # 名称:NamesrvConfig.clusterTest <boolean> # 默认值:false <在源程序中初始化字段时指定> # 描述:是否开启集群测试 # 建议:不主动配置 ## clusterTest = true ## # 名称:NamesrvConfig.orderMessageEnable <boolean> # 默认值:false <在源程序中初始化字段时指定> # 描述:是否支持顺序消息 # 建议:启用顺序消息时配置 ## orderMessageEnable = false ## # 名称:NettyServerConfig.listenPort <int> # 默认值:9876 <在源程序中初始化后单独设置> # 描述:服务端监听端口 # 建议:不主动配置 ## listenPort = 9876 ## # 名称:NettyServerConfig.serverWorkerThreads <int> # 默认值:8 <在源程序中初始化字段时指定> # 描述:Netty 业务线程池线程个数 # 建议:不主动配置 ## serverWorkerThreads = 8 ## # 名称:NettyServerConfig.serverCallbackExecutorThreads <int> # 默认值:0 <在源程序中初始化字段时指定> # 描述:Netty public 任务线程池线程个数,Netty 网络设计,根据业务类型会创建不同的线程池,比如处理发送消息、消息消费、心跳检测等。如果该业务类型(RequestCode)未注册线程池,则由 public 线程池执行 # 建议: ## serverCallbackExecutorThreads = 0 ## # 名称:NettyServerConfig.serverSelectorThreads <int> # 默认值:3 <在源程序中初始化字段时指定> # 描述:IO 线程池线程个数,主要是 NameServer、Broker 端解析请求、返回响应的线程个数,这类线程池主要是处理网络请求的,解析请求包,然后转发到各个业务线程池完成具体的业务操作,然后将结果再返回调用方 # 建议:不主动配置 ## serverSelectorThreads = 3 ## # 名称:NettyServerConfig.serverOnewaySemaphoreValue <int> # 默认值:256 <在源程序中初始化字段时指定> # 描述:send oneway 消息请求并发度 # 建议:不主动配置 ## serverOnewaySemaphoreValue = 256 ## # 名称:NettyServerConfig.serverAsyncSemaphoreValue <int> # 默认值:64 <在源程序中初始化字段时指定> # 描述:异步消息发送最大并发度 # 建议:不主动配置 ## serverAsyncSemaphoreValue = 64 ## # 名称:NettyServerConfig.serverChannelMaxIdleTimeSeconds <int> # 默认值:120 <在源程序中初始化字段时指定> # 描述:网络连接最大空闲时间,单位秒,如果连接空闲时间超过该参数设置的值,连接将被关闭 # 建议:不主动配置 ## serverChannelMaxIdleTimeSeconds = 120 ## # 名称:NettyServerConfig.serverSocketSndBufSize <int> # 默认值:65535 <在源程序中初始化字段时指定> # 描述:网络 socket 发送缓存区大小,单位 B,即默认为 64KB # 建议:不主动配置 ## serverSocketSndBufSize = 65535 ## # 名称:NettyServerConfig.serverSocketRcvBufSize <int> # 默认值:65535 <在源程序中初始化字段时指定> # 描述:网络 socket 接收缓存区大小,单位 B,即默认为 64KB # 建议:不主动配置 ## serverSocketRcvBufSize = 65535 ## # 名称:NettyServerConfig.serverPooledByteBufAllocatorEnable <int> # 默认值:true <在源程序中初始化字段时指定> # 描述:ByteBuffer 是否开启缓存,建议开启 # 建议:不主动配置 ## serverPooledByteBufAllocatorEnable = true ## # 名称:NettyServerConfig.useEpollNativeSelector <int> # 默认值:false <在源程序中初始化字段时指定> # 描述:是否启用 Epoll IO 模型 # 建议:Linux 环境开启 ## useEpollNativeSelector = true
上一篇: 平复一下心情