Laravel
话题列表 社区 Wiki 优质外文 招聘求职 Laravel 实战教程 社区文档
登录
注册

php 7.3 event 扩展 loop直接退出 其实已经添加了事件

问答 / 0 / 11 / 创建于 3年前 / 更新于 3年前

1. 运行环境#

php 7.3 cli 模式 debian docker 容器内部

1). 当前使用的 Laravel 版本？#

多进程编程
//: <> (使用 php artisan --version 命令查看)

2). 当前使用的 php/php-fpm 版本？#

PHP 版本：

php-fpm 版本：

3). 当前系统#

4). 业务环境#

5). 相关软件版本#

2. 问题描述？#

在串行调用时候可以正常的 loop 进入事件循环代码如下

php 7.3 event 扩展 loop直接退出 其实已经添加了事件

![php 7.3 event 扩展 loop 直接退出 其实已经添加了事件]
php 7.3 event 扩展 loop直接退出 其实已经添加了事件

换个写法就不行了，进程直接执行完，也没有什么报错，无法进入事件循环

php 7.3 event 扩展 loop直接退出 其实已经添加了事件

php 7.3 event 扩展 loop直接退出 其实已经添加了事件
有了解 libevent 编程的大佬帮忙看下嘛，不胜感激！

3. 您期望得到的结果？#

4. 您实际得到的结果？#

jjawesome
课程读者 10 声望
暂无个人描述~
《L02 从零构建论坛系统》
《L02 从零构建论坛系统》
以构建论坛项目 LaraBBS 为线索，展开对 Laravel 框架的全面学习。应用程序架构思路贴近 Laravel 框架的设计哲学。
《L01 基础入门》
《L01 基础入门》
我们将带你从零开发一个项目并部署到线上，本课程教授 Web 开发中专业、实用的技能，如 Git 工作流、Laravel Mix 前端工作流等。
echo_dump
95 声望
最佳答案

loop () 方法的调用是 EventBase 类的，第二种写法是对的

3年前 评论
echo_dump （作者） 3年前

没看到具体的代码，也不知道怎么回事，不过按照你这个逻辑，写了一个样例，是可以跑的通的

</php

class EventLoop
{
    public EventBase $base;

    public array $allEvent = [];

    public function __construct()
    {
        $this->base = new \EventBase();
    }

    public function add($fd, $cb, $type): bool
    {
        $event = new \Event($this->base, $fd, Event::READ|Event::PERSIST, $cb);

        $this->allEvent[(int)$fd][Event::READ] = $event;

        echo "调用一次 $type " . (int)$fd . "\n";

        return $event->add();
    }

    public function loop(): bool
    {
        return $this->base->loop();
    }
}

$content = stream_context_create([
    'socket' => [
        'backlog' => 1024
    ]
]);

class Master
{
    public static EventLoop $globalEvent;
}

$mainSocket = stream_socket_server('tcp://0.0.0.0:9999', $errCode, $errMsg, \STREAM_SERVER_BIND |
    \STREAM_SERVER_LISTEN, $content);

if (\function_exists('socket_import_stream')) {
    \set_error_handler(function(){});
    $socket = \socket_import_stream($mainSocket);
    \socket_set_option($socket, \SOL_SOCKET, \SO_KEEPALIVE, 1);
    \socket_set_option($socket, \SOL_TCP, \TCP_NODELAY, 1);
    \restore_error_handler();
}

\stream_set_blocking($mainSocket, false);

class TcpConn
{
    /**
     * @var resource
     */
    public $socket;

    public function __construct($socket)
    {
        $this->socket = $socket;

        Master::$globalEvent->add($this->socket, [$this, 'read'], 'stream_socket_accept');
    }

    public function read($socket)
    {
        $buff = fread($socket, 65536);

        echo "客户端请求来了~\n";

        echo $buff . "\n";

        if (is_resource($socket)) {
            fwrite($socket, "HTTP/1.1 200 OK\r\nAccept: application/json, text/plain, */*\r\nConnection: keep-alive\r\nContent-Length: 6\r\n\r\nhello~");
        }
    }
}


Master::$globalEvent = new EventLoop();

Master::$globalEvent->add($mainSocket, function ($sock) {
    $newSocket = stream_socket_accept($sock, 0, $remoteAddress);

    \stream_set_blocking($newSocket, 0);
    // Compatible with hhvm
    if (\function_exists('stream_set_read_buffer')) {
        \stream_set_read_buffer($newSocket, 0);
    }

    echo 'remote address : ' . $remoteAddress . PHP_EOL;

    new TcpConn($newSocket);

}, 'stream_socket_server');

Master::$globalEvent->loop();

echo "wait process exit~ pid = " . posix_getpid();
jjawesome （楼主） 3年前
感谢您的指正,我应该是截图的时候改错了,现已改正。
jjawesome （楼主） 3年前
但是目前的写法第一种可以正常进入事件循环,第二针写法不行,表示很奇怪,就代码逻辑而言看起来都是一样的
jjawesome （楼主） 3年前
非常感谢 对比了您的代码 和workman的代码 我大概发现了原因 $this->allEvent[(int)$fd][Event::READ] = $event; 就是少了这句 ,如果不加这句代码的话就无法正常进入事件循环,而是直接退出事件循环,我猜测的是这个event没有再被上下行文引用然后被gc回收了,导致无法正常进入事件循环
echo_dump （作者） 3年前

看了下，应该不是这个问题，具体原因没有找到，我尝试了直接以匿名函数形式来写，也是可以监听到数据的

可以看看这个

讨论数量: 11
排序：
时间 投票
echo_dump
95 声望

loop () 方法的调用是 EventBase 类的，第二种写法是对的

3年前 评论
echo_dump （作者） 3年前

没看到具体的代码，也不知道怎么回事，不过按照你这个逻辑，写了一个样例，是可以跑的通的

</php

class EventLoop
{
    public EventBase $base;

    public array $allEvent = [];

    public function __construct()
    {
        $this->base = new \EventBase();
    }

    public function add($fd, $cb, $type): bool
    {
        $event = new \Event($this->base, $fd, Event::READ|Event::PERSIST, $cb);

        $this->allEvent[(int)$fd][Event::READ] = $event;

        echo "调用一次 $type " . (int)$fd . "\n";

        return $event->add();
    }

    public function loop(): bool
    {
        return $this->base->loop();
    }
}

$content = stream_context_create([
    'socket' => [
        'backlog' => 1024
    ]
]);

class Master
{
    public static EventLoop $globalEvent;
}

$mainSocket = stream_socket_server('tcp://0.0.0.0:9999', $errCode, $errMsg, \STREAM_SERVER_BIND |
    \STREAM_SERVER_LISTEN, $content);

if (\function_exists('socket_import_stream')) {
    \set_error_handler(function(){});
    $socket = \socket_import_stream($mainSocket);
    \socket_set_option($socket, \SOL_SOCKET, \SO_KEEPALIVE, 1);
    \socket_set_option($socket, \SOL_TCP, \TCP_NODELAY, 1);
    \restore_error_handler();
}

\stream_set_blocking($mainSocket, false);

class TcpConn
{
    /**
     * @var resource
     */
    public $socket;

    public function __construct($socket)
    {
        $this->socket = $socket;

        Master::$globalEvent->add($this->socket, [$this, 'read'], 'stream_socket_accept');
    }

    public function read($socket)
    {
        $buff = fread($socket, 65536);

        echo "客户端请求来了~\n";

        echo $buff . "\n";

        if (is_resource($socket)) {
            fwrite($socket, "HTTP/1.1 200 OK\r\nAccept: application/json, text/plain, */*\r\nConnection: keep-alive\r\nContent-Length: 6\r\n\r\nhello~");
        }
    }
}


Master::$globalEvent = new EventLoop();

Master::$globalEvent->add($mainSocket, function ($sock) {
    $newSocket = stream_socket_accept($sock, 0, $remoteAddress);

    \stream_set_blocking($newSocket, 0);
    // Compatible with hhvm
    if (\function_exists('stream_set_read_buffer')) {
        \stream_set_read_buffer($newSocket, 0);
    }

    echo 'remote address : ' . $remoteAddress . PHP_EOL;

    new TcpConn($newSocket);

}, 'stream_socket_server');

Master::$globalEvent->loop();

echo "wait process exit~ pid = " . posix_getpid();
jjawesome （楼主） 3年前
感谢您的指正,我应该是截图的时候改错了,现已改正。
jjawesome （楼主） 3年前
但是目前的写法第一种可以正常进入事件循环,第二针写法不行,表示很奇怪,就代码逻辑而言看起来都是一样的
jjawesome （楼主） 3年前
非常感谢 对比了您的代码 和workman的代码 我大概发现了原因 $this->allEvent[(int)$fd][Event::READ] = $event; 就是少了这句 ,如果不加这句代码的话就无法正常进入事件循环,而是直接退出事件循环,我猜测的是这个event没有再被上下行文引用然后被gc回收了,导致无法正常进入事件循环
echo_dump （作者） 3年前

看了下，应该不是这个问题，具体原因没有找到，我尝试了直接以匿名函数形式来写，也是可以监听到数据的

可以看看这个

php_yt
1.1k 声望

第二种写法应该也没问题，创建一个资源描述符 fd 的事件对象 \Event，$event->add() 加入事件监听，由事件驱动内核 $eventBase->loop() 调度挂起事件监听。可能需要检查，要监听的 $socket 是否是个有效的资源描述符，也就是此步是否创建成功 $socket = stream_socket_server(...)

3年前 评论
jjawesome （楼主） 3年前
原因已经找到了，这里是没有问题的,确实是正确的创建了socket，事实上我尝试了创建了signal 与 timer 都是一样的现象
zhangrongwang
课程读者 117 声望

来看几段代码，猜想一下运行结果，哪些会进入事件循环，哪些会直接退出？

示例一

<?php

$eventbase = new \EventBase();

$eventbase->loop();

示例二

<?php

$eventbase = new \EventBase();

$socket = stream_socket_server('tcp://0.0.0.0:6000', $errno, $errmsg);
$event = new \Event($eventbase, $socket, \Event::READ | \Event::PERSIST, function () {
    echo 'event callback...' . PHP_EOL;
});
$event->add();

$eventbase->loop();

示例三

<?php

$eventbase = new \EventBase();

$socket = stream_socket_server('tcp://0.0.0.0:6000', $errno, $errmsg);
$event = new \Event($eventbase, $socket, \Event::READ | \Event::PERSIST, function () {
    echo 'event callback...' . PHP_EOL;
});
$event->add();

unset($event);

$eventbase->loop();

示例四

<?php 

$eventbase = new \EventBase();

function addEvent(&$eventbase){
    $socket = stream_socket_server('tcp://0.0.0.0:6000', $errno, $errmsg);
    $event = new \Event($eventbase, $socket, \Event::READ | \Event::PERSIST, function () {
        echo 'event callback...' . PHP_EOL;
    });
    $event->add();
}
addEvent($eventbase);

$eventbase->loop();

示例五

<?php 

$eventbase = new \EventBase();
$event = null;

function addEvent(&$eventbase, &$event){
    $socket = stream_socket_server('tcp://0.0.0.0:6000', $errno, $errmsg);
    $event = new \Event($eventbase, $socket, \Event::READ | \Event::PERSIST, function () {
        echo 'event callback...' . PHP_EOL;
    });
    $event->add();
}
addEvent($eventbase, $event);

$eventbase->loop();

答案是：示例一、示例三、示例四直接退出，示例二、示例五进入循环。
分析几个示例的差异：
示例一，没有添加 Event，loop 直接结束
示例二，添加 Event 后，正常进入 loop
示例三，添加 Event 后，将其 unset 掉，loop 直接结束
示例四，使用函数封装添加 Event 逻辑，loop 直接结束
示例五，使用函数封装添加 Event 逻辑，但用变量 event 保存了 Event 对象，正常进入 loop

大致得出以下结论：

  1. 当 EventBase 监听的 Events 为空时，loop 直接结束
  2. 当 EventBase 监听的 Event 被回收后，loop 直接结束
  3. 对于函数而言，函数直接后，函数作用域内的临时变量会被回收

我的理解是，能正常 loop 的条件：EventBase 监听的 Events 不能为空，EventBase 监听的 Event 不能被回收。我猜测可能 Event 扩展 Event->add () 时 EventBase 保存的是 Event 对象的引用，但在 PHP 中由于没有其它地方引用变量导致被回收，loop 时发现 Event 并不存在所以就直接结束了。

2年前 评论
jjawesome （楼主） 2年前
与我得出的结论大致一致
jjawesome （楼主） 2年前
good
2

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！
支持 MD 帮助
jjawesome 10 声望
社区赞助商
成为赞助商

关于 LearnKu

LearnKu 是终身编程者的修道场
做最专业、严肃的技术论坛
LearnKu 诞生的故事

资源推荐

  • 《社区使用指南》
  • 《文档撰写指南》
  • 《LearnKu 社区规范》
  • 《提问的智慧》

    • 服务提供商

    其他信息

  • 成为版主
  • 所有测验
  • 联系站长（反馈建议）

    • 粤ICP备18099781号-6 | 粤公网安备 44030502004330号 | 违法和不良信息举报

    由 Summer 设计和编码 | 方长科技协力运营

    请登录

    内容举报
    匿名举报，为防止滥用，仅管理员可见举报者。

    我要举报该，理由是：

    取消