因業務需要用到了pcntl_fork 處理多客戶端連線處理資料的需求

但測試下來出現一個問題:

fork 之後, 若等待子程序返回, 那麼程式就會阻塞, 不等待子程序返回, 則會出現殭屍程序

$obj = new service('127.0.0.1', 50000);
$obj->run();

class service {

    private $socket_id;
    private $socket_cid;
    private $pid;

    function __construct($host, $port) {
        $this->socket_id = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if (!$this->socket_id) {
            $this->logs("create socket error");
            return false;
        }
        if (!socket_bind($this->socket_id, $host, $port)) {
            $this->logs(socket_strerror(socket_last_error()));
            socket_close($this->socket_id);
            return false;
        }
        if (!socket_listen($this->socket_id)) {
            $this->logs(socket_strerror(socket_last_error()));
            socket_close($this->socket_id);
            return false;
        }
    }

    public function run() {
        if (!$this->socket_id) {
            $this->logs("create socket error");
            return false;
        }
        $this->logs("Starting...");
        while (true) {
            $this->socket_cid = socket_accept($this->socket_id);
            $ip = "";
            socket_getpeername($this->socket_cid, $ip);
            $this->logs("Client IP: {$ip}");
            if (!is_resource($this->socket_cid)) {
                $this->logs(socket_strerror(socket_last_error()));
                socket_close($this->socket_id);
                return false;
            }
            $this->pid = pcntl_fork();
            if ($this->pid == -1) {
                $this->logs(socket_strerror(socket_last_error()));
                socket_close($this->socket_cid);
                return false;
            } else if ($this->pid) {
                $status = 0;
                $s = pcntl_wait($status, WNOHANG); //等待子程序中斷，防止子程序成為殭屍程序, 但這樣會阻塞, 意思是隻能處理一個客戶端連線, 多個進入排隊
                //$s = pcntl_waitpid(0, $status, WUNTRACED); //如果不等待, 則子程序處理完之後, 沒有對其進行處理, 會成為殭屍程序
                $this->logs("Status: " . $status . ", pcntl_waitpid: " . $s);
            } elseif ($this->pid == 0) { //child process
                $k = 0;
                while (true) {
                    if ($data = socket_read($this->socket_cid, 1024)) {
                        $this->logs("Read Data: {$data}");
                        $flag = socket_write($this->socket_cid, date('Y-m-d H:i:s') . '|已收到');
                        $this->logs("Write Result: {$flag}");
                    }
                    sleep(1);
                    $k++;
                    $this->logs("Wait...\t" . date('Y-m-d H:i:s'));
                    if ($k > 30) {
                        break;
                    }
                }
                socket_close($this->socket_cid);
                exit(1);
            }
        }
        socket_close($this->socket_id);
    }

    /**
     * 打日誌
     * @param string $msg
     * @return int
     */
    private function logs($msg) {
        $logs_filename = LOGS_PATH;
        if (!file_exists($logs_filename)) {
            @mkdir($logs_filename, 0777, true);
        }
        $logs_filename .= date('j') . '.log';
        $logs_data = date('[H:i:s]') . " {$msg}\n";
        return file_put_contents($logs_filename, $logs_data, FILE_APPEND);
    }

    function __destruct() {
        if (is_resource($this->socket_id)) {
            socket_close($this->socket_id);
        }
        if (is_resource($this->socket_cid)) {
            socket_close($this->socket_cid);
        }
    }

}


 

在網上搜了半天, 這位仁兄的解決辦法是對的(http://blog.csdn.net/e421083458/article/details/22186475), 就是增加訊號處理,

在socket accept之前加上 pcntl_signal(SIGCHLD, SIG_IGN); //如果父程序不關心子程序什麼時候結束,子程序結束後，核心會回收。

也就是在run方法開始處 :)

    public function run() {
        if (!$this->socket_id) {
            $this->logs("create socket error");
            return false;
        }
        pcntl_signal(SIGCHLD, SIG_IGN);
        $this->logs("Starting....");
        ...
      }