php 使用 Event 进行 socket 通信时如何添加多个事件??

发布于 2022-09-06 21:31:44 字数 1401 浏览 25 评论 0

这边使用的是 PHPEvent 扩展,使用事件的方式而不是使用 stream_select 的方式来进行 socket 通信:

$tcp = '127.0.0.1:9005';
$server = stream_socket_server($tcp);

// 超时时间设置一千年
$time = 1000 * 365 * 24 * 3600;

$base = new EventBase();
$event = new Event($base , $server , Event::READ|Event::PERSIST , function($socket , $flag , $base) use($time){
    $client = stream_socket_accept($socket);
    
    stream_set_blocking($client , false);
    
    $event = new Event($base , $client , Event::READ|Event::WRITE|Event::PERSIST , function($socket , $flag){
        // 这个回调函数永远不会触发 .....
        // 郁闷 .....
        // 导致,我只能利用 Event 监听 client 连接
        // 却无法监听客户端消息,或向客户端发送消息
        // 不知道该如何解决??
        $msg = fread($socket , 65535);
        
        var_dump($msg);
    });
   
    // 注册到 event 
    $event->add($time);
    
    // 这个能正常输出
    var_dump("接收到客户端连接");
} , $base);

$event->add($time);
$base->loop(EventBase::LOOP_NONBLOCK);
$base->dispatch();

本来是打算使用 libevent 扩展的,但是 php version >=6 的就没法使用了,发觉 Event 这个扩展基本和 libevent 扩展一样,于是使用,结果碰到上面的坑(问题在上面贴出来的代码中,请耐心阅读),不知道有没有人使用过 Event 扩展的,能否说下,如何利用 Event 扩展替换 stream_select 提高 socket 通信 性能??

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

若相惜即相离 2022-09-13 21:31:45

代码没看出问题, 是不是 EventBase::LOOP_ONCE 设错了?
是每个客户端连接都能触发么? 还是连上一个程序就退了?

開玄 2022-09-13 21:31:44

Ev 事件一个样子,详情参考:PHP Ev 事件扩展如何监听嵌套的事件??

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文