php 非阻塞post请求,php 非阻塞处理多进程请求

心已赠人 2022-11-12 13:46 158阅读 0赞

$pid = pcntl\_fork();

if($pid==-1)\{

throw new RuntimeException("fork error");

exit(0);

\}else if($pid==0)\{

run();

\}else\{

exit("exit");

function run()\{

$curChildPro = 0;

$maxChildPro = 5; // 同一时刻最多 5 个进程

$index = 0;

$ppid = posix\_getpid();

$childs=\[\];

$readFds = \[\];

$writeFds= \[\];

$exceptions = \[\];

$context\_option\['socket'\]\['backlog'\] = 1024;

$context = stream\_context\_create($context\_option);

stream\_context\_set\_option($context, 'socket', 'so\_reuseport', 1);

$socket = stream\_socket\_server("tcp://0.0.0.0:8081", $errno, $errstr);

stream\_set\_blocking($socket,0);

$readFds\[\]=$socket;

while (true) \{

while (count($childs)>=$maxChildPro)\{

foreach($childs as $key => $pid) \{

$res = pcntl\_waitpid($pid, $status, WNOHANG);

// If the process has already exited

if($res == -1 || $res > 0)

unset($childs\[$key\]);

sleep(1);

$index ++;

$pid = pcntl\_fork();//在此处代码会裂开两部分，一个父进程，一个子进程，可以共享$index变量

if ($pid == -1) \{

\}elseif ($pid > 0) \{

$childs\[\]=$pid;

$curChildPro++;

//父进程会得到子进程号$pid，所以这里是父进程执行的逻辑

//echo "-------- current process\\e\[1;31m" . $curChildPro . "\\e\[0m--------.\\r\\n";

//echo "\\e\[1;31m我是父进程\{$index\},我的进程id是\{$ppid\}.我的子进程id\{$pid\}\\e\[0m".PHP\_EOL;

cli\_set\_process\_title("我是父进程\{$index\},我的进程id是\{$ppid\}.我的子进程id\{$pid\}");

\}elseif($pid==0)\{

$cpid = posix\_getpid();

//echo "我是\{$ppid\}的子进程,我的进程\{$index\}id是\{$cpid\}.".PHP\_EOL;

cli\_set\_process\_title("我是\{$ppid\}的子进程,我的进程id是\{$cpid\}.");

while (1) \{

$reads = $readFds;

$writes = $writeFds;

$ret = @stream\_select($reads, $writes, $exceptions, null);

if (!$ret)\{

continue;

if (!empty($reads)) \{

foreach ($reads as $fd) \{

if ($fd == $socket) \{

set\_error\_handler(function () \{

\});

$connect = stream\_socket\_accept($socket, 0, $remoteAddr);

stream\_set\_blocking($connect, 0);

restore\_error\_handler();

$readFds\[\] = $connect;

$writeFds\[\] = $connect;

\} else \{

$data = fread($fd, 1024);

if ($data == '') \{

$ret = array\_search($fd, $readFds);

if ($ret !== false) \{

unset($readFds\[$ret\]);

fclose($fd);

\} else \{

//request data

if(!empty($writes))\{

foreach ($writes as $fd) \{

if ($fd != $socket) \{

set\_error\_handler(function () \{

\});

$res = "HTTP/1.1 200 ok\\r\\nAccept-Ranges: bytes\\r\\ncontent-type: text/html; charset=utf-8\\r\\n\\r\\nThe local time is " . date('Y-m-d H:i:s') . "\\r\\n";

fwrite($fd, $res);

restore\_error\_handler();

$wet = array\_search($fd, $writeFds);

if ($wet !== false) \{

unset($writeFds\[$wet\]);

fclose($fd);

exit();

php 非阻塞post请求,php 非阻塞处理多进程请求

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关同步&异步+阻塞&非阻塞

相关 php 非阻塞post请求,php 非阻塞处理多进程请求

相关阻塞与非阻塞

相关 php使用flock阻塞写入文件和非阻塞写入文件

相关同步异步阻塞非阻塞

相关等待队列阻塞非阻塞

相关如何理解同步阻塞、同步非阻塞、异步阻塞、异步非阻塞

相关阻塞和非阻塞~

相关同步异步阻塞非阻塞

相关同步阻塞、同步非阻塞、异步阻塞、异步非阻塞