来源: 最后更新:24-07-02 06:06:37
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
标签: [db:关键词]
“快讯!外媒:欧尔班抵达基辅,系其自俄乌冲突爆发以来首次访乌“快讯!外媒:欧尔班抵达基辅,系其自俄乌冲突爆发以来首次访乌,欧尔
2024年1月常州普通话证书邮寄查询系统在哪里? 罐车运输乱象调查:卸完煤制油直接装运食用大豆油 wap开发详细解释(wap2app开发) 2023第二季度天津西青区公租房登记公告