Micronaut 1.0.0 刚刚发布(2018-10-25),其 documentation for RabbitMQ它似乎没有说明如何实际消费或发布消息。它只是说您可以使用以下方法创建一个支持 RabbitMQ 的项目:
mn create-app my-app --features rabbitmq
但是一旦完成,生成的唯一感兴趣的是 Application
类:
import io.micronaut.runtime.Micronaut;
public class Application {
public static void main(String[] args) {
Micronaut.run(Application.class);
}
}
和一些 yaml
配置:
---
micronaut:
application:
name: my-app
---
rabbitmq:
uri: amqp://user:pass@host:10000/vhost
requestedFrameMax: 10
requestedChannelMax: 10
connectionTimeout: 5000
但是我怎样才能真正开始使用 Micronaut 通过 RabbitMQ 消费和发布消息呢?
最佳答案
目前 RabbitMQ 支持非常少。为您提供的是使用 micronaut 环境配置 ConnectionFactory 的能力。
“将根据rabbitmq配置键下提供的配置值提供RabbitMQ连接工厂bean。ConnectionFactory上的所有setter方法都可以配置。”
然后您可以根据rabbitmq文档https://www.rabbitmq.com/api-guide.html使用连接工厂。
更好地支持 RabbitMQ(类似于 Kafka)是 Micronaut 1.1.0 的首要任务。
关于java - 如何使用 Micronaut 和 RabbitMQ 消费和发布消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53019908/