SpringBoot整合RabbitMQ超级详细教程

淡淡的烟草味﹌ 2023-06-23 03:54 66阅读 0赞

### 首先最重要的是思路：SpringBoot整合RabbitMQ可分为生产者工程与消费者工程分为以下几步 ###

> **生产者工程  
> 1）添加RabbitMQ的起步依赖  
> 2）在application.yml中配置RabbitMQ的信息  
> 3）创建一个rabbitMQ配置类  
> 4）创建生产者**

> **消费者工程  
> 1）添加RabbitMQ的起步依赖  
> 2）在application.yml中配置RabbitMQ的信息  
> 3）创建一个rabbitMQ配置类  
> 4）消费者工程**

### 生产者工程开始 ###

1）添加RabbitMQ的起步依赖

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

2）在application.yml中配置RabbitMQ的信息

server:
      port: 8081
    spring:
      application:
        name: test-rabbitmq-producer
      rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: guest
        password: guest
        virtualHost: /

3）创建一个rabbitMQ配置类 ，配置Exchange、Queue、及绑定交换机。  
   本例配置Topic交换机。

package com.example.config;
    
    import org.springframework.amqp.core.*;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * @ClassName RabbitmqConfig
     * @Description TODO
     * @Author 胡泽
     * @Date 2019/12/17 12:35
     * @Version 1.0
     */
    @Configuration
    public class RabbitmqConfig {
    
        public static final String QUEUE_INFORM_EMAIL = "queue_inform_email";
        public static final String QUEUE_INFORM_SMS = "queue_inform_sms";
        public static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform";
        public static final String ROUTINGKEY_EMAIL="inform.#.email.#";
        public static final String ROUTINGKEY_SMS="inform.#.sms.#";
    
        //声明交换机
        @Bean(EXCHANGE_TOPICS_INFORM)
        public Exchange EXCHANGE_TOPICS_INFORM(){
            //durable(true) 持久化，mq重启之后交换机还在
            return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build();
        }
    
        //声明QUEUE_INFORM_EMAIL队列
        @Bean(QUEUE_INFORM_EMAIL)
        public Queue QUEUE_INFORM_EMAIL(){
            return new Queue(QUEUE_INFORM_EMAIL);
        }
        //声明QUEUE_INFORM_SMS队列
        @Bean(QUEUE_INFORM_SMS)
        public Queue QUEUE_INFORM_SMS(){
            return new Queue(QUEUE_INFORM_SMS);
        }
    
        //ROUTINGKEY_EMAIL队列绑定交换机，指定routingKey
        @Bean
        public Binding BINDING_QUEUE_INFORM_EMAIL(@Qualifier(QUEUE_INFORM_EMAIL) Queue queue,
                                                  @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
            return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_EMAIL).noargs();
        }
        //ROUTINGKEY_SMS队列绑定交换机，指定routingKey
        @Bean
        public Binding BINDING_ROUTINGKEY_SMS(@Qualifier(QUEUE_INFORM_SMS) Queue queue,
                                              @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
            return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_SMS).noargs();
        }
    
    }

4）创建生产者

使用RarbbitTemplate发送消息

package com.example;
    
    import com.example.config.RabbitmqConfig;
    import org.junit.jupiter.api.Test;
    import org.junit.runner.RunWith;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    @SpringBootTest
    @RunWith(SpringRunner.class)
    class ProdcerTopicsSpringbootApplicationTests {
        @Autowired
        RabbitTemplate rabbitTemplate;
    
        @Test
        public void Producer_topics_springbootTest() {
    
            //使用rabbitTemplate发送消息
            String message = "send email message to user";
            /**
             * 参数：
             * 1、交换机名称
             * 2、routingKey
             * 3、消息内容
             */
            rabbitTemplate.convertAndSend(RabbitmqConfig.EXCHANGE_TOPICS_INFORM, "inform.email", message);
    
        }
    
    
    }

### 生产者工程结束 ###

### 消费者工程开始 ###

1.）起步依赖

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

2.）配置application.yml

server:
      port: 8082
    spring:
      application:
        name: test-rabbitmq-consumer
      rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: guest
        password: guest
        virtualHost: /

3.）创建一个rabbitMQ配置类

package com.example.config;
    
    import org.springframework.amqp.core.*;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * @ClassName RabbitmqConfig
     * @Description TODO
     * @Author 胡泽
     * @Date 2019/12/17 12:35
     * @Version 1.0
     */
    @Configuration
    public class RabbitmqConfig {
    
        public static final String QUEUE_INFORM_EMAIL = "queue_inform_email";
        public static final String QUEUE_INFORM_SMS = "queue_inform_sms";
        public static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform";
        public static final String ROUTINGKEY_EMAIL="inform.#.email.#";
        public static final String ROUTINGKEY_SMS="inform.#.sms.#";
    
        //声明交换机
        @Bean(EXCHANGE_TOPICS_INFORM)
        public Exchange EXCHANGE_TOPICS_INFORM(){
            //durable(true) 持久化，mq重启之后交换机还在
            return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build();
        }
    
        //声明QUEUE_INFORM_EMAIL队列
        @Bean(QUEUE_INFORM_EMAIL)
        public Queue QUEUE_INFORM_EMAIL(){
            return new Queue(QUEUE_INFORM_EMAIL);
        }
        //声明QUEUE_INFORM_SMS队列
        @Bean(QUEUE_INFORM_SMS)
        public Queue QUEUE_INFORM_SMS(){
            return new Queue(QUEUE_INFORM_SMS);
        }
    
        //ROUTINGKEY_EMAIL队列绑定交换机，指定routingKey
        @Bean
        public Binding BINDING_QUEUE_INFORM_EMAIL(@Qualifier(QUEUE_INFORM_EMAIL) Queue queue,
                                                  @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
            return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_EMAIL).noargs();
        }
        //ROUTINGKEY_SMS队列绑定交换机，指定routingKey
        @Bean
        public Binding BINDING_ROUTINGKEY_SMS(@Qualifier(QUEUE_INFORM_SMS) Queue queue,
                                              @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
            return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_SMS).noargs();
        }
    
    }

4）监听队列，接收消息

package com.example.controller;
    
    import com.example.config.RabbitmqConfig;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.impl.AMQImpl;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    
    import org.springframework.boot.autoconfigure.amqp.RabbitProperties;
    import org.springframework.stereotype.Component;
    
    /**
     * @ClassName ReceiveHandler
     * @Description TODO
     * @Author 胡泽
     * @Date 2019/12/17 13:02
     * @Version 1.0
     */
    @Component
    public class ReceiveHandler {
        //监听email队列
        @RabbitListener(queues = {RabbitmqConfig.QUEUE_INFORM_EMAIL})
        public void receive_email(Object msg, Message message, Channel channel){
            System.out.println("QUEUE_INFORM_EMAIL msg"+msg);
        }
       //监听sms队列
        @RabbitListener(queues = {RabbitmqConfig.QUEUE_INFORM_SMS})
        public void receive_sms(Object msg, Message message, Channel channel){
            System.out.println("QUEUE_INFORM_SMS msg"+msg);
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70][]

启动生产者：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 1][]

启动成功，

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 3][]

启动消费者：查看信息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 4][]

以上是SpringBoot整合RabbitMQ全部过程

**RabbitMQ超级详解**：  [https://blog.csdn.net/huzecom/article/details/103499692][https_blog.csdn.net_huzecom_article_details_103499692]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191217220616959.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191217220720988.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191217220806246.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20191217220855461.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/2019121722121098.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1emVjb20=,size_16,color_FFFFFF,t_70
[https_blog.csdn.net_huzecom_article_details_103499692]: https://blog.csdn.net/huzecom/article/details/103499692

发表评论取消回复

表情：

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

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

相关阅读

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

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

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

相关 springboot集成RabbitMQ-超级详细步骤

本文对应的代码地址：[https://github.com/zhangshilin9527/rabbitmq-study][https_github.com_zhangs

ゝ一纸荒年。/ 2023年02月26日 05:19/ 0 赞/ 4 阅读

相关 RabbitMQ教程_5 整合SpringBoot

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

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

相关 SpringBoot整合MyBatis详细教程~

-------------------- 目录 1. 导入依赖 2. 连接数据库 3. 编写数据库配置信息 4. 编写pojo实体类 5.

旧城等待，/ 2022年12月15日 02:26/ 0 赞/ 291 阅读

相关 SpringBoot 整合 UEditor 详细教程（一）| 整合教程

SpringBoot 整合 UEditor 详细教程（一）| 整合教程 -------------------- 官方文档：[http://fex.baidu.com

怼烎@/ 2022年12月03日 05:13/ 0 赞/ 384 阅读

相关 SpringBoot整合MyBatis超级详细教学

SpringBoot整合MyBatis超级详细教学项目的整体结构第一步导入依赖pom.xml 第二步配置ap

「爱情、让人受尽委屈。」/ 2022年11月29日 05:50/ 0 赞/ 295 阅读

相关 SpringBoot整合RabbitMQ详细步骤

SpringBoot整合RabbitMQ 文章目录 SpringBoot整合RabbitMQ 一、整合生产者二、整合消费者一

忘是亡心i/ 2022年11月16日 01:35/ 0 赞/ 280 阅读

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

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

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

相关 SpringBoot整合Mybatis详细教程

一、准备工作先在eclipse中导入mybatis的dtd约束： mybatis-3-config.dtd mybatis-3-mapper.dtd 导

男娘i/ 2022年05月17日 13:36/ 0 赞/ 320 阅读

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

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

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