RocketMQ 5.x，当使用Proxy时消费者无法从slave节点拉取消息

[lemoay]

RocketMQ版本5.3，部署采用主从异步复制，Proxy独立部署。
当主节点宕机后，使用Proxy无法从slave节点拉取消息，而使用Remoting协议+Nameserver可以从slave节点拉取消息。

官方文档：

多节点（集群）多副本模式-异步复制
每个Master配置一个Slave，有多组 Master-Slave，HA采用异步复制方式，主备有短暂消息延迟（毫秒级），这种模式的优缺点如下：
优点：即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，同时Master宕机后，消费者仍然可以从Slave消费，而且此过程对应用透明，不需要人工干预，性能同多Master模式几乎一样；

请问这是正常的吗？

[francisoliverlee]

使用remoting客户端是的。方法是: findBrokerAddressInSubscribe(), AI解释如下：
流程说明：

1. 首先检查brokerName是否为空，如果为空则直接返回null
2. 检查brokerAddrTable中是否存在该brokerName，如果不存在或为空则返回null
3. 根据传入的brokerId查找对应的broker地址
4. 如果未找到且是slave，则尝试查找brokerId+1的地址
5. 如果仍未找到且不要求只查找该broker，则取第一个broker地址
6. 根据找到的broker地址判断是master还是slave
7. 返回FindBrokerResult对象，包含broker地址、是否slave和broker版本信息

这个方法主要用于在订阅场景下查找指定broker的地址，支持查找master和slave，并且可以根据brokerId精确查找或随机查找。

实现代码

rocketmq/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java

Lines 1153 to 1188 in 2219fd8

	public FindBrokerResult findBrokerAddressInSubscribe(
	final String brokerName,
	final long brokerId,
	final boolean onlyThisBroker
	) {
	if (brokerName == null) {
	return null;
	}
	String brokerAddr = null;
	boolean slave = false;
	boolean found = false;
	HashMap<Long/* brokerId */, String/* address */> map = this.brokerAddrTable.get(brokerName);
	if (map != null && !map.isEmpty()) {
	brokerAddr = map.get(brokerId);
	slave = brokerId != MixAll.MASTER_ID;
	found = brokerAddr != null;
	if (!found && slave) {
	brokerAddr = map.get(brokerId + 1);
	found = brokerAddr != null;
	}
	if (!found && !onlyThisBroker) {
	Entry<Long, String> entry = map.entrySet().iterator().next();
	brokerAddr = entry.getValue();
	slave = entry.getKey() != MixAll.MASTER_ID;
	found = brokerAddr != null;
	}
	}
	if (found) {
	return new FindBrokerResult(brokerAddr, slave, findBrokerVersion(brokerName, brokerAddr));
	}
	return null;