php开启多进程的方法
本文实例讲述了php开启多进程的方法。分享给大家供大家参考。具体实现方法如下：
<?php
$IP='192.168.1.1';//Windows電腦的IP
$Port='5900'; //VNC使用的Port
$ServerPort='9999';//LinuxServer對外使用的Port
$RemoteSocket=false;//連線到VNC的Socket
functionSignalFunction($Signal){
//這是主Process的訊息處理函數
global$PID;//ChildProcess的PID
switch($Signal)
{
caseSIGTRAP:
caseSIGTERM:
//收到結束程式的Signal
if($PID)
{
//送一個SIGTERM的訊號給Child告訴他趕快結束掉嘍
posix_kill($PID,SIGTERM);
//等待ChildProcess結束，避免zombie
pcntl_wait($Status);
}
//關閉主Process開啟的Socket
DestroySocket();
exit(0);//結束主Process
break;
caseSIGCHLD:
/*
當ChildProcess結束掉時，Child會送一個SIGCHLD訊號給Parrent
當Parrent收到SIGCHLD，就知道ChildProcess已經結束嘍，該做一些
結束的動作*/
unset($PID);//將$PID清空，表示ChildProcess已經結束
pcntl_wait($Status);//避免Zombie
break;
default:
}
}
functionChildSignalFunction($Signal){
//這是ChildProcess的訊息處理函數
switch($Signal)
{
caseSIGTRAP:
caseSIGTERM:
//ChildProcess收到結束的訊息
DestroySocket();//關閉Socket
exit(0);//結束ChildProcess
default:
}
}
functionProcessSocket($ConnectedServerSocket){
//ChildProcessSocket處理函數
//$ConnectedServerSocket->外部連進來的Socket
global$ServerSocket,$RemoteSocket,$IP,$Port;
$ServerSocket=$ConnectedServerSocket;
declare(ticks=1);//這一行一定要加，不然沒辦法設定訊息處理函數。
//設定訊息處理函數
if(!pcntl_signal(SIGTERM,"ChildSignalFunction"))return;
if(!pcntl_signal(SIGTRAP,"ChildSignalFunction"))return;
//建立一個連線到VNC的Socket
$RemoteSocket=socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
//連線到內部的VNC
@$RemoteConnected=socket_connect($RemoteSocket,$IP,$Port);
if(!$RemoteConnected)return;//無法連線到VNC結束
//將Socket的處理設為Nonblock，避免程式被Block住
if(!socket_set_nonblock($RemoteSocket))return;
if(!socket_set_nonblock($ServerSocket))return;
while(true)
{
//這邊我們採用pooling的方式去取得資料
$NoRecvData=false; //這個變數用來判別外部的連線是否有讀到資料
$NoRemoteRecvData=false;//這個變數用來判別VNC連線是否有讀到資料
@$RecvData=socket_read($ServerSocket,4096,PHP_BINARY_READ);
//從外部連線讀取4096bytes的資料
@$RemoteRecvData=socket_read($RemoteSocket,4096,PHP_BINARY_READ);
//從vnc連線連線讀取4096bytes的資料
if($RemoteRecvData==='')
{
//VNC連線中斷，該結束嘍
echo"RemoteConnectionClose\n";
return;
}
if($RemoteRecvData===false)
{
/*
由於我們是採用nonblobk模式
這裡的情況就是vnc連線沒有可供讀取的資料
*/
$NoRemoteRecvData=true;
//清除掉LastErrror
socket_clear_error($RemoteSocket);
}
if($RecvData==='')
{
//外部連線中斷，該結束嘍
echo"ClientConnectionClose\n";
return;
}
if($RecvData===false)
{
/*
由於我們是採用nonblobk模式
這裡的情況就是外部連線沒有可供讀取的資料
*/
$NoRecvData=true;
//清除掉LastErrror
socket_clear_error($ServerSocket);
}
if($NoRecvData&&$NoRemoteRecvData)
{
//如果外部連線以及VNC連線都沒有資料可以讀取時，
//就讓程式睡個0.1秒，避免長期佔用CPU資源
usleep(100000);
//睡醒後，繼續作pooling的動作讀取socket
continue;
}
//RecvData
if(!$NoRecvData)
{
//外部連線讀取到資料
while(true)
{
//把外部連線讀到的資料，轉送到VNC連線上
@$WriteLen=socket_write($RemoteSocket,$RecvData);
if($WriteLen===false)
{
//由於網路傳輸的問題，目前暫時無法寫入資料
//先睡個0.1秒再繼續嘗試。
usleep(100000);
continue;
}
if($WriteLen===0)
{
//遠端連線中斷，程式該結束了
echo"RemoteWriteConnectionClose\n";
return;
}
//從外部連線讀取的資料，已經完全送給VNC連線時，中斷這個迴圈。
if($WriteLen==strlen($RecvData))break;
//如果資料一次送不完就得拆成好幾次傳送，直到所有的資料全部送出為止
$RecvData=substr($RecvData,$WriteLen);
}
}
if(!$NoRemoteRecvData)
{
//這邊是從VNC連線讀取到的資料，再轉送回外部的連線
//原理跟上面差不多不再贅述
while(true)
{
@$WriteLen=socket_write($ServerSocket,$RemoteRecvData);
if($WriteLen===false)
{
usleep(100000);
continue;
}
if($WriteLen===0)
{
echo"RemoteWriteConnectionClose\n";
return;
}
if($WriteLen==strlen($RemoteRecvData))break;
$RemoteRecvData=substr($RemoteRecvData,$WriteLen);
}
}
}
}
functionDestroySocket(){
//用來關閉已經開啟的Socket
global$ServerSocket,$RemoteSocket;
if($RemoteSocket)
{
//如果已經開啟VNC連線
//在CloseSocket前必須將Socketshutdown不然對方不知到你已經關閉連線了
@socket_shutdown($RemoteSocket,2);
socket_clear_error($RemoteSocket);
//關閉Socket
socket_close($RemoteSocket);
}
//關閉外部的連線
@socket_shutdown($ServerSocket,2);
socket_clear_error($ServerSocket);
socket_close($ServerSocket);
}
//這裡是整個程式的開頭，程式從這邊開始執行
//這裡首先執行一次fork
$PID=pcntl_fork();
if($PID==-1)die("couldnotfork");
//如果$PID不為0表示這是ParrentProcess
//$PID就是ChildProcess
//這是ParrentProcess自己結束掉，讓Child成為一個Daemon。
if($PID)die("DaemonPID:$PID\n");
//從這邊開始，就是Daemon模式在執行了
//將目前的Process跟終端機脫離成為daemon模式
if(!posix_setsid())die("couldnotdetachfromterminal\n");
//設定daemon的訊息處理函數
declare(ticks=1);
if(!pcntl_signal(SIGTERM,"SignalFunction"))die("Error!!!\n");
if(!pcntl_signal(SIGTRAP,"SignalFunction"))die("Error!!!\n");
if(!pcntl_signal(SIGCHLD,"SignalFunction"))die("Error!!!\n");
//建立外部連線的Socket
$ServerSocket=socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
//設定外部連線監聽的IP以及Port，IP欄位設0，表示經聽所有介面的IP
if(!socket_bind($ServerSocket,0,$ServerPort))die("CannotBindSocket!\n");
//開始監聽Port
if(!socket_listen($ServerSocket))die("CannotListen!\n");
//將Socket設為nonblock模式
if(!socket_set_nonblock($ServerSocket))die("CannotSetServerSockettoBlock!\n");
//清空$PID變數，表示目前沒有任何的ChildProcess
unset($PID);
while(true)
{
//進入pooling模式，每隔1秒鐘就去檢查有沒有連線進來。
sleep(1);
//檢查有沒有連線進來
@$ConnectedServerSocket=socket_accept($ServerSocket);
if($ConnectedServerSocket!==false)
{
//有人連進來嘍
//起始一個ChildProcess用來處理連線
$PID=pcntl_fork();
if($PID==-1)die("couldnotfork");
if($PID)continue;//這是daemonprocess，繼續回去監聽。
//這裡是ChildProcess開始
//執行Socket裡函數
ProcessSocket($ConnectedServerSocket);
//處理完Socket後，結束掉Socket
DestroySocket();
//結束ChildProcess
exit(0);
}
}
希望本文所述对大家的php程序设计有所帮助。