[原创]PHP与外部服务器的持久连接

bs

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

php做为脚本语言，有时也有特殊的需求对外连接到其它服务器发送消息，简单的方法可以直接使用socket扩展，比如连接一个TCP服务器：

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.'; //发送的内容
   
7.   socket_send($socket, $pack, strlen($pack), 0);
   
8.   socket_recv($socket, $buffer, 1024, 0);
   
9.   echo $buffer; //接收的内容
   
10. }
    

复制代码

这些socket功能已经可以满足大多数对外连接的需要了，但面对一些连接特别频繁的环境就显得有些力不从心，系统频繁地建立和销毁连接的开销是很大的，这时需要一种持久连接，说到持久连接，很多人可能会马上想到mysql_pconnect这类函数（有点谈虎色变），由于PHP的运行机制造成持久连接一直有着这样那样的问题（不细谈），其实对于目前高版本的PHP，启用php-fpm运行在fast-cgi下
的持久连接使用还是比较理想的。

php很早就提供了一个这样的函数：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. }
   

复制代码

php建立了一个和目标服务器8081端口连接，当PHP脚本执行完成后不会断开连接，并在下一次脚本运行时重新使用这个连接，
使用php-fpm环境下会建立与其进程数相同的连接数，这样就类似形成一个“连接池”。

hightman

关于socket你提到的写法已经out了。。。

参见 stream 相关的函数，那才叫猛，而且不需要额外的扩展，可控性也很强，还能异步连接呢。

stream_socket_server(), stream_socket_client() ...

bs

关于socket你提到的写法已经out了。。。

参见 stream 相关的函数，那才叫猛，而且不需要额外的扩展，可控 ...
hightman 发表于 2011-07-02 00:25

   
果然很猛，见识了

imbiss

web service的服务器端还是apache好,客户端就由不得你了。js, curl. 啥都可以，谁叫他是客户端呢？

imbiss

没用过。  curl实现很方便，干嘛要stream?
另外 zend freamwork 里面有现成的 client, 比如  xmlrpc_client, rest_client
都封装好了，干嘛还要去发明轮子？

bs

方便不方便不一定，看自己喜好和应用情况，摘自手册

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. ?>
    

复制代码

maochanglu

stream_socket_server 确实挺方便的