范例

Example #1 polling STDIN using basic API


<?php

function print_line($fd, $events, $arg)
{
    static $max_requests = 0;

    $max_requests++;

    if ($max_requests == 10) {
        // exit loop after 10 writes
        event_base_loopexit($arg[1]);
    }

    // print the line
    echo  fgets($fd);
}

// create base and event
$base = event_base_new();
$event = event_new();

$fd = STDIN;

// set event flags
event_set($event, $fd, EV_READ | EV_PERSIST, "print_line", array($event, $base));
// set event base
event_base_set($event, $base);

// enable event
event_add($event);
// start event loop
event_base_loop($base);

?>

Example #2 polling STDIN using buffered event API


<?php

function print_line($buf, $arg)
{
    static $max_requests;

    $max_requests++;

    if ($max_requests == 10) {
        event_base_loopexit($arg);
    }

    // print the line
    echo event_buffer_read($buf, 4096);
}

function error_func($buf, $what, $arg)
{
    // handle errors
}

$base = event_base_new();
$eb = event_buffer_new(STDIN, "print_line", NULL, "error_func", $base);

event_buffer_base_set($eb, $base);
event_buffer_enable($eb, EV_READ);

event_base_loop($base);

?>

User Contributed Notes

Alexis 29-Jul-2010 02:23


Server example:

<?php

$socket = stream_socket_server ('tcp://0.0.0.0:2000', $errno, $errstr);

stream_set_blocking($socket, 0);

$base = event_base_new();

$event = event_new();

event_set($event, $socket, EV_READ | EV_PERSIST, 'ev_accept', $base);

event_base_set($event, $base);

event_add($event);

event_base_loop($base);



$GLOBALS['connections'] = array();

$GLOBALS['buffers'] = array();



function ev_accept($socket, $flag, $base) {

    static $id = 0;

    

    $connection = stream_socket_accept($socket);

    stream_set_blocking($connection, 0);

    

    $id += 1;

    

    $buffer = event_buffer_new($connection, 'ev_read', NULL, 'ev_error', $id);

    event_buffer_base_set($buffer, $base);

    event_buffer_timeout_set($buffer, 30, 30);

    event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff);

    event_buffer_priority_set($buffer, 10);

    event_buffer_enable($buffer, EV_READ | EV_PERSIST);

    

    // we need to save both buffer and connection outside

    $GLOBALS['connections'][$id] = $connection;

    $GLOBALS['buffers'][$id] = $buffer;

}



function ev_error($buffer, $error, $id) {

    event_buffer_disable($GLOBALS['buffers'][$id], EV_READ | EV_WRITE);

    event_buffer_free($GLOBALS['buffers'][$id]);

    fclose($GLOBALS['connections'][$id]);

    unset($GLOBALS['buffers'][$id], $GLOBALS['connections'][$id]);

}



function ev_read($buffer, $id) {

    while ($read = event_buffer_read($buffer, 256)) {

        var_dump($read);

    }

}

?>