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

背景

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

商品成交

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

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

1. 当系统启动时，扫描已经发布的商品，并将商品id存放入Redis的延迟队列
2. 如果有新商品发布，将新商品id存入延迟队列
3. 启动一个常驻线程，扫描延迟队列，获取已到竞拍时间结束的商品，并获取对应商品的竞拍信息，存入用户商品成交表中
4. 使用一个兜底的定时任务，每晚执行一次步骤1

延迟队列

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

关于Redis的Zset实现延迟队列，有兴趣的同学可以看看我写的这篇文章：

“👉Redis实现延迟队列

代码实现

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

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

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

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

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

handleMsg方法具体如下：

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

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

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

public RedisDelayingQueue(List<DelayHandler> delayHandlers) {
    delayHandlers.forEach(delayHandler -> map.put(delayHandler.getQueueKey(), delayHandler));
}

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

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

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

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

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

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

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

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

测试

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

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

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

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

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

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

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

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