排他锁,请求各位大神指点

问答 / 2 / 11 / 创建于 2年前

1. 运行环境#

liunx

1). 当前使用的 Laravel 版本？#

laravel9
//: <> (使用 php artisan --version 命令查看)

2). 当前使用的 php/php-fpm 版本？#

PHP 版本：
8.1
//: <> (使用 php --version 命令查看 php 版本)

1. 问题描述？#

排他锁，是否可以这样使用。

  DB::beginTransaction();
        try {
            $order = Order::LockForUpdate()->where('order_sn', 订单号)->first();
            $order->update($date);
            $order->user->LockForUpdate()->increment('sum', $this->collection->get('amount'));
            $order->user->notify(new UserOrder($order));
            $order->user->increment('notification_count');
            DB::commit();
        } catch (\Exception $exception) {
            Log::info($exception->getMessage() ?? $this->collection->get('order_sn') . '订单处理失败');
            DB::rollBack();
        }

在反响关联的时候加锁，这样是否合理。？
订单表 Order 加锁了。

Order::LockForUpdate()

修改用户表 User 时候也加锁。

$order->user->LockForUpdate()

2. 您期望得到的结果？#

希望在修改订单的时候禁止其他用户修改订单信息
同时修改用户金额的时候也禁止修改用户的金额
//: <> (能截图就截图。)

排他锁

chen900804

课程读者 37 声望

暂无个人描述~

0 人点赞

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

从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。

推荐文章：

更多推荐...

博客

Redis 实用小技巧—— bitmap 应用之「位排序」 13 / 5 |

博客

Redis 实用小技巧——如何实现一个排行榜功能 25 / 17 |

博客

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

博客

使用laravel解决库存超出的几个方案 86 / 49 |

博客

redis应用系列一：分布式锁正确实现姿势 66 / 24 |

博客

月半谈（一）redis-分布式锁与应用 23 / 12 |

gongmeng

见习版主 169 声望 / PHP开发工程师 @ 麦风科技

最佳答案

  DB::beginTransaction();
        try {
            $order = Order::LockForUpdate()->where('order_sn', 订单号)->first();
            $order->update($date);
            $order->user->LockForUpdate()->increment('sum', $this->collection->get('amount'));
            $order->user->notify(new UserOrder($order));
            $order->user->increment('notification_count');
            DB::commit();
        } catch (\Exception $exception) {
            Log::info($exception->getMessage() ?? $this->collection->get('order_sn') . '订单处理失败');
            DB::rollBack();
        }

如果只是当前事务并发的话，这段我认为，只需要第一句话加锁就行了，后续加锁意义不大，整个事务阶段由于第一段加锁，其他事务在获取第一句话的就被阻塞了。

2年前评论

hhhhkkk

不同订单号，同一用户，第一句的锁就会失效，第二句就可能导致问题。建议改订单是一个锁，改用户是一个锁（自旋锁）

chen900804 （楼主）

@hhhhkkk $order->user->LockForUpdate()这样子呢？

hhhhkkk

@chen900804 是我才疏学浅了, 楼主正解

gongmeng （作者）

@hhhhkkk 这里改用户的操作是increment的原子操作，本身是支持并发的。只需要保证单的更新并发应该就可以了把。

hhhhkkk

@gongmeng 是的，所以第一个锁不能去，第二个本身update就带了锁 (我以为update的incr 内部逻辑是： select num from table (无锁), udpate *** num= num + 1 有锁)

讨论数量: 11

gongmeng

见习版主 169 声望 / PHP开发工程师 @ 麦风科技

  DB::beginTransaction();
        try {
            $order = Order::LockForUpdate()->where('order_sn', 订单号)->first();
            $order->update($date);
            $order->user->LockForUpdate()->increment('sum', $this->collection->get('amount'));
            $order->user->notify(new UserOrder($order));
            $order->user->increment('notification_count');
            DB::commit();
        } catch (\Exception $exception) {
            Log::info($exception->getMessage() ?? $this->collection->get('order_sn') . '订单处理失败');
            DB::rollBack();
        }

如果只是当前事务并发的话，这段我认为，只需要第一句话加锁就行了，后续加锁意义不大，整个事务阶段由于第一段加锁，其他事务在获取第一句话的就被阻塞了。

2年前评论

hhhhkkk

不同订单号，同一用户，第一句的锁就会失效，第二句就可能导致问题。建议改订单是一个锁，改用户是一个锁（自旋锁）

chen900804 （楼主）

@hhhhkkk $order->user->LockForUpdate()这样子呢？

hhhhkkk

@chen900804 是我才疏学浅了, 楼主正解

gongmeng （作者）

@hhhhkkk 这里改用户的操作是increment的原子操作，本身是支持并发的。只需要保证单的更新并发应该就可以了把。

hhhhkkk

@gongmeng 是的，所以第一个锁不能去，第二个本身update就带了锁 (我以为update的incr 内部逻辑是： select num from table (无锁), udpate *** num= num + 1 有锁)

ysxpark

课程读者 11 声望

increment 是原子的，不上锁也行，并发情况下也能保证原子性

2年前评论

chen900804 （楼主）

就是因为这个愿意。未就想知道。到底是需要加那个锁还是不加

ysxpark （作者）

@chen900804 两个都没必要,就算不上锁,你对订单和会员的操作还是原子性的,又不需要对数据判断运算什么的

勇敢的心

见习助教 850 声望

update 本身就有排他锁

2年前评论

levi

65 声望

我写了一个中间件服务对象，我贴部分代码吧，没办法在这里贴全

    private function _doit(BaseEvent $event): ?array
    {
        $this->_stopPropagation($event);

        $transaction = $event::transaction() === 0;
        if ($transaction) 
        {
            $transaction = (int)max(0, min(4, $this->_option[self::TRANSACTION] ?? 2));
            $event->beginTransaction($transaction);
        }

        $action = $this->_before ? ($this->_before)($event) : null;
        if ($action === false) return [null];

        $data = event($event);
        $transaction && $event->commit();

        return $data;
    }

我说下我的思路

我所有的事务都基于一个 BaseEvent
在 BaseEvent 通过 beginTransaction 开启事务

在 event 中 t 通过 actionPush 引入 model（实际我是引入一个 service，这里可以按需求来）

  public function actionPush(?TransactionContract $server): ?TransactionContract
  {
      if (0 !== self::$_transaction && $server && !in_array($server, self::$_actionList)) 
      {
          self::$_actionList[] = $server;
          $server->mark(self::$_transaction);
      }

      return $server;
  }

然后在 Controller 调用 event，所有的事务都将开启排它锁

    $event = new TaskCreateEvent($task_info, $service, $tags);
    app('Event\Middleware')->dispatch(
          $event, fn() => $this->authorize('canStore', [$event->task()])
      );

这里要说一点事，我的鉴权也是在 event 中的闭包中去执行的，这样就实现了并发同时开启排他锁鉴权是否要继续操作。

2年前评论

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

帮助

排他锁,请求各位大神指点

1. 运行环境#

1). 当前使用的 Laravel 版本？#

2). 当前使用的 php/php-fpm 版本？#

1. 问题描述？#

2. 您期望得到的结果？#

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

排他锁,请求各位大神指点

1. 运行环境#

1). 当前使用的 Laravel 版本？#

2). 当前使用的 php/php-fpm 版本？#

1. 问题描述？#

2. 您期望得到的结果？#

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录