注意：本教程使用的数据库脚本、数据模型和环境信息请参考 “MyBatis Plus环境准备” 章节，点击下载示例源码。
乐观锁（Optimistic Locking）是相对悲观锁而言的，乐观锁假设数据一般情况下不会造成冲突，所以在数据进行提交更新的时候，才会正式对数据的冲突进行检测。如果发现冲突了，则返回给用户错误的信息，让用户决定如何去做。乐观锁适用于读操作多的场景，这样可以提高程序的吞吐量。
乐观锁实例：
（1）存在两个线程 A 和 B，分别从数据库读取数据。执行后，线程 A 和 线程 B 的 version 均等于 1。如下图：
（2）线程 A 处理完业务，提交数据。此时，数据库中该记录的 version 为 2。如下图：
（3）线程 B 也处理完业务了，提交数据。此时，数据库中的 version 已经等于 2，而线程的 version 还是 1。程序给出错误信息，不允许线程 B 操作数据。如下图：
乐观锁机制采取了更加宽松的加锁机制。乐观锁是相对悲观锁而言，也是为了避免数据库幻读、业务处理时间过长等原因引起数据处理错误的一种机制，但乐观锁不会刻意使用数据库本身的锁机制，而是依据数据本身来保证数据的正确性。乐观锁的实现：
CAS 实现：Java 中 java.util.concurrent.atomic 包下面的原子变量使用了乐观锁的一种 CAS 实现方式。
版本号控制：一般是在数据表中加上一个数据版本号 version 字段，表示数据被修改的次数。当数据被修改时，version 值会+1。当线程A要更新数据值时，在读取数据的同时也会读取 version 值，在提交更新时，若刚才读取到的 version 值与当前数据库中的 version 值相等时才更新，否则重试更新操作，直到更新成功。
在 MyBatis Plus 中，使用 @Version 实现乐观锁，该注解用于字段上面。
本实例将在前面用到的 user 表上面进行。在进行之前，现在 user 表中添加 version 字段。SQL 如下：
ALTER TABLE `user` ADD COLUMN `version` int UNSIGNED NULL COMMENT '版本信息';
定义 user 表的 JavaBean，代码如下：
package com.hxstrive.mybatis_plus.model;
import com.baomidou.mybatisplus.annotation.*;
@TableName(value = "user")
public class AnnotationUser5Bean {
@TableId(value = "user_id", type = IdType.AUTO)
private String userId;
@TableField("name")
private String name;
@TableField("sex")
private String sex;
@TableField("age")
private Integer age;
@Version
private int version;
// 忽略 getter 和 setter 方法
}添加 MyBatis Plus 的乐观锁插件，该插件会自动帮我们将 version 加一操作。如下：
package com.hxstrive.mybatis_plus;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor paginationInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
// 乐观锁插件
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
return interceptor;
}
}测试乐观锁代码，我们创建两个线程 A 和 B 分别去修改用户ID为 1 的用户年龄，然后观察年龄和version字段的值。代码如下：
package com.hxstrive.mybatis_plus.simple_mapper.annotation;
import com.hxstrive.mybatis_plus.mapper.AnnotationUser5Mapper;
import com.hxstrive.mybatis_plus.model.AnnotationUser5Bean;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.concurrent.CountDownLatch;
@RunWith(SpringRunner.class)
@SpringBootTest
class AnnotationDemo5 {
@Autowired
private AnnotationUser5Mapper userMapper;
@Test
void contextLoads() throws Exception {
// 重置数据
AnnotationUser5Bean user5Bean = new AnnotationUser5Bean();
user5Bean.setUserId(1);
user5Bean.setAge(0);
user5Bean.setVersion(0);
userMapper.updateById(user5Bean);
// 修改数据
for (int i = 0; i < 10; i++) {
System.out.println("第 " + (i + 1) + " 次修改数据");
final CountDownLatch countDownLatch = new CountDownLatch(2);
modifyUser(countDownLatch, "My-Thread-A", 1);
modifyUser(countDownLatch, "My-Thread-B", 1);
countDownLatch.await();
Thread.sleep(100L);
}
}
private void modifyUser(final CountDownLatch countDownLatch, String threadName, int userId) {
Thread t = new Thread(new Runnable() {
@Override
public void run() {
try {
String threadName = Thread.currentThread().getName();
try {
AnnotationUser5Bean userBean = userMapper.selectById(userId);
if (null == userBean) {
return;
}
AnnotationUser5Bean newBean = new AnnotationUser5Bean();
newBean.setName(userBean.getName());
newBean.setSex(userBean.getSex());
newBean.setAge(userBean.getAge() + 1);
newBean.setUserId(userBean.getUserId());
newBean.setVersion(userBean.getVersion());
int result = userMapper.updateById(newBean);
System.out.println("result=" + result + " ==> " + userBean);
} catch (Exception e) {
System.err.println(threadName + " " + e.getMessage());
}
} finally {
countDownLatch.countDown();
}
}
});
t.setName(threadName);
t.start();
}
}在运行上面代码之前，我们数据库中的记录值如下：
运行上面程序，数据库记录如下：
上面代码将执行10次循环操作，每次操作启动两个线程（线程 A 和 线程 B）去修改用户数据。如果数据没有任何冲突，则用户的年龄应该是 20。但是上面程序运行完成后年龄为 16。
每次更新数据时，MyBatis Plus 将使用下面的 SQL 语句：
UPDATE user SET name=?, sex=?, age=?, version=? WHERE user_id=? AND version=? Parameters: 测试(String), 男(String), 2(Integer), 3(Integer), 1(Integer), 2(Integer)
特别说明:
支持的数据类型只有：int,Integer,long,Long,Date,Timestamp,LocalDateTime
整数类型下 newVersion = oldVersion + 1
newVersion 会回写到 entity 中
仅支持 updateById(id) 与 update(entity, wrapper) 方法
在 update(entity, wrapper) 方法下, wrapper 不能复用!
川公网安备51010802032098
