如何解决并发更新
我在 MySQL 中有一个表,用于存储用户的余额:
我还有一个使用 Spring Boot 和 Kotlin(Restful Services)构建的应用程序,每次进行交易时都需要更新余额表,但该应用程序支持来自同一应用程序实例下的同一用户的多个同时连接,这里是我有问题的地方。
我有一个使用 R2dbcEntityTemplate 的数据更新方法:
此方法从表中读取当前余额,并基于此在每次进行交易时进行折扣,但是,如果用户并行执行多个请求,那么这些请求中的几个可以读取相同的平衡并错误地打折,例如:
我想要做的是“并发更新安全”,但是,使用 R2dbc 的 API:
update balance
SET balance = balance - @amount
WHERE user = @user
解决方法
好吧,在更彻底地阅读 R2dbc 文档后发现可以从 R2dbcEntityTemplate 运行本机 SQL 查询,这不是我所期望的,但是,它非常适合我的应用程序的并发级别。如果有人对此有更好的解决方案,那就太好了,请不要犹豫发布它,因为我最初需要的是这样做,但不是使用本机 SQL 查询,而是直接使用 R2dbc API。这是它最终的样子,它也可以异步执行而不会丢失数据的保真度:
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。