为什么使用MQ?在项目中,可将一些无需即时返回且耗时的 *** 作提取出来,进行异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量2.应用场景2.1 任务异步处理将不需要同步处理的并且耗时长的 *** 作由消息队列通知消息接收方进行异步处理。
提高了应用程序的响应时间。
2.2 应用程序解耦合MQ相当于一个中介,通过它让生产者与消费者交互,将应用程序进行解耦合。
2.3 削峰填谷如某个系统会往数据库写数据,但是数据库只能支撑每秒1000左右的并发写入,并发量再高就容易宕机。
在系统低峰期的时候并发也就100多个,但在高峰期时候,并发量会突然激增到5000以上,这个时候数据库肯定会卡死。
这时候,可以使用MQ,消息会被MQ保存起来,然后系统就可以按照自己的消费能力来消费,比如每秒1000个数据,慢慢写入数据库,就不会卡死数据库了。
但使用了MQ之后,限制消费消息的速度为1000,但是这样一来,高峰期产生的数据势必会被积压在MQ中,高峰就被“削”掉了。
但是因为消息积压,在高峰期过后的一段时间内,消费消息的速度还是会维持在1000QPS,直到消费完积压的消息,这就叫做**“填谷”**3. AMQP 和 JMSMQ是消息通信的模型;实现MQ的大致有两种主流方式:AMQP、JMS。
3.1 AMQPAMQP 是一种协议,更准确地说是一种 binary wire-level protocol(链接协议)。
与 JMS 的本质差别 : AMQP不从API层进行限定,而是直接定义网络交换的数据格式。
3.2 JMSJMS 即Java消息服务(JavaMessage Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。
3.3 AMQP 与 JMS 区别JMS 是定义了统一的接口,来对消息 *** 作进行统一; AMQP是通过规定协议来统一数据交互的格式JMS 限定了必须使用Java语言; AMQP只是协议,不规定实现方式,因此是跨语言的。
JMS 规定了两种消息模式; AMQP的消息模式更加丰富4.多种消息中间件常见的消息队列有如下: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
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)