Service Mesh 下 RocketMQ 消息的发送与消费过程是什么样的？

过程为：

（1）Pilot 获取到 Topic 的路由信息并通过 xDS 的形式下发给数据平面/Envoy ， Envoy 会代理 SDK 向 Broker/Nameserver 发送的所有的网络请求；

（2）发送时，Envoy 通过 request code 判断出请求为发送，并根据 topic 和 request code 选出对应的 CDS，然后通过 Envoy 提供的负载均衡策略选出对应的 Broker 并发送，这里会使用数据平面的 subset 机制来确保选出的 Broker 是可写的；

（3）消费时，Envoy 通过 request code 判断出请求为消费，并根据 topic 和 request code 选出对应的 CDS，然后和发送一样选出对应的 Broker 进行消费（与发送类 似，这里也会使用 subset 来确保选出的 Broker 是可读的），并记录相应的元数 据，当消息消费 SDK 发出 ACK 请求时会取出相应的元数据信息进行比对，再通 过路由来准确将 ACK 请求发往上次消费时所使用的 Broker。

资料来源：《云原生消息队列 Apache RocketMQ》，下载链接：https://developer.aliyun.com/topic/download?id=1217。