记一次线上问题 → Deadlock 的分析与优化

问题复现

　　需求背景

MySQL8.0.30 ，隔离级别是默认的，也就是 REPEATABLE-READ

　　表： tbl_class_student ，id 非自增，整张表的全部字段数据都是从上游服务进行同步

　　需求：上游服务发送同步MQ，本服务收到消息后再调上游服务接口，查询全量数据，对 tbl_class_student 表数据进行更新，若记录存在则更新，不存在则插入

　　这需求是不是很明确？放心，没有下套！

　　线上问题

　　通过线上异常日志，最终定位到如下代码

　　咋一看，这代码是不是无比的清晰明了？

　　都不用注释，就能清楚的知道这个代码是在做什么：逐行更新，存在则更新，不存在则插入

　　是不是无比的契合需求？

　　但是，真的就完美无瑕吗

　　且看我表演一波

　　表演代码如下：

代码语言：javascript复制

@Override
@Transactional(rollbackFor = Exception.class)
public void batchSaveOrUpdate(List<TblClassStudent> classStudents) {
    if(CollectionUtils.isEmpty(classStudents)) {
        return;
    }
    classStudents.forEach(classStudent -> {
        this.getBaseMapper().saveOrUpdate(classStudent);
        try {
            // 为了方便复现问题，睡眠1秒
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    });
}

// 单元测试
@Test
public void batchSaveOrUpdateTest() throws InterruptedException {

    TblClassStudent classStudent = new TblClassStudent();
    classStudent.setId(1);
    classStudent.setClassNo("20231010");
    classStudent.setStudentNo("20231010201");

    TblClassStudent classStudent1 = new TblClassStudent();
    classStudent1.setId(2);
    classStudent1.setClassNo("20231010");
    classStudent1.setStudentNo("20231010202");

    List<TblClassStudent> classStudents1 = new ArrayList<>();
    classStudents1.add(classStudent);
    classStudents1.add(classStudent1);

    List<TblClassStudent> classStudents2 = new ArrayList<>();
    classStudents2.add(classStudent1);
    classStudents2.add(classStudent);

    // 模拟2个线程，同时批量更新
    CountDownLatch latch = new CountDownLatch(2);
    new Thread(() -> {
        studentService.batchSaveOrUpdate(classStudents1);
        latch.countDown();
    }, "t1").start();
    new Thread(() -> {
        studentService.batchSaveOrUpdate(classStudents2);
        latch.countDown();
    }, "t2").start();
    latch.await();
    System.out.println("主线程执行完毕");
}

Deadlock 就这么诞生了！