哪个网站比较好,湖北公众号定制开发,怎么做繁体字网站,上海中小企业网站建设一、消息队列 网络端的Http请求默认采用的是同步请求方式#xff0c;客户端与服务器端是基于请求和响应模式进行通信的。也就意味着#xff0c;客户端发起请求。必须要等待服务器端完成处理结果给客户端才能继续进行下一步操作#xff0c;如果服务器发送网络延迟、宕机、卡顿…一、消息队列 网络端的Http请求默认采用的是同步请求方式客户端与服务器端是基于请求和响应模式进行通信的。也就意味着客户端发起请求。必须要等待服务器端完成处理结果给客户端才能继续进行下一步操作如果服务器发送网络延迟、宕机、卡顿那么客户端势必会受到影响。 基于这个问题下MQ应运而生。MessageQueue消息队列是一个按照先进先出队列设计的容器主要用于对系统中产生的消息进行存储和消费。使用消息队列主要为了通过异步处理提高系统性能和降低峰值、降低系统耦合度等目的。主流的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ。 消息队列的本质其实就是生产-消费模型。系统运行过程中按照不同的应用场景不断地产生消息并发送至消息队列当需要使用消息时则按照先进先出的方式取出队列中的消息进而消费消息。 二、消息中间件的应用场景 1.异步处理 实际应用短信通知、终端状态推送、App推送、用户注册等。 设想一下当前场景用户完成注册后要实现发送注册邮件及注册短信功能。 1串行方式 客户端发起请求注册信息写入数据库后先实现发送注册邮件再发送注册短信耗时150毫秒。 2并行方式 客户端发起请求注册信息写入数据库后同时执行发送注册邮件和短信耗时100毫秒。 3如果引入消息中间件即为 将想要发送的消息写入消息队列再由消息队列异步读取消费消息这个过程耗时55毫秒几乎等同于注册信息写入数据库极大的提高了系统吞吐量。 2.流量控制 我们经常可以见到的例子在某些直播间或者节日活动去秒杀某类热销商品时如果说请求超过了一定的上限很容易造成服务器瘫痪的情况这就造成了一定成度的麻烦。利用消息队列可以有效的阻隔相应的请求从而减少服务器的压力。 在通过网关服务将请求转发到后端服务时通过消息队列隔离网关和后端服务来达到流量控制和保护后端服务的目的。设置消息队列的最大限制数在达到最大数量时网关不再生产消息到消息队列中例如秒杀活动下商品数量为100即消息队列的上限超过100时下一个用户请求直接返回秒杀失败。 3.服务解耦 微服务架构服务与服务之间的通信是面向接口编程如果引入消息队列消息存储于消息队列中当前服务有需要则从MQ获取消息消费即可不需要也可以不消费。 4.发布订阅 用户想要获取消息队列中的消息必须先注册订阅该消息。 5.高并发缓冲 系统在某个时间点的访问量巨大依然超出了后端接口的每秒最大处理能力这就导致服务器过载响应延迟甚至于服务器宕机。 针对这样场景吗可以利用消息队列将临时数据写入消息队列由消息队列临时缓存至磁盘降低高峰数据对后端的短暂冲击。 三、常见消息中间件
常见消息队列 特性MQActiveMQRabbitMQRocketMQKafka是否支持生产者消费模式√√√√是否支持发布订阅模式√√√√是否支持请求回应模式√√××Api完整性高高 高 高是否支持多语言√√ Java √单机吞吐量万级万级万级十万级消息延迟无微妙级毫秒级毫秒级可用性高主从高主从非常高分布式非常高分布式消息丢失低低几乎不几乎不文档的完备性高高较高高提供快速入门√√√√社区活跃度有有有有商业支持××商业云商业云 以上就是对消息队列的初步认识喽。
