spring boot 捕获乐观锁异常的核心做法是拦截 `optimisticlockingfailureexception`,在 `@controlleradvice` 中统一处理并返回业务友好的错误信息。具体实现时,需确保引入了 jpa 依赖,并在全局异常处理器类上标注 `@restcontrolleradvice`,然后编写一个使用 `@exceptionhandler(optimisticlockingfailureexception.class)` 注解的方法,该方法接收异常对象作为参数,返回包含错误码和提示信息的 json 响应。这样做可以将底层的数据库并发冲突转化为前端可理解的 http 409 conflict 或自定义状态码,避免直接暴露堆栈信息。

如何配置全局异常处理器以拦截特定异常
要实现对 `OptimisticLockingFailureException` 的捕获,必须创建一个继承自 `HandlerExceptionResolver` 或直接使用 Spring MVC 扩展点的组件。最简便的方式是使用 `@RestControllerAdvice` 注解的类,它会自动扫描所有 Controller 抛出的异常。在该类中定义一个方法,专门处理 `org.springframework.orm.OptimisticLockingFailureException`。当 Service 层因版本检查失败抛出此异常时,Spring 的异常分发机制会将其路由到该方法。开发者需要在此方法中构建一个统一的响应体,通常包含错误代码(如 409)和人类可读的消息(如“数据已被修改,请刷新后重试”)。这种方法解耦了业务逻辑与异常处理逻辑,使得 Controller 保持简洁。

package com.example.demo.config;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.orm.ObjectOptimisticLockingFailureException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import java.util.HashMap;
import java.util.Map;
@RestControllerAdvice
public class GlobalExceptionHandler {
@ExceptionHandler(ObjectOptimisticLockingFailureException.class)
public ResponseEntity<Map<String, Object>> handleOptimisticLocking(ObjectOptimisticLockingFailureException ex) {
Map<String, Object> body = new HashMap<>();
body.put("code", 409);
body.put("message", "数据版本冲突,请刷新页面后重试");
body.put("timestamp", System.currentTimeMillis());
return ResponseEntity.status(HttpStatus.CONFLICT).body(body);
}
}如何在 Service 层触发并验证乐观锁异常
为了验证上述全局处理器是否生效,需要在 Service 层构造一个能触发乐观锁冲突的场景。这通常涉及两个步骤:首先从数据库中读取一条带有 `@Version` 字段的数据;其次,在另一个线程或事务中修改同一条数据并提交,导致第一条数据的版本号过期。当第一个事务尝试更新该数据时,JPA 生成的 SQL 语句会包含 `WHERE version = ?` 条件,由于版本号已变,影响行数为 0,JPA 便会抛出 `ObjectOptimisticLockingFailureException`。通过模拟这种并发场景,可以确保异常被正确抛出并被全局处理器捕获。测试时应关注返回的 HTTP 状态码是否为 409,以及 JSON 内容是否符合预期格式。

package com.example.demo.service;
import com.example.demo.entity.User;
import com.example.demo.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
@Transactional
public User updateUserWithConflict(User user) {
// 1. 获取当前用户,此时 version 为 V
User existingUser = userRepository.findById(user.getId())
.orElseThrow(() -> new RuntimeException("User not found"));
// 假设在另一个事务中,existingUser 的 version 已经被其他操作增加到了 V+1
// 这里模拟直接设置新值,但保留旧的 version 对象引用
existingUser.setName("Updated Name");
// 2. 保存时,JPA 会生成 UPDATE ... SET name=? WHERE id=? AND version=V
// 如果 version 已变为 V+1,则更新行数为 0,抛出 OptimisticLockingFailureException
return userRepository.save(existingUser);
}
}基于程序中某个输入、条件或结果的具体问题
在上述代码中,具体的输入条件是 `User` 实体的 `id` 存在且 `version` 字段在两次操作间发生了改变。结果是程序不会静默失败,而是抛出异常。如果未配置全局异常处理器,这个异常将导致 500 内部服务器错误,并可能泄露堆栈信息。配置后,客户端收到 409 状态码。关键在于 `@Version` 注解必须正确应用在实体类的字段上,且该字段类型为 `int`, `Integer`, `long`, `Long`, `Timestamp` 等支持比较的类型。若字段类型不支持或注解缺失,JPA 不会生成版本检查条件,从而无法触发此异常。


















