PHPマルチスレッドプログラミング–パイプ通信

2014年6月17日

サンプルコード：

<?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);
}
}
?>