php实现的简单多进程服务器类完整示例
吾爱主题
阅读：120
2021-09-28 11:40:00
评论：0
本文实例讲述了php实现的简单多进程服务器类。分享给大家供大家参考，具体如下：
php写的一个简单的多进程服务器。
?| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 | <?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程序设计有所帮助。
原文链接：https://blog.csdn.net/qq_22640823/article/details/103468715
声明
1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，请转载时务必注明文章作者和来源，不尊重原创的行为我们将追究责任；3.作者投稿可能会经我们编辑修改或补充。
