PHP에서 네트웍 관련 프로그램을 짜다 보면 쓰레드 지원이 되지 않음으로 인해
가끔씩 불편할 때가 있습니다. 이런 경우에 사용하려고 예전에 짜두었던 건데 혹시나
필요하신 분들이 있을거 같아 올려봅니다.

알고리즘은 간단합니다.
먼저 단일처리를 하는 PHP를 작성합니다. 예를 들어 single_process.php 라고 이름합니다.
이 PHP에서는 결과를 단순 text 로 출력합니다. 예를 들어 Success 와 같이... 아니면
serialize 를 이용해서 배열을 출력할수도 있습니다.
다음에 이 단일처리 PHP를 비동기식으로 호출할 쓰레드 PHP를 작성합니다.
즉 쓰레드 PHP 에서 비동기식으로 단일처리 PHP를 여러개 호출하고 결과를 한꺼번에
받는 방식입니다.
엄밀히 말해 멀티 쓰레드를 흉내낸 멀티 프로세스 방식이라고 할수 있습니다. ^^;

무슨 말인지 잘 모르시겠죠.. 저도 써놓구 좀 그렇네요..
소스를 보면서 설명을 드리겠습니다.

# single_process.php 소스코드
<?php
mail("xxx@xxx.com", "멀티쓰레드 흉내내기 $no", "쓰레드 번호 : $no");
echo "Success";
?>

# thread.php 소스코드
<?php
include "class.Thread.php";

$obj_thread = new Thread;
$obj_thread->setURL("http://xxx.com/single_process.php");

for($i=0; $i<20; $i++) {
       $obj_thread->setParam("no", $i);
       $obj_thread->send();
}

$ret = $obj_thread->gather();
//$obj_thread->close();

echo "<pre>";
print_r($ret);
?>

위에서 보면 single_process.php 에 변수값이 달리해서 계속 접속하는 것을 볼수 있습니다.
class.Thread.php 에 보면 비동기식으로 접속하기 때문에 시간지연이 없습니다.
그후에 gather() 이란 메쏘드를 통해 결과값을 받게 됩니다. 이때도 순차적으로 받는게
아니라 먼저오는 놈부터 처리하기 때문에 약간의 시간은 경과되지만 순차적일 때보다는
상당히 빠르게 진행됩니다. 혹시 위 예제대로 했는데 메일이 20가 다 안온다고 저에게
뭐라고 하지 마십쇼 ^^; 제가 위 예제로 테스트하다보니 단박에 메일서버에서 제 아이피가
막혀버리더군요...

아래는 위에서 사용한 class.Thread.php 소스이며 class.Http.php 소스는 링크걸어놓았습니다.

<?php

require_once("class.Http.php");

class Thread extends Http {

       var $handles;

       # constructor
       function Thread($url="") {
              $this->Http($url);
              $this->handles = array();
       }

       /**
        * 데이타 전송함수
        *
        * @param string $mode : POST, GET 중 하나를 입력한다.
        * @return string
        */
       function send($mode="GET") {
              
              // 웹서버에 접속한다.
              $fp = fsockopen($this->host, $this->port, $errno, $errstr, 10);
              if(!$fp) return $this->setError($this->host."로의 접속에 실패했습니다.");

              // GET, POST 방식에 따라 헤더를 다르게 구성한다.
              if(strtoupper($mode) == "POST") $this->query = $this->postMethod();
              else $this->query = $this->getMethod();

              fputs($fp,$this->query);
              socket_set_blocking($fp, FALSE);

              $this->handles[] = $fp;
              
              // 접속을 해제한다.
              //fclose($fp);

              return $fp;
       }

       function gather() {
              $ret = array();
              $max = count($this->handles);
              while(1) {
                     $i = 0;
                     for($i=0; $i<$max; $i++) {
                            $body = '';
                            if(!$fp = $this->handles[$i]) continue;
                            if(!$buffer = fgets($fp, 1024)) continue;
                            while(trim($buffer = fgets($fp,1024)) != "") {}
                            while(!feof($fp)) {
                                   $body .= fgets($fp,1024);
                            }
                            $ret[] = $body;
                            $this->close($fp);
                            $this->handles[$i] = 0;
                     }
                     if(count($ret) == $max) break;
                     usleep(10000);
              }
              return $ret;
       }

       function close($fp="") {
              if($fp) fclose($fp);
              else {
                     foreach($this->handles as $fp) {
                            if($fp) fclose($fp);
                     }
              }
              return true;
       }

}

?>