网站地图    收藏   

子栏目

主页 > php专栏 > php应用 >

PHP多线程的实现方法详解 - php高级应用

来源：自学PHP网    时间：2014-11-27 22:16 作者： 阅读:次

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

PHP多线程的实现方法详解

多线程是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.  } 
  55. } 
  56. foreach ($hosts as $id => $host) { 
  57.  echo "Host: $hostn"; 
  58.  echo "Status: " . $status[$id] . "nn"; 
  59. }  
  60. ?> 

我们用stream_select()等待sockets打开的连接事件,stream_select()调用系统的select(2)函数来工作,前面三个参数是你要使用的streams的数组,你可以对其读取,写入和获取异常,分别针对三个参数,stream_select()可以通过设置$timeout（秒）参数来等待事件发生-事件发生时,相应的sockets数据将写入你传入的参数.

下面是PHP4.1.0之后版本的实现,如果你已经在编译PHP时包含了sockets(ext/sockets)支持，你可以使用根上面类似的代码,只是需要将上面的streams/filesystem函数的功能用ext/sockets函数实现,主要的不同在于我们用下面的函数代替stream_socket_client()来建立连接,代码如下:

  1. <?php 
  2. // This value is correct for Linux, other systems have other values 
  3. define('EINPROGRESS', 115); 
  4. function non_blocking_connect($host, $port, &$errno, &$errstr, $timeout) { 
  5.  $ip = gethostbyname($host); 
  6.  $s = socket_create(AF_INET, SOCK_STREAM, 0); 
  7.  if (socket_set_nonblock($s)) { 
  8.   $r = @socket_connect($s, $ip, $port); 
  9.   if ($r || socket_last_error() == EINPROGRESS) { 
  10.    $errno = EINPROGRESS; 
  11.    return $s; 
  12.   } 
  13.  } 
  14.  $errno = socket_last_error($s); 
  15.  $errstr = socket_strerror($errno); 
  16.  socket_close($s); 
  17.  return false; 
  18. } 
  19. ?> 

现在用socket_select()替换掉stream_select(),用socket_read()替换掉fread(),用socket_write()替换掉fwrite(),用socket_close()替换掉fclose()就可以执行脚本了.

PHP5的先进之处在于,你可以用stream_select()处理几乎所有的stream-例如你可以通过include STDIN用它接收键盘输入并保存进数组,你还可以接收通过proc_open()打开的管道中的数据.

下面来分享一个PHP多线程类,代码如下:

  1. * @title:      PHP多线程类(Thread) 
  2. * @version:    1.0 
  3. * @author:     phper.org.cn < web@phper.org.cn > 
  4. * @published:  2010-11-2 
  5. *  
  6. * PHP多线程应用示例： 
  7. *  require_once 'thread.class.php'; 
  8. *  $thread = new thread(); 
  9. *  $thread->addthread('action_log','a'); 
  10. *  $thread->addthread('action_log','b'); 
  11. *  $thread->addthread('action_log','c'); 
  12. *  $thread->runthread(); 
  13. *   
  14. *  function action_log($info) { 
  15. *      $log = 'log/' . microtime() . '.log'; 
  16. *      $txt = $info . "rnrn" . 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn"; 
  17. *      $fp = fopen($log, 'w'); 
  18. *      fwrite($fp, $txt); 
  19. *      fclose($fp); 
  20. *  } 
  21. */ 
  22. lass thread { 
  23.  
  24.    var $hooks = array(); 
  25.    var $args = array(); 
  26.  
  27.    function thread() { 
  28.    } 
  29.  
  30.    function addthread($func) 
  31.    { 
  32.        $args = array_slice(func_get_args(), 1); 
  33.        $this->hooks[] = $func; 
  34.        $this->args[] = $args; 
  35.        return true; 
  36.    } 
  37.  
  38.    function runthread() 
  39.    { 
  40.        if(isset($_GET['flag'])) 
  41.        { 
  42.            $flag = intval($_GET['flag']); 
  43.        } 
  44.        if($flag || $flag === 0) 
  45.        { 
  46.            call_user_func_array($this->hooks[$flag], $this->args[$flag]); 
  47.        } 
  48.        else 
  49.        { 
  50.            for($i = 0, $size = count($this->hooks); $i < $size; $i++) 
  51.            { 
  52.                $fp=fsockopen($_SERVER['HTTP_HOST'],$_SERVER['SERVER_PORT']);//开源代码phpfensi.com 
  53.                if($fp) 
  54.                { 
  55.                    $out = "GET {$_SERVER['PHP_SELF']}?flag=$i HTTP/1.1rn"; 
  56.                    $out .= "Host: {$_SERVER['HTTP_HOST']}rn"; 
  57.                    $out .= "Connection: Closernrn"; 
  58.                    fputs($fp,$out); 
  59.                    fclose($fp); 
  60.                } 
  61.            } 
  62.        } 
  63.    } 

最新评论

    加载更多~~

    添加评论

    更多文章推荐

    自学PHP网专注网站建设学习,PHP程序学习,平面设计学习，以及操作系统学习

    京ICP备14009008号-1@版权所有www.zixuephp.com

    网站声明：本站所有视频，教程都由网友上传，站长收集和分享给大家学习使用，如由牵扯版权问题请联系站长邮箱904561283@qq.com

    添加评论