使用队列时发生了 MySQL 死锁

问答 / 504 / 4 / 创建于 3年前

队列使用database

 production.ERROR: SQLSTATE[40001]: Serialization failure: 1213 Deadlock found when trying to get lock; try restarting transaction (SQL: delete from `jobs` where `id` = 1790893) {"exception":"[object] (Illuminate\\Database\\QueryException(code: 40001): SQLSTATE[40001]: Serialization failure: 1213 Deadlock found when trying to get lock; try restarting transaction (SQL: delete from `jobs` where `id` = 1790893)
[stacktrace]

我一开始开启了10个队列进程，因为又加了一些队列业务又增加了8个队列进程
运行一段时间后发现在删除队列时会频繁的出现死锁，
我希望能够定位到问题并解决此死锁问题

mysql 队列锁

课程读者 43 声望

多语言CRUD攻城狮，技术菜鸡

《L05 电商实战》

从零开发一个电商项目，功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等

《G01 Go 实战入门》

从零开始带你一步步开发一个 Go 博客项目，让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。

推荐文章：

更多推荐...

Mysql 的 varchar 字段最大长度真的是 65535 吗？ 33 / 10 |

MySQL 实用小技巧——谁动了我的 MySQL ？ 63 / 18 |

对线面试官：MySQL 事务、锁和MVCC 23 / 4 |

对线面试官：12个MySQL慢查询的原因分析 55 / 8 |

laravel-soar(2.x) - 自动监控输出 SQL 优化建议、辅助 laravel 应用 SQL 优化 34 / 42 |

每天新增8640w数据，怎么存储比较好 21 / 50 |

cheer

课程读者 64 声望

最佳答案

    /**
     * Delete a reserved job from the queue.
     *
     * @param  string  $queue
     * @param  string  $id
     * @return void
     *
     * @throws \Throwable
     */
    public function deleteReserved($queue, $id)
    {
        $this->database->transaction(function () use ($id) {
            if ($this->database->table($this->table)->lockForUpdate()->find($id)) {
                $this->database->table($this->table)->where('id', $id)->delete();
            }
        });
    }

datebase作为队列引擎时，会开启一个事务同时加上排它锁，还是推荐改成用redis吧。

3年前评论

oursdreams （楼主）

您好，我能否问一下引起该死锁的原因是什么，在我的设想里多个进程它应该不会接收执行同一任务

cheer （作者）

@Dream_java_php 按我的理解，每个消费进程的执行，他们都是并行同时存在的，所以还是会可能出现“抢”同个任务的情况。还有一点，消费脚本在调用delete之前你是否有开启了一层事务包住了？

oursdreams （楼主）

@cheer 我并没有在delete前开启事务，我采用你推荐的redis后解决了问题，看来可能如你所说的由并行引发

讨论数量: 4

00x00

84 声望

很明显mysql的问题，用redis或者rabbit搞吧。

3年前评论

cheer

课程读者 64 声望

    /**
     * Delete a reserved job from the queue.
     *
     * @param  string  $queue
     * @param  string  $id
     * @return void
     *
     * @throws \Throwable
     */
    public function deleteReserved($queue, $id)
    {
        $this->database->transaction(function () use ($id) {
            if ($this->database->table($this->table)->lockForUpdate()->find($id)) {
                $this->database->table($this->table)->where('id', $id)->delete();
            }
        });
    }

datebase作为队列引擎时，会开启一个事务同时加上排它锁，还是推荐改成用redis吧。

3年前评论

oursdreams （楼主）

您好，我能否问一下引起该死锁的原因是什么，在我的设想里多个进程它应该不会接收执行同一任务

cheer （作者）

@Dream_java_php 按我的理解，每个消费进程的执行，他们都是并行同时存在的，所以还是会可能出现“抢”同个任务的情况。还有一点，消费脚本在调用delete之前你是否有开启了一层事务包住了？

oursdreams （楼主）

@cheer 我并没有在delete前开启事务，我采用你推荐的redis后解决了问题，看来可能如你所说的由并行引发

Hollie

课程读者 107 声望

这个是从 Laravel/framework 的 Github 中的 Issues 中找到的。

希望这个 issue 对你有帮助

看不懂可以百度翻译~

3年前评论

直面苦痛的人生

10 声望 / 逗逼 @ 海南拓奇之光

:joy: :sob: :sob: :sob: :sob: :sob: :sleepy: :weary: :sweat: :sweat: :cold_sweat: :cry: :pensive:

3年前评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助