01、RabbitMQ之入门

旧城等待， 2023-06-24 14:25 22阅读 0赞

## RabbitMQ之入门 ##

**一、什么是MQ？**  
消息队列(Message Queue，简称MQ)，从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已

**二、主流MQ框架**  
MQ框架非常之多，比较流行的有RabbitMq、ActiveMq、ZeroMq、kafka，以及阿里开源的RocketMQ。  
区别：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70]  
本文主要介绍RabbitMQ  
**三、应用场景**  
主要解决异步处理、应用解耦、流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构  
1.异步处理  
用户注册后，需要发注册邮件和注册短信  
![在这里插入图片描述][20191223180816522.png]  
2.应用解耦  
用户下单后，订单系统需要通知库存系统  
![在这里插入图片描述][20191223180915747.png]  
3.流量削锋(重点)  
流量削锋也是消息队列中的常用场景，一般在秒杀或团抢活动中使用广泛，例如双十一  
![在这里插入图片描述][20191223181012941.png]

**四、Docker安装部署RabbitMQ**  
注意获取镜像的时候要获取`management`版本的，不要获取last版本的，management版本的才带有管理界面  
1.查询镜像

$ docker search rabbitmq:management

2.获取镜像

$ docker pull rabbitmq:management

3.运行镜像  
\#\#方式一：默认guest用户，密码也是guest

$ docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management

\#\#方式二：设置用户名和密码（推荐）

$ docker run -d \
         --name my-rabbitmq \
         -p 5672:5672 -p 15672:15672 \
         -v /data:/var/lib/rabbitmq \
         --hostname my-rabbitmq-host \
         -e RABBITMQ_DEFAULT_VHOST=my_vhost \
         -e RABBITMQ_DEFAULT_USER=admin \
         -e RABBITMQ_DEFAULT_PASS=admin \
         --restart=always \
         rabbitmq:management

**参数说明**：  
\-d：后台运行容器  
\-name：指定容器名  
\-p：指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）  
\-v：映射目录或文件，启动了一个数据卷容器，数据卷路径为：/var/lib/rabbitmq，再将此数据卷映射到住宿主机的/data目录  
–hostname：主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）  
\-e：指定环境变量；（  
RABBITMQ\_DEFAULT\_VHOST：默认虚拟机名；  
RABBITMQ\_DEFAULT\_USER：默认的用户名；  
RABBITMQ\_DEFAULT\_PASS：默认用户名的密码）  
–restart=always：当Docker重启时，容器能自动启动  
rabbitmq:management：镜像名  
端口解释：  
15672：后台界面地址：http://\[宿主机IP\]:15672 ；  
5672：Rabbit服务器端口  
**注意**：  
1.请记住虚拟机名称，后面yml配置文件需要用到，如果启动时没指定，默认值为`/`  
2.**容器启动后，可以通过docker logs 窗口ID/容器名字 查看日志**

docker logs my-rabbitmq

**五、RabbitMQ管理平台**

**1.Virtual Hosts**  
就象mysql有数据库的概念并且可以指定用户对库和表等操作的权限。那RabbitMQ呢？RabbitMQ也有类似的权限管理。  
在RabbitMQ中可以虚拟消息服务器VirtualHost，每个VirtualHost相当于一个相对独立的RabbitMQ服务器，  
每个VirtualHost之间是相互隔离的。exchange、queue、message不能互通  
另外，虚拟主机的限制有两个：最大连接数和最大队列数  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 1]

**MQ的核心概念**:  
生产者、队列、消费者、消息

生产者生产消息并投递到队列中，  
消费者可以从队列中获取消息并消费，  
消息指的是各个服务之间要传递的数据\*\*

**六、 springboot整合rabbitmq**  
单一生产者和单一消费者  
1.安装好rabbitmq，登陆RabbitMQ管理平台，新增管理用户并设置权限  
![在这里插入图片描述][20191223182613335.png]  
2.切换到springboot用户登陆，在All users中，点击Name为springboot， 进入权限设置页面  
![在这里插入图片描述][20191223182629809.png]  
3.在权限设置页面，进入Permissions页面，点击“Set permission"  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 2]  
4.新建springboot项目，pom.xml添加rabbitmq依赖

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

也可以网站在线生成  
[https://start.spring.io/][https_start.spring.io]

5.rabbitmq连接配置

# 服务的端口和项目名称
    server:
      port: 8081
      servlet:
        context-path: /rabbitmq01
    ## rabbitmq config
    spring:
      rabbitmq:
        host: 你的ip地址 		#rabbitma服务器的id地址
        port: 5672 #rabbitmq服务器的端口号
        username: springcloud   #用户名称
        password: 123456 #密码
    ## 与启动容器时虚拟主机名字一致~~~与启动容器时虚拟主机名字一致~~~与启动容器时虚拟主机名字一致~~~
        virtual-host: my_vhost  #和你创建容器时的服务名称一样

6.生成配置类

package com.zking.rabbitmq01.rabbitmq;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class RabbitConfig { 
    
        /* * 功能描述: 定义消息队列，并指定队列名称first-queue和two-queue * 〈〉 * @Param: * @Return: * @Author: 骄傲的骨傲天 * @Date: 2019/12/22 21:45 */
        @Bean
        public Queue firstQueue(){ 
            return new Queue("first-queue",true);
        }
    
        @Bean
        public Queue twoQueue(){ 
            return new Queue("two-queue",true);
        }
    }

7.创建生产者，给消息列表添加消息

package com.zking.rabbitmq01.controller;
    
    import org.apache.tomcat.jni.Local;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import javax.xml.crypto.Data;
    import java.time.LocalDateTime;
    import java.time.format.DateTimeFormatter;
    
    /* * 功能描述: <br> * 〈〉生产者发送消息——》队列 * @Param: * @Return: * @Author: 骄傲的骨傲天 * @Date: 2019/12/22 21:48 */
    @Component
    public class SendController { 
    
        @Autowired
        private AmqpTemplate amqpTemplate;
    
        public void send(){ 
        //创建时间
            String createDate= LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
            //发送
            amqpTemplate.convertAndSend("first-queue","hello,rabbitmq!!!+date="+createDate);
        }
    
        public void send2(){ 
        //创建时间
            String createDate= LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
            //发送
            amqpTemplate.convertAndSend("two-queue","hello,rabbitmq!!!+date="+createDate);
        }
    }

8.消费者

package com.zking.rabbitmq01.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /* * 功能描述: <br> * 〈〉消费者，消费消息队列中的消息 * @Param: * @Return: * @Author: 骄傲的骨傲天 * @Date: 2019/12/23 17:05 */
    @Component
    @RabbitListener(queues = { "first-queue","two-queue"})
    @Slf4j
    public class QueueReceiver { 
    
    
        @RabbitHandler
        public void handlerMessage(String message){ 
            log.info("消费者已经接收到队列中的message");
            log.info("message={}",message);
        }
    }

给生产者创建Junit测试

package com.zking.rabbitmq01.controller;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import static org.junit.Assert.*;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest
    public class SendControllerTest { 
    
        @Autowired
        private SendController sendController;
    
        @Test
        public void send() { 
        //调用两方法给消息队列发送信息
            sendController.send();
            sendController.send2();
        }
    }

**七、测试**  
运行测试类

最终效果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 3]  
在这里插入图片描述

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191223181918819.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4,size_16,color_FFFFFF,t_70
[20191223180816522.png]: https://img-blog.csdnimg.cn/20191223180816522.png
[20191223180915747.png]: https://img-blog.csdnimg.cn/20191223180915747.png
[20191223181012941.png]: https://img-blog.csdnimg.cn/20191223181012941.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191223182103823.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4,size_16,color_FFFFFF,t_70
[20191223182613335.png]: https://img-blog.csdnimg.cn/20191223182613335.png
[20191223182629809.png]: https://img-blog.csdnimg.cn/20191223182629809.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191223182643187.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4,size_16,color_FFFFFF,t_70
[https_start.spring.io]: https://start.spring.io/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20191223184115126.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDY5NzE4,size_16,color_FFFFFF,t_70