使用Redis+MQ+MySql实现商品秒杀

Posted 2021-01-04

基本思路是通过Redis高速缓存来代替缓慢的数据库操作，借此提高系统在高并发情况下的数据处理能力。
原系统：
1)秒杀请求进入后台后被发送到消息队列，并返回入队成功；
2)消息队列的消费者依次处理执行SQL处理消息队列中的秒杀请求；
根据测试，SQL函数的执行时间约为30ms，属于慢SQL，在1000次/s,总计50次请求下，系统能够很快的对50万次请求进行入队操作，但是后续消息队列中请求大约需要执行6小时。
修改后：
1)秒杀请求进入后台后，判断Redis中对应秒杀商品的库存，若有库存则发送到消息队列1，返回入队成功，否则，返回秒杀结束；
2)消息队列1使用Redis对请求进行去重处理，去掉重复的请求后发送给消息队列2；
3)消息队列2使用Redis对对应秒杀商品进行减库存操作，之后发送给消息队列3；
4)消息队列3执行原秒杀系统中SQL,对mysql中对应数据表进行操作；
修改后的系统由于消息队列1、2中都是对Redis的操作，所以执行速度非常快，响应非常迅速，等到了消息队列3时，请求数基本上已经等于秒杀的商品数，需要执行的SQL数量少了，速度自然也就快了，不会发生消息队列的拥堵。