PHP多進程編程(四) 用php實現管道通訊類

實現代碼以下：

<?php

class Pipe

{

    public  $fifoPath;

    private $w_pipe;

    private $r_pipe;

    /**

     * 自動建立一個管道

     *

     * @param string $name 管道名字

     * @param int $mode  管道的權限，默認任何用戶組能夠讀寫

     */

    function __construct($name = 'pipe', $mode = 0666)

    {

        $fifoPath = "/tmp/$name." . posix_getpid();

        if (!file_exists($fifoPath)) {

            if (!posix_mkfifo($fifoPath, $mode)) {

                error("create new pipe ($name) error.");

                return false;

            }

        } else {

            error( "pipe ($name) has exit.");

            return false;

        }

        $this->fifoPath = $fifoPath;

    }

   

///////////////////////////////////////////////////

//  寫管道函數開始

///////////////////////////////////////////////////

    function open_write()

    {

        $this->w_pipe = fopen($this->fifoPath, 'w');

        if ($this->w_pipe == NULL) {

            error("open pipe {$this->fifoPath} for write error.");

            return false;

        }

        return true;

    }

 

    function write($data)

    {

        return fwrite($this->w_pipe, $data);

    }

    function write_all($data)

    {

        $w_pipe = fopen($this->fifoPath, 'w');

        fwrite($w_pipe, $data);

        fclose($w_pipe);

    }

    function close_write()

    {

        return fclose($this->w_pipe);

    }

/////////////////////////////////////////////////////////

/// 讀管道相關函數開始

////////////////////////////////////////////////////////

    function open_read()

    {

        $this->r_pipe = fopen($this->fifoPath, 'r');

        if ($this->r_pipe == NULL) {

            error("open pipe {$this->fifoPath} for read error.");

            return false;

        }

        return true;

    }

    function read($byte = 1024)

    {

        return fread($this->r_pipe, $byte);

    }

    function read_all()

    {

        $r_pipe = fopen($this->fifoPath, 'r');

        $data = '';

        while (!feof($r_pipe)) {

            //echo "read one K\n";

            $data .= fread($r_pipe, 1024);

        }

        fclose($r_pipe);

        return $data;

    }

    function close_read()

    {

        return fclose($this->r_pipe);

    }

////////////////////////////////////////////////////

    /**

     * 刪除管道

     *

     * @return boolean is success

     */

    function rm_pipe()

    {

        return unlink($this->fifoPath);

    }

}

?>

有了這個類，就能夠實現簡單的管道通訊了，由於這個教程是多進程編程系列教程的一個部分。

這個管道類的應用部分，將放到下一節。