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

前言

消息队列（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;
    }
}