EventBufferEvent::connect

<?php
/*
 * 1. Connexion à l'adresse 127.0.0.1 sur le port 80
 * en appelant la méthode EventBufferEvent::connect().
 *
 * 2. Demande /index.cphp via HTTP/1.0
 * en utilisant le tampon de sortie.
 *
 * 3. Lit la réponse de façon asynchrone, et l'affiche dans stdout.
 */

/* Fonction de rappel de lecture */
function readcb($bev, $base) {
	$input = $bev->getInput();

	while (($n = $input->remove($buf, 1024)) > 0) {
		echo $buf;
	}
}

/* Fonction de rappel d'événement */
function eventcb($bev, $events, $base) {
	if ($events & EventBufferEvent::CONNECTED) {
		echo "Connecté.\n";
	} elseif ($events & (EventBufferEvent::ERROR | EventBufferEvent::EOF)) {
		if ($events & EventBufferEvent::ERROR) {
			echo "Erreur DNS : ", $bev->getDnsErrorString(), PHP_EOL;
		}

		echo "Fermeture\n";
		$base->exit();
		exit("Fait !\n");
	}
}

$base = new EventBase();

echo "étape 1\n";
$bev = new EventBufferEvent($base, /* use internal socket */ NULL,
	EventBufferEvent::OPT_CLOSE_ON_FREE | EventBufferEvent::OPT_DEFER_CALLBACKS);
if (!$bev) {
	exit("Echec lors de la création du socket bufferevent\n");
}

echo "étape 2\n";
$bev->setCallbacks("readcb", /* writecb */ NULL, "eventcb", $base);
$bev->enable(Event::READ | Event::WRITE);

echo "étape 3\n";
/* Envoi la demande */
$output = $bev->getOutput();
if (!$output->add(
	"GET /index.cphp HTTP/1.0\r\n".
	"Connection: Close\r\n\r\n"
)) {
	exit("Echec lors de l'ajout de la demande dans le tampon de sortie\n");
}

/* Connection à l'hôte de façon asynchrone.
 * Nous connaissons l'IP, et donc, nous n'avons pas besoin de résolution DNS. */
if (!$bev->connect("127.0.0.1:80")) {
	exit("Impossible de se connecter à l'hôte\n");
}

/* Distribue les événements en attente */
$base->dispatch();

<?php
class MyUnixSocketClient {
	private $base, $bev;

	function __construct($base, $sock_path) {
		$this->base = $base;
		$this->bev = new EventBufferEvent($base, NULL, EventBufferEvent::OPT_CLOSE_ON_FREE,
			array ($this, "read_cb"), NULL, array ($this, "event_cb"));

		if (!$this->bev->connect("unix:$sock_path")) {
			trigger_error("Echec lors de la connexion au socket `$sock_path'", E_USER_ERROR);
		}

		$this->bev->enable(Event::READ);
	}

	function __destruct() {
		if ($this->bev) {
			$this->bev->free();
			$this->bev = NULL;
		}
	}

	function dispatch() {
		$this->base->dispatch();
	}

	function read_cb($bev, $unused) {
		$in = $bev->input;

		printf("Réception de %ld octets\n", $in->length);
		printf("----- données ----\n");
		printf("%ld:\t%s\n", (int) $in->length, $in->pullup(-1));

		$this->bev->free();
		$this->bev = NULL;
		$this->base->exit(NULL);
	}

	function event_cb($bev, $events, $unused) {
		if ($events & EventBufferEvent::ERROR) {
			echo "Erreur depuis bufferevent\n";
		}

		if ($events & (EventBufferEvent::EOF | EventBufferEvent::ERROR)) {
			$bev->free();
			$bev = NULL;
		} elseif ($events & EventBufferEvent::CONNECTED) {
			$bev->output->add("test\n");
		}
	}
}

if ($argc <= 1) {
	exit("Le chemin vers le socket n'est pas fourni\n");
}
$sock_path = $argv[1];

$base = new EventBase();
$cl = new MyUnixSocketClient($base, $sock_path);
$cl->dispatch();
?>