<?php
class Worker{
     //監聽socket
     protected $socket = NULL;
     //連接事件回調
     public $onConnect = NULL;
     //接收消息事件回調
     public $onMessage = NULL;
     protected $workerNumber = 10;
     public function __construct($socket_address) {
          // 協議解析
          if (!$res = parse_url($socket_address))
          {
               echo "failed to parse address";
               exit();
          }
          extract($res);

          $protocol = SOCK_STREAM;
          switch ($scheme) {
               case 'tcp':
                    $protocol = SOCK_STREAM;
                    break;
               case 'udp':
                    $protocol = SOCK_DRAM;
                    break;
               default:
                    # code...
                    break;
          }

          // 初始化socket句柄
          if(($sock = socket_create(AF_INET, $protocol, 0)) < 0)
          {
              echo "failed to create socket: ".socket_strerror($sock)."\n"; 
              exit(); 
          } 

          if(($ret = socket_bind($sock, $host, $port)) < 0) 
          { 
              echo "failed to bind socket: ".socket_strerror($ret)."\n"; 
              exit(); 
          } 

          if( ( $ret = socket_listen( $sock, 0 ) ) < 0 ) 
          { 
              echo "failed to listen to socket: ".socket_strerror($ret)."\n"; 
              exit(); 
          }

          $this->socket = $sock;

     }

     public function fork()
     {
          for ($i=0; $i < $this->workerNumber; $i  ) {
               $pid = pcntl_fork();
               if ($pid == -1) {
                    die('could not fork');
               } else if ($pid == 0) {
                    // we are the child
                    $this->accept();
                    exit;
               }
          }

          for ($i=0; $i < $this->workerNumber; $i  ) { 
               $status=0;
               $pid=pcntl_wait($status); //Protect against Zombie children
               echo "子進程回收了:$pid".PHP_EOL;
          }
           
     }

     public function accept()
     {
          $client_id = 0;
          while (true) {
               if (($msgsock = socket_accept($this->socket)) === false) {
                    echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($this->socket)) . "\n";
               }
               else {
                   $client_id  = 1;
                   if (is_callable($this->onConnect)) {
                         call_user_func($this->onConnect, (int)$msgsock);
                   }
               }

               if (false === ($buf = @socket_read($msgsock, 2048))) {
                    echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($msgsock)) . "\n";
               } else
               {
                    if (is_callable($this->onMessage)) {
                         call_user_func($this->onMessage, $msgsock, $buf);
                    }
               }

               socket_close($msgsock);
          }
     }

     public function run() {
          $this->fork();
     }

}
 
$worker = new Worker('tcp://0.0.0.0:9800');
 
$worker->onConnect = function ($fd) {
     echo '新的連接來了'.$fd. 'pid' . posix_getpid() . PHP_EOL;
};

$worker->onMessage = function ($conn, $message) {
     // echo "讀取到數據: {$message}";
     $content = "Hello World";
     $http_resonse = "HTTP/1.1 200 OK\r\n";
     $http_resonse .= "Content-Type: text/html;charset=UTF-8\r\n";
     $http_resonse .= "Connection: keep-alive\r\n";
     $http_resonse .= "Server: php socket server\r\n";
     $http_resonse .= "Content-length: ".strlen($content)."\r\n\r\n";
     $http_resonse .= $content;

     socket_write($conn, $http_resonse, strlen($http_resonse));
};
$worker->run();