2

Micronaut 1.0.0 刚刚发布 (2018-10-25)，在其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 消费和发布消息呢？

4

1 回答 1

5

目前对 RabbitMQ 的支持非常少。为您提供的是使用 micronaut 环境配置 ConnectionFactory 的能力。

“将根据 rabbitmq 配置键下提供的配置值提供 RabbitMQ 连接工厂 bean。ConnectionFactory 上的所有 setter 方法都可以配置。”

然后由您根据 rabbitmq 文档https://www.rabbitmq.com/api-guide.html使用连接工厂

更好地支持 RabbitMQ（类似于 Kafka）是 Micronaut 1.1.0 的高优先级。

于 2018-10-30T16:40:33.213 回答