SpringBoot 集成 rabbitmq 消息队列

我不是女神ヾ 2021-11-11 12:06 515阅读 0赞

今天，日月教大家如何使用springboot 集成 rabbitmq，话不多说，直接贴代码。

**1 、rabbitmq下载**

[RabbitMQ安装教程][RabbitMQ]

**2、创建两个springboot项目**

ribbitMqSend （mq消息发送）

ribbitMqReceive （mq消息接收）

## ribbitMqSend 项目 ##

**（1）、配置文件application.yml**

server:
      port: 8001
    rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest

**pom依赖：**

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

**（2）、RabbitMqController**

package com.chenqi.ribbitMqSend.controller;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.bind.annotation.RestController;
    import com.chenqi.ribbitMqSend.rabbitmq.RabbitMqSender;
     
     
    /**
     * 
    * @ClassName: RabbitMqController
    * @Description: 测试Rabbit MQ
    * @author chenqi
    * @date 2018年9月28日
    *
     */
    @RestController
    @RequestMapping(value="/rabbitmq")
    public class RabbitMqController {
     
        @Autowired
        private RabbitMqSender demoRabbitMqSender;
        
        /**
         * 发送测试消息队列
         */
        @RequestMapping(value = "/sendMsg", method = RequestMethod.GET)
        public @ResponseBody String sendRabbitMq() {
            demoRabbitMqSender.send("hello RabbitMq");
            return "SUCCESS";
        }
        
    }

**（3）、mq 消息发送类**

package com.chenqi.ribbitMqSend.rabbitmq;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    /**
     * 
    * @ClassName: RabbitMqSender
    * @Description: mq 消息发送类
    * @author chenqi
    * @date 2018年9月28日
    *
     */
    @Component
    public class RabbitMqSender {
     
        @Autowired
        private AmqpTemplate rabbitTemplate;
     
        public void send(String content) {
            System.out.println("Sender : " + content);
            this.rabbitTemplate.convertAndSend("hello", content);
        }
        
    }

## ribbitMqReceive 项目 ##

**（1）、配置文件application.yml**

server:
      port: 8002
    rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest

**pom依赖：**

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

**（2）、mq队列**

package com.chenqi.ribbitMqReceive.config;
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    /**
     * 
    * @ClassName: RabbitMqConfig
    * @Description: mq队列
    * @author chenqi
    * @date 2018年9月28日
    *
     */
    @Configuration
    public class RabbitMqConfig {
        
        @Bean
        public Queue helloQueue() {
            return new Queue("hello");
        }
    }

**（3）、消息队列接收类**

package com.chenqi.ribbitMqReceive.rabbitmq;
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
     
    /**
     * 
    * @ClassName: RabbitMqReceiver
    * @Description: 消息队列接收类
    * @author chenqi
    * @date 2018年9月28日
    *
     */
    @Component
    @RabbitListener(queues = "hello")
    public class RabbitMqReceiver {
     
        @RabbitHandler
        public void process(String content) {
            System.out.println("Receiver : " + content);
        }
     
    }

**3、测试**  
分别启动两个项目，浏览器访问：[http://localhost:8001/rabbitmq/sendMsg][http_localhost_8001_rabbitmq_sendMsg]  
看图：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]  
查看mq消息发送日志输出  
![在这里插入图片描述][20190805202713242.]

查看mq消息接收日志输出  
![在这里插入图片描述][20190805202725534.]

mq连接  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 1]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 2]

mq队列  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 3]

至此，springboot集成rabbitmq的一个简单示例就完成了。

ps:如果该文章有帮助到您，就点个赞吧！您的支持是我持续更新最大的动力。

[RabbitMQ]: https://blog.csdn.net/weixin_40623736/article/details/97545691
[http_localhost_8001_rabbitmq_sendMsg]: http://localhost:8001/rabbitmq/sendMsg
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]: /images/20211109/99e6150623064d229d3b12bf7f080f26.png
[20190805202713242.]: /images/20211109/d4e5eacd3d454ee6a60b32f8ce4d1eb9.png
[20190805202725534.]: /images/20211109/f16563b990684274bfd90d66b0ee06ca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 1]: /images/20211109/171947d26408435cbb5fcfc6b8149ddd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 2]: /images/20211109/58288dae421848ec9796e3bf08213fb1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 3]: /images/20211109/d6f990eb9bae4c808f05dd910d60b607.png