文件锁
$fp = fopen('/tmp/file.lock',"a+");
//进行排他锁定，阻塞等待,等待上一个用户释放
if(flock($fp,LOCK_EX)) {
//LOCK_EX 就是独占锁，排他锁 悲观锁
// mysql 中也有排他锁， update tablename set for update ,这个for update 就是排他锁
fwrite($fp,"Lock Success");//模拟执行业务逻辑
//执行业务逻辑
sleep(5);
flock($fp,LOCK_UN);//释放锁定
} else {
echo "文件正在被其他线程占用";
}
fclose($fp);
redis锁
class Lock {
protected $redis;
protected $lockId;//记录加锁客户端的id
public function __construct($redis) {
$this->redis = $redis;
}
/**
* @param sting $scene 业务场景
* @param int $expire 过期时间
* @param int $retry 等待尝试次数
* @param int $sleep 等待时间
*/
public function Lock($scene="secKill",$expire=5,$retry=5,$sleep=10000){
//同一个时刻只能有一个用户持有锁，并且不能出现死锁
$res = false;
while($retry-- >0) {
$value = session_create_id();//生成不重复的字符串(唯一的值)
//NX 表示只在键不存在时，才对键进行设置操作。
$res = $this->redis->set($scene,$value,['NX','EX'=>$expire]);
if($res) {
//加锁成功了
//这样存储 应该是存在php对象里面
$this->lockId[$scene] = $value;
var_dump('加锁成功了');
break;//跳出循环
}
echo '尝试获取锁'.PHP_EOL;
usleep($sleep);//usleep 是以微秒为单位
}
return $res;
}
public function unLock($scene) {
if (isset($this->lockId[$scene])) {
$id = $this->lockId[$scene]; // 当前请求记录的value 值，我认为是从内存中取出来的
//在极端情况下，还是会出现误删除锁
//redis 中嵌入lua 脚本
// 减少网络开销 不使用Lua 的代码需要向redis 发送多次请求 ，而脚本只需要一次即可，减少网络传输
//应该删除自己的锁，而不应该删除别人的锁
$value = $this->redis->get($scene);//先取出当前数据库当中记录的锁，从数据库当中取出来的
//从redis中获取的id 跟当前请求记录的id 是否是同一个。
if($value == $id) {
sleep(5);//阻塞 这种情况考虑的应该是在解锁过程中出现了阻塞，那么还是会出现误删其他请求锁的情况（需要通过原子性去解决）
var_dump('正常删除');
return $this->redis->del($scene);//删除锁
}
}
}
}
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
$lock = new Lock($redis);
//如果加锁成功，某个业务只允许一个用户操作
$scene="secKill";
if($lock->Lock($scene,5)) {
var_dump('执行业务逻辑');
sleep(10);
$res = $lock->unLock($scene);
var_dump($res);
var_dump('解锁成功');
return;
}
var_dump('获取锁失败');
//分布式锁的基本条件
//1.互斥性 在任意时刻，只有一个客户端能够持有锁
//2.不会发生死锁。即使有一个客户端在持有锁期间奔溃而没有主动解锁，也能保证后续其他客户能加锁。
//3.加锁，解锁必须是同一客户端。
