$worker->onMessage = function($connection, $buffer)
	{

	    // Parse http header.
	    list($method, $addr, $http_version) = explode(' ', $buffer);
	    $url_data = parse_url($addr);
	    $addr = !isset($url_data['port']) ? "{$url_data['host']}:80" : "{$url_data['host']}:{$url_data['port']}";


	    $data = switchIp();
	    //$data = array();
	    if(is_array($data) && !empty($data)){
		$ip = $data['use_ip'];
		$context = (array(
		    'socket' => array(
			'bindto' => $ip,
		    ),
		));
		// Async TCP connection.


		$remote_connection = new AsyncTcpConnection("tcp://$addr",$context);

	    }else{
		$remote_connection = new AsyncTcpConnection("tcp://$addr");

	    }
	    // CONNECT.
	    if ($method !== 'CONNECT') {
		$remote_connection->send($buffer);
		// POST GET PUT DELETE etc.
	    } else {
		$connection->send("HTTP/1.1 200 Connection Established\r\n\r\n");
	    }
	    // Pipe.


	    $remote_connection ->pipe($connection);
	    $connection->pipe($remote_connection);

	    $remote_connection->connect();

	};