MQ全称为Message Queue,消息队列是应用程序和应用程序之间的通信方法。
为什么使用MQ?
在项目中,可将一些无需即时返回且耗时的操作提取出来,进行异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量
将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。
MQ相当于一个中介,通过它让生产者与消费者交互,将应用程序进行解耦合。
如某个系统会往数据库写数据,但是数据库只能支撑每秒1000左右的并发写入,并发量再高就容易宕机。
在系统低峰期的时候并发也就100多个,但在高峰期时候,并发量会突然激增到5000以上,这个时候数据库肯定会卡死。
这时候,可以使用MQ,消息会被MQ保存起来,然后系统就可以按照自己的消费能力来消费,比如每秒1000个数据,慢慢写入数据库,就不会卡死数据库了。
但使用了MQ之后,限制消费消息的速度为1000,但是这样一来,高峰期产生的数据势必会被积压在MQ中,高峰就被“削”掉了。
但是因为消息积压,在高峰期过后的一段时间内,消费消息的速度还是会维持在1000QPS,直到消费完积压的消息,这就叫做**“填谷”**
MQ是消息通信的模型;实现MQ的大致有两种主流方式:AMQP、JMS。
AMQP 是一种协议,更准确地说是一种 binary wire-level protocol(链接协议)。与 JMS 的本质差别 : AMQP不从API层进行限定,而是直接定义网络交换的数据格式。
JMS 即Java消息服务(JavaMessage Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。
常见的消息队列有如下:
ActiveMQ:基于 JMSZeroMQ:基于 C 语言开发RabbitMQ:基于 AMQP 协议,erlang 语言开发,稳定性好RocketMQ:基于 JMS,阿里巴巴产品Kafka:类似MQ的产品;分布式消息系统,高吞吐量RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。
RabbitMQ官方地址:http://www.rabbitmq.com/
RabbitMQ提供了6种模式:
简单模式
work模式
Publish/Subscribe 发布与订阅模式
Routing 路由模式
Topics 主题模式
RPC 远程调用模式;
官网对应模式介绍:https://www.rabbitmq.com/getstarted.html
来源:
https://www.cnblogs.com/MoYu-zc/p/15144660.html
特斯拉进入江苏省政府用车采购目录,工作人员:特斯拉不属于进口,属于国产的
特斯拉进入江苏省政府用车采购目录,工作人员:特斯拉不属于进口,属于国产的,汽车,沃尔沃,电动车,江苏省政府,用车采购目,特斯拉(公司)(1)人阅读时间:2024-07-04外媒:菲军方称,为美菲联演部署在菲的一套美国中程导弹发射系统将从菲撤出
外媒:菲军方称,为美菲联演部署在菲的一套美国中程导弹发射系统将从菲撤出,导弹,美国,演习,美菲,美军,菲军,菲律宾(1)人阅读时间:2024-07-04高分报考北大“冷门专业”的女孩毕业了!新去向披露
高分报考北大“冷门专业”的女孩毕业了!新去向披露,北大,文博,本科,专业,考古学,樊锦诗,敦煌研究院(1)人阅读时间:2024-07-04哭着忏悔的落马女正厅、自称“土皇帝”的公安厅副厅长,案件细节披露
哭着忏悔的落马女正厅、自称“土皇帝”的公安厅副厅长,案件细节披露,赵翔,红琼,副厅长,公安厅,落马女正厅(1)人阅读时间:2024-07-04关于和的名言俗语(关于和的名言谚语)
举杠铃的标准动作是什么 举杠铃是什么运动
身份证号码后x代表什么意思(身份证号码后x是什么意思)
c语言break用法 c语言break用法举例