首页 / PHP / PHP编程中的锁

PHP编程中的锁

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP编程中的锁，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7314字，纯文字阅读大概需要11分钟。

内容图文

PHP编程中的锁

最近看了《理解Linux进程》这本开源书，链接。该书描述了linux中的进程概念，对锁和进程间通信(IPC)有一些总结。不过该书的描述语言是golang, 平时用的比较少，就想对应概念找找php中的接口。

文件锁

全名叫 advisory file lock, 书中有提及。这类锁比较常见，例如 mysql, php-fpm 启动之后都会有一个pid文件记录了进程id，这个文件就是文件锁。

这个锁可以防止重复运行一个进程，例如在使用crontab时，限定每一分钟执行一个任务，但这个进程运行时间可能超过一分钟，如果不用进程锁解决冲突的话两个进程一起执行就会有问题。

使用PID文件锁还有一个好处，方便进程向自己发停止或者重启信号。例如重启php-fpm的命令为

kill -USR2 `cat /usr/local/php/var/run/php-fpm.pid`

发送USR2信号给pid文件记录的进程，信号属于进程通信，会另开一个篇幅。

php的接口为flock，文档比较详细。先看一下定义，bool flock ( resource $handle , int $operation [, int &$wouldblock ] ).

$handle是文件系统指针，是典型地由 fopen() 创建的 resource(资源)。这就意味着使用flock必须打开一个文件。
$operation 是操作类型。
&$wouldblock 如果锁是阻塞的，那么这个变量会设为1.

需要注意的是，这个函数默认是阻塞的，如果想非阻塞可以在 operation 加一个 bitmask LOCK_NB. 接下来测试一下。

$pid_file = "/tmp/process.pid";$pid = posix_getpid();$fp = fopen($pid_file, 'w+');if(flock($fp, LOCK_EX | LOCK_NB)){    echo "got the lock \n";    ftruncate($fp, 0);      // truncate file    fwrite($fp, $pid);    fflush($fp);            // flush output before releasing the lock    sleep(300); // long running process    flock($fp, LOCK_UN);    // 释放锁定} else {    echo "Cannot get pid lock. The process is already up \n";}fclose($fp);

保存为 process.php，运行php process.php &, 此时再次运行php process.php，就可以看到错误提示。flock也有共享锁，LOCK_SH.

互斥锁和读写锁

sync模块中的Mutex

Mutex是一个组合词，mutual exclusion。用pecl安装一下sync模块, pecl install sync。文档中的SyncMutex只有两个方法，lock 和 unlock，我们就直接上代码测试吧。没有用IDE写，所以cs异常丑陋，请无视。

$mutex = new SyncMutex("UniqueName");for($i=0; $i<2; $i++){    $pid = pcntl_fork();    if($pid <0){        die("fork failed");    }elseif ($pid>0){        echo "parent process \n";    }else{        echo "child process {$i} is born. \n";        obtainLock($mutex, $i);    }}while (pcntl_waitpid(0, $status) != -1) {     $status = pcntl_wexitstatus($status);     echo "Child $status completed\n"; }function obtainLock ($mutex, $i){    echo "process {$i} is getting the mutex \n";    $res = $mutex->lock(200);    sleep(1);    if (!$res){        echo "process {$i} unable to lock mutex. \n";    }else{        echo "process {$i} successfully got the mutex \n";        $mutex->unlock();    }    exit();}

保存为mutex.php, run php mutex.php, output is

parent process parent process child process 1 is born. process 1 is getting the mutex child process 0 is born. process 0 is getting the mutex process 1 successfully got the mutex Child 0 completedprocess 0 unable to lock mutex. Child 0 completed

这里子进程0和1不一定谁在前面。但是总有一个得不到锁。这里SyncMutex::lock(int $millisecond)的参数是 millisecond, 代表阻塞的时长， -1 为无限阻塞。

sync模块中的读写锁

SyncReaderWriter的方法类似，readlock, readunlock, writelock, writeunlock,成对出现即可，没有写测试代码，应该和Mutex的代码一致，把锁替换一下就可以。

sync模块中的Event

感觉和golang中的Cond比较像，wait()阻塞，fire()唤醒Event阻塞的一个进程。有一篇好文介绍了Cond, 可以看出Cond就是锁的一种固定用法。SyncEvent也一样。
php文档中的例子显示，fire()方法貌似可以用在web应用中。

上测试代码

for($i=0; $i<3; $i++){    $pid = pcntl_fork();    if($pid <0){        die("fork failed");    }elseif ($pid>0){        //echo "parent process \n";    }else{        echo "child process {$i} is born. \n";        switch ($i) {        case 0:            wait();            break;        case 1:            wait();            break;        case 2:            sleep(1);            fire();            break;        }    }}while (pcntl_waitpid(0, $status) != -1) {     $status = pcntl_wexitstatus($status);     echo "Child $status completed\n"; }function wait(){    $event = new SyncEvent("UniqueName");    echo "before waiting. \n";    $event->wait();    echo "after waiting. \n";    exit();}function fire(){    $event = new SyncEvent("UniqueName");    $event->fire();    exit();}

这里故意少写一个fire(), 所以程序会阻塞，证明了 fire() 一次只唤醒一个进程。

pthreads模块

貌似也看到了Mutex, Cond, Pool. 没来得及看，看完再补充。

信号量

sync模块中的信号量

SyncSemaphore文档中显示，它和Mutex的不同之处，在于Semaphore一次可以被多个进程(或线程)得到，而Mutex一次只能被一个得到。所以在SyncSemaphore的构造函数中，有一个参数指定信号量可以被多少进程得到。
public SyncSemaphore::__construct ([ string $name [, integer $initialval [, bool $autounlock ]]] ) 就是这个$initialval (initial value)

$lock = new SyncSemaphore("UniqueName", 2);for($i=0; $i<2; $i++){    $pid = pcntl_fork();    if($pid <0){        die("fork failed");    }elseif ($pid>0){        echo "parent process \n";    }else{        echo "child process {$i} is born. \n";        obtainLock($lock, $i);    }}while (pcntl_waitpid(0, $status) != -1) {     $status = pcntl_wexitstatus($status);     echo "Child $status completed\n"; }function obtainLock ($lock, $i){    echo "process {$i} is getting the lock \n";    $res = $lock->lock(200);    sleep(1);    if (!$res){        echo "process {$i} unable to lock lock. \n";    }else{        echo "process {$i} successfully got the lock \n";        $lock->unlock();    }    exit();}

这时候两个进程都能得到锁。

sysvsem模块中的信号量

sem_get 创建信号量
sem_remove 删除信号量（一般不用）
sem_acquire 请求得到信号量
sem_release 释放信号量。和 sem_acquire 成对使用。

$key = ftok('/tmp', 'c');$sem = sem_get($key);for($i=0; $i<2; $i++){    $pid = pcntl_fork();    if($pid <0){        die("fork failed");    }elseif ($pid>0){        //echo "parent process \n";    }else{        echo "child process {$i} is born. \n";        obtainLock($sem, $i);    }}while (pcntl_waitpid(0, $status) != -1) {     $status = pcntl_wexitstatus($status);     echo "Child $status completed\n"; }sem_remove($sem); // finally remove the semfunction obtainLock ($sem, $i){    echo "process {$i} is getting the sem \n";    $res = sem_acquire($sem, true);    sleep(1);    if (!$res){        echo "process {$i} unable to get sem. \n";    }else{        echo "process {$i} successfully got the sem \n";        sem_release($sem);    }    exit();}

这里有一个问题，sem_acquire()第二个参数$nowait默认为false，阻塞。我设为了true，如果得到锁失败，那么后面的sem_release会报警告 PHP Warning: sem_release(): SysV semaphore 4 (key 0x63000081) is not currently acquired in /home/jason/sysvsem.php on line 33, 所以这里的release操作必须放在得到锁的情况下执行，前面的几个例子中没有这个问题，没得到锁执行release也不会报错。当然最好还是成对出现，确保得到锁的情况下再release。

此外，ftok这个方法的参数有必要说明下，第一个必须是existing, accessable的文件, 一般使用项目中的文件，第二个是单字符字符串。返回一个int。

输出为

parent process parent process child process 1 is born. process 1 is getting the mutex child process 0 is born. process 0 is getting the mutex process 1 successfully got the mutex Child 0 completedprocess 0 unable to lock mutex. Child 0 completed

最后，如果文中有错误的地方，希望大神指出，帮助一下菜鸟进步，谢谢各位。

内容总结

以上是互联网集市为您收集整理的PHP编程中的锁全部内容，希望文章能够帮你解决PHP编程中的锁所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/207169.html

来源：【匿名】

【上一篇】php的异常和处理【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【PHP编程中的锁】教程文章相关的互联网学习教程文章

简单的php笔试编程题

//三角形function sanjiaoxing(){for($i=0;$i<6;$i++){for($j=0;$j<=$i;$j++){echo "*";}echo "<br>";}}sanjiaoxing(); //三角形例二for($i=1;$i<=10;$i++){for($x=1;$x<=10-$i;$x++){echo "&nbsp";}for($j=1;$j<=$i;$j++){echo "&nbsp*";}echo "<br>";} //杨辉三角function yanghui($n){for($i=0;$i<$n;$i++){$arr[$i][0]=1;$arr[$i][$i]=1;}for($i=2;$i<$n;$i++){for($j=1;$j<$i;$j++){$arr[$i][$j]=$arr[$i-1][$i-1]+$arr[$i-1]...

2020/2/5 php编程学习【图】

一事无成的上午。。就安了框架解决了一些报错信息下面简单了解一下安装一下框架：什么是路由：系统从URI（唯一资源定位器）参数中分析出当前请求的分组（平台），控制器和操作方法的过程就是路由。URL ：统一资源定位符 URI: 统一资源标识符 URL是URI的一个子集原文：https://www.cnblogs.com/wangtanzhi/p/12263110.html

PHP系统编程--02.PHP守护进程化【代码】

什么是守护进程?一个守护进程通常补认为是一个不对终端进行控制的后台任务。它有三个很显著的特征:在后台运行，与启动他的进程脱离，无须控制终端。常用的实现方式是fork() -> setsid() -> fork()在glibc里有一个函数daemon。调用此函数，就可使当前进程脱离终端变成一个守护进程，具体内容参见man daemon。PHP中暂时没有此函数，PHP程序实现守护进程化有2种方法：使用系统命令nohupnohup php myprog.php > log.txt &&，这样执行程...

PHP Socket编程之使用fsockopen()函数

PHPSocket编程Socket可以理解为两台计算机相互通信的通道。用法：使用fsockopen()函数具体用法详见上篇文章。函数的参数为URL、端口号、一个存放错误编号的变量、一个存放错误信息字符串的变量和超时等待时间。（只有第一个参数是必须的）常见的端口表：端口号主要用途21FTP22SSH23Telnet25SMTP80Web110POP其中，组成URl的几个部分为：协议名（scheme），主机（host），端口号（port），文件路径（path），查询参数（query）。当ur...

php多进程编程实现与优化【代码】

PHP多进程API创建子进程@params void @returns int int pcntl_fork(void) 成功时，在父进程执行线程内返回产生的子进程PID，在子进程执行线程内返回0，失败时，在父进程上下文返回-1，不会创建子进程，并且会引发一个php错误获取当前进程id@params void @returns int int posix_getpid(void) 返回进程id，类型为整型父进程等待子进程退出@params $status@params $option@return bool int pcntl_wait(int &$status[,int $options=0]...

PHP socket网络编程之使用curl

PHPsocket 网络编程之使用cURLcURl代表客户端URL，是一种专门处理URL的命令行工具。本文介绍cURl打开网页并向其提交数据。【示例】：cURL库被PHP用于向页面传递数据<?PHP//创建cURL事务$url = 'HTTP://localhost/service.php';$curl = curl_init($url);//如果发生错误，直接运行失败curl_setopt($curl,CURLOPT_FAILONERROR,1);//支持重定向curl_setopt($curl,CURLOPT_FOLLOWLOCATION,1);//设置是否将处理结果存入一个变量的选项cur...

提高PHP编程效率的20个要点

用单引号代替双引号来包含字符串，这样做会更快一些。因为PHP会在双引号包围的字符串中搜寻变量，单引号则不会，注意：只有echo能这么做，它是一种可以把多个字符串当作参数的“函数”(译注：PHP手册中说echo是语言结构，不是真正的函数，故把函数加上了双引号)。　 1、如果能将类的方法定义成static，就尽量定义成static，它的速度会提升将近4倍。 2、$row[’id’] 的速度是$row[id]的7倍。　　3、echo 比 print 快，并且...

PHP5权威编程阅读学习笔记附电子书下载

PHP 5 权威编程(PHP 5 Power Programming) PDF下载地址 http://www.jb51.net/books/28207.html PHP4中，不使用__construct()作为构造函数的名字，必须使用类的名字定义一个方法，就像在C++中一样。 PHP5中，使用新的统一的构造函数命名方式：__construct()，当然，使用类名同样也是可以的。但是，你如果两个同时使用的话，系统默认会使用__construct()的形式。复制代码代码如下:<?php class Person{ //PHP4中的方法 public func...

php编程零基础如何快速入门。门头沟编程

昨天遇到一个人，说知道thinktphp,不过几年前的事了。我先跟他讲了下，xyhcms后台功能，各个版块，以及数据库都介绍了一下。跟他说了一个功能现场实现，说了实现方法。然后上机操作，发现他表单提交、方法传值、页面传值、传值获取没有做，也不知道问。甚至input标签都不知道。这样的基础肯定面试很难通过。如果想快速入门要么看视频、要么报个培训班、要么找个人带。视频网站建议:php.cn原文：https://www.cnblogs.com/phpfangzh...

atitit.泛型编程总结最佳实践 vO99 java c++ c#.net php

atitit.泛型编程总结最佳实践 vO99 java c++ c#.net php\1. 泛型历史 1由来 12. 泛型的机制编辑 1机制 1编译机制 23. 泛型方法定义1::前定义 2标签... 2' ref='nofollow'>4. 泛型方法定义2::后定义，方法也需要加标签... 2meth(); 2' ref='nofollow'>5. 调用泛型方法::: cls.meth(); 26. //反回值为范型 27. 参考 3 1. 泛型历史泛型编程（Generic Programming）最初提出时的动机很简单直接：发明一种语言机制，能够帮助实现一个通...

9条PHP编程小知识及易犯的小错误

变量声明如果在一条语句中声明一个变量，如下所示：$var=‘value‘;编译器首先会求出语句右半部分的值，恰恰正是语句的这一部分常常会引发错误。如果使用的语法不正确，就会出现解析错误。解析错误例如，Parse error:解析错误，unexpected T_WHILE in c:program filesapache groupapachehtdocsscript.php on line 19每次确定了前一错误时，解析错误一个接一个地不断出现，PHP在第一个解析错误之后就停止执行脚本。而且，解析错误具...

php socket编程入门【代码】

服务端<?php /*** File name server.php* 服务器端代码* * @author guisu.huang* @since 2012-04-11* *///确保在连接客户端时不会超时set_time_limit(0); //设置IP和端口号$address = "127.0.0.1"; $port = 2046; //调试的时候，可以多换端口来测试程序！ /*** 创建一个SOCKET * AF_INET=是ipv4 如果用ipv6，则参数为 AF_INET6* SOCK_STREAM为socket的tcp类型，如果是UDP则使用SOCK_DGRAM */$sock = socket_create(AF_INET, SOCK_S...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / PHP编程中的锁

PHP编程中的锁

内容导读

内容图文

文件锁

互斥锁和读写锁

sync模块中的Mutex

sync模块中的读写锁

sync模块中的Event

pthreads模块

信号量

sync模块中的信号量

sysvsem模块中的信号量

内容总结

内容备注

内容手机端

【PHP编程中的锁】教程文章相关的互联网学习教程文章

简单的php笔试编程题

2020/2/5 php编程学习【图】

PHP系统编程--02.PHP守护进程化【代码】

PHP Socket编程之使用fsockopen()函数

php多进程编程实现与优化【代码】

PHP socket网络编程之使用curl

提高PHP编程效率的20个要点

PHP5权威编程阅读学习笔记附电子书下载

php编程零基础如何快速入门。门头沟编程

atitit.泛型编程总结最佳实践 vO99 java c++ c#.net php

9条PHP编程小知识及易犯的小错误

php socket编程入门【代码】

php设计模式介绍之编程惯用法【图】

2020/2/12 PHP编程学习

Android之网络编程利用PHP操作MySql插入数据（四）【代码】【图】

PHP - 相关标签

编程 - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程