The proxy local mode?

[echooymxq]

Proxy local mode has the ability of multi-protocol adaptation, with the advantages of low latency and high throughput. But it has additional problems, in local deployment mode, it becomes stateful. The client always need know which broker of Proxy is master, if the current connected proxy of broker is SLAVE, it will send message error. We should escape the message to remote broker in LocalMessageService when the current broker is SLAVE.

/cc @drpmma

[drpmma]

The local mode represents that the connection between Proxy and Broker is a local procedure call. So escaping the message to the remote broker is not recommended.

As an alternative plan, the SLAVE broker should also have a proxy. The client will only send messages to MASTER node. If the MASTER node is down, the client will send messages to the new MASTER after the election.

[francisoliverlee]

+1.
proxies should be stateless， as the RED LINE shows.

[echooymxq]

Yeah, But in the current implementation, it will not escape. In local mode, the client doesn't actually know who is MASTER, because the topic route is wrapped. And as your say, in production, we will deploying the proxy on all the broker nodes(Because we don't know which broker is Master on autoswicth HA or Dledger mode).
I will submit a PR to optimize the message escape on local mode.

[drpmma]

The escape concept is not necessary for local mode.

In local mode, the client is able to know who is MASTER just from the topic route. And the client will only send or receive from master.

See the code below.

rocketmq/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java

Lines 183 to 215 in 3fe81bf

	protected Map<String /*brokerName*/, Map<Long /*brokerID*/, Broker>> buildBrokerMap(
	List<ProxyTopicRouteData.ProxyBrokerData> brokerDataList) {
	Map<String, Map<Long, Broker>> brokerMap = new HashMap<>();
	for (ProxyTopicRouteData.ProxyBrokerData brokerData : brokerDataList) {
	Map<Long, Broker> brokerIdMap = new HashMap<>();
	String brokerName = brokerData.getBrokerName();
	for (Map.Entry<Long, List<org.apache.rocketmq.proxy.common.Address>> entry : brokerData.getBrokerAddrs().entrySet()) {
	Long brokerId = entry.getKey();
	List<Address> addressList = new ArrayList<>();
	AddressScheme addressScheme = AddressScheme.IPv4;
	for (org.apache.rocketmq.proxy.common.Address address : entry.getValue()) {
	addressScheme = AddressScheme.valueOf(address.getAddressScheme().name());
	addressList.add(Address.newBuilder()
	.setHost(address.getHostAndPort().getHost())
	.setPort(address.getHostAndPort().getPort())
	.build());
	}
	Broker broker = Broker.newBuilder()
	.setName(brokerName)
	.setId(Math.toIntExact(brokerId))
	.setEndpoints(Endpoints.newBuilder()
	.setScheme(addressScheme)
	.addAllAddresses(addressList)
	.build())
	.build();
	brokerIdMap.put(brokerId, broker);
	}
	brokerMap.put(brokerName, brokerIdMap);
	}
	return brokerMap;
	}

[echooymxq]

Yeah, i misunderstood the local mode routing data, thank you.