我是 Spring Boot 的新手,正在尝试它。目前我已经构建了一些应用程序,我希望能够通过队列相互通信。
我目前有一个侦听器对象,可以从特定队列接收消息。
@Configuration
public class Listener {
final static String queueName = "myqueue";
@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames(queueName);
container.setMessageListener(listenerAdapter);
return container;
}
@Bean
Receiver receiver() {
return new Receiver();
}
@Bean
MessageListenerAdapter listenerAdapter(Receiver receiver) {
return new MessageListenerAdapter(receiver, "receiveMessage");
}
}
这有效。但是,现在我希望能够收听另一个队列。所以我想我应该复制上面的对象并更改队列名称。不幸的是,这不起作用,因为 Spring boot 只为其中之一创建连接。
关于如何让我的 Spring Boot 应用程序监听多个队列有什么想法吗?
好的,我想出了如何让它监听多个队列。认为与我的其他解决方案相比可能存在一些缺点,主要是如果列出的队列不存在,它就不起作用。
我最终使用了一种完全不同的方法,使用@RabbitListener
@Component
public class EventListener {
private static Logger LOG = LoggerFactory.getLogger(EventListener.class);
private CountDownLatch latch = new CountDownLatch(1);
@RabbitListener(queues = "myqueue")
public void processPaymentMessage(Object message) {
LOG.info("Message is of type: " + message.getClass().getName());
if(!(message instanceof byte[])) message = ((Message) message).getBody();
String content = new String((byte[])message, StandardCharsets.UTF_8);
LOG.info("Received on myqueue: " + content);
latch.countDown();
}
@RabbitListener(queues = "myotherqueue")
public void processOrderMessage(Object message) {
LOG.info("Message is of type: " + message.getClass().getName());
if(!(message instanceof byte[])) message = ((Message) message).getBody();
String content = new String((byte[])message, StandardCharsets.UTF_8);
LOG.info("Received on myotherqueue: " + content);
latch.countDown();
}
}
对 byte[] 的整个检查都在那里,因为从命令行发送的消息看起来就像这样。否则它是 org.springframework.amqp.core.Message。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)