一台服务器可以部署2m-2s-同步?4.5.2版

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

展开
收起
芬奇福贵 2023-05-26 15:52:08 119 分享 版权
1 条回答
写回答
取消 提交回答
  • 您在一台服务器中使用了相同的端口。

    原回答者GitHub用户duhenglucky

    2023-05-26 17:52:32
    赞同 展开评论

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理