一,Mq概念
1.1 Mq概述
Mq全称 Message Queue,是在消息传输过程中保存消息的容器,多用于分布式系统之间的通信
1.2 Mq优势
1,应用解耦
如下图,假设a和bcde系统都要实现交互,在不使用mq的情况下,那么就会增加系统之间的耦合性,并且增加系统之间的开销,在使用mq的情况下,a只需将消息发到队列中去即可,bcde直接去mq中取就可以了。
2,异步提速
如下图,在没使用mq的情况下,用户在点击按钮之后,需要同步按顺序做这些事情,5ms查库存,减库存等,300毫秒得到响应,再5ms调用支付系统,以此类推大概需要 20+300+300+300 = 920ms;但是如果使用异步的话,只需要 20+5 = 25ms,可以大大的提升用户体验以及系统吞吐量。
3,削峰填谷
有点类似于限流,在消息高峰的时候,将消息的消费速度进行限制,从而使消息堆积在Mq里面,由于消息长时间堆积,而消费速度进行了限制,所以会有一段长时间的平谷期。从而实现提升系统的稳定性。
1.3 Mq的劣势
1,系统引入的外部依赖越多,系统稳定性越差。一旦 MQ 宕机,就会对业务造成影响
2,MQ 的加入大大增加了系统的复杂度,以前系统间是同步的远程调用,现在是通过 MQ 进行异步调用
二,RabbitMQ 简介
官网:https://www.rabbitmq.com/getstarted.html
2.1 mq的基本组成组件如下
Publisher:生产者,即消息的发送者,用于对消息的发送
Exchange:message 到达 broker 的第一站,根据分发规则,匹配查询表中的 routing key,分发消息到queue 中去。常用的类型有:直连direct (point-to-point), Topic通配符模式 和 Fanout广播模式,但是交换机并没有持久化的能力,只负责消息的转发,所以如果使用可交换机而并没有绑定队列的情况下,会造成数据的丢失。
Queue:消息最终被送到这里等待 consumer 取走
Consumer:消费者,用于去队列中获取消息,从而实现对消息的消费
2.2 Mq基础架构图如下
Broker:用于接收和分发消息的应用,里面主要包含虚拟机,每个虚拟机可以包含多个交换机和队列
Virtual host:存储在Broker中,每个虚拟机可以包含多个交换机和队列
Connection:publisher/consumer 和 broker 之间的 TCP 连接
Channel:由于TCP的建立连接需要进行大量的可靠连接以及TCP的创建和销毁,会浪费很多系统资源,从而降低系统的吞吐量,因此采用信道的方式建立连接,从而减少了大量的TCP可靠连接的开销
三,rabbitmq的安装
3.1 使用docker安装
1,下载rabbitMq镜像
docker pull rabbitmq:management
2,后台方式运行:
docker run --name rabbitmq -d -p 15672:15672 -p 5672:5672 rabbitmq:management
3,OK了,这样rabbitmq3.7.3-manager就安装好了,一定要把manager加上,不然图形化界面出现不了
在服务器上开放5672和15672端口
4,可以查看一下正在运行的容器
docker ps
4,测试连接,可以发现是没问题的。(如果有,那就关闭一下防火墙或者看看端口是否开放)
curl 0.0.0.0:5672
浏览器测试:服务器ip:15672
默认的账号密码都是guest,输入到达以下界面,那么rabbitmq就成功安装了
3.2 图形化界面相关参数讲解
Users
可以增加用户,并且为用户设置权限,该用户在登录之后就可以查看到对应创建的mq的信息,如可以看到对应的虚拟机,交换机和队列等信息
Virtual host
相对于mysql来说,这个虚拟机就是对应的数据库,因此在建表的时候,就需要提前建立数据库,这个mq和mysql一样,在建立交换机或者队列之前需要先建立虚拟机,如下图,可以看该虚拟机的相关信息,点击这个Name也可以为这个虚拟机设置哪个用户可以使用
Exchange
交换机,用于分发消息,在建表的时候需要先建立数据库,因此在建立交换机的时候就需要先建立虚拟机,在建立交换机的时候需要选择具体的虚拟机,并且类型有direct直连模式,topic发布订阅模式和fanout模式。
Queue
队列,用于存储发送的消息,也需要绑定虚拟机,同时也可以绑定对应的交换机,如下图,可以发现具体绑定了的虚拟机名字,也可以通过 total 查看消息未被消费的个数等。