ｓｐｒｉｎｇｂｏｏｔ rabbitmq队列

Spring Boot 是一个基于 Spring 框架的快速开发应用程序的工具，它提供了很多基础设施的支持，包括对 RabbitMQ 消息队列的支持。

RabbitMQ 是一个开源的 AMQP（高级消息队列协议）实现，它可以用来实现高效、可靠的消息传递系统。Spring Boot 提供了对 RabbitMQ 的支持，可以轻松地在应用程序中集成 RabbitMQ，实现消息的发送和接收。

以下是基于 Spring Boot 的 RabbitMQ 队列的示例代码：

1. 添加 RabbitMQ 依赖

在项目的 pom.xml 文件中添加以下依赖：

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

2. 配置 RabbitMQ 连接信息

在 application.properties 文件中添加以下配置：

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

3. 创建消息发送者

在需要发送消息的地方，创建一个消息发送者类，示例代码如下：

@Component
public class MessageSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);
    }
}

这里使用了 RabbitTemplate 类来发送消息，其中 myExchange 表示交换机名称，myRoutingKey 表示路由键，message 表示要发送的消息。

4. 创建消息接收者

在需要接收消息的地方，创建一个消息接收者类，示例代码如下：

@Component
public class MessageReceiver {

    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

这里使用了 @RabbitListener 注解来监听队列，其中 myQueue 表示队列名称，receiveMessage 方法表示接收到消息后要执行的操作。

5. 测试发送和接收消息

在测试类中，创建一个 MessageSender 对象，并调用 sendMessage 方法发送消息，示例代码如下：

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqApplicationTests {

    @Autowired
    private MessageSender messageSender;

    @Test
    public void testSendMessage() {
        messageSender.sendMessage("Hello, RabbitMQ!");
    }
}

这里使用了 Spring Boot 的测试框架，调用 sendMessage 方法发送消息。

在控制台中可以看到接收到的消息，示例代码如下：

Received message: Hello, RabbitMQ!

以上就是基于 Spring Boot 的 RabbitMQ 队列的示例代码。