注意：
我不需要关于乐观锁的解释。
这个问题是关于在使用乐观锁时似乎出现的特定Spring Data行为。
每当一个实体有一个@Version注释字段时，从jpa specs开始，乐观锁应自动在实体上启用。
如果我在使用Repositories的spring数据测试项目中这样做，那么似乎没有激活锁定。实际上，在进行非重复读取测试时（请参见JPA规范第93页的P2），没有抛出OptimisticLockException。
但是，从spring docs中，如果我们使用@Lock(LockModeType.OPTIMISTIC)注释单个方法，则底层系统会正确地抛出OptimisticLockException（然后由spring捕获并以稍微不同的形式向上传播）。
这是正常的还是我错过了什么？我们是否必须注释所有方法（或创建一个基本存储库实现来获取锁），才能在spring数据中启用乐观行为？
我正在使用spring boot项目的spring data，版本为1.4.5。
测试：
public class OptimisticLockExceptionTest {
static class ReadWithSleepRunnable extends Thread {
private OptimisticLockExceptionService service;
private int id;
UserRepository userRepository;
public ReadWithSleepRunnable(OptimisticLockExceptionService service, int id, UserRepository userRepository) {
this.service = service;
this.id = id;
this.userRepository = userRepository;
}
@Override
public void run() {
this.service.readWithSleep(this.userRepository, this.id);
}
}
static class ModifyRunnable extends Thread {
private OptimisticLockExceptionService service;
private int id;
UserRepository userRepository;
public ModifyRunnable(OptimisticLockExceptionService service, int id, UserRepository userRepository) {
this.service = service;
this.id = id;
this.userRepository = userRepository;
}
@Override
public void run() {
this.service.modifyUser(this.userRepository, this.id);
}
}
@Inject
private OptimisticLockExceptionService service;
@Inject
private UserRepository userRepository;
private User u;
@Test(expected = ObjectOptimisticLockingFailureException.class)
public void thatOptimisticLockExceptionIsThrown() throws Exception {
this.u = new User("email", "p");
this.u = this.userRepository.save(this.u);
try {
Thread t1 = new ReadWithSleepRunnable(this.service, this.u.getId(), this.userRepository);
t1.start();
Thread.sleep(50);// To be sure the submitted thread starts
assertTrue(t1.isAlive());
Thread t2 = new ModifyRunnable(this.service, this.u.getId(), this.userRepository);
t2.start();
t2.join();
assertTrue(t1.isAlive());
t1.join();
} catch (Exception e) {
e.printStackTrace();
}
}
}
测试服务：
@Component
public class OptimisticLockExceptionService {
@Transactional
public User readWithSleep(UserRepository userRepo, int id) {
System.err.println("started read");
User op = userRepo.findOne(id);
Thread.currentThread();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.err.println("read end");
return op;
}
@Transactional
public User modifyUser(UserRepository userRepo, int id) {
System.err.println("started modify");
User op = userRepo.findOne(id);
op.setPassword("p2");
System.err.println("modify end");
return userRepo.save(op);
}
}
代码库：
@Repository
public interface UserRepository extends CrudRepository<User, Integer> {
}
- 从规范中我看到，乐观锁定不仅仅是你所说的那样。它必须防止脏读和不可重复读取。
- 我认为处理版本号的不是 Spring，而是底层的 JPA 提供程序（在此情况下是 Hibernate）。
- Spring 不使用字符串版本，这是 JPA，并且可以在一组之间进行选择。
- 正如我所说，如果我注释 findOne 方法，则会抛出乐观锁异常，因此这意味着您刚刚说的是错误的。
- vratojr