怎么在php中實(shí)現(xiàn)一個(gè)多進(jìn)程服務(wù)器類

這篇文章給大家介紹怎么在php中實(shí)現(xiàn)一個(gè)多進(jìn)程服務(wù)器類，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

PHP開發(fā)環(huán)境搭建工具有哪些

一、phpStudy，是一個(gè)新手入門最常用的開發(fā)環(huán)境。二、WampServer，WampServer也同樣的也是和phpStudy一樣操作簡單對小白比較友好。三、XAMPP，XAMPP（Apache+MySQL+PHP+PERL）是一個(gè)功能強(qiáng)大的建站集成軟件包；四、MAMP，MAMP分為兩種MAMP和MAMP Pro for Mac。五、寶塔面板，寶塔面板是一款服務(wù)器管理軟件，支持windows和linux系統(tǒng)。六、UPUPW，UPUPW是目前Windows平臺下最具特色的Web服務(wù)器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(); //創(chuàng)建一個(gè)通訊節(jié)點(diǎn)
  }
  public function listen($callback)
  {
    if(!is_callable($callback)){
      throw new Exception('不是閉包，請傳遞正確的參數(shù)');
    }
    //只要我們接收到客戶端的數(shù)據(jù)，就fork一個(gè)子進(jìn)程處理
    while ($client = socket_accept($this->server)) { //等待客戶端接入，返回的是客戶端的連接
      $buf = socket_read($client, 1024); //讀取客戶端內(nèi)容
      $pid=pcntl_fork(); //創(chuàng)建子進(jìn)程
      //父進(jìn)程和子進(jìn)程都會執(zhí)行下面代碼
      if ($pid == -1) {
        //錯(cuò)誤處理：創(chuàng)建子進(jìn)程失敗時(shí)返回-1.
        die('could not fork');
      } else if ($pid) {
        //父進(jìn)程會得到子進(jìn)程號，所以這里是父進(jìn)程執(zhí)行的邏輯
        var_dump('父進(jìn)程',$pid);
        pcntl_wait($status); //等待子進(jìn)程中斷，防止子進(jìn)程成為僵尸進(jìn)程。
      } else {
        //子進(jìn)程得到的$pid為0, 所以這里是子進(jìn)程執(zhí)行的邏輯。
        //睡眠
        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;
        }
        //響應(yīng)
        $response= call_user_func($callback,$buf); //回調(diào)$callback函數(shù)
        $this->response($response,$client);
        usleep(1000); //微妙為單位，1000000 微妙等于1秒
        socket_close($client);
        exit(); //直接退出
      }
    }
//    while (true) {
//      $client = socket_accept($this->server); //等待客戶端接入，返回的是客戶端的連接
//      $buf = socket_read($client, 1024); //讀取客戶端內(nèi)容
//
//      //睡眠
//      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;
//      }
//
//      //響應(yīng)
//      $response= call_user_func($callback,$buf); //回調(diào)$callback函數(shù)
//      $this->response($response,$client);
//      usleep(1000); //微妙為單位，1000000 微妙等于1秒
//      socket_close($client);
//
//    }
    socket_close($this->server);
  }
  //io 復(fù)用
  //epoll 模型
  //多進(jìn)程
  protected function createSocket()
  {
    $this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    //bind
    socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1); //復(fù)用還處于 TIME_WAIT
    socket_bind($this->server, $this->ip, $this->port); //細(xì)節(jié)性的處理自行完成
    socket_listen($this->server); //開始監(jiān)聽
  }
  /**
   * 協(xié)議過濾
   * @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協(xié)議訪問
//    if(preg_match("GET\s(.*?)\sHTTP/1.1",$buf,$matchs)){ //匹配到http協(xié)議
//      return true;
//    }else{
//      return false;
//    }
    //2.過濾掉/favicon.ico
    //3.獲取請求信息
  }
  protected function response($content,$client){
    //返回?cái)?shù)據(jù)給客戶端,響應(yīng)處理
    $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);
  }
}

關(guān)于怎么在php中實(shí)現(xiàn)一個(gè)多進(jìn)程服務(wù)器類就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。