Spring boot集成RabbitMQ的示例代码

下面是Spring boot集成RabbitMQ的示例代码的完整攻略，包含两个示例说明。

简介

RabbitMQ是一个开源的消息队列系统，它支持多种消息协议，包括AMQP、STOMP、MQTT等。在Spring Boot中，我们可以使用Spring AMQP来实现与RabbitMQ的交互，从而实现消息队列功能。

本文将介绍如何在Spring Boot中集成RabbitMQ，并提供两个示例说明。

示例一：发送和接收消息

步骤1：添加依赖

在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：定义消息发送者

在Java代码中，我们需要定义一个消息发送者，用于发送消息到RabbitMQ。代码如下：

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("my_exchange", "my_routing_key", message);
    }
}

在上面的代码中，我们使用AmqpTemplate来发送消息。我们使用rabbitTemplate.convertAndSend方法发送一条消息到交换机。我们指定了交换机名称为my_exchange，路由键为my_routing_key，消息内容为message。

步骤4：定义消息接收者

在Java代码中，我们需要定义一个消息接收者，用于从RabbitMQ接收消息。代码如下：

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

@Component
public class MessageReceiver {

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

在上面的代码中，我们使用@RabbitListener注解来监听队列my_queue。当有消息到达队列时，receiveMessage方法将被调用，并打印消息内容。

步骤5：测试

现在，我们可以运行发送者和接收者代码，并观察控制台输出。在测试时，我们先运行接收者代码，然后再运行发送者代码。在消息到达接收者时，我们可以在控制台中看到消息。

示例二：使用DirectExchange

步骤1：添加依赖

与示例一相同。

步骤2：配置RabbitMQ连接

与示例一相同。

步骤3：定义消息发送者

在Java代码中，我们需要定义一个消息发送者，用于发送消息到RabbitMQ。代码如下：

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, String routingKey) {
        rabbitTemplate.convertAndSend("my_direct_exchange", routingKey, message);
    }
}

在上面的代码中，我们使用AmqpTemplate来发送消息。我们使用rabbitTemplate.convertAndSend方法发送一条消息到交换机。我们指定了交换机名称为my_direct_exchange，路由键为routingKey，消息内容为message。

步骤4：定义消息接收者

在Java代码中，我们需要定义一个消息接收者，用于从RabbitMQ接收消息。代码如下：

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

@Component
public class MessageReceiver {

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

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

在上面的代码中，我们使用@RabbitListener注解来监听队列my_queue和my_another_queue。当有消息到达队列时，对应的方法将被调用，并打印消息内容。

步骤5：测试

现在，我们可以运行发送者和接收者代码，并观察控制台输出。在测试时，我们可以先运行接收者代码，然后再运行发送者代码。在消息到达接收者时，我们可以在控制台中看到消息。