Swoole 一键协程化设置 flags 的问题

2021-09-14 10:54:59 浏览数 (1)

从 Swoole4 版本开始，提供了一键协程化的功能，采用 Hook 原生 PHP 函数的方式实现协程客户端，通过一行代码就可以让原来的同步 IO 的代码变成可以协程调度的异步 IO，即一键协程化。

目前有两种方式设置要 Hook 的函数范围：

代码语言：javascript复制
SwooleCoroutine::set(['hook_flags'=> SWOOLE_HOOK_ALL]);

SwooleRuntime::enableCoroutine(SWOOLE_HOOK_ALL);

同时从v4.6.0版本开始，协程容器中默认开启所有 Hook，即 SWOOLE_HOOK_ALL：

代码语言：javascript复制
use SwooleRuntime;
use function SwooleCoroutinerun;

run(function () {
    assert(Runtime::getHookFlags() === SWOOLE_HOOK_ALL);
});

那么有两种方式可以设置，具体使用哪种方式来设置呢？

先来看一段代码：

基于 Swoole v4.7.1 版本，并开启了--enable-swoole-curl

代码语言：javascript复制
use SwooleCoroutine;
use SwooleRuntime;

function hook_dump()
{
    var_dump([
        'file' => (Runtime::getHookFlags() & SWOOLE_HOOK_FILE) === SWOOLE_HOOK_FILE,
        'native' => (Runtime::getHookFlags() & SWOOLE_HOOK_NATIVE_CURL) === SWOOLE_HOOK_NATIVE_CURL,
        'curl' => (Runtime::getHookFlags() & SWOOLE_HOOK_CURL) === SWOOLE_HOOK_NATIVE_CURL,
    ]);
}

Coroutinerun(function () {
    hook_dump();

    $flags = SWOOLE_HOOK_ALL ^ (SWOOLE_HOOK_FILE | SWOOLE_HOOK_NATIVE_CURL | SWOOLE_HOOK_CURL);

    Coroutine::set(['hook_flags' => $flags]);
    hook_dump();

    Runtime::enableCoroutine($flags);
    hook_dump();
});

是不是觉得应该输出为：

代码语言：javascript复制
array(3) {
  ["file"]=>
  bool(true)
  ["native"]=>
  bool(true)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}

但实际上输出结果却为：

代码语言：javascript复制
array(3) {
  ["file"]=>
  bool(true)
  ["native"]=>
  bool(true)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(true)
  ["native"]=>
  bool(true)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}

这个时候就会以为是Coroutine::set(['hook_flags' => $flags]);没生效，是 Bug 吗？当然不是 Bug 了。

分开来测试一下：

代码语言：javascript复制
use SwooleCoroutine;
use SwooleRuntime;

function hook_dump()
{
    var_dump([
        'file' => (Runtime::getHookFlags() & SWOOLE_HOOK_FILE) === SWOOLE_HOOK_FILE,
        'native' => (Runtime::getHookFlags() & SWOOLE_HOOK_NATIVE_CURL) === SWOOLE_HOOK_NATIVE_CURL,
        'curl' => (Runtime::getHookFlags() & SWOOLE_HOOK_CURL) === SWOOLE_HOOK_NATIVE_CURL,
    ]);
}

$flags = SWOOLE_HOOK_ALL ^ (SWOOLE_HOOK_FILE | SWOOLE_HOOK_NATIVE_CURL | SWOOLE_HOOK_CURL);
Coroutine::set(['hook_flags' => $flags]);
Coroutinerun(function () {
    hook_dump();

    Coroutine::set(['hook_flags' => SWOOLE_HOOK_ALL]);
    hook_dump();
});

再增加一个协程嵌套进行测试

代码语言：javascript复制
Coroutinerun(function () {
    hook_dump();

    Coroutine::set(['hook_flags' => SWOOLE_HOOK_ALL]);
    go(function () {
        hook_dump();
    });
});

输出发现全是false，也就是说在协程中通过Coroutine::set动态设置 flags 不会生效

代码语言：javascript复制
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}

将协程容器中的Coroutine::set换为Runtime::enableCoroutine进行测试

代码语言：javascript复制
Coroutinerun(function () {
    hook_dump();

    Runtime::enableCoroutine(SWOOLE_HOOK_ALL);

    hook_dump();

    go(function () {
        hook_dump();
    });
});

发现结果是生效的。

代码语言：javascript复制
array(3) {
  ["file"]=>
  bool(false)
  ["native"]=>
  bool(false)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(true)
  ["native"]=>
  bool(true)
  ["curl"]=>
  bool(false)
}
array(3) {
  ["file"]=>
  bool(true)
  ["native"]=>
  bool(true)
  ["curl"]=>
  bool(false)
}

综上所述，可以得到以下结论：

  1. Runtime::enableCoroutine() 可以在服务启动后 (运行时) 动态设置 flags，调用方法后当前进程内全局生效
  2. Coroutine::set() 可以理解为 PHP 的 ini_set()，需要在 Server->start() 前或 Coroutinerun() 前调用，否则设置的 hook_flags 不会生效
  3. 无论是 Coroutine::set() 还是 Runtime::enableCoroutine() 的方式，都应该只调用一次，重复调用会被覆盖

即 Runtime::enableCoroutine()支持动态设置 flags，而Coroutine::set()的方式不支持。

编程算法 腾讯云测试服务 容器 swoole php

0 人点赞