用 PHP V5 开发多任务应用程序
| out); 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. 了解这其中的工作原理至关重要。在较高层次上，第一个程序将发出几个 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. 延迟服务器将作为 CGI 实现，如下所示： 清单 3. 延迟服务器实现 #!/bin/sh echo "Content-type: text/html ＜HTML＞ ＜HEAD＞＜/HEAD＞ ＜BODY＞" echo "Starting at `date`." 虽然清单 3 的特殊实现特定于 UNIX?，但是本文中几乎所有实现都将很好地应用于 Windows?（尤其是 Windows 98 以后的版本）或 PHP 的 UNIX 安装。特别地，清单 1 可以托管在任意一个操作系统中。因此，Linux? 和 Mac OS X 都是 UNIX 变体，因此这里所有的代码都可以在两者的任意一种中运行。 按照以下顺序向延迟服务器发出请求。 清单 4. 进程启动顺序 delay=15 stream_select 的作用是尽可能快速地接收结果。在这种情况下，它执行的顺序与发出结果的顺序刚好相反。3 秒后，第一个页面已经准备好读取。程序的这一部分也符合常规 PHP —— 在本例中，使用 fread。就像在其他 PHP 程序一样，读取可以很好地通过 fgets 完成。 处理将以同样的方法继续。程序将在 stream_select 停止，直至数据就绪。重要的一点是，只要任何 连接具有数据，不管顺序怎样，程序都将开始读取。这是程序进行多任务处理或并发处理来自多个请求的结果的方法。 注意，这没有对主 |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
