使用RabbitMQ的Direct Reply-To时是否还需要correlation-id？

你的假设完全正确，并发RPC调用场景下即使使用Direct Reply-To，也必须使用correlation-id做请求响应匹配。 #

• 网上资料提到的「无需使用correlation-id」有严格的适用前提：仅当你每次发起RPC调用时，都单独创建专属消费者监听Direct Reply-To伪队列时才成立。这种场景下每个消费者只会收到对应自己那次调用的响应，天然不需要额外做匹配。
• 但实际生产中的并发RPC场景，为了避免频繁创建消费者带来的性能损耗，几乎都会复用同一个连接、同一个信道，仅注册一个全局消费者来消费所有Direct Reply-To的响应消息。这种场景下收到的响应是完全乱序的，没有correlation-id就完全无法判断当前响应对应哪一个请求，会直接出现响应串给错误调用方的问题。
• 通用的正确实现逻辑是：
  1. 发送RPC请求时生成唯一correlation-id写入消息属性，同时本地维护「correlation-id -> 待回调请求上下文」的映射表
  2. 服务端处理完请求后，将请求携带的correlation-id原样写入响应消息的属性中返回
  3. 消费响应时，用拿到的correlation-id匹配本地映射表，找到对应的请求上下文返回结果，同时删除映射表中对应的记录

注意：大部分网上资料省略了「单调用单消费者」的前置条件，才会产生所有场景都不需要correlation-id的误导性结论，在并发场景下忽略这个参数会引发严重的业务逻辑错误。

内容的提问来源于stack exchange，提问作者Fabis