`
zhangchibang
  • 浏览: 345299 次
社区版块
存档分类
最新评论

用 PHP V5 开发多任务应用程序

    博客分类:
  • PHP
阅读更多

http://www.ibm.com/developerworks/cn/opensource/os-php-multitask/
许多 PHP 开发人员认为,由于标准的 PHP 缺少线程功能,因此实际 PHP 应用程序不可能执行多任务处理。例如,如果应用程序需要其他 Web 站点的信息,那么在远程检索完成之前它都必须停止。这是错误的!通过本文了解如何使用 stream_select 和 stream_socket_client 实现进程内 PHP 多任务处理。

PHP 不支持线程。尽管如此,与前述大多数 PHP 开发人员所相信的想法形成对比的是,PHP 应用程序可以 执行多任务处理。让我们开始尽可能清晰地描述一下 “多任务” 和 “线程” 对于 PHP 编程的意义。

并发的种类

首先抛开几个和主题无关的例子。PHP 与多任务或并发的关系十分复杂。在较高层次上,PHP 经常涉及多任务:以多任务方式使用 标准的服务器端 PHP 安装 —— 例如,作为 Apache 模块。换句话说,若干个客户机 —— Web 浏览器 —— 可以同时请求同一个 PHP 解释的页面,而 Web 服务器将差不多同时返回所有这些页面。

一个 Web 页面不会妨碍其他 Web 页面的发送,尽管可能会由于诸如服务器内存或网络带宽之类的受限资源而使它们相互之间略有妨碍。这样,实现并发 的系统级需求可能适合使用基于 PHP 的解决方案。就实现而言,PHP 允许它的管理 Web 服务器负责实现并发。

Ajax 名下的客户端并发近几年来也已成为开发人员关注的焦点。虽然 Ajax 的含义已经变得十分模糊,但是它的一个方面是浏览器显示可以同时执行计算 保留对诸如选择菜单项之类的用户操作的响应。这实际上就是某种 多任务。用 PHP 编码的 Ajax 就是这样 —— 但是不涉及任何特定的 PHP;用于其他语言的 Ajax 框架均以完全相同的方法操作。

只粗略地涉及 PHP 的第三个并发实例是 PHP/TK。PHP/TK 是 PHP 的扩展,用于为核心 PHP 提供可移植图形用户界面(GUI)绑定。PHP/TK 允许用 PHP 编写代码构造桌面 GUI 应用程序。其基于事件的特性将模拟一种易于掌握并且比线程更少出错的并发形式。此外,并发是 “继承” 自一项辅助技术,而不是 PHP 的基本功能。

向 PHP 本身添加线程支持的试验已经做过多次。据我所知,没有一次是成功的。但是,Ajax 框架和 PHP/TK 的面向事件的实现表明事件可能比线程能更好地体现 PHP 的并发。PHP V5 证明事实确实如此。





回页首


PHP V5 将提供 stream_select()

使用标准的 PHP V4 和更低版本,必须按顺序执行 PHP 应用程序的所有工作。例如,如果程序需要在两个商业站点检索商品的价格,则请求第一个站点的价格,等待至响应到达,再请求第二个站点的价格,然后再次等待。

如果程序请求同时完成若干项任务会怎么样?总体来看,程序将在一段时间内完成,在这段时间内,将始终进行连续处理。

第一个示例

新的 stream_select 函数及它的几个助手使这成为可能。请考虑以下示例。


清单 1. 同时请求多个 HTTP 页面
                
       <?php
	echo "Program starts at ". date('h:i:s') . ".\n";

        $timeout=10; 
        $result=array(); 
        $sockets=array(); 
        $convenient_read_block=8192;
        
        /* Issue all requests simultaneously; there's no blocking. */
        $delay=15;
        $id=0;
        while ($delay > 0) {
            $s=stream_socket_client("phaseit.net:80", $errno,
                  $errstr, $timeout,
                  STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT); 
            if ($s) { 
                $sockets[$id++]=$s; 
                $http_message="GET /demonstration/delay?delay=" .
                    $delay . " HTTP/1.0\r\nHost: phaseit.net\r\n\r\n"; 
                fwrite($s, $http_message);
            } else { 
                echo "Stream " . $id . " failed to open correctly.";
            } 
            $delay -= 3;
        } 
        
        while (count($sockets)) { 
            $read=$sockets; 
            stream_select($read, $w=null, $e=null, $timeout); 
            if (count($read)) {
                /* stream_select generally shuffles $read, so we need to
                   compute from which socket(s) we're reading. */
                foreach ($read as $r) { 
                    $id=array_search($r, $sockets); 
                    $data=fread($r, $convenient_read_block); 
                    /* A socket is readable either because it has
                       data to read, OR because it's at EOF. */
                    if (strlen($data) == 0) { 
                        echo "Stream " . $id . " closes at " . date('h:i:s') . ".\n";
                        fclose($r); 
                        unset($sockets[$id]); 
                    } else { 
                        $result[$id] .= $data; 
                    } 
                } 
            } else { 
                /* A time-out means that *all* streams have failed
                   to receive a response. */
                echo "Time-out!\n";
                break;
            } 
        } 
       ?>
      

如果运行此清单,您将看到如下所示的输出。


清单 2. 从清单 1 中的程序获得的典型输出
                
	 Program starts at 02:38:50.
         Stream 4 closes at 02:38:53.
	 Stream 3 closes at 02:38:56.
	 Stream 2 closes at 02:38:59.
	 Stream 1 closes at 02:39:02.
	 Stream 0 closes at 02:39:05.
      

了解这其中的工作原理至关重要。在较高层次上,第一个程序将发出几个 HTTP 请求并接收 Web 服务器发送给它的页面。虽然生产应用程序将很可能寻找若干个 Web 服务器的地址 —— 可能是 google.com、yahoo.com、ask.com 等 —— 但是此示例将把它的所有请求发送到位于 Phaseit.net 的企业服务器上,只为降低复杂度。

Web 页面请求在延迟(可变)后返回结果,如下所示。如果程序按顺序发出请求,则需花费大约 15+12+9+6+3 (45) 秒钟才能完成。如清单 2 所示,它实际上花费 15 秒钟完成。性能提高了三倍。

使这成为可能的是 PHP V5 的新 stream_select 函数。请求都是以常规方法发起,方法为打开几个 stream_socket_client 并向对应于 http://phaseit.net/demonstration/delay?delay=$DELAY 的每个stream_socket_client 写入 GET。如果您通过浏览器请求此 URL,则在几秒钟之后,您将看到:

	  Starting at Thu Apr 12 15:05:01 UTC 2007. 
	  Stopping at Thu Apr 12 15:05:05 UTC 2007. 
	  4 second delay.
      

延迟服务器将作为 CGI 实现,如下所示:


清单 3. 延迟服务器实现
                
	  #!/bin/sh

	  echo "Content-type: text/html

	  <HTML> <HEAD></HEAD> <BODY>"

	  echo "Starting at `date`."
	  RR=`echo $REQUEST_URI | sed -e 's/.*?//'`
	  DELAY=`echo $RR | sed -e 's/delay=//'`
	  sleep $DELAY
	  echo "<br>Stopping at `date`."
	  echo "<br>$DELAY second delay.</body></html>"
      

虽然清单 3 的特殊实现特定于 UNIX®,但是本文中几乎所有实现都将很好地应用于 Windows®(尤其是 Windows 98 以后的版本)或 PHP 的 UNIX 安装。特别地,清单 1 可以托管在任意一个操作系统中。因此,Linux® 和 Mac OS X 都是 UNIX 变体,因此这里所有的代码都可以在两者的任意一种中运行。

按照以下顺序向延迟服务器发出请求。


清单 4. 进程启动顺序
                
	delay=15
	delay=12
	delay= 9
	delay= 6
	delay= 3
      

stream_select 的作用是尽可能快速地接收结果。在这种情况下,它执行的顺序与发出结果的顺序刚好相反。3 秒后,第一个页面已经准备好读取。程序的这一部分也符合常规 PHP —— 在本例中,使用 fread。就像在其他 PHP 程序一样,读取可以很好地通过 fgets 完成。

处理将以同样的方法继续。程序将在 stream_select 停止,直至数据就绪。重要的一点是,只要任何 连接具有数据,不管顺序怎样,程序都将开始读取。这是程序进行多任务处理或并发处理来自多个请求的结果的方法。

注意,这没有对主机 CPU 造成任何负担。经常会遇到这样一些连网程序,以 CPU 使用率急速上升至 100% 的方式在 while 中使用 fread。那种情况不会出现在这里,因为 stream_select 拥有支持立即响应所需的属性(只要有任何读取信息),但是它将在各读取操作间隙的等待时间内产生可忽略的 CPU 负载。





回页首


必备的 stream_select() 知识

诸如此类的基于事件的编程并不是最基本的。虽然清单 1 被简化到只包含最基本要素,但是涉及作为多任务应用程序必要元素的回调或协调的任何编码,比简单的程序顺序更让人觉得陌生。在这种情况下,大多数挑战集中在 $read 数组上。注意,它是一个引用stream_select 将通过改变 $read 的内容返回重要信息。就像指针是 C 的最大绊脚石一样,引用似乎是 PHP 中最让程序员感到棘手的一部分。

您可以使用这项技术向任意个外部 Web 站点发出请求,确信您的程序会尽快收到所有结果,而无需等待其他请求。实际上,该技术将正确处理所有 TCP/IP 连接,而不只是 Web 端口 80 上的连接,因此您可以大体上管理 LDAP 检索、SMTP 传输、SOAP 请求等。

但那不是全部。PHP V5 将管理 “流” 之类的各种连接,而不仅是简单的套接字。PHP 的 Client URL library (CURL) 支持 HTTPS 证书、FTP 上传、cookie 等。(CURL 允许 PHP 应用程序使用各种协议连接至服务器)。由于 CURL 将提供流接口,因此从程序的角度来看,连接是透明的。下一个部分将展示 stream_select 如何多路传输本地计算。

对于 stream_select 还有几点需要注意。它还在进行文档整理,因为即使最新的 PHP 书籍都没有涉列它。可在 Web 上获得的几个代码示例完全不能工作或者让人产生混淆。stream_select 的第二个和第三个参数用于管理与清单 1 的 read 通道相对应的 write 和 exception 通道,应当始终为 null。除了少数例外情况,在可写通道或异常通道中选择这两个参数是错误的。除非您有经验,否则请坚持可读选择。

此外,至少在 PHP V5.1.2 之前,stream_select 还明显存在错误。最重要的是,不能信任函数的返回值。虽然我尚未调试过实现,但是经验告诉我,可以安全地测试清单 1 中的 count($read),但是测试stream_select 本身的返回值并不 安全(尽管有官方文档)。





回页首


本地 PHP 并发

示例及上面的大部分讨论主要讨论了如何同时管理若干个远程资源并接收到达的结果,而不是按照最初请求的顺序等待处理各个请求。这肯定是 PHP 并发的重要应用。实际应用程序的速度有时候可以提高 10 倍或更多。

如果出现性能衰退怎么办?有没有一种方法可以提升受限于本地处理的 PHP 结果的速度?方法有多种。要说有什么不同的话,这些方法不如清单 1 中的面向套接字的方法有名。造成这种情况的原因有很多,包括:

  • 大多数 PHP 页面已经足够快 —— 更好的性能会是一种优势,但是还不值得对新代码进行投入。
  • 在 Web 页面中使用 PHP 可以放弃部分无关紧要的性能提升 —— 当惟一的价值标准是交付整个 Web 页面需要的时间时,那么重新安排计算以更快地获得中间结果并不重要。
  • PHP 不能控制本地瓶颈 —— 用户可能会为花 8 秒的时间提取帐户记录的详细信息而抱怨,但是那很可能是数据库处理或某种其他 PHP 外部资源的约束。即使将 PHP 处理降至零,单是查找就仍需要花费超过 7 秒的时间。
  • 甚至很少有约束是并行的 —— 假定某特定页面将为具体列出的普通股计算建议交易价格,并且计算十分复杂,需要花费一段时间。计算在本质上可能是顺序执行的。没有一种明显的方法可以将其划分为 “团队协作”。
  • 很少有 PHP 程序员能够认识到 PHP 实现并发的潜力。在具有使用并行实现性能需求的少数人当中,我遇到的大多数人全都说 PHP “不支持线程”,并且甘于使用现有的计算模型。

可是,有时我们可以做得更好。假定 PHP 页面需要计算两只股票价格,可能还需要将两者相比较,并且底层主机刚好是多处理器。在这种情况下,通过将两个截然不同并且十分耗时的计算分配给不同处理器,可能会提高几乎两倍的性能。

在所有 PHP 计算领域中,此类实例很少见。但是,由于我发现到处都没有对它的精确记录,因此需要在这里包括用于此类加速的模型。


清单 5. 延迟服务器实现
                
          <?php
          echo "Program starts at ". date('h:i:s') . ".\n";
          
          $timeout=10; 
          $streams=array();
          $handles=array();
          
	  /* First launch a program with a delay of three seconds, then
	     one which returns after only one second. */
          $delay=3;
          for ($id=0; $id <= 1; $id++) {
	      $error_log="/tmp/error" . $id . ".txt"
              $descriptorspec=array(
                  0 => array("pipe", "r"),
                  1 => array("pipe", "w"),
                  2 => array("file", $error_log, "w")
              );
              $cmd='sleep ' . $delay . '; echo "Finished with delay of ' .
                      $delay . '".';
              $handles[$id]=proc_open($cmd, $descriptorspec, $pipes);
              $streams[$id]=$pipes[1];
              $all_pipes[$id]=$pipes;
              $delay -= 2;
          }
          
          while (count($streams)) { 
              $read=$streams; 
              stream_select($read, $w=null, $e=null, $timeout); 
              foreach ($read as $r) { 
                  $id=array_search($r, $strea**ms); 
                  echo stream_get_contents($all_pipes[$id][1]);
                  if (feof($r)) {
                      fclose($all_pipes[$id][0]);
                      fclose($all_pipes[$id][1]);
                      $returnvalue=proc_close($handles[$id]);
                      unset($streams[$id]); 
                  }
              } 
          } 
         ?>
      

此程序将生成如下输出:

	  Program starts at 10:28:41.
	  Finished with delay of 1.
	  Finished with delay of 3.
      

这里的关键在于 PHP 启动了两个独立子进程,取回待完成的第一个进程的输出,然后取回第二个进程的输出,即使后者启动得较早。如果主机是多处理器计算机,并且操作系统已正确配置,则操作系统本身负责将各个子程序分配给不同的处理器。这是在多处理器主机中良好应用 PHP 的一种方法。





回页首


结束语

PHP 支持多任务。PHP 不按照诸如 Java™ 编程语言或 C++ 等其他语言所采用的方法支持线程,但是以上示例表明 PHP 具有更多的超乎想象的加速潜力。

分享到:
评论

相关推荐

    V5程序多开器-32位程序多开器

    V5程序多开器是一款专为32位操作系统设计的应用程序,它允许用户在同一台计算机上同时运行多个相同的应用程序实例。在许多情况下,这样的工具非常有用,例如,对于需要多账号管理的游戏用户、社交媒体管理人员或者...

    V5程序多开器.zip

    本文将深入探讨V5程序多开器的核心功能、应用场景以及使用技巧,帮助您更好地理解和利用这一实用工具。 首先,理解“多开器”的概念至关重要。多开器是一种软件工具,它能够突破系统限制,使同一应用程序能够在同一...

    IAR EWARM V5嵌入式系统应用编程与开发光盘

    IAR EWARM V5嵌入式系统应用编程与开发图书简介: 本书以瑞典iar systems 公司最新推出的v5版本iar embedded workbench for arm为核心,详细介绍iar c/c++编译器、ilink链接器、iar powerpac 嵌入式实时操作系统以及...

    电脑端V5程序_多开器0.1 Beta原始版可以多开exe程序

    在当今数字化时代,计算机用户对于软件的多任务处理需求日益增长,特别是对于那些需要同时运行多个相同应用程序的用户。这时,一款名为“电脑端V5程序_多开器0.1 Beta原始版”的工具就显得尤为重要。这款多开器专门...

    EXCEL 测量程序V5.rar

    标题“EXCEL 测量程序V5.rar”指的是一个基于Excel的测量应用程序的第五个版本,这个程序可能被设计用于处理与测绘相关的计算任务。在描述中,“EXCEL 测量程序V5”进一步确认了这是一个专为测量工作定制的Excel工具...

    S60v5开发工具含模拟器1.0.1版

    "开发工具含模拟器1.0.1版"指的是用于S60v5应用开发的软件开发工具包(SDK),其中包含了模拟器功能,允许开发者在没有实际设备的情况下测试和调试他们的应用。1.0.1版可能表示这是一个早期版本,但已经足够稳定用于...

    微信小程序-V5KF客服SDK of 微信小程序

    V5智能客服——客户端小程序接入 小程序客服接口接入配置(建议使用) 小程序客服接入建议采用小程序官方客服接口(因小程序内部websocket连接问题未解决,本SDK界面接入方式不建议使用),客服接口接入具体操作步骤如下...

    电脑端V5程序聚合多开器0.1 Beta原始版.zip

    V5程序多开器是一款简单易用的程序多开器软件,V5程序多开器可以帮助用户在一...程序多开器就是针对目前很多程序都加入防止多开功能而开发的,可以多开很多常见的应用程序。目前已经测试过的程序有:MYPTC,FlashGet。

    V5-000_程序模板.rar

    它提供任务调度、同步机制、内存管理等功能,使开发者能构建多任务的嵌入式应用。在STM32平台上,FreeRTOS可以帮助实现高效的系统管理。 4. **ucos-iii**:uC/OS-III是另一款流行的RTOS,同样适合STM32。相比...

    WK系列开发框架-V1至V5 Java开源企业级开发框架(单应用/微服务/分布式)

    WK系列开发框架-V1至V5 Java开源企业级开发框架(单应用/微服务/分布式)。BudWk-V5 Mini 微服务单应用版本(一个jar或打成war运行),管理后台 jQuery + Vue.js + ElementUI,非常适合个人项目快速开发

    IIS和WEB应用程序的具体细节

    虽然本书第一部分以抽象术语讨论了代码编写,但熟悉面向对象编程(OOP)后,详细掌握IIS和Web应用程序的工作机制,将有助于提升应用程序开发的质量与效率。 总之,IIS不仅是Web应用程序的基础设施,更是连接Web...

    V5shop支付宝餐饮小程序上线.pdf

    这种集成为用户在Chromebook设备上运行Android应用提供了更流畅的体验,使得设备能够更好地处理多任务和应用兼容性问题。集成被恰当地命名为“BetterTogether”,意在强调ChromeOS与Android系统的深度融合。 2. ...

    V5多开软件

    【V5多开软件】是一款专门针对需要限制多开的应用程序设计的工具,它允许用户在同一设备上...总的来说,V5多开软件提供了一种解决方案,帮助用户克服了单个应用程序限制多开的问题,提高了工作效率和多任务处理能力。

    v5双开多开器工具.zip

    "v5双开多开器工具"正是一款针对这一需求而设计的专业软件,它允许用户在同一设备上同时运行同一应用程序的多个实例,极大地提高了效率和便利性。 该工具的核心功能是"双开"和"多开",这意味着用户可以开启两个或更...

    v5多开器,沙盒,游戏多开

    【标题】"v5多开器,沙盒,游戏多开"所指的是一款名为v5的多开工具,主要用于实现应用程序,特别是游戏的多个实例同时运行。在IT领域,多开器是一种软件,它允许用户在同一设备上开启同一程序的多个副本,这样就可以在...

    电脑应用程序多开工具.rar

    在IT领域,电脑应用程序多开工具是一种非常实用的软件,它允许用户在同一台电脑上同时运行多个相同的应用程序实例。这种技术在很多场景下都非常有用,例如游戏多开、办公应用多任务处理或者进行测试工作等。下面我们...

    CATIA二次开发

    - **开发流程**:详细介绍CAA V5应用程序的开发流程,包括需求分析、设计、编码、测试等阶段。 - **项目组织**:指导如何组织CAA V5项目的文件结构,包括类库、资源文件等。 - **调试与优化**:提供调试CAA V5应用...

    V5游戏程序多开器适合游戏多开.rar

    V5游戏程序多开器是一款专门针对游戏爱好者设计的实用工具,它允许用户在同一台计算机上同时运行多个游戏实例,极大地满足了玩家进行游戏多账号管理、多任务处理的需求。这款多开器以其简单易用的特性,深受广大用户...

Global site tag (gtag.js) - Google Analytics