Spring Cloud Stream集成测试中连接RabbitMQ失败问题咨询

我来帮你搞定这个问题——你大概率是被spring-cloud-stream-test-support的默认自动配置坑了：它会悄悄把消息binder替换成内存测试版，导致你的测试根本不会去连接真实的RabbitMQ。下面是一步步的解决方法：

1. 排除测试用Binder的自动配置 #

这是最关键的一步，直接在测试类的@SpringBootTest注解里排除测试用的binder配置类，让应用使用真实的RabbitMQ binder：

@RunWith(SpringRunner.class)
@SpringBootTest(
    webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
    exclude = TestSupportBinderAutoConfiguration.class
)
@EnableBinding(Source.class)
public class StreamIT {

    @Autowired
    private Source source;

    // 你的测试方法...
}

2. 配置真实RabbitMQ连接信息 #

在测试环境的配置文件（比如src/test/resources/application.yml）里，添加RabbitMQ的连接参数和Stream绑定配置：

spring:
  rabbitmq:
    host: localhost  # 替换成你的RabbitMQ服务器地址
    port: 5672
    username: guest  # 你的RabbitMQ账号
    password: guest  # 你的RabbitMQ密码
  cloud:
    stream:
      bindings:
        output:  # Source接口默认的output通道
          destination: test-exchange  # 指定要发送的交换机名称
          binder: rabbit  # 明确指定使用RabbitMQ作为binder

3. 验证消息是否成功发送到RabbitMQ #

你可以借助RabbitTemplate来消费消息，确认发送逻辑正常。如果没有提前创建队列和绑定关系，还可以在测试前后临时创建/清理资源：

@Autowired
private Source source;

@Autowired
private RabbitTemplate rabbitTemplate;

@Autowired
private AmqpAdmin amqpAdmin;

private static final String TEST_QUEUE = "test-queue";
private static final String TEST_EXCHANGE = "test-exchange";

@Before
public void setupRabbitResources() {
    // 创建临时队列
    Queue queue = new Queue(TEST_QUEUE, false);
    amqpAdmin.declareQueue(queue);
    // 绑定交换机与队列（用通配符路由键确保能收到消息）
    Binding binding = BindingBuilder.bind(queue)
            .to(new TopicExchange(TEST_EXCHANGE))
            .with("#");
    amqpAdmin.declareBinding(binding);
}

@Test
public void testMessageSending() throws InterruptedException {
    // 发送测试消息
    String testPayload = "Hello Real RabbitMQ!";
    source.output().send(MessageBuilder.withPayload(testPayload).build());

    // 异步发送需要短暂等待投递完成
    Thread.sleep(1000);

    // 从队列获取消息并验证内容
    Object receivedPayload = rabbitTemplate.receiveAndConvert(TEST_QUEUE);
    assertEquals(testPayload, receivedPayload);
}

@After
public void cleanUpRabbitResources() {
    // 清理测试产生的资源
    amqpAdmin.deleteQueue(TEST_QUEUE);
    amqpAdmin.deleteExchange(TEST_EXCHANGE);
}

4. 检查依赖配置 #

确保你的依赖中，RabbitMQ的Stream Starter是正常依赖，而测试支持包仅在test scope生效：
Maven示例：

<!-- 生产/集成测试用的RabbitMQ Binder -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

<!-- 仅测试场景使用的支持包，不要放到主依赖中 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-test-support</artifactId>
    <scope>test</scope>
</dependency>

调整完成后，你的集成测试就会真实连接RabbitMQ，而不是使用内存模拟的binder了。

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