rabbitmq - Micronaut 和 RabbitMQ
问题描述
我正在开发一个使用 Micronaut 并且需要使用 RabbitMQ 队列中的消息的应用程序。问题是队列可以提供很多消息,所以我想要一个参数化的消费者实例数。
例如以下代码自动生成一个消费者实例:
@RabbitListener
public class TestConsumer {
@Queue("TestQueue")
public void handleMessage(String message) {
// some treatment
}
}
有没有办法告诉 micronaut 实例化多个实例?
解决方案
如果我理解正确,您想配置多少线程消耗队列中的消息。您可以通过您在 application.yml 中配置的执行程序来执行此操作
请参阅以下来自micronaut-rabbitmq 文档的示例。
@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
推荐阅读
- python - 如何在 Python 中将 dict 元素值作为列表
- r - 使用 y 轴值在 ggplot2 中创建辅助 x 轴
- c# - 通过脚本更改导入的图像设置
- c# - 在 IIS 上托管时拆分字符串会引发 InvalidOperationException
- rust - 如何使用 ioctl + nix 宏来获取可变大小的缓冲区
- python - 查找列表中缺失的元素
- ruby-on-rails-4 - 应用程序未加载:“本地主机没有发送任何数据。ERR_EMPTY_RESPONSE”
- arduino - 如何防止其他电话/手机号码向 Arduino 发送 SMS 命令?
- python - 在 python 中使用参数从不同的文件夹运行脚本(如在 cmd 中)
- java - 仅当用户输入关键字时,如何使计数器加 1