WebSVN – php-qbpwcf – Diff – /trunk/usr/bin/webSocketClientDaemon.php

 #!/usr/bin/php
 <?php
 /*
 	QBPWCF, Quick Build PHP website Component base on Fedora Linux.
-    Copyright (C) 2015~2024 Min-Jhin,Chen
+    Copyright (C) 2014~2025 MIN ZHI, CHEN
     This file is part of QBPWCF.
     QBPWCF is free software: you can redistribute it and/or modify
     it under the terms of the GNU General Public License as published by
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     GNU General Public License for more details.
     You should have received a copy of the GNU General Public License
     along with QBPWCF.  If not, see <http://www.gnu.org/licenses/>.
 */
 /*
 說明:
 啟動 用來接收 request 來跟 web socket server 互動.
 	#結束執行,回傳shell 1.
 	exit(1);
 	}#if end
 #設置 include path
 set_include_path($output[0].PATH_SEPARATOR.get_include_path());
 #匯入外部套件
 include("allInOne.php");
 #說明函式
 function help()
+{
 	#印出指令說明
 	echo "Usage of ".basename(__FILE__).":".PHP_EOL;
 	echo "--domain 代表要連線的 web socket 服務域名".PHP_EOL;
 	echo "--path 代表要連線的 web socket 服務path,預設為 wss".PHP_EOL;
 	echo "--port 代表要連線的 web socket 服務port,預設為 443".PHP_EOL;
 	#結束執行
 	exit;
+}
 #函式說明:
 #如果解析參數失敗
 if($parseArgu["status"]==="false")
+{
 	#印出結果
 	var_dump($parseArgu);
 	#結束執行,回傳shell 1
 	exit(1);
 }#if end
 #檢查參數
 #函式說明:
 #檢查必填與可省略參數，可省略參數可指定預設要給與什麼數值內容。
 #若執行失敗
 if($checkArguments["status"]==="false"){
 	#印出結果
 	var_dump($checkArguments);
 	#結束執行,回傳shell 1
 	exit(1);
 	}#if end
 #若檢查不通過
 if($checkArguments["passed"]==="false"){
 	#印出結果
 	var_dump($checkArguments);
 	#結束執行,回傳shell 1
 	exit(1);
 	}#if end
 	#等待1毫秒
 	usleep(100000);
 	#針對每個程序
 	foreach($proc["content"] as $index=>$process){
 		#如果程序執行異常
 		if($process["status"]==="false"){
 			#debug
 			var_dump($proc);
 			#移除該程序資訊
 			unset($proc["content"][$index]);
 			}#if end
 		#如果是 resource
 		if(is_resource($process["process"])){
 			#如果error為resource
 			if(is_resource($process["error"])){
 				#將建立的 listen sock 放到 $master 陣列
 				$master[] = $process["error"];
 				#設置給 stream_select 監控的sock變數
 				$read = $write = $except = $master;
 				#等待0.1秒，看有沒有讀寫的狀況
 				$mod_fd = stream_select($read, $write, $except, 1);
 				#如果偵測異動失敗
 				if($mod_fd===FALSE){
 					#monitior stream failed
 					#debug
 					var_dump($proc);
 					#結束執行,回傳shell 1
 					exit(1);
 					}#if end
 				#如果有異動的跡象
 				else if($mod_fd>0){
 					#針對每個異動的 stream
 					foreach($read as $readStream){
 						#如果是有錯誤輸出
 						if($readStream===$process["error"]){
 							#debug
 							#echo "try read std error output".PHP_EOL;
 							#讀取1Kbyte
 							$errorByte=fread($process["error"],1024);
 							#提示為錯誤訊息
 							echo "error:";
 							#印出內容
 							echo $errorByte;
 							#換行
 							echo PHP_EOL;
 							}#if end
 						}#foreach end
 					}#if end
 				}#if end
 			#如果content為resource
 			if(is_resource($process["content"])){
 				#將建立的 listen sock 放到 $master 陣列
 				$master[] = $process["content"];
 				#設置給 stream_select 監控的sock變數
 				$read = $write = $except = $master;
 				#等待1秒，看有沒有讀寫的狀況
 				$mod_fd = stream_select($read, $write, $except, 1);
 				#如果偵測異動失敗
 				if($mod_fd===FALSE){
 					#monitior stream failed
 					#debug
 					var_dump($proc);
 					#結束執行,回傳shell 1
 					exit(1);
 					}#if end
 				#如果有異動的跡象
 				else if($mod_fd>0){
 					#針對每個異動的 stream
 					foreach($read as $readStream){
 						#如果是有標準輸出
 						if($readStream===$process["content"]){
 							#debug
 							#echo "try read std output".PHP_EOL;
 							#不讓標準輸出會阻擋程式執行
 							#stream_set_blocking($process["content"],false);
 							#讀取1Kbyte
 							$contentByte=fread($process["content"],1024);
 							#如果有資料
 							if(strlen($contentByte)>0){
 								#如果有關鍵字
 								if(strpos($contentByte,"unixDomainSocket:")===0){
 									#函式說明:
 									#將固定格式的字串分開,並回傳分開的結果.
 									#回傳結果:
 									#$result["status"],執行是否正常,"true"代表正常,"false"代表不正常.
 									#$result["error"],錯誤訊息陣列
 									#無.
 									#備註:
 									#無.
 									$spiltString=stringProcess::spiltString($conf);
 									unset($conf);
 									#debug
 									#var_dump(__LINE__,$spiltString);
 									#如果執行失敗
 									if($spiltString["status"]==="false"){
 										#debug
 										var_dump($spiltString);
 										#結束執行,回傳shell 1
 										exit(1);
 										}#if end
 									#如果有分割用的關鍵字
 									if($spiltString["found"]==="true"){
 										#如果分割出來的數量為1
 										if($spiltString["dataCounts"]===1){
 											#取得 unix doamin socket 的位置
 											$unixDomainSocket=$spiltString["dataArray"][0];
 											#提示透過 unix domain socket 來傳接收要做的事情
 											echo "Using unix domain socket:".$unixDomainSocket." 來跟 web socket server 互動".PHP_EOL;
 											#後面忽略，換下一個
 											continue;
 											}#if end
 										}#if end
 									}#if end
 								#印出內容
 								echo $contentByte;
 								#換行
 								echo PHP_EOL;
 								}#if end
 							}#if end
 						}#foreach end
 					}#if end
 					#反之代表沒有任何輸出
 					else{
 						#提示在等待任何輸出
 						echo ".";
 						}#else end
 				}#if end
 			#如果已經結束執行
 			if($process["proc_get_status"]["running"]==="false"){
 				#移除該程序資訊
 				unset($proc["content"][$index]);
 				}#if end
 			#反之
 			else{
 				#更新 "proc_get_status"
 				$proc["content"][$index]["proc_get_status"]=proc_get_status($process["process"]);
 				}#else end
 			}#if end
 		#反之
 		else{
 			#移除該程序資訊
 			unset($proc["content"][$index]);
 			}#else end
 		}#foreach end
-	}#while end
 	}#while end

Subversion Repositories php-qbpwcf

(root)/trunk/usr/bin/webSocketClientDaemon.php – Rev 3 → 226