电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

用 PHP V5 開發多任務應用程序

瀏覽:2日期:2024-02-15 15:29:46

許多 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 頁面

<?phpecho '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.0rnHost: phaseit.netrnrn'; 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 tocompute 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 failedto 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 $DELAYecho '<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=15delay=12delay= 9delay= 6delay= 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. 延遲服務器實現

<?phpecho 'Program starts at '. date('h:i:s') . '.n';

$timeout=10; $streams=array();$handles=array();

/* First launch a program with a delay of three seconds, thenone 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]); $return_value=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 具有更多的超乎想象的加速潛力。

標簽: PHP
主站蜘蛛池模板: 骨密度仪-骨密度测定仪-超声骨密度仪-骨龄测定仪-天津开发区圣鸿医疗器械有限公司 | 粉丝机械,粉丝烘干机,粉丝生产线-招远市远东粉丝机械有限公司 | 哔咔漫画网页版在线_下载入口访问指引 | 蓝莓施肥机,智能施肥机,自动施肥机,水肥一体化项目,水肥一体机厂家,小型施肥机,圣大节水,滴灌施工方案,山东圣大节水科技有限公司官网17864474793 | SEO网站优化,关键词排名优化,苏州网站推广-江苏森歌网络 | 螺旋叶片_螺旋叶片成型机_绞龙叶片_莱州源泽机械制造有限公司 | 电磁流量计_智能防腐防爆管道式计量表-金湖凯铭仪表有限公司 | 五轴加工中心_数控加工中心_铝型材加工中心-罗威斯 | 金属抛光机-磁悬浮抛光机-磁力研磨机-磁力清洗机 - 苏州冠古科技 | 散热器厂家_暖气片_米德尔顿散热器 | 钢格板|镀锌钢格板|热镀锌钢格板|格栅板|钢格板|钢格栅板|热浸锌钢格板|平台钢格板|镀锌钢格栅板|热镀锌钢格栅板|平台钢格栅板|不锈钢钢格栅板 - 专业钢格板厂家 | 盘煤仪,盘料仪,盘点仪,堆料测量仪,便携式激光盘煤仪-中科航宇(北京)自动化工程技术有限公司 | 留学生辅导网-在线课程论文辅导-留学生挂科申诉机构 | 便携式XPDM露点仪-在线式防爆露点仪-增强型烟气分析仪-约克仪器 冰雕-冰雪世界-大型冰雕展制作公司-赛北冰雕官网 | 陕西鹏展科技有限公司| 自动钻孔机-全自动数控钻孔机生产厂家-多米(广东)智能装备有限公司 | 合肥升降机-合肥升降货梯-安徽升降平台「厂家直销」-安徽鼎升自动化科技有限公司 | 安徽千住锡膏_安徽阿尔法锡膏锡条_安徽唯特偶锡膏_卡夫特胶水-芜湖荣亮电子科技有限公司 | 提升海外网站流量,增加国外网站访客UV,定制海外IP-访客王 | 范秘书_懂你的范文小秘书| 实验室隔膜泵-无油防腐蚀隔膜泵-耐腐蚀隔膜真空泵-杭州景程仪器 电杆荷载挠度测试仪-电杆荷载位移-管桩测试仪-北京绿野创能机电设备有限公司 | 电磁流量计_智能防腐防爆管道式计量表-金湖凯铭仪表有限公司 | EFM 022静电场测试仪-套帽式风量计-静电平板监测器-上海民仪电子有限公司 | 吲哚菁绿衍生物-酶底物法大肠菌群检测试剂-北京和信同通科技发展有限公司 | CXB船用变压器-JCZ系列制动器-HH101船用铜质开关-上海永上船舶电器厂 | 整车VOC采样环境舱-甲醛VOC预处理舱-多舱法VOC检测环境仓-上海科绿特科技仪器有限公司 | 福兰德PVC地板|PVC塑胶地板|PVC运动地板|PVC商用地板-中国弹性地板系统专业解决方案领先供应商! 福建成考网-福建成人高考网 | 北京公积金代办/租房发票/租房备案-北京金鼎源公积金提取服务中心 | 压滤机-洗沙泥浆处理-压泥机-山东创新华一环境工程有限公司 | 上海电子秤厂家,电子秤厂家价格,上海吊秤厂家,吊秤供应价格-上海佳宜电子科技有限公司 | 智能垃圾箱|垃圾房|垃圾分类亭|垃圾分类箱专业生产厂家定做-宿迁市传宇环保设备有限公司 | 美的商用净水器_美的直饮机_一级代理经销商_Midea租赁价格-厂家反渗透滤芯-直饮水批发品牌售后 | 影像测量仪_三坐标测量机_一键式二次元_全自动影像测量仪-广东妙机精密科技股份有限公司 | 顶呱呱交易平台-行业领先的公司资产交易服务平台 | 拖链电缆_柔性电缆_伺服电缆_坦克链电缆-深圳市顺电工业电缆有限公司 | 锂电混合机-新能源混合机-正极材料混料机-高镍,三元材料混料机-负极,包覆混合机-贝尔专业混合混料搅拌机械系统设备厂家 | 楼承板设备-楼承板成型机-免浇筑楼承板机器厂家-捡来 | 一体化污水处理设备_生活污水处理设备_全自动加药装置厂家-明基环保 | 新型锤式破碎机_新型圆锥式_新型颚式破碎机_反击式打沙机_锤式制砂机_青州建源机械 | 深圳市超时尚职业培训学校,培训:月嫂,育婴,养老,家政;化妆,美容,美发,美甲. | 海鲜池-专注海鲜鱼缸、移动海鲜缸、饭店鱼缸设计定做-日晟水族厂家 |