laravel 死锁处理机制+测试

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

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

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

/**
* 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'
];
}

/**
* 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），之后才会拿到两个记录的锁，然后去执行后续计划）。

最后

以上就是糟糕大树为你收集整理的laravel 死锁处理机制+测试的全部内容，希望文章能够帮你解决laravel 死锁处理机制+测试所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。