rocketmq集群方式：双主双从 异步复制 版本：rocketmq-all-4.9.1-bin-release
问题产生原因：集群部署在阿里云vpc网络下，使用公网slb映射到内网9876 和 10911端口，生产者在外网 获取到的broker地址是内网地址，因此修改了broker的配置文件，如下： broker-master ： brokerIP1=123.41.156.234 brokerIP2=192.168.11.123
broker-slave： brokerIP1=192.168.11.124 brokerIP2=192.168.11.124
此时发现外网生产者Producer的消息接收到，但是slave启动时报错：发现slave 连接master走的是brokerIP1，没有走brokerIP2。现在不想让slave通过公网IP连接master。 ERROR BrokerControllerScheduledThread1 - SyncSubscriptionGroup Exception, 123.41.156.234:10911 org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 123.41.156.234:10911 failed at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:394) ~[rocketmq-remoting-4.9.1.jar:4.9.1] at org.apache.rocketmq.broker.out.BrokerOuterAPI.getAllSubscriptionGroupConfig(BrokerOuterAPI.java:381) ~[rocketmq-broker-4.9.1.jar:4.9.1] at org.apache.rocketmq.broker.slave.SlaveSynchronize.syncSubscriptionGroupConfig(SlaveSynchronize.java:125) [rocketmq-broker-4.9.1.jar:4.9.1] at org.apache.rocketmq.broker.slave.SlaveSynchronize.syncAll(SlaveSynchronize.java:52) [rocketmq-broker-4.9.1.jar:4.9.1] at org.apache.rocketmq.broker.BrokerController$12.run(BrokerController.java:1144) [rocketmq-broker-4.9.1.jar:4.9.1] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_281] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_281] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_281] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_281] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_281] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_281] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_281]
原提问者GitHub用户sydcph
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
这是一个问题。主备之间的日志数据复制用的是brokerIP2，但元数据复制（topics.json，subscriptionGroup.json等 ）用的brokerIP1，我认为两者都应该使用brokerIP2
rocketmq/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
Line 971 in 47561bd
this.slaveSynchronize.setMasterAddr(registerBrokerResult.getMasterAddr());
源码上应该把this.slaveSynchronize.setMasterAddr(registerBrokerResult.getMasterAddr());改为this.slaveSynchronize.setMasterAddr(registerBrokerResult.getHaServerAddr());就可以。
原回答者GitHub用户RongtongJin
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践，通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式，助力制造业企业高效上云，实现系统稳定、应用敏捷智能。拥抱云原生，让创新无处不在。
你好，我是AI助理
可以解答问题、推荐解决方案等
评论
全部评论 (0)