如何在@RabbitListener中通过ConfigurationProperties引用队列名

我完全懂这种硬编码队列/交换机名称的痛苦——一旦配置变更，漏改一处就会导致消息监听失效，排查起来还麻烦。刚好我在项目里解决过一模一样的问题，核心就是利用**Spring表达式语言（SpEL）**直接引用你的ConfigurationProperties Bean，彻底告别硬编码。

步骤1：确保你的ConfigurationProperties Bean正确注册 #

首先，先确认你的配置属性类已经被Spring容器管理，比如加上@Component或者通过@ConfigurationPropertiesScan扫描：

@ConfigurationProperties(prefix = "rabbitmq")
@Component // 或者用@ConfigurationPropertiesScan扫描该类所在包
public class RabbitMqProperties {
    // 示例属性：队列名、交换机名、路由键
    private String orderQueue;
    private String orderExchange;
    private String orderRoutingKey;

    // 生成对应的getter方法（Setter可选，Spring Boot会自动绑定配置）
    public String getOrderQueue() {
        return orderQueue;
    }

    public String getOrderExchange() {
        return orderExchange;
    }

    public String getOrderRoutingKey() {
        return orderRoutingKey;
    }
}

步骤2：交换机/队列/绑定的配置（你已经在做的部分） #

这部分你已经在用getter方法获取属性了，这里再贴个示例确认下：

@Configuration
public class RabbitMqConfig {
    private final RabbitMqProperties rabbitProps;

    // 构造注入配置属性Bean
    public RabbitMqConfig(RabbitMqProperties rabbitProps) {
        this.rabbitProps = rabbitProps;
    }

    @Bean
    public Queue orderQueue() {
        return QueueBuilder.durable(rabbitProps.getOrderQueue()).build();
    }

    @Bean
    public DirectExchange orderExchange() {
        return ExchangeBuilder.directExchange(rabbitProps.getOrderExchange()).build();
    }

    @Bean
    public Binding orderBinding() {
        return BindingBuilder.bind(orderQueue())
                .to(orderExchange())
                .with(rabbitProps.getOrderRoutingKey());
    }
}

步骤3：用SpEL给@RabbitListener动态注入属性 #

关键来了！@RabbitListener的queues属性支持SpEL表达式，你可以直接引用容器中的RabbitMqProperties Bean来获取队列名：

@Component
public class OrderMessageListener {

    // 用SpEL引用配置Bean的属性，彻底替代硬编码
    @RabbitListener(queues = "#{rabbitMqProperties.orderQueue}")
    public void handleOrderMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws IOException {
        try {
            // 处理消息逻辑
            System.out.println("收到订单消息：" + message);
            channel.basicAck(deliveryTag, false);
        } catch (Exception e) {
            channel.basicNack(deliveryTag, false, true);
        }
    }
}

这里的#{rabbitMqProperties.orderQueue}中：

• rabbitMqProperties是你的配置Bean在Spring容器中的默认名称（类名首字母小写）
• orderQueue直接对应配置类中的属性名（Spring会自动调用对应的getter方法）

额外优化：给配置Bean指定明确名称 #

如果你担心默认的Bean名称容易写错，可以给RabbitMqProperties指定一个更简洁的名称：

@ConfigurationProperties(prefix = "rabbitmq")
@Component("rabbitProps") // 指定Bean名称
public class RabbitMqProperties {
    // ... 属性和getter
}

然后在@RabbitListener中就可以用：

@RabbitListener(queues = "#{rabbitProps.orderQueue}")

注意事项 #

• 确保你的ConfigurationProperties Bean已经被Spring正确加载：如果没有加@Component，记得在启动类上加上@ConfigurationPropertiesScan并指定配置类所在的包
• SpEL表达式中引用的属性名要和配置类中的属性完全一致（包括大小写）

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