(PECL event >= 1.8.0)
EventHttpConnection::setCloseCallback — Define una función de retrollamada al cerrar la conexión
Define una función de retrollamada al cerrar la conexión.
callback
Función de retrollamada a llamar al cerrar la conexión. Debe corresponder al siguiente prototipo:
No se retorna ningún valor.
Ejemplo #1 Ejemplo con EventHttpConnection::setCloseCallback()
<?php
/*
* Configuración de la retrollamada de cierre de conexión
*
* El script maneja las conexiones cerradas utilizando la API HTTP.
*
* Uso:
* 1) Iniciar el servidor:
* $ php examples/http_closecb.php 4242
*
* 2) Iniciar un cliente en otra terminal. La sesión de tipo telnet
* debe verse como sigue:
*
* $ nc -t 127.0.0.1 4242
* GET / HTTP/1.0
* Connection: close
*
* El servidor debe mostrar algo similar a lo siguiente:
*
* HTTP/1.0 200 OK
* Content-Type: multipart/x-mixed-replace;boundary=boundarydonotcross
* Connection: close
*
* <html>
*
* 3) Terminar la conexión del cliente abruptamente,
* es decir, matar el proceso o simplemente presionar Ctrl-C.
*
* 4) Verificar si el servidor llamó a _close_callback.
* El script debe mostrar la cadena "_close_callback" en la salida estándar.
*
* 5) Verificar si el proceso del servidor no tiene conexiones huérfanas,
* por ejemplo, con la utilidad `lsof`.
*/
function _close_callback($conn)
{
echo __FUNCTION__, PHP_EOL;
}
function _http_default($req, $dummy)
{
$conn = $req->getConnection();
$conn->setCloseCallback('_close_callback', NULL);
/*
Al habilitar Event::READ se protege al servidor contra conexiones no cerradas.
Esta es una peculiaridad de Libevent. La biblioteca deshabilita los eventos Event::READ
en esta conexión, y el servidor no es notificado sobre las conexiones terminadas.
Por lo tanto, cada vez que el cliente termina la conexión abruptamente, obtenemos una conexión huérfana. Por ejemplo, lo siguiente es parte del comando `lsof -p $PID | grep TCP`
después de que el cliente ha terminado la conexión:
57-php 15057 ruslan 6u unix 0xffff8802fb59c780 0t0 125187 socket
58:php 15057 ruslan 7u IPv4 125189 0t0 TCP *:4242 (LISTEN)
59:php 15057 ruslan 8u IPv4 124342 0t0 TCP localhost:4242->localhost:37375 (CLOSE_WAIT)
donde $PID es el ID del proceso.
El siguiente bloque de código corrige este tipo de conexiones huérfanas.
*/
$bev = $req->getBufferEvent();
$bev->enable(Event::READ);
// Debemos liberarlo explícitamente. Ver EventHttpRequest::getConnection
$bev->free(); // Debemos liberarlo explícitamente
$req->addHeader(
'Content-Type',
'multipart/x-mixed-replace;boundary=boundarydonotcross',
EventHttpRequest::OUTPUT_HEADER
);
$buf = new EventBuffer();
$buf->add('<html>');
$req->sendReply(200, "OK");
$req->sendReplyChunk($buf);
}
$port = 4242;
if ($argc > 1) {
$port = (int) $argv[1];
}
if ($port <= 0 || $port > 65535) {
exit("Puerto no válido");
}
$base = new EventBase();
$http = new EventHttp($base);
$http->setDefaultCallback("_http_default", NULL);
$http->bind("0.0.0.0", $port);
$base->loop();
?>