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 声望
暂无个人描述~
《L05 电商实战》
《L05 电商实战》
从零开发一个电商项目，功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等
《L04 微信小程序从零到发布》
《L04 微信小程序从零到发布》
从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。
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并不存在所以就直接结束了。

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

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

关于 LearnKu

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

资源推荐

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

    • 服务提供商

    其他信息

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

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

    由 Summer 设计和编码 ❤

    请登录

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

    我要举报该，理由是：

    取消