如何解决Micronaut 和 RabbitMQ
我正在开发一个使用 Micronaut 并需要使用来自 RabbitMQ 队列的消息的应用程序。问题是队列可以提供很多消息,所以我想要一个参数化数量的消费者实例。
@RabbitListener
public class TestConsumer {
@Queue("TestQueue")
public void handleMessage(String message) {
// some treatment
}
}
有没有办法告诉 micronaut 实例化多个实例?
解决方法
如果我理解正确,您想配置多少线程使用队列中的消息。您可以通过在 application.yml 中配置的执行程序来执行此操作
请参阅以下来自 micronaut-rabbitmq docu 的示例。
@RabbitListener
public class ProductListener {
List<String> messageLengths = Collections.synchronizedList(new ArrayList<>());
@Queue(value = "product",executor = "product-listener")
public void receive(byte[] data) {
messageLengths.add(new String(data));
System.out.println("Java received " + data.length + " bytes from RabbitMQ");
}
}
使用 application.yml
micronaut:
executors:
product-listener:
type: fixed
nThreads: 25
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。