php libev扩展使用

       在WorkerMan源码分析 - 实现最简单的原型文章中提到了libevent网络库，前者和libev都是事件驱动编程库高性能。简单说libev对libevent做了改进和精简。libevent使用全局变量，导致非线程安全。它的watcher结构也过大，把I/O、计时器、信号句柄整合在一起。而且（作者认为）libevent的附加组件如http和dns库都实现不好，且有安全问题。libev对这些地方做了改进，避免使用全局变量，拆分watcher等。另外libev去掉了外部库（比如http和dns），只专注于事件驱动服务，所以更精简。

安装libev扩展

地址：https://pecl.php.net/package/ev

实例

定时器实现

<?php
//定时器的实现，2秒后每2秒触发1次注册的事件

$loop = new EvLoop();

function timers()
{
    echo date("Y-m-d H:i:s") . "
";
}

//$event = $loop->timer(2,0,'timers');
$event = $loop->timer(2,2,'timers');
$loop->run();

结果如下：

2018-04-25 16:57:54
2018-04-25 16:57:55
2018-04-25 16:57:56
2018-04-25 16:57:57

基于事件循环 异步io 的socket读写

<?php
$loop = new EvLoop();
$arr = [];
$data = "hello world
";

function add($fd,$ev,$func){
    global $arr,$loop;
    $func = getStreamListenerClosure($fd,$func);
    //创建观察者监听io $ev事件
    $event = $loop->io($fd,$ev,$func);
    $arr[posix_getpid()][(int)$fd] = $event;
}

//返回闭包
function getStreamListenerClosure($stream, $listener){
    return function () use ($stream,$listener){
        call_user_func($listener,$stream);
    };
}

//读
function baseRead($socket){
    $buffer = @fread($socket, 2);

    if ($buffer == "
"){
        //结尾
        fclose($socket) && removeStream($socket);
    } else {
        echo $buffer;
    }
}

//写
function baseWrite($socket){

    global $data;

    $written = fwrite($socket, $data,1);
    if ($written === strlen($data)) {
        fclose($socket);
        removeStream($socket);
    } else {
        $data = substr($data, $written);
    }

}

//停止指定事件并销魂指定流资源
function removeStream($stream){

    global $arr,$loop;
    $key = (int)$stream;
    $pid = posix_getpid();

    if (!isset($arr[$pid][$key]))
        return;

    $arr[$pid][$key]->stop();
    unset($arr[$pid][$key]);
}

function acceptConnection($socket){

    $new_socket = @stream_socket_accept($socket);
    if (!$new_socket) {
        return;
    }

    stream_set_blocking($new_socket,false);
    stream_set_read_buffer($new_socket, 0);

    //add($new_socket,Ev::READ,'baseRead');
    add($new_socket,Ev::WRITE,'baseWrite');

}

//定时器
function timers()
{
    echo date("Y-m-d H:i:s") . "
";
}

$socketmain = stream_socket_server('tcp://127.0.0.1:7777');
//非阻塞
stream_set_blocking($socketmain,false);

add($socketmain,Ev::READ,'acceptConnection');

$event = $loop->timer(2,2,'timers');

$loop->run();

/*
while (true){
    //EV::RUN_ONCE 事件只触发1次
    $loop->run(EV::RUN_ONCE);
}
*/

利用telnet测试，具体参考WorkerMan源码分析 - 实现最简单的原型文章。