這篇文章已經寫完將近一年了，最近從歷史郵件裡面翻出來，和大家分享一下。
其中使用PHP實現持久的HTTP連接，讓我費了很多心思。
曾經想過使用C語言編寫一個PHP的擴展來實現，後來發現pfsockopen這個函數，讓我豁然開朗，避免重新發明一個輪子，呵呵。
一，KeepAlive的概念：
參見 http://en.wikipedia.org/wiki/HTTP_persistent_connection
二，KeepAlive的客戶端實現：
使用了PHP支持的 pfsockopen 來實現，參見：http://cn.PHP.Net/pfsockopen
KeepAlive必要的Header有：
Connection: Keep-Alive
Content-Length: xxx
三，性能對比測試：
幾種對比實現方式：
1，使用fsockopen來實現，讀取body內容後，關閉連接，參見測試程序中的ohttp_get實現。
2，使用pfsockopen來實現，讀取body內容後，不關閉連接，參見測試程序中的phttp_get實現。
3，PHP實現的file_get_contents
4，第三方測試工具ab
前三種測試在測試程序中都包含了。
測試用例 一：
前三種PHP實現的客戶端單進程單線程請求lighttpd服務器一個16字節的靜態文件。順序請求10000次。
客戶端與服務器部署在不同服務器，通過內網請求。
測試結果：
第一次：
[root@localhost ~]# /opt/bin/php tp.PHP
phttp_get: 5.3641529083252
ohttp_get: 8.1628580093384
file_get_contents: 12.217950105667
第二次：
[root@localhost ~]# /opt/bin/php tp.PHP
phttp_get: 5.033059835434
ohttp_get: 9.589075088501
file_get_contents: 12.775387048721
第三次：
[root@localhost ~]# /opt/bin/php tp.PHP
phttp_get: 5.0181269645691
ohttp_get: 8.2286441326141
file_get_contents: 11.089616060257
測試用例 二：
使用第三方工具ab來進行測試，-k參數開打開keepalive支持，不做並發測試，順序請求10000次。
客戶端與服務器部署在不同服務器，通過內網請求。
以下測試結果部分省略：
未打開keepalive：
[root@localhost ~]# ab -n 10000 -c 1 “http://10.69.2.206:8080/sms/ns2/save_msg.txt”
Finished 10000 requests
Concurrency Level: 1
Time taken for tests: 10.410467 seconds
Complete requests: 10000
Failed requests: 0
Write errors: 0
Total transferred: 2480000 bytes
Html transferred: 160000 bytes
Requests per second: 960.57 [#/sec] (mean)
Time per request: 1.041 [ms] (mean)
Time per request: 1.041 [ms] (mean, across all concurrent requests)
Transfer rate: 232.55 [Kbytes/sec] receivedConnection Times (ms)
min mean[+/-sd] median max
Connect: 0 0 30.0 0 3002
Processing: 0 0 0.4 0 9
Waiting: 0 0 0.3 0 9
Total: 0 0 30.0 0 3003
打開keepalive：
[root@localhost ~]# ab -k -n 10000 -c 1 “http://10.69.2.206:8080/sms/ns2/save_msg.txt”
Finished 10000 requests
Concurrency Level: 1
Time taken for tests: 4.148619 seconds
Complete requests: 10000
Failed requests: 0
Write errors: 0
Keep-Alive requests: 9412
Total transferred: 2527060 bytes
Html transferred: 160000 bytes
Requests per second: 2410.44 [#/sec] (mean)
Time per request: 0.415 [ms] (mean)
Time per request: 0.415 [ms] (mean, across all concurrent requests)
Transfer rate: 594.66 [Kbytes/sec] receivedConnection Times (ms)
min mean[+/-sd] median max
Connect: 0 0 0.1 0 5
Processing: 0 0 2.1 0 203
Waiting: 0 0 2.1 0 203
Total: 0 0 2.1 0 203
四，在實際中的應用
以上實現的phttp_get和MySQL memcache的 中的“保持連接”概念類似，這種技術一般來說，只適用於fastCGI模式的web服務器。
對於本機之間的http通信，在測試過程中發現phttp_get的優勢有限，基本合乎邏輯。
對於本身處理時間比較長的服務，phttp_get的優勢也不明顯。
綜上，phttp_get適用於fastCGI模式的web應用調用遠程http服務，且此http服務器響應時間比較短的情況。
五，服務端需要注意的事項
1，http服務器必須支持HTTP/1.1協議
2，PHP應用必須返回Content-Length:的header，具體實現參見：
http://cn.PHP.Net/manual/en/function.ob-get-length.PHP
需要在代碼中加入：
ob_start();
$size=ob_get_length();
header(”Content-Length: $size”);
ob_end_flush();
最後附上測試代碼：
<?PHP
//$url=http://10.69.2.206:8080/sms/ns2/save_msg.txt
function ohttp_get($host,$port,$query,&$body)
{
$fp=pfsockopen($host,$port,$errno,$errstr,1);
if(!$fp)
{
var_dump($errno,$errstr);
return -1;
}
$out = “GET ${query} HTTP/1.1\r\n”;
$out.= “Host: ${host}\r\n”;
$out.= “Connection: close\r\n”;
$out.= “\r\n”;
fwrite($fp,$out);
$line=trim(fgets($fp));
$header.=$line;
list($proto,$rcode,$result)=explode(” “,$line);
$len=-1;
while( ($line=trim(fgets($fp))) != “” )
{
$header.=$line;
if(strstr($line,”Content-Length:”))
{
list($cl,$len)=explode(” “,$line);
}
if(strstr($line,”Connection: close”))
{
$close=true;
}
}
if($len < 0)
{
echo “ohttp_get must cope with Content-Length header!\n”;
return -1;
}
$body=fread($fp,$len);
if($close)
fclose($fp);
return $rcode;
}
function phttp_get($host,$port,$query,&$body)
{
$fp=pfsockopen($host,$port,$errno,$errstr,1);
if(!$fp)
{
var_dump($errno,$errstr);
return -1;
}
$out = “GET ${query} HTTP/1.1\r\n”;
$out.= “Host: ${host}\r\n”;
$out.= “Connection: Keep-Alive\r\n”;
$out.= “\r\n”;
fwrite($fp,$out);
$line=trim(fgets($fp));
$header.=$line;
list($proto,$rcode,$result)=explode(” “,$line);
$len=-1;
while( ($line=trim(fgets($fp))) != “” )
{
$header.=$line;
if(strstr($line,”Content-Length:”))
{
list($cl,$len)=explode(” “,$line);
}
if(strstr($line,”Connection: close”))
{
$close=true;
}
}
if($len < 0)
{
echo “phttp_get must cope with Content-Length header!\n”;
return -1;
}
$body=fread($fp,$len);
if($close)
fclose($fp);
return $rcode;
}$time1=microtime(true);
for($i=0;$i<10000;$i++)
{
$host=”10.69.2.206″;
$port=8080;
$query=”/sms/ns2/save_msg.txt”;
$body=”";
$r=ohttp_get($host,$port,$query,$body);
if($r != 200)
{
echo “return code : $r\n”;
}
}
$time2=microtime(true);
for($i=0;$i<10000;$i++)
{
$url=”http://10.69.2.206:8080/sms/ns2/save_msg.txt”;
$host=”10.69.2.206″;
$port=8080;
$query=”/sms/ns2/save_msg.txt”;
$body=”";
$r=phttp_get($host,$port,$query,$body);
if($r != 200)
{
echo “return code : $r\n”;
}
}
$time3=microtime(true);
for($i=0;$i array( ‘timeout’ => 1 )
)
);
$body=file_get_contents($url, 0, $ctx);
$r=200;
if($r != 200)
{
echo “return code : $r\n”;
}
}
$time4=microtime(true);echo “phttp_get: “.($time3-$time2).”\n”;
echo “ohttp_get: “.($time2-$time1).”\n”;
echo “file_get_contents: “.($time4-$time3).”\n”;?>
