并发更新

问题描述

我在 MysqL 中有一个表，用于存储用户的余额：

我还有一个使用 Spring Boot 和 Kotlin（Restful Services）构建的应用程序，每次进行交易时都需要更新余额表，但该应用程序支持来自同一应用程序实例下的同一用户的多个同时连接，这里是我有问题的地方。

我有一个使用 R2dbcEntityTemplate 的数据更新方法：

此方法从表中读取当前余额，并基于此在每次进行交易时进行折扣，但是，如果用户并行执行多个请求，那么这些请求中的几个可以读取相同的平衡并错误地打折，例如：

我想要做的是“并发更新安全”，但是，使用 R2dbc 的 API：

update balance
SET balance = balance - @amount
WHERE user = @user

解决方法

好吧，在更彻底地阅读 R2dbc 文档后发现可以从 R2dbcEntityTemplate 运行本机 SQL 查询，这不是我所期望的，但是，它非常适合我的应用程序的并发级别。如果有人对此有更好的解决方案，那就太好了，请不要犹豫发布它，因为我最初需要的是这样做，但不是使用本机 SQL 查询，而是直接使用 R2dbc API。这是它最终的样子，它也可以异步执行而不会丢失数据的保真度：