如何使用 Micronaut 和 RabbitMQ 消费和发布消息？答案

【问题标题】：How consume and publish messages with Micronaut and RabbitMQ?如何使用 Micronaut 和 RabbitMQ 消费和发布消息？
【发布时间】：2018-10-27 08:02:57
【问题描述】：

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 消费和发布消息？

【问题讨论】：

标签： java rabbitmq micronaut

【解决方案1】：

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

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

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

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

【讨论】：