발진!! 아스라다

set_time_limit(0);

define("_IP",    {IP});
define("_PORT",  {PORT});
define("_TIMEOUT", 10);

$cSock = array();
$cInfo = array();

$sSock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_bind($sSock, _IP, _PORT);
socket_listen($sSock);

while(1)
{
  $sockArr = array_merge(array($sSock), $cSock);

  if(socket_select($sockArr, $tWrite = NULL, $tExcept = NULL, _TIMEOUT) > 0)
  {
       foreach($sockArr as $key => $sock)
       {
           // Listen 하고 있는 서버 소켓일 경우
           // 새로운 클라이언트의 접속을 의미
           echo $sock.'/'.$sSock."\n";

           if($sock == $sSock)
           {
               $tSock = socket_accept($sSock);

               socket_getpeername($tSock, $sockIp, $sockPort);

               $cSock[$tSock] = $tSock;
               $cInfo[$tSock] = array('ip'=>$sockIp, 'port'=>$sockPort);

               msg("client connect : ".$sockIp.":".$sockPort."\n");
           }
           // 클라이언트 접속해 있는 소켓중 하나일경우
           // 해당 클라이언트에서 이벤트가 발생함을 의미
           else
           {
               $buf = socket_read($sock, 4096);

               // 접속 종료
               if(!$buf)
               {
                   exceptSocket($cSock, $cInfo, $sock);
                   msg("client connection broken : ".$sockIp.":".$sockPort."\n");
               }
               // 메시지 수신 이벤트
               else
               {
                   msg("recive data : ".$buf."\n");

                   $thisSockInfo = $cInfo[$sock];
                   //$cmd = substr($buf, 0, 4);
                   $cmd = $buf;

                   switch($cmd)
                   {
                       // 시간전송
                       case "time":
                           msg("client(".$thisSockInfo['port'].") time data request\n");
                           socket_write($sock, date("Y/m/d H:i:s"));
                           break;

                       // 종료
                       case "quit":
                           msg("client(".$thisSockInfo['port'].") quit request\n");
                           socket_write($sock, "quit");
                           socket_close($sock);
                           exceptSocket($cSock, $cInfo, $sock);
                           break;
                       default:
                           if(substr($cmd,0,1) == ':'){
                               msg("client(".$thisSockInfo['port'].") sendmsg : ".substr($cmd,1)."\n");
                               broadCasting($sockArr,$sock,substr($cmd,1));
                           }else{
                               msg("client(".$thisSockInfo['port'].") invalid command $cmd\n");
                           }
                           break;
                   }
               }
           }
       }
  }

  $i++;

}

function exceptSocket(&$sockSet, &$infoSet, $sock)
{
  unset($sockSet[$sock]);
  unset($infoSet[$sock]);
  // array_merge 함수에서 error 발생을 막기위한 처리
  if(count($sockSet)==0)
  {
       $sockSet = array();
       $infoSet = array();
  }
}

function msg($msg)
{
  echo "SERVER >> ".$msg;
}

function broadCasting($socks,$cSock,$msg){
  global $sSock;

  foreach($socks as $key => $sock){
       if($sock != $sSock && $sock != $cSock){
           socket_write($sock,$msg);
       }
  }
}

define("_IP",    {IP});
define("_PORT",  {PORT});

$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_connect($sock, _IP, _PORT);

msg("socket connect to "._IP.":"._PORT."\n");

while(1)
{
  msg("Enter command time or quit : ");

  // 사용자의 명령어를 입력받습니다.
  $stdin = ereg_replace("\n|\r", "", read_data());
  //$stdin = substr($stdin, 0, 4);

  // time 또는 quit 메시지 말고는 무시 합니다.
  if($stdin == "time" || $stdin == "quit")
  {
       msg("Input command : ".$stdin."\n");
  }else{
       if(substr($stdin,0,1) == ':'){
           msg("sendmsg : ".$stdin."\n");
       }else{
           msg("invalid command (not send). If you want said ':' and your message.: ".$stdin."\n");
           continue;
       }
  }

  socket_write($sock, $stdin);
  $sMsg  = socket_read($sock, 4096);

  if(substr($sMsg, 0, 4) == 'quit')
  {
       socket_close($sock);
       exit;
  }else
  {
       msg("recived data : ".$sMsg."\n");
  }
}

// 표준입력을 받아 값을 리턴하는 함수
function read_data()
{
  $in = fopen("php://stdin", "r");
  $in_string = fgets($in, 255);
  fclose($in);
  return $in_string;
}

// 로그 출력
function msg($msg)
{
  echo "CLIENT >> ".$msg;
}