如何让无生产者的Spring Cloud Stream自动创建RabbitMQ队列与绑定？

我来帮你搞定这个问题。首先咱们先理清楚Spring Cloud Stream Rabbit Binder的自动创建逻辑，然后一步步排查解决：

先明确默认行为 #

在Spring Cloud Stream Rabbit Binder中，只要你配置了消费者绑定（input）并且指定了group，默认情况下应该自动创建对应的资源：

• 一个topic类型的交换器，名称就是你配置的destination（比如dest-group1）
• 一个持久化队列，名称格式为{destination}.{group}（比如dest-group1.group1）
• 队列与交换器之间的绑定，使用你指定的bindingRoutingKey（比如key1.#）

如果你的应用启动后没有自动创建这些资源，大概率是配置或权限的问题，咱们一步步排查：

1. 显式开启自动声明配置 #

默认情况下，spring.cloud.stream.rabbit.bindings.<inputName>.consumer.auto-declare是true，但如果全局配置或者某个绑定被隐式设置为false，就会阻止自动创建。你可以显式在每个消费者绑定中添加这个配置，确保自动声明开启：

spring:
  cloud:
    stream:
      bindings:
        input1:
          bindingRoutingKey: key1.#
          binder: rabbit
          group: group1
          destination: dest-group1
          transacted: true
          consumer:
            auto-declare: true # 显式开启自动声明，避免隐式配置干扰
        input2:
          bindingRoutingKey: key2.#
          binder: rabbit
          group: group2
          destination: dest-group2
          transacted: true
          consumer:
            auto-declare: true

2. 检查RabbitMQ用户权限 #

如果配置没问题，那就要检查连接RabbitMQ的账号权限了。你的应用账号需要拥有configure权限才能创建队列、交换器和绑定。你可以登录RabbitMQ管理后台，在「Admin」->「Users」页面查看对应账号的权限，确保对当前使用的虚拟主机（默认是/）有configure权限。

3. 考虑版本兼容性问题 #

你使用的Spring Cloud Finchley.RC1是候选发布版本，可能存在一些小bug。如果上面的配置都没解决问题，可以尝试升级到Finchley正式版（比如Finchley.RELEASE），它和Spring Boot 2.0.x完全兼容，能避免候选版本的已知问题。

4. 代码层面手动声明（备选方案） #

如果配置方式始终不生效，你可以通过代码使用RabbitAdmin手动声明所需资源，这样能确保启动时创建：

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQCustomConfig {

    // 为input1声明交换器、队列和绑定
    @Bean
    public TopicExchange destGroup1Exchange() {
        return new TopicExchange("dest-group1");
    }

    @Bean
    public Queue input1Queue() {
        return new Queue("dest-group1.group1", true); // 创建持久化队列
    }

    @Bean
    public Binding input1Binding(Queue input1Queue, TopicExchange destGroup1Exchange) {
        return BindingBuilder.bind(input1Queue)
                .to(destGroup1Exchange)
                .with("key1.#");
    }

    // 为input2声明交换器、队列和绑定
    @Bean
    public TopicExchange destGroup2Exchange() {
        return new TopicExchange("dest-group2");
    }

    @Bean
    public Queue input2Queue() {
        return new Queue("dest-group2.group2", true);
    }

    @Bean
    public Binding input2Binding(Queue input2Queue, TopicExchange destGroup2Exchange) {
        return BindingBuilder.bind(input2Queue)
                .to(destGroup2Exchange)
                .with("key2.#");
    }

    @Bean
    public RabbitAdmin rabbitAdmin(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) {
        return new RabbitAdmin(connectionFactory);
    }
}

按照上面的步骤排查，应该就能解决自动创建队列和绑定的问题了。

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