代金券锁券优化方式
有一个用券逻辑,券有金额/剩余金额属性。并发场景有很多请求使用同一张券,我用到了 select for update 的方式进行锁券,当一个请求消耗完券之后,update 记录(券剩余金额),然后会释放锁,下一个请求再继续用券。
但现在同一张券,券金额比较大且并发场景的情况下,某些请求耗时会比较长,因为等待锁释放
请教下,这里有什么优化点么,合并请求之类的改动太大,需要上游配合
我说的场景是类似那种后付费的场景,会定时扣费,所以会有同一个用户同一张券并发使用的情况
我完全不懂,但是按金额切分券,分别锁,闲时再合并?
可能没说清
- 券可以用多次
用券请求是并发的
所以会出现一张券要被并发使用多次的情况。因为要修改剩余金额,所以需要给券加锁,但加了锁之后,等待锁释放的请求又会慢一些券不是发放到个人账户上然后消费吗? OP 问的是发的券超库存了吗?
券余额也是余额, 所以你要问的是并发余额怎么减.
问题是单用户会有并发么?
如果是全局有一个“该券能用多少次、最多全局抵多少钱”.
那就是减库存问题了.
最好的就是落到缓存,然后用队列按顺序处理.
当用户从页面点选那张优惠券还没有提交时,立刻把券切成两张,并锁住相应金额的那张,如果用户提交,就更新,如果不更新页面关闭了,把两张券再合起来......
或者你也可以提供一个功能让用户自己切然后一张一张用(很丑陋,但代码最少
1 、内存队列(或者 MQ ),排队对单券扣减,减少无畏的 CPU 消耗、加解锁消耗
2 、使用 Redis 的 decrby 进行扣减,通过内存扣减提升性能
3 、如果是多次的金额相同,还可以使用券预置拆分策略,减少锁竞争
就是类似京东的 e 卡 说是卷 就是一个单独的存储余额
用 redis 缓存剩余金额,直接在 redis 中 decrby 可行吗?
楼上说的 MQ 比较靠谱。如果还没屎山堆到动不了数据结构,可以考虑
你 update 剩余金额一定要放在处理完业务逻辑的事务的最后么,可不可以加锁后就 update 金额 释放锁,然后去处理其他业务逻辑,如果处理出错,订单失败,则回滚剩余金额。。这样慢不了多少。。
感谢,我思考下
创建事务,直接跑 sql:
update tblStoredValueCard set fldBalance=fldBalance-@value where fldCardID=@id and fldBalance>=@value
然后获取变更记录数,如果变更记录为 0 条就回滚,如果>0 就写其它表,然后 commit trans
赞同 11 楼。
读写锁 -> 读取数据库为变量 -> 修改 -> 解锁。 # 也就这部分会影响到其他用户
time.sleep(.5)# 业务逻辑
except Exception as e:
加读写锁,回滚。 (怕其他请求读取为变量,所以读也锁)
ps: 似乎有点不对,"a 请求"回滚,"b 请求"的内存变量又不会改。 (不过很难发生)
接#13 ,没有显性锁,使用 update 的数据一致性的特性,对并发影响最小吧。
“显性锁+事务处理”会扼制脏记录特性,可能会严重影响数据库性能
业务逻辑现在也不是很复杂,就是锁了之后写了用券记录,更新金额。写用券记录后置也是准备优化的点
感谢我也看下
个人感觉首先在处理逻辑上优化会比较好,像我刚刚说的加锁后立刻 update 后释放延迟不了多少,贸然引入第三方组件比如消息队列会增加业务复杂度,久而久之就变屎山了,尤其是系统本来就没用到消息队列的情况下。。。
一个事务会有多条 sql 交互,应用服务器与数据库服务器交互 1 次至少 1-2ms ,如果一个事务有 5 次 sql 交互,总耗时 6-10ms ,加锁的情况下 100 次事务处理就累积耗时 1 秒+,感知明显。优化方式是用数据库的存储过程,减少应用服务器与数据库服务器的网络延时。
对,我个人倾向也是不想用别的组件,链路越复杂问题越多。看了大家回复我感觉可以用乐观锁代替 select for update ,但乐观锁失败之后的重试处理以及如何保证请求顺序还得再看看
你对券的基础理解是不是错了?
看你说的是所有人共用一张券,实际你得每个人都发一张券或领一张,然后对券进行核销
看我的附言哈,不同的业务场景。券怎么用要看业务逻辑,我没说过所有人共用一张。
可是你的场景就是高并发的情况,感觉乐观锁并不适合,如果冲突会产生大量重试,数据库负担会加重,select for update 感觉就够了
嗯理解,锁券到更新金额中间只有一个写用券记录,这个我后置试试
看起来有点像预算池的场景:比如:发了 100 张券,总共 100 元的预算,每个人都能用,先到先得,预算用完即止。
有点不是太理解需求,如果是后付费,是不是可以理解成用户有多个需要扣费的业务,然后在某一个时间点需要自动扣费?以我的理解这部分并不需要并行处理,因为不是用户通过多个客户端同时操作进行的,直接照#13 楼的处理方式就行了。如果需要返回余额,还可以使用 returning fldBalance 来获取最新的余额,select 都省了
近日,Stack Exchange系统管理员blog上发布了一篇关于Stack Exchange的架构一瞥,其包括了Stack Overflow, Server Fault 和…
朋友的 OPPO 手机,聊天记录被清空,需要恢复 1-2 月内的聊天记录。手机自从删除聊天记录后,还一直在使用着,到现在有半个月了,这个是不是会对恢复造成影响? 想问大家,这种…
carbon 是一个轻量级、语义化、对开发者友好的 golang 时间处理库,支持链式调用。 目前已被 awesome-go 收录,如果您觉得不错,请给个 star 吧 git…