RabbitMQ集成测试和线程

Question

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

1. 创建消息
2. 将消息推送到我的RabbitMQ服务器
3. 等待消息被我的MessageListener实现消耗
4. 测试做了一些断言，一旦一切都完成了

然而，由于我的MessageListener是在一个单独的线程中运行的，这使得单元测试变得困难。用一根线。在测试中睡眠等待MessageListener是不可靠的，我需要某种阻塞方法。

正在设置响应队列并使用rabbitmplate。ConvertSendReceive我唯一的选择？我希望避免设置响应队列，因为它们不会在实际系统中使用。

有没有办法只用rabbitmplate就可以实现这一点。convertAndSend然后以某种方式等待我的MessageListener接收并处理消息？理想情况下，我会这样设想：

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

我知道我可以直接将消息传递给我的MessageListener，而根本不需要连接到RabbitMQ，但如果可能的话，我希望测试整个系统。如果没有办法以合理的方式实现我的目标，我打算回到那个解决方案上来。

Answer 1

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

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

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

另请参见框架本身中的集成测试用例。