broker-a.properties
` brokerClusterName=RocketMQCluster
brokerName=broker-a
brokerId=0
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
listenPort=10911
namesrvAddr=XXX.XXX.XXX.217:9876
brokerIP1=XXX.XXX.XXX.217
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
storePathRootDir=/opt/rocketmq-4.5.2/dataAmaster/store
storePathCommitLog=/opt/rocketmq-4.5.2/dataAmaster/store/commitlog
storePathConsumerQueue=/opt/rocketmq-4.5.2/dataAmaster/store/consumequeue
storePathIndex=/opt/rocketmq-4.5.2/dataAmaster/store/index
storeCheckpoint=/opt/rocketmq-4.5.2/dataAmaster/store/checkpoint
abortFile=/opt/rocketmq-4.5.2/dataAmaster/store/abort
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000 `
broker-a-s.properties
` brokerClusterName=RocketMQCluster
brokerName=broker-a
brokerId=1
listenPort=10921
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=XXX.XXX.XXX.217:9876
brokerIP1=XXX.XXX.XXX.217
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
storePathRootDir=/opt/rocketmq-4.5.2/dataAslave/store
storePathCommitLog=/opt/rocketmq-4.5.2/dataAslave/store/commitlog
storePathConsumerQueue=/opt/rocketmq-4.5.2/dataAslave/store/consumequeue
storePathIndex=/opt/rocketmq-4.5.2/dataAslave/store/index
storeCheckpoint=/opt/rocketmq-4.5.2/dataAslave/store/checkpoint
abortFile=/opt/rocketmq-4.5.2/dataAslave/store/abort
maxMessageSize=65536
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
`
broker-b.properties
` brokerClusterName=RocketMQCluster
brokerName=broker-b
brokerId=0
brokerRole=ASYNC_MASTER
listenPort=10909
flushDiskType=ASYNC_FLUSH
namesrvAddr=XXX.XXX.XXX.217:9876
brokerIP1=XXX.XXX.XXX.217
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
storePathRootDir=/opt/rocketmq-4.5.2/dataBmaster/store
storePathCommitLog=/opt/rocketmq-4.5.2/dataBmaster/store/commitlog
storePathConsumerQueue=/opt/rocketmq-4.5.2/dataBmaster/store/consumequeue
storePathIndex=/opt/rocketmq-4.5.2/dataBmaster/store/index
storeCheckpoint=/opt/rocketmq-4.5.2/dataBmaster/store/checkpoint
abortFile=/opt/rocketmq-4.5.2/dataBmaster/store/abort
maxMessageSize=65536
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
`
broker-b-s.properties
` brokerClusterName=RocketMQCluster
brokerName=broker-b
brokerId=1
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
listenPort=10919
namesrvAddr=XXX.XXX.XXX.217:9876
brokerIP1=XXX.XXX.XXX.217
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
storePathRootDir=/opt/rocketmq-4.5.2/dataBslave/store
storePathCommitLog=/opt/rocketmq-4.5.2/dataBslave/store/commitlog
storePathConsumerQueue=/opt/rocketmq-4.5.2/dataBslave/store/consumequeue
storePathIndex=/opt/rocketmq-4.5.2/dataBslave/store/index
storeCheckpoint=/opt/rocketmq-4.5.2/dataBslave/store/checkpoint
abortFile=/opt/rocketmq-4.5.2/dataBslave/store/abort
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000 `
start step 1.namesrv 2.broker-a, 3.broker-b, 4.broker-a-s, 5.broker-b-s
when start step 4 or 5 is error ` nohup: ignoring input
java.net.BindException: Address already in use at sun.nio.ch.Net.bind0(Native Method) at sun.nio.ch.Net.bind(Net.java:433) at sun.nio.ch.Net.bind(Net.java:425) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67) at org.apache.rocketmq.store.ha.HAService$AcceptSocketService.beginAccept(HAService.java:177) at org.apache.rocketmq.store.ha.HAService.start(HAService.java:109) at org.apache.rocketmq.store.DefaultMessageStore.start(DefaultMessageStore.java:275) at org.apache.rocketmq.broker.BrokerController.start(BrokerController.java:826) at org.apache.rocketmq.broker.BrokerStartup.start(BrokerStartup.java:64) at org.apache.rocketmq.broker.BrokerStartup.main(BrokerStartup.java:58) `
什么是使用ip或端口,我如何配置
原提问者GitHub用户lexingrensheng
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。