php_php 팁에서 여러 프로세스를 시작하는 방법

$IP='192.168.1.1';//Windows 컴퓨터의 IP
$Port='5900'; //VNC에서 사용하는 포트
$ServerPort='9999';//Linux Server가 외부에서 사용하는 포트
$RemoteSocket=false;//VNC 소켓에 연결
함수 SignalFunction($Signal){
//메인 프로세스의 메시지 처리 기능입니다
global $PID;//하위 프로세스의 PID
스위치($Signal)
{
케이스 SIGTRAP:
케이스 SIGTERM:
//프로그램 종료 신호를 받습니다
if($PID)
{
//SIGTERM 신호를 Child에게 보내고 가능한 한 빨리 종료하라고 지시합니다
posix_kill($PID,SIGTERM);
//좀비를 피하기 위해 하위 프로세스가 끝날 때까지 기다립니다
pcntl_wait($Status);
}
//메인 프로세스에 의해 열린 소켓을 닫습니다
DestroySocket();
exit(0); //메인 프로세스 종료
휴식;
사례 SIGCHLD:
/*
하위 프로세스가 종료되면 하위는 상위로 SIGCHLD 신호를 보냅니다
부모가 SIGCHLD를 받으면 자식 프로세스가 종료되었으며 무언가를 해야 한다는 것을 알게 됩니다.
액션 종료*/
unset($PID); //$PID를 지워 하위 프로세스가 종료되었음을 나타냅니다.
pcntl_wait($Status); //좀비 피하기
휴식;
기본값:
}
}
함수 ChildSignalFunction($Signal){
//Child Process의 메시지 처리 기능입니다
스위치($Signal)
{
케이스 SIGTRAP:
케이스 SIGTERM:
//하위 프로세스가 종료 메시지를 받습니다
DestroySocket(); //소켓 닫기
exit(0); //자식 프로세스 종료
기본값:
}
}
함수 ProcessSocket($ConnectedServerSocket){
//하위 프로세스 소켓 처리 함수
//$ConnectedServerSocket -> 외부 연결 소켓
전역 $ServerSocket,$RemoteSocket,$IP,$Port;
$ServerSocket=$ConnectedServerSocket;
선언(ticks = 1); //이 줄을 추가해야 합니다. 그렇지 않으면 메시지 처리 기능을 설정할 수 없습니다.
//메시지 처리 기능 설정
if(!pcntl_signal(SIGTERM, "ChildSignalFunction")) return;
if(!pcntl_signal(SIGTRAP, "ChildSignalFunction")) return;
//VNC에 연결된 소켓 설정
$RemoteSocket=socket_create(AF_INET, SOCK_STREAM,SOL_TCP);
//내부 VNC에 연결
@$RemoteConnected=socket_connect($RemoteSocket,$IP,$Port);
if(!$RemoteConnected) return; //VNC에 연결할 수 없습니다. 종료
//프로그램이 차단되는 것을 방지하기 위해 소켓 처리를 Nonblock으로 설정
if(!socket_set_nonblock($RemoteSocket)) return;
if(!socket_set_nonblock($ServerSocket)) return;
동안(참)
{
//여기서는 풀링을 사용하여 데이터를 얻습니다
$NoRecvData=false; //외부 연결에서 데이터를 읽었는지 확인하는 변수입니다
$NoRemoteRecvData=false;//이 변수는 VNC 연결에 읽은 데이터가 있는지 확인하는 데 사용됩니다.
@$RecvData=socket_read($ServerSocket,4096,PHP_BINARY_READ);
//외부 연결에서 4096바이트의 데이터를 읽습니다
@$RemoteRecvData=socket_read($RemoteSocket,4096,PHP_BINARY_READ);
//vnc 연결에서 4096바이트의 데이터를 읽습니다.
if($RemoteRecvData===='')
{
//VNC 연결이 중단되었습니다. 이제 종료할 시간입니다
echo "원격 연결 종료";
반품
}
if($RemoteRecvData===false)
{
/*
nonblobk 모드를 사용하고 있으므로
여기서 상황은 vnc 연결에 읽을 데이터가 없다는 것입니다
*/
$NoRemoteRecvData=true;
//마지막 오류 지우기
Socket_clear_error($RemoteSocket);
}
if($RecvData==='')
{
//외부 연결이 중단되었습니다. 이제 종료할 시간입니다
echo "클라이언트 연결 종료";
반품;
}
if($RecvData===false)
{
/*
nonblobk 모드를 사용하고 있으므로
여기서의 상황은 외부 연결에 읽을 데이터가 없다는 것입니다
*/
$NoRecvData=true;
//마지막 오류 지우기
소켓_clear_error($ServerSocket);
}
if($NoRecvData&&$NoRemoteRecvData)
{
//외부 연결이나 VNC 연결 모두 읽을 데이터가 없는 경우
//CPU 자원의 장기간 사용을 피하기 위해 프로그램을 0.1초 동안 휴면 상태로 둡니다
usleep(100000);
//깨어난 후 소켓을 읽기 위해 풀링 작업을 계속합니다
계속;
}
//데이터 수신
if(!$NoRecvData)
{
//외부 연결에서 데이터 읽기
동안(참)
{
//외부 연결에서 읽은 데이터를 VNC 연결로 전송
@$WriteLen=socket_write($RemoteSocket,$RecvData);
If($WriteLen===false)
{
//네트워크 전송 문제로 현재 데이터를 쓸 수 없습니다
//0.1초 동안 휴면한 후 다시 시도하세요.
usleep(100000);
계속하세요;
}
If($WriteLen===0)
{
//원격접속이 중단되어 프로그램이 종료되어야 합니다
echo"원격 쓰기 연결 종료";
반품;
}
//외부 연결에서 읽은 데이터가 VNC 연결로 완전히 전송되면 이 루프가 중단됩니다.
If($WriteLen==strlen($RecvData)) break;
//한 번에 데이터를 전송할 수 없는 경우 모든 데이터가 전송될 때까지 여러 번 전송해야 합니다
$RecvData=substr($RecvData,$WriteLen);
}
}
if(!$NoRemoteRecvData)
{
//VNC 연결에서 읽어온 후 외부 연결로 다시 전송한 데이터입니다
//원리는 위와 거의 동일하므로 자세한 내용은 다루지 않겠습니다
동안(참)
{
@$WriteLen=socket_write($ServerSocket,$RemoteRecvData);
If($WriteLen===false)
{
usleep(100000);
계속하세요;
}
If($WriteLen===0)
{
echo"원격 쓰기 연결 종료";
반품;
}
If($WriteLen==strlen($RemoteRecvData)) break;
$RemoteRecvData=substr($RemoteRecvData,$WriteLen);
}
}
}
}
함수 DestroySocket(){
//열린 소켓을 닫는 데 사용됩니다
global$ServerSocket,$RemoteSocket;
if($RemoteSocket)
{
//VNC 연결이 이미 활성화된 경우
//소켓을 닫기 전에 소켓을 종료해야 합니다. 그렇지 않으면 상대방이 연결을 종료했다는 사실을 알 수 없습니다.
@socket_shutdown($RemoteSocket,2);
Socket_clear_error($RemoteSocket);
//소켓 닫기
소켓_닫기($RemoteSocket)
}
//외부 연결 끊기
@socket_shutdown($ServerSocket,2);
소켓_clear_error($ServerSocket);
소켓_닫기($ServerSocket);
}
//전체 프로그램의 시작 부분이며, 여기서부터 프로그램 실행이 시작됩니다
//먼저 여기서 포크
를 실행합니다. $PID=pcntl_fork();
if($PID==-1) die("포크할 수 없습니다");
//$PID가 0이 아니면 상위 프로세스임을 의미합니다
//$PID는 하위 프로세스입니다
//이것은 부모 프로세스입니다. 직접 종료하고 자식이 데몬이 되도록 합니다.
if($PID) die("데몬 PID:$PIDn");
//여기서부터 데몬모드가 실행됩니다
//현재 프로세스를 터미널에서 분리하고 데몬 모드로 들어갑니다
if(!posix_setsid()) die("터미널n에서 분리할 수 없습니다.");
//데몬의 메시지 처리 기능 설정
선언(틱 = 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");
//외부 연결을 위한 소켓 설정
$ServerSocket=socket_create(AF_INET, SOCK_STREAM,SOL_TCP);
//외부 연결 모니터링을 위한 IP 및 포트를 설정합니다. IP 필드를 0으로 설정합니다. 이는 모든 인터페이스의 IP를 수신한다는 의미입니다
if(!socket_bind($ServerSocket,0,$ServerPort)) die("소켓을 바인딩할 수 없습니다!n");
//Port 듣기 시작
if(!socket_listen($ServerSocket)) die("들을 수 없습니다!n");
//소켓을 비차단 모드로 설정
if(!socket_set_nonblock($ServerSocket)) die("서버 소켓을 차단하도록 설정할 수 없습니다!n");
//$PID 변수를 지워 현재 하위 프로세스가 없음을 나타냅니다
설정 해제($PID);
동안(참)
{
//풀링 모드로 진입하여 1초마다 연결이 있는지 확인합니다.
수면(1);
//연결이 들어오는지 확인
@$ConnectedServerSocket=socket_accept($ServerSocket);
if($ConnectedServerSocket!==false)
{
//누군가 들어오고 있어요
//연결을 처리하기 위해 하위 프로세스 시작
$PID=pcntl_fork();
If($PID==-1) die("포크할 수 없음");
If($PID) continue;//데몬 프로세스이므로 계속 모니터링하세요.
//자식 프로세스의 시작은 다음과 같습니다
//소켓에서 함수 실행
ProcessSocket($ConnectedServerSocket);
//소켓 처리 후 소켓 종료
DestroySocket();
//하위 프로세스 종료
종료(0);
}
}