php基于Socket实现多线程开发教程

由于php本身不支持多线程,如果我们想在php实现多线程是不是不可行呢？本教程来讲讲通过php的Socket方式实现php程序的多线程.

通过php的Socket方式实现php程序的多线程,php本身是不支持多线程的,那么如何在php中实现多线程呢？可以想一下,WEB服务器本身都是支持多线程的,每一个访问者,当访问WEB页面的时候,都将调用新的线程,通过这一点我们可以利用WEB服务器自身的线程来解决PHP不支持多线程的问题.

下面给出通过 fsockopen() 建立socket连接,然后用 用fputs() 发送消息,来实现的PHP多线程类代码:

1. $fp=fsockopen($_SERVER['HTTP_HOST'],80,&$errno,&$errstr,5);  
2. if(!$fp){ 
3. echo "$errstr ($errno)<br />n"; 
4. } 
5. fputs($fp,"GET $_SERVER[PHP_SELF]?flag=1rn");  
6. fclose($fp); 

上面这段代码只是一个线程的操作过程,多进行几个这样的操作就是多线程了,目前所谓PHP的多线程程序都是基于这个方式的.

下面给一个完整的线程类代码:

1. <?php  
2. /**  
3. @title:PHP多线程类(Thread)  
4. @version:1.0  Vevb.com 
5. @author:axgle <axgle@126.com>  
6. */  
7. class thread {  
8. var $count;  
9. function thread($count=1) {  
10.  
11. $this->count=$count;  
12. }  
13.  
14. function _submit() {  
15. for($i=1;$i<=$this->count;$i++) $this->_thread();  
16. return true;  
17. }  
18.  
19.  
20. function _thread() {  
21. $fp=fsockopen($_SERVER['HTTP_HOST'],80,&$errno,&$errstr,5);  
22.  
23. if(!$fp){ 
24. echo "$errstr ($errno)<br />n"; 
25. } 
26. fputs($fp,"GET $_SERVER[PHP_SELF]?flag=1rn");  
27. fclose($fp);  
28. }  
29.  
30. function exec($func) {  
31. isset($_GET['flag'])?call_user_func($func):$this->_submit();  
32. }  
33.  
34.  
35. }  
36.  
37. //应用例子： 
38. $th=new thread(10);//10个线程  
39. $th->exec('demo');//执行行自定义的函数  
40.  
41. function demo() {  
42. fopen('data/'.microtime(),'w');  
43. }
44. ?>