Spring Boot整合RabbitMQ入门指南（适合初学者）

RabbitMQ是一个开源的消息代理和队列服务器，它实现了高度可靠的消息传递机制，被广泛应用于分布式系统中的异步通信和解耦场景

weixin_39439156

1088人浏览 · 2023-12-04 22:18:23

weixin_39439156 · 2023-12-04 22:18:23 发布

本文适合没有接触过RabbitMq的同学，通过一个简单的demo体验一下消息队列，想要更多的了解MQ还是需要了解MQ更多的一些架构或者概念。

简述：
RabbitMQ是一个开源的消息代理和队列服务器，它实现了高度可靠的消息传递机制，被广泛应用于分布式系统中的异步通信和解耦场景。而Spring Boot则是一个简化了Spring应用开发的框架，它提供了丰富的开箱即用的功能和自动配置，使得我们可以更快速地构建和部署应用程序。

本文将引导你如何使用Spring Boot来整合RabbitMQ，并通过一个简单的示例来演示基本的消息生产和消费过程。

步骤1：配置RabbitMQ连接

首先，我们需要在Spring Boot应用的配置文件中配置RabbitMQ的连接信息。打开application.properties文件（或者application.yml文件），添加以下配置：

spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=your-rabbitmq-port
spring.rabbitmq.username=your-rabbitmq-username
spring.rabbitmq.password=your-rabbitmq-password

请将your-rabbitmq-host，your-rabbitmq-port，your-rabbitmq-username和your-rabbitmq-password替换为你实际的RabbitMQ连接信息。

步骤2：定义消息生产者

接下来，我们需要创建一个消息生产者来发送消息到RabbitMQ队列。创建一个Java类，命名为MessageProducer，并添加以下代码：

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Autowired
    private Queue queue;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(queue.getName(), message);
        System.out.println("Message sent: " + message);
    }
}

在上述代码中，我们使用了RabbitTemplate来发送消息，并通过Queue注入了一个队列实例。sendMessage方法用于发送消息到队列。

步骤3：定义消息消费者

然后，我们需要创建一个消息消费者来接收并处理RabbitMQ队列中的消息。创建一个Java类，命名为MessageConsumer，并添加以下代码：

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

@Component
public class MessageConsumer {

    @RabbitListener(queues = "${queue.name}")
    public void receiveMessage(String message) {
        System.out.println("Message received: " + message);
        // 处理消息逻辑
    }
}

在上述代码中，我们使用了@RabbitListener注解来标记该方法是一个消息监听器，它会自动监听指定的队列，并在有消息到达时调用receiveMessage方法处理消息。

步骤4：创建RabbitMQ队列

接下来，我们需要在应用启动时创建RabbitMQ队列。在Spring Boot应用的启动类中，添加以下代码：

import org.springframework.amqp.core.Queue;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class RabbitMQDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(RabbitMQDemoApplication.class, args);
    }

    @Bean
    public Queue queue() {
        return new Queue("myQueue");
    }
}

在上述代码中，我们使用了@Bean注解来创建一个名为myQueue的队列。

步骤5：测试消息发送和接收

最后，我们可以编写一个简单的测试方法来测试消息的发送和接收。在任意Java类中，添加以下代码：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframeworkamqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Autowired
    private Queue queue;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(queue.getName(), message);
        System.out.println("Message sent: " + message);
    }
}