RabbitMQ 集成测试和线程

Question

我通过实现 MessageListener 接口并设置 SimpleMessageListenerContainer 编写了一个 RabbitMQ 消费者。当我手动测试它时它运行良好。现在我想编写一个集成测试：

1. 创建消息
2. 将消息推送到我的 RabbitMQ 服务器
3. 等待消息被我的 MessageListener 实现使用
4. 测试完成后会做出一些断言

但是，由于我的 MessageListener 在单独的线程中运行，这使得单元测试变得困难。在我的测试中使用 Thread.sleep 来等待 MessageListener 是不可靠的，我需要某种阻塞方法。

设置响应队列并使用rabbitTemplate.convertSendAndReceive 是我唯一的选择吗？我想避免设置响应队列，因为它们不会在实际系统中使用。

有没有办法只使用rabbitTemplate.convertAndSend 来完成此操作，然后以某种方式等待我的 MessageListener 接收消息并处理它？理想情况下，我会想象这样的事情：

rabbitTemplate.convertAndSend("routing.key", testObject);
waitForListner() // Somehow wait for my MessageListener consume the message
assertTrue(...)
assertTrue(...)

我知道我可以直接将消息传递给我的 MessageListener 而不连接到 RabbitMQ，但如果可以的话，我希望测试整个系统。如果无法以相当干净的方式实现我的目标，我计划退回到该解决方案。

Answer 1

有几种方法，最简单的方法是包装你的监听器并传入一个CountDownLatch，它由监听器和主测试线程使用倒计时

assertTrue(latch.await(TimeUnit.SECONDS));

您还可以将收到的实际消息传回，以便验证它是否符合预期。

另见integration test cases in the framework itself。