请写一段PHP代码,确保多个进程同时写入同一个文件成功
发布网友
发布时间：2022-04-06 03:57
共4个回答
懂视网
时间：2022-04-06 08:19
php实现多进程的方法：通过pcntl与posix扩展来实现。根据需求我们可以使用pcntl_fork()函数创建子进程，使用pcntl_wait()函数来阻塞当前进程。
php多进程需要pcntl，posix扩展支持。
多进程实现只能在cli模式下，在web服务器环境下，会出现无法预期的结果。
（推荐视频教程：php视频教程）
多进程核心函数：
pcntl_fork(创建子进程)、pcntl_wait(阻塞当前进程)
详细介绍：
pcntl_fork:
一次调用两次返回，在父进程中返回子进程pid，在子进程中返回0，出错返回-1。
pcntl_wait ( int &$status [, int $options ] )：
阻塞当前进程，直到任意一个子进程退出或收到一个结束当前进程的信号,注意是结束当前进程的信号,子进程结束发送的SIGCHLD不算。使用$status返回子进程的状态码，并可以指定第二个参数来说明是否以阻塞状态调用
阻塞方式调用的，函数返回值为子进程的pid,如果没有子进程返回值为-1；
非阻塞方式调用，函数还可以在有子进程在运行但没有结束的子进程时返回0。
pcntl_waitpid ( int $pid , int &$status [, int $options ] )
功能同pcntl_wait，区别为waitpid为等待指定pid的子进程。当pid为-1时pcntl_waitpid与pcntl_wait 一样。在pcntl_wait和pcntl_waitpid两个函数中的$status中存了子进程的状态信息。
（相关教程推荐：php图文教程）
举例：
php中一个始终保持固定个数的子进程在跑。
根据需求使用pcntl_fork(创建子进程)、pcntl_wait(阻塞当前进程)等核心函数
代码实现：
<?php
//最大的子进程数量
$maxChildPro = 8;
//当前的子进程数量
$curChildPro = 0;
//当子进程退出时，会触发该函数,当前子进程数-1
function sig_handler($sig)
{
global $curChildPro;
switch ($sig) {
case SIGCHLD:
echo 'SIGCHLD', PHP_EOL;
$curChildPro--;
break;
}
}
//配合pcntl_signal使用，简单的说，是为了让系统产生时间云，让信号捕捉函数能够捕捉到信号量
declare(ticks = 1);
//注册子进程退出时调用的函数。SIGCHLD：在一个进程终止或者停止时，将SIGCHLD信号发送给其父进程。
pcntl_signal(SIGCHLD, "sig_handler");
while (true) {
$curChildPro++;
$pid = pcntl_fork();
if ($pid) {
//父进程运行代码,达到上限时父进程阻塞等待任一子进程退出后while循环继续
if ($curChildPro >= $maxChildPro) {
pcntl_wait($status);
}
} else {
//子进程运行代码
$s = rand(2, 6);
sleep($s);
echo "child sleep $s second quit", PHP_EOL;
exit;
}
}
热心网友
时间：2022-04-06 05:27
用flock在写文件前先锁上，等写完后解锁，这样就实现了多线程同时读写一个文件避免冲突。大概就是下面这个流程
/*
*flock(file,lock,block)
*file 必需，规定要锁定或释放的已打开的文件
*lock 必需。规定要使用哪种锁定类型。
*block 可选。若设置为 1 或 true，则当进行锁定时阻挡其他进程。
*lock
*LOCK_SH 要取得共享锁定（读取的程序）
*LOCK_EX 要取得独占锁定（写入的程序）
*LOCK_UN 要释放锁定（无论共享或独占）
*LOCK_NB 如果不希望 flock() 在锁定时堵塞
/*
if (flock($file,LOCK_EX))
{
fwrite($file,'write more words');
flock($file,LOCK_UN);
}
else
{
//处理错误逻辑
}
fclose($file);
)
热心网友
时间：2022-04-06 06:45
// 排它性的锁定 先锁上，写完，打开。
if (flock($file,LOCK_EX))
{
fwrite($file,"Write something");
// release lock
flock($file,LOCK_UN);
}
else
{
echo "Error locking file!";
}
fclose($file);
热心网友
时间：2022-04-06 08:19
function write_file($filename, $content)
{
$lock = $filename . '.lck';
$write_length = 0;
while(true) {
if( file_exists($lock) ) {
usleep(100);
} else {
touch($lock);
$write_length = file_put_contents($filename, $content, FILE_APPEND);
break;
}
}
if( file_exists($lock) ) {
unlink($lock);
}
return $write_length;
}
