php 利用flock来处理并发数据处理
2023-09-11 14:19:35 时间
利用flock()函数对文件进行加锁(排它锁),实现并发按序进行。
flock(file,lock,block)有三个参数。
- file:已经打开的文件
- lock:锁的类型
LOCK_SH:共享锁(读锁)
LOCK_EX:独占锁定(排它锁,写锁)
LOCK_UN:解锁
LOCK_NB:如果希望在文件锁定时阻塞进程,那么需要加上该参数 - block:设置为true的时候,锁定文件时,会阻止其他进程
下面是一个demo:
阻塞模式(后面的进程会一直等待前面的进程执行完毕)
$product_id = 1;//获取产品id $file = fopen('./lock/lock'.$product_id.'.txt', 'w'); //加锁 if(flock($file,LOCK_EX)){ $number=Db::table('specification')->field('inventory')->where('specification_id','=',1)->find(); // 计数器 if($number['inventory']>=1){ //处理订单 Db::table('specification')->where('specification_id','=',1)->dec('inventory')->update(); flock($file, LOCK_UN);//释放锁 fclose($file); echo json(['code'=>200,'result'=>'购买成功'])->getContent();die; }else{ flock($file, LOCK_UN);//释放锁 fclose($file); \exception('库存不足',500); } }
非阻塞模式(只要当前文件有锁存在,那么直接返回)
$product_id = 1;//获取产品id $file = fopen('./lock/lock'.$product_id.'.txt', 'w'); //加锁 if(flock($file,LOCK_EX|LOCK_NB)){ $number=Db::table('specification')->field('inventory')->where('specification_id','=',1)->find(); // 计数器 if($number['inventory']>=1){ //处理订单 Db::table('specification')->where('specification_id','=',1)->dec('inventory')->update(); flock($file, LOCK_UN);//释放锁 fclose($file); echo json(['code'=>200,'result'=>'购买成功'])->getContent();die; }else{ flock($file, LOCK_UN);//释放锁 fclose($file); \exception('库存不足',500); } }else{ \exception('系统繁忙,请稍后再试',500); }
来源:https://www.kancloud.cn/mr_y/wechat/1332950
相关文章
- [php learn] php 从头開始学习1
- 全面解读php-网络协议
- redis 在 php 中的应用(List篇)
- Can't find PHP headers in /usr/include/php
- PHP程序员的技术成长规划
- PHP 表单 - 3(PHP 表单 - 必需字段)
- php之快速入门学习-18(PHP 面向对象)
- php之快速入门学习-4(数据类型)
- 统计php程序运行时间及设置PHP最长运行时间
- 5种PHP创建数组的方式
- PHP执行系统外部命令函数:exec()、passthru()、system()、shell_exec()
- php addslashes() 函数
- 发现一php木马代码
- PHP 生成随机字符串与唯一字符串
- 转 php 框架 Php 依赖框架 后台 调用python 脚本
- PHP 小tip .(@)符号和 php if 赋值
- PHP(基本语法)PHP中的Session-登录案例
- php结合redis实现高并发下的抢购、秒杀功能
- PHP的mod_rewrite重写模块将.php后缀换成.html