我有一个与 JMS
相关的非常标准的设置 - Spring Boot
和 ActiveMQ
。它工作正常,直到我尝试进行简单的集成测试。经过一些调查后,我发现在消费了第一条 JMS 消息后,Spring 上下文和嵌入式代理都关闭了,无论在消费期间是否触发了另一个事件。我能够通过在测试设置中添加 useShutdownHook=false
连接选项来解决代理问题,即
spring.activemq.broker-url = vm://broker?async=false&broker.persistent=false&broker.useShutdownHook=false
我正在寻找的基本上是一种强制测试“保持 Activity 状态”直到所有 JMS 消息都被消耗的方法(在本例中它们只有两个)。我了解整个设置的异步性质,但在测试期间,获取这些正在生成和使用的消息的所有结果仍然很有帮助。
下面是我的设置,虽然它相当简单。
@EnableJms
public class ActiveMqConfig {
@Bean
public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
jmsTemplate.setMessageConverter(messageConverter);
return jmsTemplate;
}
@Bean
public MessageConverter messageConverter() {
MappingJackson2MessageConverter messageConverter = new MappingJackson2MessageConverter();
messageConverter.setTargetType(MessageType.TEXT);
messageConverter.setTypeIdPropertyName("_type");
return messageConverter;
}
}
然后我有一个消息驱动的 POJO 来监听给定的事件:
@JmsListener(destination = "events")
public void applicationSubmitted(MyType event) {
// do some work with the event here
jmsTemplate.convertAndSend("commands", mymessage);
}
还有一个:
@JmsListener(destination = "commands")
public void onCommand(TextMessage textMessage) {
}
我尝试过的一件事是在消息发送后添加延迟,即 sleep(200)
。然而,这是非常不可靠的,并且还会减慢测试速度,因为执行时间可能少于 50 毫秒。下面是测试本身。除非等待未被注释,否则我永远不会到达第二个事件监听器,因为应用程序上下文关闭,测试结束并且消息“被遗忘”。
@SpringBootTest
class MyEventIntegrationTest extends Specification {
@Autowired
JmsTemplate jmsTemplate
def "My event is successfully handled"() {
given:
def event = new MyEvent()
when:
jmsTemplate.convertAndSend("events", event)
// sleep(200)
then:
1 == 1
}
}
最佳答案
好吧,这是测试基于异步消息交换的系统时的标准问题。通常,它会在您跳过的测试部分中解决 - then
部分。
问题是,在您的测试中,您通常希望系统做一些有用的事情,例如在数据库中进行更改,向另一个系统发送 rest 调用,在另一个队列中发送消息等。已设置 - 那么我们可以假设测试已经通过。
该方法的伪代码如下:
for (i to MAX_RETRIES; i++) {
checkThatTheChangesInDBHasBeenMade();
checkThatTheRestCallHasBeenMade();
checkThatTheMessageIsPostedInAnotherQueue();
Thread.sleep(50ms);
}
这样,在最佳情况下,您的测试将在 50 毫秒内通过。在最坏的情况下,它将失败,这将花费 MAX_RETRIES * 50 毫秒的时间来执行测试。
此外,我应该提到有一个名为 awaitility 的好工具。它提供了很好的 API(顺便说一句,它支持 groovy DSL)来处理异步世界中的此类问题:
await().atMost(5, SECONDS).until(customerStatusIsUpdated());
关于java - 保持 spring 上下文 Activity ,直到 JMS 消息被消费,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49283280/