Java封装数据库乐观锁重试切面的核心是用@Aspect拦截带@RetryOnOptimisticLock注解的方法，捕获OptimisticLockException等异常后按配置最大重试次数和退避时间自动重试，确保数据一致性且避免无限循环。
Java 中封装数据库乐观锁重试切面，核心是用 @Aspect 拦截带特定注解的方法，在执行失败（如版本号不匹配导致的 OptimisticLockException 或自定义异常）时自动重试，直到成功或达到最大重试次数。关键在于隔离重试逻辑、保证数据一致性、避免无限循环，并支持灵活配置。
定义乐观锁重试注解
先创建一个自定义注解，用于标记需要开启乐观锁重试的方法：
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface RetryOnOptimisticLock {
int maxRetries() default 3;
long backoffMs() default 0; // 重试间隔毫秒，可选
}
该注解声明了最大重试次数和可选的退避时间，便于按需控制行为。
编写重试切面逻辑
使用 Spring AOP 编写切面，拦截被 @RetryOnOptimisticLock 标记的方法，捕获乐观锁冲突异常并重试：
立即学习“Java免费学习笔记（深入）”；
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
@Aspect
@Component
public class OptimisticLockRetryAspect {
private static final Logger log = LoggerFactory.getLogger(OptimisticLockRetryAspect.class);
@Around("@annotation(retryAnno)")
public Object retryOnOptimisticLock(ProceedingJoinPoint joinPoint,
RetryOnOptimisticLock retryAnno) throws Throwable {
int maxRetries = retryAnno.maxRetries();
long backoffMs = retryAnno.backoffMs();
for (int i = 0; i <= maxRetries; i++) {
try {
return joinPoint.proceed();
} catch (OptimisticLockException | DataIntegrityViolationException ex) {
if (i == maxRetries) {
throw ex; // 达到上限，抛出原始异常
}
if (backoffMs > 0 && i < maxRetries) {
Thread.sleep(backoffMs);
}
log.debug("Optimistic lock conflict on attempt {}/{}. Retrying...", i + 1, maxRetries + 1);
}
}
return null;
}
}
- 使用
@Around确保能捕获异常并控制重试流程 - 捕获
OptimisticLockException（JPA/Hibernate 默认异常）或DataIntegrityViolationException（MyBatis 等可能抛出的 SQL 异常，若你用 version 字段+WHERE version=xxx 方式实现） - 重试前可加日志，便于排查；支持简单退避，避免密集重试压垮 DB
确保方法可安全重试
不是所有方法都适合自动重试，必须满足以下条件：
- 幂等性：方法多次执行结果一致（例如更新余额时读取最新值再计算，而非基于入参硬编码）
- 无副作用操作：不在切面外修改共享状态、发送消息、调用外部 HTTP 接口等（否则重试会重复触发）
-
事务边界清晰：推荐将重试逻辑放在 Service 层方法上，且该方法由 Spring 管理事务（
@Transactional），每次重试都是独立事务
示例安全写法：
@Transactional
@RetryOnOptimisticLock(maxRetries = 2, backoffMs = 50)
public void updateInventory(Long itemId, int delta) {
Inventory inventory = inventoryRepository.findById(itemId).orElseThrow();
int newStock = inventory.getStock() + delta;
if (newStock < 0) throw new IllegalStateException("Insufficient stock");
inventory.setStock(newStock);
inventoryRepository.save(inventory); // JPA 自动带 version check
}
进阶建议与注意事项
生产环境建议补充以下能力：
- 异常白名单：只对明确识别为乐观锁失败的异常重试，避免掩盖其他错误（如空指针、网络超时）
- 重试指标监控：用 Micrometer 记录重试次数、耗时、成功率，便于感知并发冲突趋势
- 动态重试策略：结合 Sentinel 或自定义规则，根据 QPS/错误率动态调整重试次数
-
非 JPA 场景适配：若用 MyBatis，需在 XML 或注解 SQL 中显式写
WHERE version = #{version}，并在 DAO 层抛出自定义乐观锁异常（如VersionMismatchException），切面中一并捕获
不复杂但容易忽略。
