运用PHP怎样写一个多进程服务器？
发布时间：2021-12-31 11:15:07 所属栏目：PHP教程 来源：互联网
导读：使用PHP怎样写一个多进程服务器？很多新手对于如何多进程服务器比较感兴趣，因此下面给大家分享一个实现简单多进程服务器的实例，大家可以参考看看，希望对大家了解多进程服务器的实现有帮助。 php写的一个简单的多进程服务器。 ?php class server { publi
|
使用PHP怎样写一个多进程服务器？很多新手对于如何多进程服务器比较感兴趣，因此下面给大家分享一个实现简单多进程服务器的实例，大家可以参考看看，希望对大家了解多进程服务器的实现有帮助。 php写的一个简单的多进程服务器。 <?php class server { public $port; public $ip; protected $server; public function __construct($ip = '0.0.0.0', $port) { $this->ip = $ip; $this->port = $port; $this->createSocket(); //创建一个通讯节点 } public function listen($callback) { if(!is_callable($callback)){ throw new Exception('不是闭包，请传递正确的参数'); } //只要我们接收到客户端的数据，就fork一个子进程处理 while ($client = socket_accept($this->server)) { //等待客户端接入，返回的是客户端的连接 $buf = socket_read($client, 1024); //读取客户端内容 $pid=pcntl_fork(); //创建子进程 //父进程和子进程都会执行下面代码 if ($pid == -1) { //错误处理：创建子进程失败时返回-1. die('could not fork'); } else if ($pid) { //父进程会得到子进程号，所以这里是父进程执行的逻辑 var_dump('父进程',$pid); pcntl_wait($status); //等待子进程中断，防止子进程成为僵尸进程。 } else { //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。 //睡眠 if($this->checkRule("/sleep/i",$buf)){ sleep(10); $this->response('休眠10S',$client); socket_close($client); return; } //请求过滤 if(empty($this->checkRule("/GETs(.*?)sHTTP/1.1/i",$buf))){ socket_close($client); return; } //响应 $response= call_user_func($callback,$buf); //回调$callback函数 $this->response($response,$client); usleep(1000); //微妙为单位，1000000 微妙等于1秒 socket_close($client); exit(); //直接退出 } } // while (true) { // $client = socket_accept($this->server); //等待客户端接入，返回的是客户端的连接 // $buf = socket_read($client, 1024); //读取客户端内容 // // //睡眠 // if($this->checkRule("/sleep/i",$buf)){ // sleep(10); // $this->response('休眠10S',$client); // socket_close($client); // return; // } // //请求过滤 // if(empty($this->checkRule("/GETs(.*?)sHTTP/1.1/i",$buf))){ // socket_close($client); // return; // } // // //响应 // $response= call_user_func($callback,$buf); //回调$callback函数 // $this->response($response,$client); // usleep(1000); //微妙为单位，1000000 微妙等于1秒 // socket_close($client); // // } socket_close($this->server); } //io 复用 //epoll 模型 //多进程 protected function createSocket() { $this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //bind socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1); //复用还处于 TIME_WAIT socket_bind($this->server, $this->ip, $this->port); //细节性的处理自行完成 socket_listen($this->server); //开始监听 } （编辑：PHP编程网 - 黄冈站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
浙公网安备 33038102330482号