标签: 锁 - 遇寻笔记

2019-03-20发表2021-02-09更新数据库 / 后端开发5 分钟读完 (大约785个字)

问题描述

在这里插入图片描述

分析

登录函数中有一个事务，如下：
在这里插入图片描述
事务里面有一个有可能操作比较耗时的过程：

在新增登录日志的时候，获取用户的ip。

具体干了啥不重要，重要的是发了一个http请求，并且是串行的，所以这个请求比较耗时的可能是很大的，并且具备不确定性因素。
在这里插入图片描述

反思

TransactionRollbackException的文档注释为：

This exception indicates that the transaction associated with processing of the request has been rolled back, or marked to roll back. Thus the requested operation either could not be performed or was not performed because further computation on behalf of the transaction would be fruitless

可能的过程为：线程1进入事务、然后进行了一次update操作，获得了一个排他锁，然后被卡在了获取ip的那个地方，即此事务持有着排他锁，然后还长时间不结束（50s+），然后线程2也进入了事务，此时在进行update的时候，需要等待线程1释放排它锁，在50秒过后，仍未获取到锁，此时获取锁时间超过了预设，抛出上述异常。

解决

规避潜在的耗时操作。但是由于此服务没人维护，因此通过本地编译，然后拉包替换相应class文件，再上传到服务器的方式进行修改。

复现

查看获取锁的超时阀值：

1	SHOW VARIABLES LIKE '%timeout%';

输出如下：

+-----------------------------+----------+
| Variable_name               | Value    |
+-----------------------------+----------+
| connect_timeout             | 10       |
| delayed_insert_timeout      | 300      |
| have_statement_timeout      | YES      |
| innodb_flush_log_at_timeout | 1        |
| innodb_lock_wait_timeout    | 50       |
| innodb_rollback_on_timeout  | OFF      |
| interactive_timeout         | 28800    |
| lock_wait_timeout           | 31536000 |
| net_read_timeout            | 30       |
| net_write_timeout           | 60       |
| rpl_stop_slave_timeout      | 31536000 |
| slave_net_timeout           | 60       |
| wait_timeout                | 28800    |
+-----------------------------+----------+
13 rows in set (0.01 sec)

代码如下：

// --------------------------Controller------------
  /**
   * 测试web端登录锁表
   */
  @GetMapping("/hotline/test")
  public void testSomeThing() throws InterruptedException {
    testService.doSomething();
  }
// ----------------------------Service----------------
@Service
public class TestService {

  @Autowired
  private BizConfMapper confMapper;

  @Transactional(rollbackFor = Exception.class)
  public void doSomething() throws InterruptedException {
    // 共享锁
    BizConf conf = confMapper.selectByPrimaryKey(0);
    // 排它锁
    confMapper.updateByPrimaryKey(conf);
    // 等待让下个线程超时，最起码要大于50
    Thread.sleep(60000);
  }
}