如何设计高并发下的抽奖?
我写的伪代码如下,但出现了个bug,抽奖现在要限制每日抽奖结果出现的次数,但实际运行是在并发时不能限制住,如何解决?
<code>resultDayLimitTimes = { resultA => 2 # 每天最多出现2次 resultB => 5 # 每天最多出现5次 resultC => 20 # 每天最多出现20次 resultD => Infinite # 每天出现次数没有限制 } Begin transaction select * from lottery_chance where id =XX and result = null limit 1 for update #bug 就在下面这个循环里,如果resultA今天已经出现过一次了, #然后有2个人(这2人的XX是不同的,所以前面的for update对 #于这种并发不能限制,前面的for update是用来防止同一次抽奖机会被并发时使用多次的) #同时抽到YY=resultA,由于事务还未提 #交那么yyCount都是1,小于每日限制2,于是跳出循环,这2人 #都中了resultA,这时当天出现了3个resultA 超出2个限制, #我应该怎么写才能解决这个问题? while true { YY = randomIn [resultA,resultB,resultC,resultD] yyCount = select count(*) from lottery_chance where result=YY and used_time > todayDate if yyCount </code>
回复内容:
我写的伪代码如下,但出现了个bug,抽奖现在要限制每日抽奖结果出现的次数,但实际运行是在并发时不能限制住,如何解决?
<code>resultDayLimitTimes = { resultA => 2 # 每天最多出现2次 resultB => 5 # 每天最多出现5次 resultC => 20 # 每天最多出现20次 resultD => Infinite # 每天出现次数没有限制 } Begin transaction select * from lottery_chance where id =XX and result = null limit 1 for update #bug 就在下面这个循环里,如果resultA今天已经出现过一次了, #然后有2个人(这2人的XX是不同的,所以前面的for update对 #于这种并发不能限制,前面的for update是用来防止同一次抽奖机会被并发时使用多次的) #同时抽到YY=resultA,由于事务还未提 #交那么yyCount都是1,小于每日限制2,于是跳出循环,这2人 #都中了resultA,这时当天出现了3个resultA 超出2个限制, #我应该怎么写才能解决这个问题? while true { YY = randomIn [resultA,resultB,resultC,resultD] yyCount = select count(*) from lottery_chance where result=YY and used_time > todayDate if yyCount </code>
暂时能想到的是:
再增加一个表来专门记录某天某个result的发放次数,缺点是需要预先创建好期间每天每个result初始数据,并且循环里使用行锁在高并发里效率就非常低了,这是不能被接受的:
<code>resultDayLimitTimes = { resultA => 2 # 每天最多出现2次 resultB => 5 # 每天最多出现5次 resultC => 20 # 每天最多出现20次 resultD => Infinite # 每天出现次数没有限制 } Begin transaction select * from lottery_chance where id =XX and result = null limit 1 for update todayDate = now.Date while true { YY = randomExcludeBeforeIn [resultA,resultB,resultC,resultD] dayResultTimes = select * from result_day_times where date=todayDate and result=YY limit 1 for update if dayResultTimes['times'] </code>
关于抽奖,需要考虑的点有很多,这里稍微整理了下主要需要考虑以下三点:
- 用户抽奖次数限制
- 奖品数量限制
- 奖品发放的分布
- 中奖的概率的可控性
用户抽象次数限制
一个用户必须限制抽奖的次数,而同一个用户的并发几率其实是很小的,所以这里可以用悲观锁来控制用户的抽奖次数。
奖品数量限制
因为并发修改一个奖品的数量可能性是很大的,特别是一些安慰奖,如果这里我们再用悲观锁的话,很容易造成锁超时。所以这里我选择用乐观锁来解决可能出现的并发脏读的情况。
奖品发放的分布
为了防止用脚本来刷抽奖,所以这里需要控制一下奖品发放的一个分布,中大奖需要一个时间间隔,当然这里通过代码来控制是很容易实现的(当然这里也需要考虑一下并发中到两个大奖的情况,也可以通过乐观锁来控制)
中奖的概率的可控性
当我们开始估计抽奖大概会有10W人参加,所以我在设计概率的时候是按照10w来设计的,但是突然发现活动开始一个小时候以后抽奖人数就达到了5W,这个时候就需要可以动态来调整中奖的概率了。这里最好的方式是,不要把中奖概论写死在数据库,而是通过中奖次数/参加人数
来计算出来,这样就可以方便的动态的改变中奖概率了。
关于优化
如果并发量实在是太大,导致数据库的QPS异常的高。那么可以在数据库前面加一层缓存来挡一下,把需要写进数据库的数据放入队列。当使用了这种架构架构,就需要考虑一些数据一致性的问题了,比如说
- 怎么保证数据库的数据和缓存的数据是一致的
- 如果队列挂掉了,怎么保证缓存的数据能够及时更新到数据库中。如果缓存挂掉了,怎么保证抽奖能够继续进行下去(当然这里可以进行业务妥协,如果缓存挂掉整个抽奖挂掉,如果来不及写进数据库的数据,就当做这些事情没有发生,这就会导致某些人抽奖次数超过限定次数,或者某些奖中奖次数超过了限定次数)
关于优化中我对一些异常情况的解决方法不是很了解,希望懂的朋友可以指教一下
附录(简单流程图)
先插入中奖结果 之后根据唯一主键取得中奖数量
select count(*) from table where id
数量超出返回失败 后台根据限定的中奖数取前n个即可
高并发下抽奖跟秒杀系统有些类似。
比如,中奖只是少数,大部分人并不会中奖。所以可以在第一步便限制只有少数用户的请求能够打到真正抽奖逻辑上。这样一来服务器压力就小了很多。
真正参与抽奖的用户,先随机下该用户能不能中奖,中什么奖, 如果是中了,再去查询有没有该奖(若没有奖则显示未中)。这样,又减少了一些对数据库的请求。
这样,高并发也只限于http服务器,对数据库的压力不是很大。
把中奖逻辑倒过来看,当他还没有抽奖的时候其实就相当于某个人已经中奖。
在向服务器请求的时候就已经把中奖结果在过程中分发下去,抽奖过程就一个简单的显示结果。这样就没有抽奖的压力了,非中奖用户根本没有走抽奖逻辑。压力自然就降下来了。
参考一下小米的抢手机
我觉得这个是设计思路的问题,
你应该先取当天已发奖品的数量,并且加上排它锁
<code>yyCount = select count(*) from lottery_chance where result=YY and used_time > todayDate for update </code>
这样当存在并发时,取奖品数量能保证有唯一进程在(奖品等于 YY 上)抽奖,其他进程处于等待加锁状态,直到上一次抽奖结束,然后获取锁,继续下面的操作
高并发还想着用mysql解决问题,恐怕就不太合适.
建议考虑下队列.或者将数据放在redis这类单线处理数据的功能中.
memcache不行啦,需要注意下.
reids是个好选择,可以考虑使用.或者考虑使用队列系统处理
高并发下,我觉得大概是这么几个步骤:
1、是否丢弃该抽奖请求(根据服务器的承受能力,会有一部分请求直接丢弃);
2、用户本次抽奖是否符合业务逻辑(是否有剩余抽奖次数等);
3、如果有多个奖品,那么去掉不符合规则的奖品(比如有的奖品只能中一次,而该用户已经中了一次);
4、在剩下的奖品中按照规则抽取(这里的规则可能简单也可能复杂);
5、如果抽中了某奖品,立刻尝试从奖品队列(这里可以是缓存队列,也可以是数据库记录,但要保证该操作的原子性)中拿取奖品,如果拿取成功(即奖品有剩余)则告诉用户已经中奖。
最OK的办法就是乐观锁
只要是抽奖,必然有并发问题。
涉及到利益的东西,必然有人通过工具刷请求

热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

记事本++7.3.1
好用且免费的代码编辑器

SublimeText3汉化版
中文版,非常好用

禅工作室 13.0.1
功能强大的PHP集成开发环境

Dreamweaver CS6
视觉化网页开发工具

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)

PHP 8.4 带来了多项新功能、安全性改进和性能改进,同时弃用和删除了大量功能。 本指南介绍了如何在 Ubuntu、Debian 或其衍生版本上安装 PHP 8.4 或升级到 PHP 8.4

Visual Studio Code,也称为 VS Code,是一个免费的源代码编辑器 - 或集成开发环境 (IDE) - 可用于所有主要操作系统。 VS Code 拥有针对多种编程语言的大量扩展,可以轻松编写

本教程演示了如何使用PHP有效地处理XML文档。 XML(可扩展的标记语言)是一种用于人类可读性和机器解析的多功能文本标记语言。它通常用于数据存储

Java 8引入了Stream API,提供了一种强大且表达力丰富的处理数据集合的方式。然而,使用Stream时,一个常见问题是:如何从forEach操作中中断或返回? 传统循环允许提前中断或返回,但Stream的forEach方法并不直接支持这种方式。本文将解释原因,并探讨在Stream处理系统中实现提前终止的替代方法。 延伸阅读: Java Stream API改进 理解Stream forEach forEach方法是一个终端操作,它对Stream中的每个元素执行一个操作。它的设计意图是处

字符串是由字符组成的序列,包括字母、数字和符号。本教程将学习如何使用不同的方法在PHP中计算给定字符串中元音的数量。英语中的元音是a、e、i、o、u,它们可以是大写或小写。 什么是元音? 元音是代表特定语音的字母字符。英语中共有五个元音,包括大写和小写: a, e, i, o, u 示例 1 输入:字符串 = "Tutorialspoint" 输出:6 解释 字符串 "Tutorialspoint" 中的元音是 u、o、i、a、o、i。总共有 6 个元

胶囊是一种三维几何图形,由一个圆柱体和两端各一个半球体组成。胶囊的体积可以通过将圆柱体的体积和两端半球体的体积相加来计算。本教程将讨论如何使用不同的方法在Java中计算给定胶囊的体积。 胶囊体积公式 胶囊体积的公式如下: 胶囊体积 = 圆柱体体积 两个半球体体积 其中, r: 半球体的半径。 h: 圆柱体的高度(不包括半球体)。 例子 1 输入 半径 = 5 单位 高度 = 10 单位 输出 体积 = 1570.8 立方单位 解释 使用公式计算体积: 体积 = π × r2 × h (4

Spring Boot简化了可靠,可扩展和生产就绪的Java应用的创建,从而彻底改变了Java开发。 它的“惯例惯例”方法(春季生态系统固有的惯例),最小化手动设置

数组是编程中用于处理数据的线性数据结构。有时在处理数组时,我们需要向现有数组中添加新元素。在本文中,我们将讨论几种在PHP中向数组末尾添加元素的方法,并附带代码示例、输出以及每种方法的时间和空间复杂度分析。 以下是向数组添加元素的不同方法: 使用方括号 [] 在PHP中,向数组末尾添加元素的方法是使用方括号[]。此语法仅适用于我们只想添加单个元素的情况。以下是语法: $array[] = value; 示例
