张家港网站建设早晨设计seo是什么级别
一、需求
最常见的一个场景,账户余额更新! 业务场景稍复杂点,一个客户有多个虚拟余额账户,产生交易时,需要同时更新客户的多个余额账户,现在需要为余额更新做并发控制。
二、解决方案
1、依赖数据的乐观锁,内存中不做更新余额的判断,update语句中增加条件,扣减的金额必须小于当前余额,代码中以返回的更新行数判断是否扣减成功。
2、由于一些原因,逼着这里采用的是代码中加锁来解决的,首先需要明确一个前提,如下代码中加同步锁的方案是针对单节点的服务,若是多节点,则无法控制并发了。
三、核心代码
锁的颗粒度:最暴力的同步锁就是整个方法加同步,这样是以牺牲接口性能为代价一刀切的做法,笔者这里实现的是按客户余额账号加锁,同一个账号(账号唯一)更新余额加锁控制即可,不同的账户可以同时更新余额,逻辑上并不冲突。
/*** 账户信息*/
@Slf4j
@Component
public class AccountDemo{// 同步锁容器,一定注意容器必须是线程安全的private final Map<String, Object> accountLocks = new ConcurrentHashMap<>();public int updateBalance( String accountNo, long amount) {if (StrUtil.isBlank(accountNo)) {throw new ServiceException(EnumErrorCode.EC_COMMON_REQ_PARAM_ERROR);}if (amount == 0) {log.warn("amount is zero.");return 1;}// 根据账户ID获取或创建锁对象Object lock = accountLocks.computeIfAbsent(accountNo, k -> new Object());synchronized (lock) {// 判断客户余额是否充足if (checkBalance(accountNo, amount)) {throw new ServiceException("余额不足!"); }// 更新余额代码实现int update = updateBalance(accountNo, amount);}return update;}}
注意:该方法或方法上游加事务控制要特别小心,笔者在外层增加了事务控制,就导致了方法里面锁的执行顺序控制失效了!