备份下代码
<?php
namespace Lib\Library;
use Closure;
use Exception;
/**
* 文件锁
* 1.阻塞,进程加锁时发现其他进程已经加锁会一直阻塞等待,一直等到可以加锁成功,然后去执行业务代码
* 2.非阻塞,进程加锁时发现其他进程已经加锁直接返回,不会执行业务代码
* 3.注意Erp默认Session驱动为文件,本身请求已经存Session锁机制,所以测试非阻塞时请修改Session驱动为Redis
* @package Lib\Library
*/
class FileLock
{
/**
* 锁文件位置
* @var string
*/
private $file;
/**
* 锁文件句柄
* @var
*/
private $fileHandle;
/**
* 构造函数
* @param string $name 锁名称
* @throws Exception
*/
public function __construct($name = 'lock')
{
//初始化文件
$path = RUNTIME_PATH . 'Lock' . DIRECTORY_SEPARATOR;
$this->file = $path . md5($name);
if (!is_dir($path)) {
if (!mkdir($path, 0777, true)) {
throw new Exception('文件锁目录创建失败,请检查目录' . $path . '是否可写');
}
}
if (!file_exists($this->file)) {
if (file_put_contents($this->file, '')) {
throw new Exception('文件锁创建失败,请检查文件' . $this->file . '是否可写');
}
}
}
/**
* 加锁
* @param bool $block
* @return bool
*/
public function lock($block = true)
{
$this->fileHandle = fopen($this->file, 'r');
$is_flock = $block ? flock($this->fileHandle, LOCK_EX) : flock($this->fileHandle, LOCK_EX | LOCK_NB);
if (!$is_flock) {
fclose($this->fileHandle);
}
return $is_flock;
}
/**
* 释放
*/
public function release()
{
if (!$this->fileHandle) {
return false;
}
$unlock = flock($this->fileHandle, LOCK_UN);
if ($unlock) {
fclose($this->fileHandle);
$this->fileHandle = null;
}
return $unlock;
}
/**
* 加锁执行
* @param Closure $func 执行闭包函数
* @param bool $block 是否阻塞
* @return mixed 闭包函数的返回值
*/
public function lockToExecute($func, $block = true)
{
$is_flock = $this->lock($block);
$call_back = null;
if ($is_flock) {
$call_back = $func();
$this->release();
}
return $call_back;
}
} 首先看看以下代码:代码1:<?php $a=0.1; $b=0.7; if($a+$b==0.8) { echo "1"; } else{ echo "2"; } ?>代码2:<?php &n...
if($_SERVER['REQUEST_METHOD'] == 'POST') { echo('This is post '); } elseif ($_SERVER['...
xmlrpc协议是通过http请求xml数据进行通信。webservice中和它相同的是soap。soap调用的确很简单,但是创建wsdl太繁琐,效率低下。xmlrpc很好的解决这个问题。(1).创建xmlrpc服务端(求和函数api)function getSum($method,$ar...
<?php $member = new class { public function getInfo() { ...
自己的composer已经发布到packagist,但是无法使用composer require easy-task/easy-task来安装,只能在配置文件使用如下方式安装:"require": { "easy...
第一次听说端口复用是在mixphp最新版本中发现的,mixphp启动监听9501端口,现在作者说可以多开几个进程来执行mixphp,我心里想了下再启动不是会端口冲突嘛,但是却没有问题,于是下载mixphp的源码解读,原来是启动http服务器使用new Co\Http\Server('0.0....