进程锁
使用进程锁
进程锁在特定场景是非常适用的,而操作系统默认不会为每个程序创建进程锁,那我们该如何使用呢?
-
其实要实现一个进程锁很简单,通过文件就可以实现了。例如程序开始运行时去检查一个PID文件,如果文件存在就直接退出,如果文件不存在就创建一个,并把当前进程的PID写入文件中。这样我们很容易可以实现进程锁,但是所有流程都需要自己控制。
-
当然根据DRY(Don’t Repeat Yourself)原则,Linux已经为我们提供了flock接口。
使用Flock
- Flock提供的是advisory lock,也就是建议性的锁,其他进程实际上也可以读写这个锁文件。Linux上可以直接使用flock命令,使用C可以调用原生的flock接口
- php 也提供了 flock 文件锁函数,下面我们来实现一下进程锁
$file = 'process.pid';
$fp = fopen($file, 'c');
if (!$fp) {
throw new \Exception('Can\'t create lock file!');
}
if(flock($fp, LOCK_EX)){
ftruncate($fp, 0); //清空文件内容
$pid = getmypid(); //获取当前进程pid
fwrite($fp, $pid);
fflush($fp); //释放锁之前刷新输出
flock($fp , LOCK_UN);//释放锁
}else{
echo "打不开锁\n";
}
- 区分读锁定 和 写 锁定。
如果每次都使用 写锁定,那么连多个进程读取一个文件也要排队,这样的效率肯定不行。 - 读锁:
LOCK_SH
(share-lock)共享锁,读操作前,期望增加的锁定。导致,允许并发读,阻塞额外的写操作。 - 写锁:
LOCK_EX
(exclusive-lock)排他锁,独占锁,写操作前,尝试添加的锁定类型。导致,其他脚本不能读也不能写。 - 这两种都是阻塞模式
$file = 'process.pid';
$fp = fopen($file, 'c');
if (!$fp) {
throw new \Exception('Can\'t create lock file!');
}
if(flock($fp, LOCK_EX)){
ftruncate($fp, 0); //清空文件内容
$pid = getmypid(); //获取当前进程pid
fwrite($fp, $pid);
fflush($fp); //释放锁之前刷新输出
sleep(30); //模拟并发
flock($fp , LOCK_UN);//释放锁
}else{
echo "打不开锁\n";
}
- 可以通过
LOCK_NB
来在锁定失败时,不阻塞:
$file = 'process.pid';
$fp = fopen($file, 'c');
if (!$fp) {
throw new \Exception('Can\'t create lock file!');
}
if(flock($fp, LOCK_EX|LOCK_NB)){
ftruncate($fp, 0); //清空文件内容
$pid = getmypid(); //获取当前进程pid
fwrite($fp, $pid);
fflush($fp); //释放锁之前刷新输出
sleep(30); //模拟并发
flock($fp , LOCK_UN);//释放锁
}else{
echo "打不开锁\n";
}