quarkus集成rabbitmq

在Quarkus中集成RabbitMQ可以通过使用Quarkus提供的RabbitMQ扩展来实现。下面是一个简单的示例代码，演示了如何在Quarkus中集成RabbitMQ并发送和接收消息：

首先，确保你已经安装了Quarkus开发环境。然后，在你的Quarkus项目中添加RabbitMQ扩展依赖：

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-rabbitmq</artifactId>
</dependency>

接下来，在你的应用程序中创建一个RabbitMQ生产者和一个RabbitMQ消费者。这里是一个简单的示例：

import io.quarkus.rabbitmq.RabbitMQClient;
import io.quarkus.scheduler.Scheduled;
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;

@ApplicationScoped
public class RabbitMQProducer {

    @Inject
    RabbitMQClient rabbitMQClient;

    @Scheduled(every = "10s")
    public void sendMessage() {
        rabbitMQClient.send("my-queue", "Hello from Quarkus!");
    }
}

import io.quarkus.rabbitmq.Consume;
import javax.enterprise.context.ApplicationScoped;

@ApplicationScoped
public class RabbitMQConsumer {

    @Consume("my-queue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的示例中，RabbitMQProducer类使用@Scheduled注解定时发送消息到名为"my-queue"的队列。RabbitMQConsumer类使用@Consume注解监听"my-queue"队列，并在接收到消息时进行处理。

最后，你可以运行你的Quarkus应用程序，并观察控制台输出来验证消息的发送和接收。

请注意，你需要在application.properties文件中配置RabbitMQ连接信息，例如：

quarkus.rabbitmq.host=localhost
quarkus.rabbitmq.port=5672
quarkus.rabbitmq.username=guest
quarkus.rabbitmq.password=guest