PHP多线程的实现方法详解

点击数：10502015-07-19 17:50:00　来源: 外贸网站建设,深圳外贸网站建设,深圳网站建设,外贸商城网站制作-亿恩科技

多线程是java中一个很不错的东西,很多朋友说在php中不可以使用PHP多线程了,其实那是错误的说法PHP多线程实现方法和fsockopen函数有关,下面我们来介绍具体实现程序代码,有需要了解的同学可参考.

当有人想要实现并发功能时,他们通常会想到用fork或者spawn threads,但是当他们发现php不支持多线程的时候,大概会转换思路去用一些不够好的语言,比如perl.

其实的是大多数情况下,你大可不必使用 fork 或者线程,并且你会得到比用 fork 或 thread 更好的性能.

假设你要建立一个服务来检查正在运行的n台服务器,以确定他们还在正常运转,你可能会写下面这样的代码:

1. <?php 
2. $hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); 
3. $timeout = 15; 
4. $status = array(); 
5. foreach ($hosts as $host) { 
6.  $errno = 0; 
7.  $errstr = ""; 
8.  $s = fsockopen($host, 80, $errno, $errstr, $timeout); 
9.  if ($s) { 
10.   $status[$host] = "Connectedn"; 
11.   fwrite($s, "HEAD / HTTP/1.0rnHost: $hostrnrn"); 
12.   do { 
13.    $data = fread($s, 8192); 
14.    if (strlen($data) == 0) { 
15.    break; 
16.    } 
17.    $status[$host] .= $data; 
18.   } while (true); 
19.   fclose($s); 
20.  } else { 
21.   $status[$host] = "Connection failed: $errno $errstrn"; 
22.  } 
23. } 
24. print_r($status); 
25. ?> 

它运行的很好,但是在fsockopen()分析完hostname并且建立一个成功的连接,或者延时$timeout秒之前,扩充这段代码来管理大量服务器将耗费很长时间.

因此我们必须放弃这段代码,我们可以建立异步连接-不需要等待fsockopen返回连接状态。PHP仍然需要解析hostname,所以直接使用ip更加明智,不过将在打开一个连接之后立刻返回,继而我们就可以连接下一台服务器.

有两种方法可以实现,PHP5中可以使用新增的stream_socket_client()函数直接替换掉fsocketopen(),PHP5之前的版本,你需要自己动手,用sockets扩展解决问题.

下面是PHP5中的解决方法,代码如下:

1. <?php 
2. $hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); 
3. $timeout = 15; 
4. $status = array(); 
5. $sockets = array(); 
6. /* Initiate connections to all the hosts simultaneously */ 
7. foreach ($hosts as $id => $host) { 
8.  $s = stream_socket_client(" 
9. $ 
10. $host:80", $errno, $errstr, $timeout, 
11.   STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT); 
12.  if ($s) { 
13.   $sockets[$id] = $s; 
14.   $status[$id] = "in progress"; 
15.  } else { 
16.   $status[$id] = "failed, $errno $errstr"; 
17.  } 
18. } 
19. /* Now, wait for the results to come back in */ 
20. while (count($sockets)) { 
21.  $read = $write = $sockets; 
22.  /* This is the magic function - explained below */ 
23.  $n = stream_select($read, $write, $e = null, $timeout); 
24.  if ($n > 0) { 
25.   /* readable sockets either have data for us, or are failed 
26.    * connection attempts */ 
27.   foreach ($read as $r) { 
28.       $id = array_search($r, $sockets); 
29.       $data = fread($r, 8192); 
30.       if (strlen($data) == 0) { 
31.    if ($status[$id] == "in progress") { 
32.     $status[$id] = "failed to connect"; 
33.    } 
34.    fclose($r); 
35.    unset($sockets[$id]); 
36.       } else { 
37.    $status[$id] .= $data; 
38.       } 
39.   } 
40.   /* writeable sockets can accept an HTTP request */ 
41.   foreach ($write as $w) { 
42.    $id = array_search($w, $sockets); 
43.    fwrite($w, "HEAD / HTTP/1.0rnHost: " 
44.     . $hosts[$id] .  "rnrn"); 
45.    $status[$id] = "waiting for response"; 
46.   } 
47.  } else { 
48.   /* timed out waiting; assume that all hosts associated 
49.    * with $sockets are faulty */ 
50.   foreach ($sockets as $id => $s) { 
51.    $status[$id] = "timed out " . $status[$id]; 
52.   } 
53.   break; 
54. 【责任编辑：】(Top) 返回页面顶端

下一篇：php中读取大文件实现方法详解

上一篇：php中fsockopen模仿post与get详解