springboot rabbitmq使用

### 如何在 Spring Boot 中集成和使用 RabbitMQ 进行消息传递

#### 安装和配置 RabbitMQ

为了使 Spring Boot 应用程序能够与 RabbitMQ 协同工作，需先安装并启动 RabbitMQ 服务。这一步骤通常涉及下载 RabbitMQ 并按照官方文档完成其设置过程[^1]。

#### 添加依赖项到 `pom.xml`

为了让 Spring Boot 支持 RabbitMQ 功能，在项目的 Maven 构建文件 (`pom.xml`) 中加入如下依赖：

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

此操作使得开发者可以利用 Spring AMQP 抽象层来简化对不同消息代理的支持，而无需关心底层协议细节[^2]。

#### 配置 RabbitMQ 参数

接着定义连接至 RabbitMQ 所必需的各项参数，一般是在 application.properties 或者 application.yml 文件内指定这些属性值。例如：

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

上述配置指定了主机地址、端口号以及认证凭证等基本信息，确保应用程序能成功建立与 RabbitMQ Server 的会话链接。

#### 创建生产者发送消息

编写一个简单的 Java 类作为消息生产者，负责向特定队列推送数据包。下面是一个基本的例子展示怎样封装一条字符串形式的消息并通过默认交换器路由给名为 "hello" 的队列：

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;

@Service
public class Producer {

    private final AmqpTemplate amqpTemplate;

    public Producer(AutoWired AmqpTemplate amqpTemplate){
        this.amqpTemplate = amqpTemplate;
    }

    @Bean
    Queue queue() {
        return new Queue("hello");
    }
    
    public void sendMessage(String message) {
        System.out.println("[x] Sent '" + message + "'");
        amqpTemplate.convertAndSend("hello", message);
    }
}

这段代码展示了如何声明一个新的队列实例，并通过调用 `convertAndSend` 方法把待传输的内容打包成二进制流注入目标队列中去[^3]。

#### 实现消费者接收消息

最后一步就是设计监听器类等待来自某个具体队列的通知事件发生时触发回调函数执行业务处理流程。这里给出了一种基于注解的方式实现自动化的消费行为模式：

package cn.juwatech.messaging;

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

@Component
public class Consumer {

    @RabbitListener(queues = {"hello"})
    public void listen(String message) {
        System.out.println("[x] Received '" + message + "'");
        // Add your processing logic here.
    }
}

每当有新条目进入 “hello” 队列之后就会激活这里的 `listen()` 函数进而打印接收到的数据内容出来供调试查看之用。