第PHP實現(xiàn)非阻塞模式的方法分析本文實例講述了PHP實現(xiàn)非阻塞模式的方法。分享給大家供大家參考，具體如下：

程序非阻塞模式，這里也可以理解成并發(fā)。而并發(fā)又暫且可以分為網(wǎng)絡(luò)請求并發(fā)和本地并發(fā)。

先說一下網(wǎng)絡(luò)請求并發(fā)

理論描述

假設(shè)有一個client，程序邏輯是要請求三個不同的server，處理各自的響應(yīng)。傳統(tǒng)模型當(dāng)然是順序執(zhí)行，先發(fā)送第一個請求，等待收到響應(yīng)數(shù)據(jù)后再發(fā)送第二個請求，以此類推。就像是單核CPU，一次只能處理一件事，其他事情被暫時阻塞。而并發(fā)模式可以讓三個server同時處理各自請求，這就可以使大量時間復(fù)用。

畫個圖更好說明問題：

前者為阻塞模式，忽略請求響應(yīng)等時間，總耗時為700ms；而后者非阻塞模式，由于三個請求可以同時得到處理，總耗時只有300ms。

代碼實現(xiàn)

echo"Programstartsat".date('h:i:s')."./n";

$timeout=3;

$sockets=array();//socket句柄數(shù)組

//一次發(fā)起多個請求

$delay=0;

while($delay++3)

$sh=stream_socket_client("localhost:80",$errno,$errstr,$timeout,

STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);

/*這里需要稍微延遲一下，否則下面fwrite中的socket句柄不一定能真正使用

這里應(yīng)該是PHP的一處bug，查了一下，官方bug早在08年就有人提交了

我的5.2.8中尚未解決，不知最新的5.3中是否修正

usleep(10);

if($sh){

$sockets[]=$sh;

$http_header="GET/test.phpn={$delay}HTTP/1.0/r/n";

$http_header.="Host:localhost/r/n";

$http_header.="Accept:*/*/r/n";

$http_header.="Accept-Charset:*/r/n";

$http_header.="/r/n";

fwrite($sh,$http_header);

}else{

echo"Streamfailedtoopencorrectly./n";

//非阻塞模式來接收響應(yīng)

$result=array();

$read_block_size=8192;

while(count($sockets))

$read=$sockets;

$n=stream_select($read,$w=null,$e=null,$timeout);

//if($n0)//據(jù)說stream_select返回值不總是可信任的

if(count($read))

/*stream_selectgenerallyshuffles$read,soweneedto

computefromwhichsocket(s)we'rereading.*/

foreach($readas$r)

$id=array_search($r,$sockets);

$data=fread($r,$read_block_size);

if(strlen($data)==0)

echo"Stream{$id}closesat".date('h:i:s')."./n";

fclose($r);

unset($sockets[$id]);

}else{

if(!isset($result[$id]))$result[$id]='';

$result[$id].=$data;

}else{

echo"Time-out!/n";

break;

//print_r($result);

幾點說明：

1、使用stream_socket_client函數(shù)鏈接請求服務(wù)器和端口（簡便起見這里使用同一地址localhost）。這里不受限于http協(xié)議，可廣泛用于所有TCP/IP協(xié)議。詳細(xì)內(nèi)容請參考手冊。

2、這里鏈接成功后通過發(fā)送各自http頭信息來獲取不同響應(yīng)（這里使用網(wǎng)站根目錄下的test.php做服務(wù)端）。

3、發(fā)送header前需要個微小的延遲，代碼中已經(jīng)做了注釋。

CLI模式運行結(jié)果：

多運行幾次會發(fā)現(xiàn)，三次請求結(jié)束順序是無序的。該demo太過簡單導(dǎo)致整個過程一秒內(nèi)已完成，但可以針對三次不同請求做相應(yīng)延遲，來看出非阻塞時時間復(fù)用的效果。

下面再大概說下本地并發(fā)

本地并發(fā)只能通過語言自己的特性在程序本身實現(xiàn)多任務(wù)效果，一般來說現(xiàn)在的語言會通過多線程或多進(jìn)程的方式來實現(xiàn)。由于PHP不支持多線程，目前只能采用多進(jìn)程方式，讓操作系統(tǒng)來幫助實現(xiàn)本地并發(fā)。

至于代碼實現(xiàn)，可以通過pcntl擴(kuò)展（封裝fork等進(jìn)程控制函數(shù)，和C語言中使用非常相似，windows下不可用）、proc_open、popen等方式，方法不止一種，這里就不做詳細(xì)介紹了。詳情可自行搜索“php多進(jìn)程”進(jìn)行了解:)

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《phpsocket用法總結(jié)》、《php字符串(string