如何在Micronaut中用Spock测试RabbitMQ消费者时Mock服务

核心原因是Micronaut的RabbitMQ消费者由框架内部容器管理，启动时会独立创建消费者实例并注入依赖。测试中手动Mock的SimpleService没有替换掉框架上下文里的原始实例，导致消息触发消费时，消费者使用的还是未Mock的服务；而直接调用receive方法时，用的是测试类中注入的消费者实例（已绑定Mock依赖），所以能正常触发Mock逻辑。

1. 用@MockBean替换应用上下文的Bean实例 #

在测试类中通过Micronaut Test提供的@MockBean注解，将SimpleService替换为Spock Mock，确保框架上下文内的所有消费者都使用这个Mock实例：

import io.micronaut.test.extensions.spock.annotation.MicronautTest
import spock.lang.Specification
import io.micronaut.context.annotation.MockBean
import jakarta.inject.Inject
import java.util.concurrent.TimeUnit

@MicronautTest
class RabbitMqConsumerSpec extends Specification {

    @Inject
    SimpleService simpleService

    @Inject
    RabbitMqProducer producer

    @MockBean(SimpleService)
    SimpleService mockSimpleService() {
        Mock(SimpleService)
    }

    def "test message triggers mocked service"() {
        given:
        def latch = new CountDownLatch(1)
        simpleService.process(_) >> { latch.countDown() }

        when:
        producer.send("test message")
        def consumed = latch.await(5, TimeUnit.SECONDS)

        then:
        consumed
        1 * simpleService.process("test message")
    }
}

2. 处理异步消费的时序问题 #

RabbitMQ消费是异步执行的，直接断言会因为消费线程未完成导致失败。使用CountDownLatch可以可靠等待消费完成，避免时序问题。

3. 确保消费者依赖注入方式正确 #

消费者类必须通过构造注入或Micronaut支持的字段注入方式获取SimpleService，禁止手动创建实例：

@RabbitListener
public class MessageConsumer {

    private final SimpleService simpleService;

    public MessageConsumer(SimpleService simpleService) {
        this.simpleService = simpleService;
    }

    @Queue("test-queue")
    public void receive(String message) {
        simpleService.process(message);
    }
}

• 测试中必须使用框架上下文注入的消费者实例，不能手动创建，否则无法绑定Mock依赖。
• @MockBean会全局替换应用上下文中的对应Bean，确保所有组件（包括RabbitMQ消费者）都能拿到Mock实例。
• 异步场景下必须等待消费完成后再断言，避免因线程执行时序导致的断言失败。

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