SpringBoot + MyBatis-Plus 并发更新数据丢失问题解决方案 - 悲观锁与分布式锁

SpringBoot + MyBatis-Plus 并发更新同一行数据导致更新丢失问题解决方法 - 不适用乐观锁，附上完整代码

问题描述：

在使用 SpringBoot 和 MyBatis-Plus 时，如果多个线程同时更新同一行数据，会出现更新丢失的问题。

解决方法：

1. 使用悲观锁

在 MyBatis-Plus 中，可以使用悲观锁来解决并发更新同一行数据的问题。在查询数据时，使用 select for update 语句来获取锁，保证在更新数据时，只有一个线程能够访问该行数据。

示例代码：

@Transactional
public void updateDataById(Long id, String data) {
    // 获取悲观锁
    DataEntity entity = dataMapper.selectByIdForUpdate(id);
    entity.setData(data);
    dataMapper.updateById(entity);
}

2. 使用分布式锁

在分布式系统中，可以使用分布式锁来解决并发更新同一行数据的问题。使用分布式锁可以保证在更新数据时，只有一个线程能够访问该行数据。

可以使用 Redis 或者 Zookeeper 来实现分布式锁，具体实现方式可以参考其他文章。

示例代码：

@Transactional
public void updateDataById(Long id, String data) {
    // 获取分布式锁
    String lockKey = 'data_' + id;
    DistributedLock lock = getDistributedLock(lockKey);
    lock.lock();
    try {
        DataEntity entity = dataMapper.selectById(id);
        entity.setData(data);
        dataMapper.updateById(entity);
    } finally {
        lock.unlock();
    }
}

完整代码：

DataEntity.java：

@Data
@TableName('data')
public class DataEntity {

    @TableId(type = IdType.AUTO)
    private Long id;

    private String data;

}

DataMapper.java：

@Mapper
public interface DataMapper extends BaseMapper<DataEntity> {

    @Select('select * from data where id = #{id} for update')
    DataEntity selectByIdForUpdate(Long id);

}

DataService.java：

@Service
public class DataService {

    @Autowired
    private DataMapper dataMapper;

    @Transactional
    public void updateDataById(Long id, String data) {
        DataEntity entity = dataMapper.selectById(id);
        entity.setData(data);
        dataMapper.updateById(entity);
    }

}

注意： 上述代码中没有使用悲观锁或者分布式锁，因此会出现并发更新同一行数据导致更新丢失的问题。在实际使用时，需要根据具体情况选择合适的解决方案。