php管道邮件,php进程通信-PIPE管道通信
上一篇文章講到了php進(jìn)程通信的進(jìn)程信號(hào)通信方法,本文介紹的是有名管道:
管道通信,主要是利用文件,寫入以及讀取來(lái)進(jìn)行通信的,
通俗來(lái)講,就是A進(jìn)程在1.txt寫入1,B進(jìn)程讀取1.txt,就能讀取到這個(gè)1,這樣就通信成功了.
當(dāng)然,php進(jìn)程管道通信沒(méi)有這么簡(jiǎn)單
注意:多進(jìn)程系列文章,都建立在linux環(huán)境,php-cli運(yùn)行模式下
一:創(chuàng)建個(gè)專屬管道的文件:$fifoPath?=?"tmp/$name".getmypid()?;//定義文件名
if?(!file_exists($fifoPath))?{
if?(!posix_mkfifo($fifoPath,?0666))?{//posix函數(shù),創(chuàng)建一個(gè)特殊的pipe文件
//????????????????error("create?new?pipe?($name)?error.");
return?false;
}
}?else?{
//????????????error("pipe?($name)?has?exit.");
return?false;
}
二:讀取數(shù)據(jù)$r_pipe?=?fopen($fifoPath,?'r');//正常讀取文件
if?($r_pipe?==?NULL)?{
return?false;
}
$data?=?fread($r_pipe,?1024);
三:寫入數(shù)據(jù)$w_pipe?=?fopen($fifoPath,?'w');//正常操作文件一樣打開該管道
if?($w_pipe?==?NULL)?{
throw?new?Exception('打開管道錯(cuò)誤!');
}
$result?=?fwrite($w_pipe,?$data);//寫入文件一樣寫入數(shù)據(jù)
四:刪除管道unlink($tfifoPath);//刪除文件
五:封裝類<?php
/**
*?Created?by?PhpStorm.
*?User:?tioncico
*?Date:?18-5-21
*?Time:?下午11:51
*/
class?Pipe
{
public?$fifoPath;
private?$w_pipe;
private?$r_pipe;
/**
*?自動(dòng)創(chuàng)建一個(gè)管道
*
*?@param?string?$name?管道名字
*?@param?int?$mode?管道的權(quán)限，默認(rèn)任何用戶組可以讀寫
*/
function?__construct($name?=?'pipe',?$mode?=?0666)
{
$fifoPath?=?"tmp/$name".getmypid()?;
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;
}
///
//??寫管道函數(shù)開始
///
function?open_write()
{
$this->w_pipe?=?fopen($this->fifoPath,?'w');
//????????var_dump($this->w_pipe);
if?($this->w_pipe?==?NULL)?{
throw?new?Exception('打開管道錯(cuò)誤!');
//????????????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);
}
/
///?讀管道相關(guān)函數(shù)開始
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);
}
}
六:注意事項(xiàng)
1:管道與普通文件有一點(diǎn)非常不同的就是:管道需要先有個(gè)進(jìn)程讀取進(jìn)程,才可以寫入,否則按寫入模式打開文件時(shí)阻塞,以下是測(cè)試截圖:
本文為仙士可原創(chuàng)文章,轉(zhuǎn)載無(wú)需和我聯(lián)系,但請(qǐng)注明來(lái)自仙士可博客www.php20.cn
總結(jié)
以上是生活随笔為你收集整理的php管道邮件,php进程通信-PIPE管道通信的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： php 导出csv 转义 逗号转义,在c
- 下一篇： php获得指定位置中间的数据库,PHP