使用RabbitMQ RPC无消费者时未报错，此行为是否符合预期？

这确实是rabbitTemplate.convertSendAndReceive()方法的默认预期行为，咱们来拆解原因和应对方案：

为什么会持续等待？ #

这个方法是为同步RPC场景量身设计的，它的核心工作逻辑是：

• A服务发送请求消息时，会自动生成唯一的correlationId，同时监听一个临时响应队列，专门等待匹配该ID的回复
• 如果B服务（消费者）未运行，请求消息会一直停留在对应的请求队列里，永远不会被处理和返回响应
• 由于默认没有设置超时阈值，A服务会一直阻塞在这个调用上，直到收到匹配的响应——显然这种情况下永远不会发生

如何验证这个行为？ #

你可以登录RabbitMQ管理控制台查看对应的请求队列：当B未运行时，发送的消息会处于Ready状态堆积在队列中，没有被消费，这也能直观印证A服务一直等待的原因。

解决办法：给调用设置超时 #

要避免A服务无限阻塞，最直接的方式是设置调用超时时间，有两种实用方式：

1. 单次调用时指定超时 #

在调用convertSendAndReceive时，直接传入超时参数（单位：毫秒）：

// 示例：设置5秒超时
Object response = rabbitTemplate.convertSendAndReceive("exchangeName", "routingKey", request, 5000);
if (response == null) {
    // 处理超时逻辑，比如抛出异常、返回默认值等
    throw new RuntimeException("调用B服务超时，未获取到响应");
}

2. 全局配置统一超时 #

如果所有RPC调用都需要统一的超时规则，可以在配置RabbitTemplate时全局设置：

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    // 设置全局默认超时时间为5秒
    rabbitTemplate.setReplyTimeout(5000);
    return rabbitTemplate;
}

额外优化：设置消息过期时间 #

为了避免没有消费者时请求消息一直堆积在队列里，还可以给消息设置过期时间，确保未被消费的消息会被自动清理：

Object response = rabbitTemplate.convertSendAndReceive("exchangeName", "routingKey", request, message -> {
    // 设置消息5秒后过期
    message.getMessageProperties().setExpiration("5000");
    return message;
}, 5000);

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