laravel 死锁处理机制+测试

146 阅读 0 评论 97 点赞

我是靠谱客的博主糟糕大树，这篇文章主要介绍laravel 死锁处理机制+测试，现在分享给大家，希望可以做个参考。

在日常交易场景中，我们有用户A向用户B进行转账，用户B向用户A进行转账的情况，那么当两个请求并发一起执行的时候怎么办呢。

复制代码

1
2
$user1 = AppModelsUser::query()->where('id',1)->lockForUpdate()->first();

我制作了如下测试
首先是在事务中绑定一个死锁。

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
/**
* Notes:死锁1
* Author:tanyong
* DateTime:2022/5/19
*/
public function index11()
{
DB::transaction(function(){
$user1 = AppModelsUser::query()->where('id',1)->lockForUpdate()->first();
//一旦锁住user1，等待10s，在10s内我们马上去执行index12函数锁住user2
sleep(10);
$user2 = AppModelsUser::query()->where('id',2)->lockForUpdate()->first();
$user1->increment('versionId',1);
$user2->increment('versionId',1);
},2);
return [
'code'
=>
0,
'message'
=>
'success'
];
}

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/**
* Notes:死锁2
* Author:tanyong
* DateTime:2022/5/19
*/
public function index12()
{
DB::transaction(function(){
$user2 = AppModelsUser::query()->where('id',2)->lockForUpdate()->first();
$user1 = AppModelsUser::query()->where('id',1)->lockForUpdate()->first();
$user2->increment('versionId',1);
$user1->increment('versionId',1);
},2);
return [
'code'
=>
0,
'message'
=>
'success'
];
}

先执行index11，再执行index12。此时就会产生死锁

当死锁产生后，首先index11因一直拿不到user_id = 2的锁，会抛出异常，并释放自己占用的user_id=1的锁。此时，index12就能拿到user_id=1的锁并执行后续程序计划。因我们设置了重试，所以当index11抛出锁异常后，会再次执行（又因此时index12已获得两个记录的记录锁，所以会等待index12执行完成后并释放锁（commit或是rollback），之后才会拿到两个记录的锁，然后去执行后续计划）。