• 我使用延迟队列实现商品的竞拍成交功能


    背景

    我们平时开发可能要求实现这样的需求:用户可以在有效的时间内进行商品竞拍,当有效时间过了之后,取竞拍价最高的用户成交。我们一般可以使用定时任务每5s定时扫描数据库,获取有效时间大于当前时间的商品列表,然后取每个商品中竞价最高的用户存入商品成交表中。

    商品成交

    如果使用定时任务,这里会有一个问题,定时任务每5s执行一次,就会查询一次数据库,这样对系统,对数据库压力会有一定的压力,并且时间精确度不是很高。个人觉得不是最好的方法。

    对于上面的需求,我决定使用延迟对列实现。实现的逻辑为:

    1. 当系统启动时,扫描已经发布的商品,并将商品id存放入Redis的延迟队列

    2. 如果有新商品发布,将新商品id存入延迟队列

    3. 启动一个常驻线程,扫描延迟队列,获取已到竞拍时间结束的商品,并获取对应商品的竞拍信息,存入用户商品成交表中

    4. 使用一个兜底的定时任务,每晚执行一次步骤1

    延迟队列

    这样我们将原来数据库的压力转移到了Redis上,并且Redis本身的Zset也可实现延迟队列,性能会更好。

    关于RedisZset实现延迟队列,有兴趣的同学可以看看我写的这篇文章:

    👉Redis实现延迟队列

    代码实现

    我们先来写一个Redis的工具类RedisDelayingQueue,用于将数据放入Zset中。

    上面代码中queueKeyRediskeymsgkey对应的值,endDate为结束时间,即消费的时间。我们将msg信息封装成TaskItem对象,以便存取。

    TaskItem的id可以使用id生成器生成唯一id。

    将数据存入Redis后。我们需要延迟消费它。

    上面代码是将指定score的数据从Redis中取出,即当前时间小于Redis存入的时间时,我们将这个数据传给handleMsg方法执行。

    handleMsg方法具体如下:

     

    这里每一个queueKey对应一个消费类,map中存入的是queueKey和对应的消费类。

    Map<String, DelayHandler> map = Maps.newHashMap();
    

    当实例化RedisDelayingQueue时,实例化DelayHandler所有的实现类。

    1. public RedisDelayingQueue(List delayHandlers) {
    2.     delayHandlers.forEach(delayHandler -> map.put(delayHandler.getQueueKey(), delayHandler));
    3. }

    所以当我们执行map.get(queueKey)时,获取到的就是queueKey和对应的消费类。因此消费后的业务代码,我们只需要写一个类实现DelayHandler,并重写handler(msg)

    这里我们重写一个商品消费类。

    接下来我们就是将业务中的数据塞入Redis中。

    这里我们使用异步的方式将数据推入Redis中,将符合条件的数据消费出来。

    启动系统时需要执行delayxxxDealResult方法用于向Redis中推送数据。

    如果我们需要新发布商品时,也需要向Redis中推送数据。

    当然如果你不放心,还可以用定时任务每天执行一次数据的推送。

    为了保证我们消费的数据不重复,在将消费的数据入库时需要做一下去重判断哦。

    测试

    如上图,我们将其中一个商品竞拍结束时间设置为比当前时间大,另一个商品为比当前时间小。启动系统控制台打印了如下日志:

     

    状态为DOING的商品为竞拍中的商品,因此都进入了延迟队列。

    启动系统后我们发现结束时间小于当前时间的商品已经被消费,因为没有人竞拍,而竞拍时间到了,这里显示为流拍UNSETTLE。

    时间一到,延迟队列准时消费满足条件的数据。

     

    看数据库中商品的状态也改变了。

    交易结果也插入了相关的商品信息。

    到这里我们就实现了商品竞拍成交功能。

    如果你有更好的想法,欢迎评论给出意见。如果这篇文章对你有帮助,欢迎点赞转发。

  • 相关阅读:
    pgsql数据库实现导入导出
    Python中prettytable库
    为什么选择B+树作为数据库索引结构?
    (6)SpringCloud-Spring Boot项目详细搭建步骤
    linux查看服务器内核CUP版本相关命令
    期货开户公司底蕴深厚实力强大
    ElasticSearch 学习(docker,传统方式安装、安装遇到的问题解决,)
    CMU15445 (Fall 2019) 之 Project#3 - Query Execution 详解
    Python基础——魔法方法(一)
    使用项目的prettier格式化项目代码
  • 原文地址:https://blog.csdn.net/wujialv/article/details/126437055