$obj = new proc_interface('./test.php');

if(!$obj->create_node())
{
	echo 'timeout';
	exit;
}

while(1)
{
	$response = $obj->send_command(mt_rand(100,1000));
	
	if($response === 'socket_closed')
		exit;
	
	usleep(100);
}

$obj = new proc_interface();
$obj->attach();

while(1)
{
	$response = $obj->get_command();
	
	var_dump($response)."\n";
	
	if($response === 'socket_closed')
		exit;
	sleep(1);
}

<?php

class proc_interface
{
	private $handle_connection;
	private $handle_client_connection;
	private $handle_current_connection;
	private $socket_port;
	private $socket_tcp_recvspace = 1024;
	private $socket_type = 0;
	private $file_name = null;
	
	function __construct($file_name = null)
	{
		$this->file_name = $file_name;
	}
	
	public function send_command($cmd)
	{
		if($this->socket_type === 1)
			$this->handle_current_connection = $this->handle_client_connection;
		else
			$this->handle_current_connection = $this->handle_connection;
			
		if($this->sock_error_trigger())
			return 'socket_closed';
	
		$this->write_socket($cmd);
	}
	
	public function get_command()
	{	
		if($this->socket_type === 1)
			$this->handle_current_connection = $this->handle_client_connection;
		else
			$this->handle_current_connection = $this->handle_connection;
			
		if($this->sock_error_trigger())
			return 'socket_closed';

		$read = array($this->handle_current_connection);
		$num_changed_sockets = socket_select($read, $write  = NULL, $except = NULL, 0);

		if($num_changed_sockets === false)
			return false;
		else if($num_changed_sockets === 0)
			return false;
			
		return $this->read_socket();
	}

	public function create_node()
	{
		$this->handle_connection = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		socket_bind($this->handle_connection, 'localhost', 0);
		$this->socket_tcp_recvspace = socket_get_option($this->handle_connection, SOL_SOCKET, SO_RCVBUF);
		socket_getsockname($this->handle_connection, $socket_address, $this->socket_port);
		socket_set_nonblock($this->handle_connection);
		socket_listen($this->handle_connection);
		$this->socket_type = 1; // Server
		
		if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN')
			pclose(popen('start php.exe '.$this->file_name.' '.$this->socket_port, 'r'));
		else
			pclose(popen('php '.$this->file_name.' '.$this->socket_port.' > /dev/null &', 'r'));
		
		$err_counter = 0;

		while(1)
		{
			if(($tmp_client = @socket_accept($this->handle_connection)) !== false)
			{
				$this->handle_client_connection = $tmp_client;
				break;
			}
			else
			{
				$err_counter++;
				usleep(10000);
			}
			
			// TimeOut
			if($err_counter === 500)
				return false; // 10000 * 500 = 5 sec.
		}
		
		return true;
	}
	
	public function attach()
	{
		global $argv;
	
		$this->handle_connection = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		socket_bind($this->handle_connection, 'localhost', 0);
		$this->socket_tcp_recvspace = socket_get_option($this->handle_connection, SOL_SOCKET, SO_RCVBUF);
		socket_connect($this->handle_connection, 'localhost', $argv[1]);
		socket_set_nonblock($this->handle_connection);
		$this->socket_type = 2; // Client
	}
	
	private function read_socket()
	{
		$return_data = trim(socket_read($this->handle_current_connection, $this->socket_tcp_recvspace, PHP_NORMAL_READ));

		if($return_data === false)
		{
			return false;
		}
		else if($return_data === '')
		{
			echo 'error read';
			return false;
		}
		
		return $return_data;
	}
	
	private function write_socket($cmd)
	{
		socket_write($this->handle_current_connection, $cmd."\n");
	}

	function __destruct()
	{
		socket_close($this->handle_connection);
	}
	
	private function sock_error_trigger()
	{
		$err_num = socket_last_error($this->handle_current_connection);

		if($err_num === 0) // *nix, Windows (In non-blocking mode when the connection is not established, but we're trying to read data from socket)
			return false;
		else if($err_num === 35) // *nix (tested on FreeBSD)
			return false;
		else if($err_num === 10035) // Windows (tested on Windows 7)
			return false;
		else
			return true;
	}
}

?>