php实现的简单多进程服务器类完整示例

本文实例讲述了php实现的简单多进程服务器类。分享给大家供大家参考，具体如下：

php写的一个简单的多进程服务器。

<?phpclass rver{  public $port;  public $ip;  protected $rver;  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->rver)) { //等待客户端接入，返回的是客户端的连接      $buf = socket_read($client, 1024); //读取客户端内容      $pid=pcntl_fork(); //创建子进程      //父进程和子进程都会执行下面代码      if ($pid == -1) {        //错误处理：创建子进程失败时返回-1.        die('could not fork');      } el if ($pid) {        //父进程会得到子进程号，所以这里是父进程执行的逻辑        var_dump('父进程',$pid);        pcntl_wait($status); //等待子进程中断，防止子进程成为僵尸进程。      } el {        //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。        //睡眠        if($this->checkrule("/sleep/i",$buf)){          sleep(10);          $this->respon('休眠10s',$client);          socket_clo($client);          return;        }        //请求过滤        if(empty($this->checkrule("/get\s(.*?)\shttp\/1.1/i",$buf))){          socket_clo($client);          return;        }        //响应        $respon= call_ur_func($callback,$buf); //回调$callback函数        $this->respon($respon,$client);        usleep(1000); //微妙为单位，1000000 微妙等于1秒        socket_clo($client);        exit(); //直接退出      }    }//    while (true) {//      $client = socket_accept($this->rver); //等待客户端接入，返回的是客户端的连接//      $buf = socket_read($client, 1024); //读取客户端内容////      //睡眠//      if($this->checkrule("/sleep/i",$buf)){//        sleep(10);//        $this->respon('休眠10s',$client);//        socket_clo($client);//        return;//      }//      //请求过滤//      if(empty($this->checkrule("/get\s(.*?)\shttp\/1.1/i",$buf))){//        socket_clo($client);//        return;//      }////      //响应//      $respon= call_ur_func($callback,$buf); //回调$callback函数//      $this->respon($respon,$client);//  中秋节佳节感恩送祝福    usleep(1000); //微妙为单位，1000000 微妙等于1秒//      socket_clo($client);////    }    socket_clo($this->rver);  }  //io 复用  //epoll 模型  //多进程  protected function createsocket()  {    $this->rver = socket_create(af_inet, sock_stream, sol_tcp);    //bind    socket_t_option($this->rver, sol_socket, so_reuaddr, 1); //复用还处于 time_wait    socket_bind($this->rver, $this->ip, $this->port); //细节性的处理自行完成    socket_listen($this->rver); //开始监听  }  /**   * 协议过滤   * 顺序有哪些@param $reg   * @param $buf   * @return mixed   */  protected function checkrule($reg,$buf){    if(preg_match($reg,$buf,$matchs)){      return $matchs;    }    return fal;  }  //请求处理类  public function request($buf){    //1.只允许http协议访问//    if(preg_match("get\s(.*?)\shttp/1.1",$buf,$matchs)){ //匹配到http协议//      return true;//    }el{//      return fal;//    }    //2.过滤掉/favicon.ico    //3.获取请求信息  }  protected function respon($content,$client){    //返回数据给客户端,响应处理    $string=2020今年闰几月"http/1.1 200 ok\r\n";    $string.="content-type: text/html;chart=utf-8\r\n";    $string.="content-length: ".strlen($content)."\r\n\r\n";    socket_write($client,$string.$content);  }}