这篇文章给大家介绍怎么在php中实现一个多进程服务器类,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
一、phpStudy,是一个新手入门最常用的开发环境。二、WampServer,WampServer也同样的也是和phpStudy一样操作简单对小白比较友好。三、XAMPP,XAMPP(Apache+MySQL+PHP+PERL)是一个功能强大的建站集成软件包;四、MAMP,MAMP分为两种MAMP和MAMP Pro for Mac。五、宝塔面板,宝塔面板是一款服务器管理软件,支持windows和linux系统。六、UPUPW,UPUPW是目前Windows平台下最具特色的Web服务器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("/GET\s(.*?)\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("/GET\s(.*?)\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); //开始监听 } /** * 协议过滤 * @param $reg * @param $buf * @return mixed */ protected function checkRule($reg,$buf){ if(preg_match($reg,$buf,$matchs)){ return $matchs; } return false; } //请求处理类 public function request($buf){ //1.只允许http协议访问 // if(preg_match("GET\s(.*?)\sHTTP/1.1",$buf,$matchs)){ //匹配到http协议 // return true; // }else{ // return false; // } //2.过滤掉/favicon.ico //3.获取请求信息 } protected function response($content,$client){ //返回数据给客户端,响应处理 $string="HTTP/1.1 200 OK\r\n"; $string.="Content-Type: text/html;charset=utf-8\r\n"; $string.="Content-Length: ".strlen($content)."\r\n\r\n"; socket_write($client,$string.$content); } }
关于怎么在php中实现一个多进程服务器类就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。