消息队列整理

定义场景

• 出处：https://github.com/jasonGeng88/blog/blob/master/201705/MQ.md

比如用户注册发邮件功能

• 直接一个方法中同步写发送邮件的功能【很多用户注册的发送邮件可能导致注册操作响应太慢】
• 多线程，另外起一个线程发送邮件【邮件发送变快了，但是出现有用户收不到邮件的问题】
• 将发送邮件的消息发送到消息队列上，对应到邮件发送服务监听到消息，进行发送邮件操作【异步化，服务间解耦】
• 有天所有的其他服务都采用消息队列发送邮件消息，【大量消息堆积在队列中】，【分布式消息处理】

定义

• 简单架构模型

  
  image.png

特性

异步性

将耗时的同步操作，通过以发送消息的方式，进行了异步化处理。减少了同步等待的时间。

松耦合

消息队列减少了服务之间的耦合性，不同的服务可以通过消息队列进行通信，而不用关心彼此的实现细节，只要定义好消息的格式就行。

分布式

通过对消费者的横向扩展，降低了消息队列阻塞的风险，以及单个消费者产生单点故障的可能性（当然消息队列本身也可以做成分布式集群）。

可靠性

消息队列一般会把接收到的消息存储到本地硬盘上（当消息被处理完之后，存储信息根据不同的消息队列实现，有可能将其删除），这样即使应用挂掉或者消息队列本身挂掉，消息也能够重新加载

业务场景

• 参考： http://www.spring4all.com/question/141

• 可以做延迟设计
  比如我们有一些数据，需要过五分钟后再被使用

• 异步处理
  对于不需要及时处理的消息，比如说写mysql后，数据还需要往缓存同步，可以通过mq来达到写缓存的目的

• 应用解耦
  在大型微服务架构中，有一些无状态的服务经常考虑使用mq做消息通知和转换。

• 分布式事务最终一致性
  可以使用基于消息中间件的队列做分布式事务的消息补偿，实现最终一致性。

• 流量削峰
  一般在秒杀或团抢活动中使用广泛，可以通过队列实现秒杀的人数和商品控制，还可以缓解短时间压垮应用系统。

• 日志处理
  我们在做监控，或者日志采集的时候经常用队列来做消息的传输和暂存。

• 广播/消息通讯

可能遇到的问题

• 参考 https://github.com/doocs/advanced-java/tree/master/docs/high-concurrency

消息队列选型和对比？

如何保证消息的高可用

如何保证消息重复消费的问题（幂等性）

如何处理消息丢失问题（消息的可靠性传输）

如何保证消息的顺序性

如何处理消息积压的问题

消息过期失效问题