SpringBoot整合RabbitMQ并实现消息发送与接收教程

前言

消息队列（Message Queue）是一种高效的异步通信机制，它在分布式应用系统中扮演着重要的角色。简单来说，消息队列将消息发送者和消息接收者解耦，消息发送者只需要将消息发送给队列，而不需要知道消息是如何被消费者处理的，同时，消息接收者也只需要从队列中订阅自己需要的消息，而不需要知道这些消息是由哪个发送者发送的。消息队列能够提高应用程序的可扩展性、可靠性以及灵活性，并且能够缓解高并发情况下的压力。

RabbitMQ 是一个开源的 AMQP 消息代理软件，它基于 Erlang/OTP 平台，具有高可靠性、高可用性、高可扩展性等特点。RabbitMQ 提供了丰富的功能和特性，包括多种消息传递模式、多种交换机类型、消息持久化、集群部署、负载均衡、事务支持、各种编程语言客户端等。同时，RabbitMQ 也提供了丰富的插件，可以与其他系统集成，如 MongoDB、MySQL、ElasticSearch 等。由于其可靠性和高可用性，RabbitMQ 被广泛应用于各种企业级的分布式应用系统中，如电商、金融、物流、游戏等。

下面我们就根据SpringBoot框架整合RabbitMQ,实现一个简单的传输案例带大家理解消息队列的执行过程。

一、导入依赖

首先要在pom.xml文件中将依赖导入，代码如下：

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

二、配置连接MQ信息

RabbitMQ 默认的端口号是 5672。这个端口用于 AMQP（高级消息队列协议）的常规连接。包括用户名、密码也是默认的。

配置如下代码所示：

spring:
#  rabbitmq消息队列配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

三、编写代码

3.1 生产者

• @Component 注解标记了该类为一个 Spring 组件，将由 Spring 进行管理和依赖注入。
• AmqpTemplate 是 RabbitMQ 提供的一个高级抽象接口，用于简化与 RabbitMQ 进行交互的操作。通过 @Autowired 注解进行依赖注入，将 AmqpTemplate 实例注入到 amqpTemplate 字段中。
• sendMessage 方法用于发送消息到指定的队列。它接受两个参数：queueName 是目标队列的名称，message 是要发送的消息内容。
• 在方法内部，首先打印出要发送的消息和目标队列的名称。
• 接下来，使用 amqpTemplate.convertAndSend(queueName, message) 方法将消息发送到指定的队列。convertAndSend 方法会自动将消息进行序列化，并发送给 RabbitMQ。
• 最后，打印出消息发送成功的提示信息。

通过调用 sendMessage 方法，可以在其他组件中发送消息到指定的队列。这个 MessageSender 类使得与 RabbitMQ 进行消息的发送变得更加简单和方便。

具体代码如下：

@Component
public class MessageSender {
    @Autowired
    private AmqpTemplate amqpTemplate;

    //This method sends a message to a queue given a queue name and message
    public void sendMessage(String queueName, String message) {
        System.out.println("发送消息:" + message + "=====队列名称：" + queueName);
        amqpTemplate.convertAndSend(queueName, message);
        System.out.println("消息发送成功：" + message);
    }
}

3.2 消费者

• @Component 注解标记了该类为一个 Spring 组件，将由 Spring 进行管理和依赖注入。
• @RabbitListener(queues = “my-queue”) 注解表示该方法是一个 RabbitMQ 消息监听器，用于监听名为 “my-queue” 的队列。当有消息到达该队列时，该方法会被自动调用。
• receiveMessage 方法定义了接收消息的逻辑。它接受一个 String 类型的参数 message，代表接收到的消息内容。
• 在方法内部，打印出接收到的消息。

通过使用 @RabbitListener 注解标记方法，并指定队列名称，你可以在应用程序中创建多个这样的消息接收器，以实现并发处理不同队列中的消息。当有消息到达 “my-queue” 队列时，MessageReceiver 组件会自动启动，receiveMessage 方法会被调用并处理接收到的消息。这样，你可以方便地编写消息处理逻辑，根据实际需求进行相应的业务操作。

具体代码如下：

@Component
public class MessageReceiver {
    @RabbitListener(queues = "my-queue")
    public void receiveMessage(String message) {
        System.out.println("接收到消息：" + message);
    }
}

3.3 编写访问接口

编写Controller,这里涉及到的知识点就是以前学习过的内容，只是设置/messages/send接口，调用生产者的sendMessage方法去实现消息的发送，看消息是否能够自动接收。

具体代码如下：

/**
 * 调用发送消息
 */
@RestController
@RequestMapping("/messages")
public class MessageController {
    @Autowired
    private MessageSender messageSender;

    @GetMapping("/send")
    public String sendMessage() {
        System.out.println("=======调用接口=======");
        String message = "Hello, RabbitMQ! 心态还需努力呀~";
        System.out.println("====开始发送消息====");
        messageSender.sendMessage("my-queue", message);
        return "消息已发送：" + message;
    }
}

四、启动RabbitMQ

4.1 下载RabbitMQ/Erlang

代码的编写已经完成，但别忘记需要启动RabbitMQ服务。如果没有下载和安装Erlang、RabbitMQ的请先到官网安装启动。

点击下方即可进行下载。注：下载前先确定要下载的两个版本是否兼容，不兼容启动会报错！

• Erlang
• RabbitMQ

4.2 打开RabbitMQ

下载完成后启动rabbitmq，然后在浏览器中访问localhost:15672接口进行登录，默认用户名、密码都是guest，登录后在下图所示的“Add a new queue”进行创建队列。

这里的队列名需和在生产者发送消息到哪个队列一致，消费者取消息就从这个队列里取

五、访问接口查看消息

这里我使用Postman进行调用接口进行测试，结果如图所示：

可以看到消息已经发送成功，我们看下idea中的打印日志：

可以看到消费者已接收到生产者在my-queue队列发送的消息。

总结

对于简单的消息发送和接收就写完了，消费者只需监听这个消息队列就可获取消息，而生产者也只需要将发送的消息内容发送给某个队列即可。

该案例重在理解过程，了解生产者，消费者如何实现的消息传送。就是一个中间件，在消息发送的过程中起到一个中间站（队列）的作用。

至于为什么能够有高效、稳定等特性，感兴趣的可以自己去研究研究。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

最新评论