spring rabbitmq

Spring RabbitMQ 是一个基于 Spring 框架的 RabbitMQ 客户端库，用于简化在 Java 应用中使用 RabbitMQ 的开发。它提供了一种简单而强大的方式来集成 RabbitMQ 到 Spring 应用中，使得消息的发送和接收变得更加方便和可靠。

你可以通过在 Maven 或 Gradle 项目中添加相应的依赖来引入 Spring RabbitMQ。然后，你可以使用 Spring 提供的注解来声明消息发送者和消息消费者，以及配置 RabbitMQ 的连接和交换机等参数。

以下是一个简单的示例：

1. 首先，在你的项目中添加 Spring RabbitMQ 的依赖：

<!-- Maven -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

<!-- Gradle -->
implementation 'org.springframework.boot:spring-boot-starter-amqp'

2. 创建一个消息发送者：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("exchange", "routingKey", message);
        System.out.println("Message sent: " + message);
    }
}

3. 创建一个消息消费者：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

    @RabbitListener(queues = "queue")
    public void handleMessage(String message) {
        System.out.println("Message received: " + message);
    }
}

4. 配置 RabbitMQ 连接和交换机等参数：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

    # 定义交换机和队列等配置
    template:
      exchange: myExchange
      routing-key: myRoutingKey
      queue: myQueue

以上是一个简单的示例，你可以根据实际需求来配置更多的参数和处理逻辑。使用 Spring RabbitMQ，你可以方便地在 Spring 应用中实现消息的发送和接收，并且通过配置文件进行灵活的配置。