Springboot如何整合rabbitMQ【简易保姆教程】

悠悠 2023-10-08 20:12 21阅读 0赞

### 一、添加Maven依赖 ###

在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的Exchange、Queue、Binding等信息：

@Configuration
    public class RabbitMQConfig {
        
        @Bean
        public Queue helloQueue() {
        
            return new Queue("hello");
        }
        @Bean
        public DirectExchange directExchange() {
        
            return new DirectExchange("directExchange");
        }
        @Bean
        public Binding binding() {
        
            return BindingBuilder.bind(helloQueue()).to(directExchange()).with("hello");
        }
    }

### 四、创建生产者 ###

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

@Component
    public class RabbitMQProducer {
        
        @Autowired
        private AmqpTemplate amqpTemplate;
        public void send(String message) {
        
            amqpTemplate.convertAndSend("directExchange", "hello", message);
        }
    }

### 五、创建消费者 ###

创建一个消费者类，用于接收RabbitMQ发送的消息：

@Component
    public class RabbitMQConsumer {
        
        @RabbitListener(queues = "hello")
        public void process(String message) {
        
            System.out.println("Received message: " + message);
        }
    }

### 六、测试发送消息 ###

在需要发送消息的地方，注入RabbitMQProducer并调用send方法即可：

@RestController
    public class TestController {
        
        @Autowired
        private RabbitMQProducer rabbitMQProducer;
        @GetMapping("/send")
        public String send() {
        
            rabbitMQProducer.send("Hello, RabbitMQ!");
            return "Message sent";
        }
    }

### 七、运行测试 ###

运行Spring Boot应用程序，并访问/send接口发送消息，可以在控制台中看到消费者打印出的消息。  
以上是Spring Boot整合RabbitMQ并在项目中使用的步骤。需要注意的是，在项目中使用RabbitMQ时，需要注意消息的格式和编码方式。

发表评论取消回复

表情：

评论列表（有 0 条评论，21人围观）

还没有评论，来说两句吧...

相关阅读

相关 XXL-JOB详解（整合springboot）保姆级教程

文章目录 XXL-JOB简介 XXL-JOB是什么为什么需要任务调度平台，而不用传统的 Timer 与 Quartz 为什

以你之姓@/ 2023年10月15日 21:59/ 0 赞/ 56 阅读

相关 Springboot整合markdown编辑器【保姆级简易教程】

在Spring Boot中，我们可以使用Thymeleaf和Spring MVC来实现整合Markdown编辑器的功能。一、添加Markdown编辑器的依赖在pom

小咪咪/ 2023年10月08日 20:26/ 0 赞/ 137 阅读

相关 Springboot如何整合rabbitMQ【简易保姆教程】

一、添加Maven依赖在pom.xml文件中添加RabbitMQ的依赖： <dependency> <groupId>org.springfr

悠悠/ 2023年10月08日 20:12/ 0 赞/ 22 阅读

相关如何通过docker部署RabbitMQ？（保姆级教程）

一、部署前提 1. 服务器或虚拟机已开放端口号 2. 已安装docker且已启动。 3. docker镜像源已做更改。（否则下载速度慢，也可忽略。）二、部署步

偏执的太偏执、/ 2023年10月07日 22:51/ 0 赞/ 29 阅读

相关 RabbitMQ保姆级教程

文章目录前言一、MQ是什么？ 1.1 AMQP 二、在Linux安装RabbitMQ 2.1 安装 2.2 R

我就是我/ 2023年10月02日 15:16/ 0 赞/ 29 阅读

相关 XXL-JOB详解（整合springboot）保姆级教程

文章目录 XXL-JOB简介 XXL-JOB是什么为什么需要任务调度平台，而不用传统的 Timer 与 Quartz 为什

忘是亡心i/ 2023年09月24日 15:32/ 0 赞/ 66 阅读

相关 SpringBoot整合RabbitMQ超级详细教程

首先最重要的是思路：SpringBoot整合RabbitMQ可分为生产者工程与消费者工程分为以下几步 > 生产者工程 > 1）添加RabbitMQ的起步依赖 >

淡淡的烟草味﹌/ 2023年06月23日 03:54/ 0 赞/ 24 阅读

相关 RabbitMQ教程_5 整合SpringBoot

https://gitee.com/fakerlove/rabbitmq 文章目录 5. 整合SpringBoot 5.1 helloword

阳光穿透心脏的1/2处/ 2023年01月03日 14:08/ 0 赞/ 196 阅读

相关 Springboot项目整合Rabbitmq详细教程

首先在springboot的pom文件里引入依赖 <dependency> <groupId>org.springframework.boot</group

「爱情、让人受尽委屈。」/ 2022年09月15日 14:50/ 0 赞/ 233 阅读

相关 RabbitMQ教程之SpringBoot整合RabbitMQ(Java)

SpringBoot整合RabbitMQ 使用SpringBoot整合RabbitMQ非常简单，它极大程度的简化了开发成本，使用SpringBoot整合RabbitMQ需

川长思鸟来/ 2021年09月22日 16:08/ 0 赞/ 389 阅读