RabbitMQ怎么与SpringBoot整合使用

94次阅读

共计 1294 个字符，预计需要花费 4 分钟才能阅读完成。

要将 RabbitMQ 与 Spring Boot 整合使用，可以按照以下步骤操作：

添加 RabbitMQ 依赖：
在 Spring Boot 项目的 pom.xml 文件中添加 RabbitMQ 依赖，例如：

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

配置 RabbitMQ 连接信息：
在 application.properties 或 application.yml 文件中配置 RabbitMQ 的连接信息，例如：

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

创建 RabbitMQ 生产者：
创建一个 RabbitMQ 生产者类，用于发送消息到 RabbitMQ 队列，例如：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

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

创建 RabbitMQ 消费者：
创建一个 RabbitMQ 消费者类，用于监听并处理 RabbitMQ 队列中的消息，例如：

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

@Component
public class RabbitMQConsumer {@RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {System.out.println("Message received: " + message);
    }
}