### 2018 年 12 月 29 日 发布
## 悲观锁和乐观锁
业务逻辑的实现过程中，往往需要保证数据访问的排他性。如在金融系统的日终结算处理中，我们希望针对某个时间点的数据进行处理，而不希望在结算进行过程中（可能是几秒种，也可能是几个小时），数据再发生变化。此时，我们就需要通过一些机制来保证这些数据在某个操作过程中不会被外界修改，这样的机制，在这里，也就是所谓的 “ 锁 ” ，即给我们选定的目标数据上锁，使其无法被其他程序修改。 通常有两种锁机制：即通常所说的 “ 悲观锁（ Pessimistic Locking ） ”和 “ 乐观锁（ Optimistic Locking ） ” 。
### 悲观锁（ Pessimistic Locking ）
悲观锁，正如其名，它指的是对数据被外界（包括本系统当前的其他事务，以及来自外部系统的事务处理）修改持保守态度，因此，在整个数据处理过程中，将数据处于锁定状态。悲观锁的实现，往往依靠数据库提供的锁机制（也只有数据库层提供的锁机制才能真正保证数据访问的排他性，否则，即使在本系统中实现了加锁机制，也无法保证外部系统不会修改数据）。 通常是使用`for update`子句来实现悲观锁机制。
ThinkPHP5支持悲观锁机制，要启用悲观锁功能，可以通过使用`lock`锁定方法，例如：
~~~
// 使用悲观锁功能
Db::name('user')->lock(true)->find(1);
~~~
就会自动在生成的SQL语句最后加上`FOR UPDATE`或者`FOR UPDATE NOWAIT`（Oracle数据库）。
`lock`方法还支持传入字符串，以实现特殊的锁机制。
```
Db::name('user')->lock('LOCK IN SHARE MODE')->find(1);
```
### 乐观锁（ Optimistic Locking ）
相对悲观锁而言，乐观锁机制采取了更加宽松的加锁机制。悲观锁大多数情况下依靠数据库的锁机制实现，以保证操作最大程度的独占性。但随之而来的就是数据库性能的大量开销，特别是对长事务而言，这样的开销往往无法承受。 如一个金融系统，当某个操作员读取用户的数据，并在读出的用户数据的基础上进行修改时（如更改用户帐户余额），如果采用悲观锁机制，也就意味着整个操作过程中（从操作员读出数据、开始修改直至提交修改结果的全过程，甚至还包括操作员中途去煮咖啡的时间），数据库记录始终处于加锁状态，可以想见，如果面对几百上千个并发，这样的情况将导致怎样的后果。乐观锁机制在一定程度上解决了这个问题。乐观锁，大多是基于数据版本（ `Version `）记录机制实现。何谓数据版本？即为数据增加一个版本标识，在基于数据库表的版本解决方案中，一般是通过为数据库表增加一个`version`字段来实现。
ThinkPHP`5.1`版本中并没有内置乐观锁功能，因此需要自己实现，本文就来利用`Trait`特性实现乐观锁的功能。
## 乐观锁的实现
要实现乐观锁功能，主要涉及三个地方：
**记录乐观锁**：第一次写入数据的时候自动记录`version`字段，当然也可以使用数据库默认值功能。
**读取乐观锁**：每次读取数据的时候都要单独记录下当前的`version`数据值。
**检测乐观锁**：每次更新数据的时候要重新检测下最新数据的`version`数据值，如果记录的版本号和最新的不一致，表示数据需要更新，否则把当前记录的版本号加1后更新到数据库。
而ThinkPHP`5.1`的模型`save`方法会统一调用`checkBeforeSave`方法，因此我们可以通过重写该方法来实现乐观锁的检测乐观锁功能。而每次查询后都会调用模型的`newInstance`方法，因此可以重写该方法添加读取乐观锁功能。
### 继承方式实现
我们可以创建一个公共的模型继承系统的`think\Model`类，当你的模型需要使用乐观锁功能的话就单独继承。
```
<?php
namespace app\common\model;
use think\Exception;
use think\Model;
class OptimLock extends Model
{
protected $optimLock = 'version';
/**
* 创建新的模型实例
* @access public
* @param array $data 数据
* @param bool $isUpdate 是否为更新
* @param mixed $where 更新条件
* @return Model
*/
public function newInstance($data = [], $isUpdate = false, $where = null)
{
// 缓存乐观锁
$this->cacheLockVersion($data);
return (new static($data))->isUpdate($isUpdate, $where);
}
/**
* 写入之前检查数据
* @access protected
* @param array $data 数据
* @param array $where 保存条件
* @return bool
*/
protected function checkBeforeSave($data, $where)
{
if (!empty($data)) {
// 数据对象赋值
foreach ($data as $key => $value) {
$this->setAttr($key, $value, $data);
}
if (!empty($where)) {
$this->isUpdate(true, $where);
}
}
// 数据自动完成
$this->autoCompleteData($this->auto);
// 事件回调
if (false === $this->trigger('before_write')) {
return false;
}
if ($this->isExists() && !$this->checkLockVersion()) {
throw new Exception('record has update');
}
return true;
}
/**
* 缓存乐观锁
* @access protected
* @param array $data 数据
* @return void
*/
protected function cacheLockVersion($data): void
{
$pk = $this->getPk();
if ($this->optimLock && isset($data[$this->optimLock]) && is_string($pk) && isset($data[$pk])) {
$key = $this->name . '_' . $data[$pk] . '_lock_version';
$_SESSION[$key] = $data[$this->optimLock];
}
}
/**
* 检查乐观锁
* @access protected
* @param array $data 数据
* @return bool
*/
protected function checkLockVersion()
{
// 检查乐观锁
$id = $this->getKey();
if (empty($id)) {
return true;
}
$key = $this->name . '_' . $id . '_lock_version';
if ($this->optimLock && isset($_SESSION[$key])) {
$lockVer = $_SESSION[$key];
$vo = $this->field($this->optimLock)->find($id);
$_SESSION[$key] = $lockVer;
$currVer = $vo[$optimLock];
if (isset($currVer)) {
if ($currVer > 0 && $lockVer != $currVer) {
// 记录已经更新
return false;
}
// 更新乐观锁
$lockVer++;
if ($this->data[$this->optimLock] != $lockVer) {
$this->data[$this->optimLock] = $lockVer;
}
$_SESSION[$key] = $lockVer;
}
}
return true;
}
}
```
对需要使用乐观锁的模型，可以使用
```
namespace app\index\model;
use app\common\model\OptimLock;
class User extends OptimLock
{
}
```
### 利用`Trait`特性实现
但由于PHP不支持多继承，因此并不建议使用模型继承功能来扩展功能。我们可以利用`Trait`特性来更方便的引入`OptimLock`后开启乐观锁功能。
因为`Trait`机制的问题，我们对上面的代码进行了一些必要的调整。
```
<?php
namespace app\common\traits;
use think\Exception;
use think\Model;
trait OptimLock
{
protected function getOptimLockField()
{
return property_exists($this, 'optimLock') && isset($this->optimLock) ? $this->optimLock : 'version';
}
/**
* 创建新的模型实例
* @access public
* @param array $data 数据
* @param bool $isUpdate 是否为更新
* @param mixed $where 更新条件
* @return Model
*/
public function newInstance($data = [], $isUpdate = false, $where = null)
{
// 缓存乐观锁
$this->cacheLockVersion($data);
return (new static($data))->isUpdate($isUpdate, $where);
}
/**
* 写入之前检查数据
* @access protected
* @param array $data 数据
* @param array $where 保存条件
* @return bool
*/
protected function checkBeforeSave($data, $where)
{
if (!empty($data)) {
// 数据对象赋值
foreach ($data as $key => $value) {
$this->setAttr($key, $value, $data);
}
if (!empty($where)) {
$this->isUpdate(true, $where);
}
}
// 数据自动完成
$this->autoCompleteData($this->auto);
// 事件回调
if (false === $this->trigger('before_write')) {
return false;
}
if ($this->isExists()) {
if (!$this->checkLockVersion()) {
throw new Exception('record has update');
}
} else {
$this->recordLockVersion();
}
return true;
}
/**
* 缓存乐观锁
* @access protected
* @param array $data 数据
* @return void
*/
protected function cacheLockVersion($data): void
{
$optimLock = $this->getOptimLockField();
$pk = $this->getPk();
if ($optimLock && isset($data[$optimLock]) && is_string($pk) && isset($data[$pk])) {
$key = $this->getName() . '_' . $data[$pk] . '_lock_version';
$_SESSION[$key] = $data[$optimLock];
}
}
/**
* 检查乐观锁
* @access protected
* @param array $data 数据
* @return bool
*/
protected function checkLockVersion()
{
// 检查乐观锁
$id = $this->getKey();
if (empty($id)) {
return true;
}
$key = $this->getName() . '_' . $id . '_lock_version';
$optimLock = $this->getOptimLockField();
if ($optimLock && isset($_SESSION[$key])) {
$lockVer = $_SESSION[$key];
$vo = $this->field($optimLock)->find($id);
$_SESSION[$key] = $lockVer;
$currVer = $vo[$optimLock];
if (isset($currVer)) {
if ($currVer > 0 && $lockVer != $currVer) {
// 记录已经更新
return false;
}
// 更新乐观锁
$lockVer++;
$data = $this->getData();
if ($data[$optimLock] != $lockVer) {
$this->data($optimLock, $lockVer);
}
$_SESSION[$key] = $lockVer;
}
}
return true;
}
}
```
对需要使用乐观锁的模型，可以使用
```
namespace app\index\model;
use app\common\traits\OptimLock;
use think\Model;
class User extends Model
{
use OptimLock;
}
```
>[info] 值得注意的是，`5.2`版本目前已经内置了一个`OptimLock`的`Trait`实现。
- 值得升级到5.1的18个理由
- 5.1.7版本新特性
- JSON字段类型在ORM中的使用
- 文件下载响应对象
- 教你使用5.1的数组对象查询
- 模型三大利器之一：搜索器
- 在ThinkPHP中使用Yaconf
- 掌握命令行的表格输出
- 5.1.25查询参数绑定的改进
- ThinkPHP安全规范指引
- 巧用数据集的排序功能实现统计排序
- think-orm ——基于5.1的独立ORM库
- think-template——基于ThinkPHP的独立模板引擎
- ThinkPHP5.1.26版本发布——修正版本，包含安全更新
- ThinkPHP5.0和3.2再发安全更新
- 官宣：ThinkPHP发布首个LTS版本
- 你真的了解Db类和模型的正确使用姿势么？
- 如何更有效的记录和管理日志
- 模型三大利器之二：修改器
- ThinkPHP5.1.28版本发布——修正上一版本问题，改进关联查询
- 模型三大利器之三：获取器
- API版本控制的几种思路
- ThinkPHP5.2第一个Beta版本发布测试
- 让你少犯错的数据查询基本原则
- ThinkPHP发布5.1.29版本——常规更新
- 这15个好习惯让你更容易升级到5.2
- 如何有效提高ThinkPHP的应用性能
- 让你提高开发效率的查询技巧
- 模型关联查询不完全指南
- 5.2发布Beta2版本——统一和精简大量用法
- ThinkPHP发布5.1.30版本——支持微秒时间字段写入
- ThinkPHP的数据缓存使用
- ThinkPHP5.2安装及入口文件
- ThinkPHP荣获2018 年度最受欢迎中国开源开发框架第1名
- 5.1路由使用心得技巧
- ThinkPHP5.*版本发布安全更新
- ThinkPHP项目及代码规范指北
- 5.2版本的设计规范指导
- ThinkPHP5.1.32版本发布——圣诞快乐
- 利用Trait特性给模型增加乐观锁功能
- 5.2数据库和模型的变化（摘要）
- ThinkPHP模板引擎实现和常见问题
- ThinkPHP5.0.24版本发布——安全更新
- 不忘初心，方得始终——ThinkPHP十三周年报告
- ThinkPHP5+相关资源汇总
- 异步社区ThinkPHP周年庆专享优惠活动
- 5.2路由的调整和改进
- ThinkPHP发布5.1.33版本——包含安全更新
- ThinkPHP扩展开发指南
- ThinkPHP发布5.2Beta3版本
- ThinkPHP发布5.1.34版本——喜迎新年
- ThinkPHP发布5.2RC1版本
- ThinkPHP发布5.1.35版本——常规更新
- 5.2配置类的调整
- 5.2时间查询的改进和优化
- 5.2RC版本升级不完全指导（仅供学习参考）
- ThinkPHP5.2版本正式变更为6.0版本
- ThinkPHP百度云云虚拟主机专享免费活动
- 事件系统以及查询事件、模型事件的使用
- ThinkPHP6.0RC2版本发布——架构升级、精简核心
- ThinkPHP5.1.36LTS版本发布——常规更新
- 新版Session和Cookie设计变化
- ThinkPHP5.1.37版本发布——常规更新
- ThinkPHP6.0RC3版本发布——细节完善，体验优化
- 6.0中间件使用详解
- Composer各大厂商镜像地址
- ThinkPHP6.0发布计划公告
- 「ThinkPHP开发者周刊」招募志愿者
- ThinkPHP6.0日志变化
- ThinkPHP5.1.38版本发布——常规更新
- ThinkPHP6.0RC4版本发布——ORM独立，日志多通道支持
- ThinkORM2.0开发指南上线
- ThinkPHP6.0RC5版本发布——多应用模式独立，中间件机制调整
- ThinkPHP6.0版本发布——程序员节福利
- ThinkPHP5.1.39LTS版本发布——常规更新
- ThinkPHP6.0.1版本发布——圣诞快乐！
- 回顾2019，展望2020！
- ThinkPHPV6.0.2版本发布——2020新春快乐！
- 周年福利系列：Swoole合作优惠
- 亿速云成为ThinkPHPV6.0独家赞助发布商🎉
- 新冠疫情工具和限免资源专题（保持更新中）
- 周年福利系列：创宇信用认证合作优惠
- 周年福利系列：码云企业版限时10%优惠
- 周年福利系列：想天短说抵现优惠
- think-swoole直播：从零开始掌握swoole开发
- 周年福利系列：B2C开源电商ShopXO授权8折优惠
- 周年福利系列：LayuiAdmin 永久授权限时优惠
- ThinkPHP资源导航站上线——构建生态 服务未来
- ThinkPHP官方技术支持服务和应用服务市场上线公测
- ThinkPHP市场精选——推广基本要素
- ThinkPHP市场精选——客服聊天专题
- ThinkPHPV6.0.3版本发布——端午安康
- ThinkPHP开发者扶持计划
- 6.0.3版本关键更新及升级事项
- 「ThinkPHP开发者周刊」改版重启
- ThinkPHP市场精选——企业建站专题
- ThinkPHP 提供统一API接口服务
- ThinkPHP市场精选——直播电商专题
- ThinkAPI服务SDK发布
- 官方服务市场启用独立子域名
- ThinkPHP市场精选——刷脸支付专题
- ThinkAPI推出会员服务计划
- ThinkPHPV6.0.4版本发布——中秋国庆双节快乐
- ThinkPHPV5.1.40版本发布——常规更新
- 1024程序员节福利走一波
- ThinkPHP V6.0.5版本发布——兼容Composer2.0
- 知识图谱应用场景——源论技术沙龙
- ThinkPHP5.*版本改进Composer2.0的兼容
- 官方市场双十一精选推荐
- 技术人做产品有机会么（文末送课程）
- 本周秒杀——古德云售后获客营销系统
- ThinkAPI服务更新——支持接口分组和PHP版本依赖调整
- PHP8新特性盘点
- PHP8新特性系列：构造器属性提升使用及注意事项
- ThinkPHP2021新年寄语
- ThinkPHP V6.0.6&V5.1.41版本发布——兼容PHP8.0
- PHP如何更优雅地调用API接口
- ThinkPHP V6.0.7发布——修正版本
- ThinkAPI服务更新——IP白名单
- 最新版ThinkORM对于时间字段的调整
- ThinkAPI短信接口正式上线
- ThinkPHP V6.0.8版本发布——多环境变量配置支持
- 顶想云写作服务开启第一次公测
- ThinkSSL上线——官方SSL/TLS证书服务
- MDBootstrap国内用户福利——ThinkPHP官方市场首发
- ThinkPHP V6.0.9版本发布——常规更新
- ThinkORM功能盘点——虚拟模型
- 全面支持主流GIT版本库——云写作服务第二次公测
- 云写作服务私有化部署方案之：版本库私有化
- 看云双十一活动
- ThinkPHP V6.0.10LTS发布——兼容PHP8.1
- ThinkPHP V6.0.12发布——命令行兼容8.1
- 顶想云知识管理上线公测——构建企业文档中心和知识库
- 顶想云上线——助力生态数字化建设
- 618活动进行中——官方市场迎来一波更新
- 顶想云知识管理正式上线——看云文档启动迁移服务
- ThinkPHP V6.0.13发布——常规更新
- 顶想云网站助理服务上线——构建产品支持服务
- ThinkPHP发布6.1.0&6.0.14版本——安全更新
- ThinkPHP新版社区上线试运营
- ThinkAPI上架人脸核身接口——助力网站实名认证
- 辞旧迎新——旧版社区停止注册及发帖
- ThinkPHP6.1.2版本发布——兼容PHP8.2