消息队列整理
2020-01-01 本文已影响0人
jey恒
定义场景
比如用户注册发邮件功能
- 直接一个方法中同步写发送邮件的功能【很多用户注册的发送邮件可能导致注册操作响应太慢】
- 多线程，另外起一个线程发送邮件【邮件发送变快了，但是出现有用户收不到邮件的问题】
- 将发送邮件的消息发送到消息队列上，对应到邮件发送服务监听到消息，进行发送邮件操作【异步化，服务间解耦】
- 有天所有的其他服务都采用消息队列发送邮件消息，【大量消息堆积在队列中】，【分布式消息处理】
定义
-
简单架构模型
image.png
特性
异步性
将耗时的同步操作，通过以发送消息的方式，进行了异步化处理。减少了同步等待的时间。
松耦合
消息队列减少了服务之间的耦合性，不同的服务可以通过消息队列进行通信，而不用关心彼此的实现细节，只要定义好消息的格式就行。
分布式
通过对消费者的横向扩展，降低了消息队列阻塞的风险，以及单个消费者产生单点故障的可能性（当然消息队列本身也可以做成分布式集群）。
可靠性
消息队列一般会把接收到的消息存储到本地硬盘上（当消息被处理完之后，存储信息根据不同的消息队列实现，有可能将其删除），这样即使应用挂掉或者消息队列本身挂掉，消息也能够重新加载
业务场景
-
可以做延迟设计
比如我们有一些数据，需要过五分钟后再被使用 -
异步处理
对于不需要及时处理的消息，比如说写mysql后，数据还需要往缓存同步，可以通过mq来达到写缓存的目的 -
应用解耦
在大型微服务架构中，有一些无状态的服务经常考虑使用mq做消息通知和转换。 -
分布式事务最终一致性
可以使用基于消息中间件的队列做分布式事务的消息补偿，实现最终一致性。 -
流量削峰
一般在秒杀或团抢活动中使用广泛，可以通过队列实现秒杀的人数和商品控制，还可以缓解短时间压垮应用系统。 -
日志处理
我们在做监控，或者日志采集的时候经常用队列来做消息的传输和暂存。 -
广播/消息通讯
