背景
我们平时开发可能要求实现这样的需求：用户可以在有效的时间内进行商品竞拍，当有效时间过了之后，取竞拍价最高的用户成交。我们一般可以使用定时任务每5s定时扫描数据库，获取有效时间大于当前时间的商品列表，然后取每个商品中竞价最高的用户存入商品成交表中。
商品成交
如果使用定时任务，这里会有一个问题，定时任务每5s执行一次，就会查询一次数据库，这样对系统，对数据库压力会有一定的压力，并且时间精确度不是很高。个人觉得不是最好的方法。
对于上面的需求，我决定使用延迟对列实现。实现的逻辑为：
当系统启动时，扫描已经发布的商品，并将商品id存放入Redis的延迟队列如果有新商品发布，将新商品id存入延迟队列启动一个常驻线程，扫描延迟队列，获取已到竞拍时间结束的商品，并获取对应商品的竞拍信息，存入用户商品成交表中使用一个兜底的定时任务，每晚执行一次步骤1
延迟队列
这样我们将原来数据库的压力转移到了Redis上，并且Redis本身的Zset也可实现延迟队列，性能会更好。
关于Redis的Zset实现延迟队列，有兴趣的同学可以看看我写的这篇文章：
我们先来写一个Redis的工具类RedisDelayingQueue<t></t>，用于将数据放入Zset中。
上面代码中queueKey为Redis的key，msg为key对应的值，endDate为结束时间，即消费的时间。我们将msg信息封装成TaskItem对象，以便存取。
TaskItem的id可以使用id生成器生成唯一id。
将数据存入Redis后。我们需要延迟消费它。
上面代码是将指定score的数据从Redis中取出，即当前时间小于Redis存入的时间时，我们将这个数据传给handleMsg方法执行。
handleMsg方法具体如下：
这里每一个queueKey对应一个消费类，map中存入的是queueKey和对应的消费类。
<code class="javascript">Map<String, DelayHandler> map = Maps.newHashMap();</code>
当实例化RedisDelayingQueue时，实例化DelayHandler所有的实现类。
<code class="javascript">public RedisDelayingQueue(List<DelayHandler> delayHandlers) { delayHandlers.forEach(delayHandler -> map.put(delayHandler.getQueueKey(), delayHandler));}</code>所以当我们执行map.get(queueKey)时，获取到的就是queueKey和对应的消费类。因此消费后的业务代码，我们只需要写一个类实现DelayHandler，并重写handler(msg)。
这里我们重写一个商品消费类。
接下来我们就是将业务中的数据塞入Redis中。
这里我们使用异步的方式将数据推入Redis中，将符合条件的数据消费出来。
启动系统时需要执行delayxxxDealResult方法用于向Redis中推送数据。
如果我们需要新发布商品时，也需要向Redis中推送数据。
当然如果你不放心，还可以用定时任务每天执行一次数据的推送。
为了保证我们消费的数据不重复，在将消费的数据入库时需要做一下去重判断哦。
测试
如上图，我们将其中一个商品竞拍结束时间设置为比当前时间大，另一个商品为比当前时间小。启动系统控制台打印了如下日志：
状态为DOING的商品为竞拍中的商品，因此都进入了延迟队列。
启动系统后我们发现结束时间小于当前时间的商品已经被消费，因为没有人竞拍，而竞拍时间到了，这里显示为流拍UNSETTLE。
时间一到，延迟队列准时消费满足条件的数据。
看数据库中商品的状态也改变了。
交易结果也插入了相关的商品信息。
到这里我们就实现了商品竞拍成交功能。
如果你有更好的想法，欢迎评论给出意见。如果这篇文章对你有帮助，欢迎点赞转发。
