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

看不見的法師

发布时间：2025-07-15 10:08:02

664人浏览过

来源于php中文网

原创

背景

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

商品成交

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

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

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

延迟队列

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

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

代码实现

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

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

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

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

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

handleMsg方法具体如下：

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

代码语言：javascript代码运行次数：0运行复制

Map map = Maps.newHashMap();

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

代码语言：javascript代码运行次数：0运行复制

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

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

商易多用户商城

功能介绍：1. 商品出售包含拍卖模式，一口价模式。2. 全套系统采用淘宝网风格，成熟，简洁大方3. 每个商品支持多张图片上传，可自由设定，满足广大网民的迫切要求4. 商品信息支持 ubb,图文并茂5. 注册用户可参与竞拍，或者拍卖自己的商品6. 拥有会员注册，交易提醒，成交商品确认等邮件发送功能7. 拥有交易双方信用评价的功能，使得交易安全可*，可信度高8. 拥有安全稳定的用户虚拟币平台，可实现商

下载

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

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

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

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

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

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

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

测试

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

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

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

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

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

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

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

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

Linux 进程被 OOM killer 杀死但 oom_score_adj 已调低无效

Linux 开机自启动服务失效但手动 systemctl start 能启动的原因

Linux 软件 RAID rebuild 非常慢的几种加速参数和注意事项

Linux 开机时出现 "Gave up waiting for root file system devices" 的修复思路

Linux 进程进入 uninterruptible sleep (D) 状态后 kill -9 无效的处理

相关专题

js获取数组长度的方法

在js中，可以利用array对象的length属性来获取数组长度，该属性可设置或返回数组中元素的数目，只需要使用“array.length”语句即可返回表示数组对象的元素个数的数值，也就是长度值。php中文网还提供JavaScript数组的相关下载、相关课程等内容，供大家免费下载使用。

556

2023.06.20

js刷新当前页面

js刷新当前页面的方法：1、reload方法，该方法强迫浏览器刷新当前页面，语法为“location.reload([bForceGet]) ”；2、replace方法，该方法通过指定URL替换当前缓存在历史里（客户端）的项目，因此当使用replace方法之后，不能通过“前进”和“后退”来访问已经被替换的URL，语法为“location.replace(URL) ”。php中文网为大家带来了js刷新当前页面的相关知识、以及相关文章等内容

374

2023.07.04

js四舍五入

js四舍五入的方法：1、tofixed方法，可把 Number 四舍五入为指定小数位数的数字；2、round() 方法，可把一个数字舍入为最接近的整数。php中文网为大家带来了js四舍五入的相关知识、以及相关文章等内容

733

2023.07.04

js删除节点的方法

js删除节点的方法有：1、removeChild()方法，用于从父节点中移除指定的子节点，它需要两个参数，第一个参数是要删除的子节点，第二个参数是父节点；2、parentNode.removeChild()方法，可以直接通过父节点调用来删除子节点；3、remove()方法，可以直接删除节点，而无需指定父节点；4、innerHTML属性，用于删除节点的内容。

477

2023.09.01

JavaScript转义字符

JavaScript中的转义字符是反斜杠和引号，可以在字符串中表示特殊字符或改变字符的含义。本专题为大家提供转义字符相关的文章、下载、课程内容，供大家免费下载体验。

414

2023.09.04

js生成随机数的方法

js生成随机数的方法有：1、使用random函数生成0-1之间的随机数；2、使用random函数和特定范围来生成随机整数；3、使用random函数和round函数生成0-99之间的随机整数；4、使用random函数和其他函数生成更复杂的随机数；5、使用random函数和其他函数生成范围内的随机小数；6、使用random函数和其他函数生成范围内的随机整数或小数。

991

2023.09.04

如何启用JavaScript

JavaScript启用方法有内联脚本、内部脚本、外部脚本和异步加载。详细介绍：1、内联脚本是将JavaScript代码直接嵌入到HTML标签中；2、内部脚本是将JavaScript代码放置在HTML文件的`<script>`标签中；3、外部脚本是将JavaScript代码放置在一个独立的文件；4、外部脚本是将JavaScript代码放置在一个独立的文件。

658

2023.09.12

Js中Symbol类详解

javascript中的Symbol数据类型是一种基本数据类型，用于表示独一无二的值。Symbol的特点：1、独一无二，每个Symbol值都是唯一的，不会与其他任何值相等；2、不可变性，Symbol值一旦创建，就不能修改或者重新赋值；3、隐藏性，Symbol值不会被隐式转换为其他类型；4、无法枚举，Symbol值作为对象的属性名时，默认是不可枚举的。

553

2023.09.20