[原創(chuàng)]PHP與外部服務(wù)器的持久連接

bs

博客地址: http://lajabs.net/?p=373

php做為腳本語言，有時也有特殊的需求對外連接到其它服務(wù)器發(fā)送消息，簡單的方法可以直接使用socket擴展，比如連接一個TCP服務(wù)器：

1. 
   
2. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
   
3. if($socket)
   
4. {
   
5.   socket_connect($socket, '127.0.0.1', 8081);
   
6.   $pack = 'hello.'; //發(fā)送的內(nèi)容
   
7.   socket_send($socket, $pack, strlen($pack), 0);
   
8.   socket_recv($socket, $buffer, 1024, 0);
   
9.   echo $buffer; //接收的內(nèi)容
   
10. }
    

復(fù)制代碼

這些socket功能已經(jīng)可以滿足大多數(shù)對外連接的需要了，但面對一些連接特別頻繁的環(huán)境就顯得有些力不從心，系統(tǒng)頻繁地建立和銷毀連接的開銷是很大的，這時需要一種持久連接，說到持久連接，很多人可能會馬上想到mysql_pconnect這類函數(shù)（有點談虎色變），由于PHP的運行機制造成持久連接一直有著這樣那樣的問題（不細(xì)談），其實對于目前高版本的PHP，啟用php-fpm運行在fast-cgi下
的持久連接使用還是比較理想的。

php很早就提供了一個這樣的函數(shù)：pfsockopen，可能更多人對于fsockopen更了解，而使用上則大同小異。

簡單地用例子說明：

1. 
   
2. $socket = pfsockopen('127.0.0.1',8081,$errno, $errstr);
   
3. if($socket)
   
4. {
   
5.   $pack = 'hello.';
   
6.   fwrite($socket, $pack);  //fput 、fget
   
7.   $buffer = fread($socket, 1024);
   
8.   echo $buffer;
   
9. }
   

復(fù)制代碼

php建立了一個和目標(biāo)服務(wù)器8081端口連接，當(dāng)PHP腳本執(zhí)行完成后不會斷開連接，并在下一次腳本運行時重新使用這個連接，
使用php-fpm環(huán)境下會建立與其進程數(shù)相同的連接數(shù)，這樣就類似形成一個“連接池”。

hightman

關(guān)于socket你提到的寫法已經(jīng)out了。。。

參見 stream 相關(guān)的函數(shù)，那才叫猛，而且不需要額外的擴展，可控性也很強，還能異步連接呢。

stream_socket_server(), stream_socket_client() ...

bs

關(guān)于socket你提到的寫法已經(jīng)out了。。。

參見 stream 相關(guān)的函數(shù)，那才叫猛，而且不需要額外的擴展，可控 ...
hightman 發(fā)表于 2011-07-02 00:25

   
果然很猛，見識了

imbiss

web service的服務(wù)器端還是apache好,客戶端就由不得你了。js, curl. 啥都可以，誰叫他是客戶端呢？

imbiss

沒用過。  curl實現(xiàn)很方便，干嘛要stream?
另外 zend freamwork 里面有現(xiàn)成的 client, 比如  xmlrpc_client, rest_client
都封裝好了，干嘛還要去發(fā)明輪子？

bs

方便不方便不一定，看自己喜好和應(yīng)用情況，摘自手冊

1. 
   
2. <?php
   
3. // Create a stream
   
4. $opts = array(
   
5.   'http'=>array(
   
6.     'method'=>"GET",
   
7.     'header'=>"Accept-language: en\r\n" .
   
8.               "Cookie: foo=bar\r\n"
   
9.   )
   
10. );
    
11. 
    
12. $context = stream_context_create($opts);
    
13. 
    
14. // Open the file using the HTTP headers set above
    
15. $file = file_get_contents('http://www.example.com/', false, $context);
    
16. ?>
    

復(fù)制代碼

maochanglu

stream_socket_server 確實挺方便的