聊聊mq的使用场景

mq的做用

1. 经过异步方式对系统解耦
2. 增长系统的并发处理能力

经过异步方式对系统解耦

以用户注册为例，通常状况下：

分下一下，上面过程存在的一些问题：

1. 注册过程会调用4个服务（注册服务、邮件服务、短信服务、积分服务），服务之间依赖性太强，任何一个服务不可用，直接影响整个注册业务
2. 接口耗时太长，每一个服务耗时100ms，注册流程耗时400ms
3. 对用户来讲，用户信息入库是主要的业务流程，其余并非响应用户过程当中直接关注的逻辑，能够异步进行处理

采用mq的方式实现：

过程：

• 调用注册服务，注册信息入库，耗时100ms
• 投递注册消息到mq
• 返回注册成功
• 对于用户来讲耗时200ms
• 其余3个操做（发邮件、发短信、增长积分）从消息队列中拉取消息进行处理，对于主流程来讲是异步操做

将依赖于3个服务转换为只依赖于mq服务，只须要保证注册服务、mq服务高可用，便可以保证注册服务的高可用，相比保证其余3个服务高可用上容易了许多。

增长系统的并发处理能力

以电商中的秒杀场景为例，采用同步处理：

• 用户点击秒杀
• 调用订单服务，验证库存、锁定库存
• 跳转到支付页面进行支付

分析一下，存在的问题：

• 验证库存、锁定库存会访问数据库

• 秒杀场景，商品数量有限，请求量很是大，每一个请求来了都作以上处理，直接会把数据库压垮，致使数据库没法对外提供服务，数据库的不可用直接致使整个业务的不可用，秒杀活动打水漂。

• 大量请求会同时到达，同时去访问数据库，数据库链接有限，致使不少请求会处于等待状态，致使并发性能急剧降低
• 大量用户同时操做库存，存在争抢数据库锁的状况，容易致使死锁

• 秒杀中数量通常是有限，大量用户抢购，其实最终只有不多的用户可以抢购到

你们都有在银行办理业务的经验，银行处理业务的流程：领号、排队、等待叫号办理业务。

秒杀中咱们也能够参考银行办理业务的流程：

• 用户点击描述
• 系统接受到用户请求后，生成一个惟一的编号，而后投递一条消息（秒杀下单）到mq
• 响应用户：秒杀正在处理中
• 秒杀系统从mq中拉取消息进行处理，处理完成以后告知用户，这步操做对于用户来讲是异步处理的过程

从上面能够看出，从接受用户请求到响应用户请求，未访问数据库，只有生成编号和发送消息的操做，这部分处理速度是很是快的，不存在性能的问题，数据库也不存在压力的问题了，全部用户的请求都被做为一条消息投递到mq进行异步处理；从而解决了秒杀中同步处理遇到的各类问题。

其余一些使用场景

1. 系统日志的处理
   系统手机日志，异步发送到mq，日志服务队从mq中拉取消息进行各类处理，关于这个之后咱们会专门讨论。
2. 经过事件驱动的一些业务，也可使用mq实现

总结

1. mq是采用异步的方式来解决系统耦合性的问题，并发处理的问题；重点是在于异步，那么什么状况下使用异步呢？当调用方不强依赖于被调用方的结果的时候，能够采用异步的方式进行处理，此时可使用mq。
2. 当调用方强依赖于被调用方的结果的时候，须要使用同步的方式，不能使用mq

mq系列整个内容，咱们将讨论：

1. mq的使用场景
2. 业务系统中投递消息的几种方式？
3. 如何确保投递消息必定成功？
4. 消息消费的几种方式
5. 如何确保消息至少消费一次
6. 如何保证消息消费的幂等性