电话

15169028800

后端程序员必备技术栈消息队列的作用是什么

标签: 技术栈怎么写 2023-06-02 

  消息队列在后台技术栈中,占有举足轻重的作用,接下来的一段时间,我们会系统的讲一讲消息队列。 今天我们主要来讲一讲消息队列的作用。

  消息队列,其实并不是什么深奥的东西,类似这次我们的国庆出行,许多的景区都会出现人满为患,到处都是人从众的现象,这个时候,景区是怎么解决问题的呢?通常就是排队限流了,在检票处设一个等待区域,如果景区里面的人太多,那么就在售票处设立一个等待区,让游客进行排队, 等景区出来一些游客后,再放一批游客进去。现实的生产环境也是如此,在生产环境中,每个系统的容量是不一样的,核心系统或者简单的系统吞吐量往往比较大,非核心系统与复杂系统往往吞吐量比较低。举个例子,在电商系统中,我们经常要对用户行为进行数据上报,相对于用户浏览、交易等行为,数据上报显得并不那么重要,所以支撑数据上报的系统性能往往是不如核心功能的。在一些流量的高峰,例如双十一大促,我们一般不会对这种上报系统进行扩容,这个时候,同步的进行数据上报容易引发雪崩,应对这种情况,我们可以把用户行为数据的写入放入异步队列,可以根据数据的写入速度进行消费,从而保证系统的鲁棒性。

  当我们开始开发一个系统的时候,逻辑总是比较清晰跟简单,随着需求的迭代,系统会变得越来越复杂,举个简单的例子,原先我们进行一次交易的时候,可能交易系统可能只是践行简单的库存扣减,然后写入订单。随着功能的迭代,我们需要通知广告系统、第三方的卖家的话、需要通知商家系统等等,像阿里巴巴,每发生一次简单的交易行为之后,可能需要通知数十个不同的业务方进行处理。

  这些增加的逻辑,假如我们都做在交易系统的话,就会发现交易系统会变得越来越臃肿不堪,而且会难以保证数据的一致性。假如成单之后,通知广告系统失败了(例如网络波动),那么,这次交易行为是否还要进行下去呢,通知广告系统这种可能失败了就算了,要是通知商家系统失败了呢?数据不一致可能会给公司带来投诉与资损,后期开发要花大量的时间进行数据修复。消息队列,是一种更简单又更可靠的方法。当我们成功完成一次交易行为之后,我们生产一条消息,所有的业务方都来消费这条消息,由业务方自己来保证成功消费。这样子,交易系统就不用关心交易行为的后续动作,大大减少了交易系统的复杂性。

  这样的场景在电商系统是非常常见的,用户创建一次订单之后,可能没有支付,我们可以在创建订单25分钟之后去提醒用户,告诉他有笔订单未支付,从而提高转化率。假如让你来实现这个功能,那么你要怎么做呢?我们可以使用一个定时任务,每分钟都去扫描数据库,把未支付的订单扫出来,然后通知用户进行支付。这也是一个不错的方法,但是,一个可靠的定时任务的难点这里就不进行赘述了,我们今天来介绍另外一个方法,那就是消息队列。一些消息队列提供了延迟队列功能,例如RabbitMQ,我们可以利用其延迟的特性,非常简单地实现这个功能。当用户下单的时候,我们发布一个延迟消息,等到消费的时候,再去查询订单的状态,后面,我们会单独讲消息队列延迟是如何保证可靠性的。

  今天我们主要讲了消息队列的三个作用,接下来我们会介绍几个常见的消息队列以及他们的特点,如果你有兴趣,欢迎关注我,我们一起学习,一起进步。同名公众号(沙茶敏碎碎念)

  特别声明:以上内容(如有图片或视频亦包括在内)为自媒体平台“网易号”用户上传并发布,本平台仅提供信息存储服务。

  去医院实习,我在深夜的值班室里发现了娶妻不选护士的线元/月,杭州一家三口挤在40㎡出租房3年。爸爸每天围着女儿转,大半年没参加过饭局了,但他说:值!

  男子拿15万积蓄赴杭州开咖啡店日入0元,当事人:最高卖过300元,没做市场调研,生意实在不好会去兼职

  2014年,墨西哥撕毁305亿合同,只赔偿我国800多万,如今报应来了

  售价超2万元!苹果首款头显Reality Pro高清渲染图出炉:下周发布