[BUG] 如何改造示例连接池以支持 amphp 的异步 redis/mysql？

[hightman]

运行环境为最新的 workerman/5.1 和 webman 框架， eventloop 采用 PHP8 自带的 Fiber 协程模式。

尝试根据官网连接池文档示例编写连接池去支持 amphp/redis, amphp/mysql 这些异步客户端，当并发数超过 max_connections 会在归还连接时抛出以下错误：

FiberError: Cannot switch fibers in current execution context

这个情况初步判断是因为 Coroutine::defer() 归还连接的调用发生在析构函数，异步客户端的纤程切换导致了异常。

示例代码我就不贴了，估计作者一看便知。

[hightman]

重新尝试和阅读代码后，该BUG仍存在，问题出在“连接池”的设计上。如果归还连接是在context或fiber结束时，并且此时连接池内恰好有其它fiber在等待pop，根据 Workerman\Coroutine\Channel\Fiber 第 122 行代码显示会尝试将连接直接转交给等待的 fiber 。此时 resume 语句抛出异常：FiberError: Cannot switch fibers in current execution context

略微复杂，需要作者看看

[hightman]

修改如下可解决，这 github 仓库间找不到 coroutine 的代码 ..

*** Fiber.php.orig	Tue Aug  5 22:37:48 2025
--- Fiber.php	Tue Aug  5 22:38:06 2025
***************
*** 17,22 ****
--- 17,23 ----
  namespace Workerman\Coroutine\Channel;
  
  use Fiber as BaseFiber;
+ use Revolt\EventLoop;
  use RuntimeException;
  use Workerman\Timer;
  use WeakMap;
***************
*** 119,125 ****
          foreach ($this->waitingPop as $popFiber => $_) {
              unset($this->waitingPop[$popFiber]);
              if ($popFiber->isSuspended()) {
!                 $popFiber->resume($data);
                  return true;
              }
          }
--- 120,128 ----
          foreach ($this->waitingPop as $popFiber => $_) {
              unset($this->waitingPop[$popFiber]);
              if ($popFiber->isSuspended()) {
!                 EventLoop::queue(static function() use ($popFiber, $data) {
!                     $popFiber->resume($data);
!                 });
                  return true;
              }
          }

[walkor]

协程部分在
https://github.com/workerman-php/coroutine

你这个方案要判断下是不是在 Workerman的运行环境Worker::isRunning()，还有要先判断$popFiber->isSuspended()才能知执行 $popFiber->resume($data);

[hightman]

协程部分在 https://github.com/workerman-php/coroutine

你这个方案要判断下是不是在 Workerman的运行环境Worker::isRunning()，还有要先判断$popFiber->isSuspended()才能知执行 $popFiber->resume($data);

感谢回复，你说的两项判断都是没有问题的，你的原代码里也有相关判断。由于异步客户端会在等待数据时被切出，这个问题也比较隐蔽。目前按上面的修改方式是可以解决，或者自己把归还代码也放进事件循环中推迟运行。

网上搜寻资料有提到，某些情况在 __destruct() 中切换 fiber 是不被允许的。

[hightman]

实际测试 webman/redis 将连接池最大数限制为2，构造以下代码强制让(主fiber)陷入等待，当 second fiber 释放归还连接时就出错了，只不过在 RedisManager 中被捕捉并且忽略了这个异常。

    public function index(Request $request)
    {
        Coroutine::create(function () {
            echo "[first] getting redis ...\n";
            $redis = Redis::connection();
            echo "[first] redis got\n";
            Timer::sleep(0.2);
            $incr = $redis->incr('incr2');
            echo "[first] incr: $incr\n";
        });
        Coroutine::create(function () {
            echo "[second] getting redis ...\n";
            $redis = Redis::connection();
            echo "[second] redis got\n";
            Timer::sleep(0.1);
            $incr = $redis->incr('incr2');
            echo "[second] incr: $incr\n";
        });
        echo "[main] getting redis ...\n";
        $redis = Redis::connection();
        echo "[main] redis got\n";
        $incr = $redis->incr('incr2');
        echo "[main] incr: $incr\n";
        return json(['foo' => 'bar', 'incr' => $incr]);
    }

因此这个问题不是异步客户端导致的，而是 Workerman\Coroutine\Channel\Fiber 固有的。

[hightman]

此前用 webman/redis 之所以没有出现这个问题，是因为 redis 为同步操作，实际上多个协程之间是线性执行，从而未曾出现卡在 pop 等待唤醒的情况。上面的示例代码通过 Timer::sleep() 强制协程切换后就出现这个问题了。因此，该 BUG 应该是确定的，根据调用栈的情况，不应在 __destruct 中切换 fiber.

#0 webman/vendor/workerman/coroutine/src/Channel/Fiber.php(126): Fiber->resume(Object(Illuminate\Redis\Connections\PhpRedisConnection))
#1 webman/vendor/workerman/coroutine/src/Channel.php(64): Workerman\Coroutine\Channel\Fiber->push(Object(Illuminate\Redis\Connections\PhpRedisConnection), -1.0)
#2 webman/vendor/workerman/coroutine/src/Pool.php(217): Workerman\Coroutine\Channel->push(Object(Illuminate\Redis\Connections\PhpRedisConnection))
#3 webman/vendor/webman/redis/src/RedisManager.php(65): Workerman\Coroutine\Pool->put(Object(Illuminate\Redis\Connections\PhpRedisConnection))
#4 webman/vendor/workerman/coroutine/src/Utils/DestructionWatcher.php(49): Webman\Redis\RedisManager->Webman\Redis\{closure}()
#5 webman/vendor/revolt/event-loop/src/EventLoop/Internal/AbstractDriver.php(437): Workerman\Coroutine\Utils\DestructionWatcher->__destruct()
#6 webman/vendor/revolt/event-loop/src/EventLoop/Internal/AbstractDriver.php(621): Revolt\EventLoop\Internal\AbstractDriver->invokeMicrotasks()
#7 [internal function]: Revolt\EventLoop\Internal\AbstractDriver->Revolt\EventLoop\Internal\{closure}()

[hightman]

更新一下，前2天把 php 从 8.2 更新到 8.4 这个问题直接消失了... 因此该 BUG 是否还需要做进一步修复？

综合考虑下来，我认为修复问题应该放在 redis/mysql 的连接池设计代码逻辑里，即 Context::onDestroy 或 Coroutine::defer 的回调中，将归还连接的代码延后执行。以 redis 为例如下：

diff -rcs vendor_orig/webman/redis/src/RedisManager.php vendor/webman/redis/src/RedisManager.php
*** vendor_orig/webman/redis/src/RedisManager.php	Tue Aug 12 07:12:18 2025
--- vendor/webman/redis/src/RedisManager.php	Tue Aug 12 07:22:11 2025
***************
*** 9,14 ****
--- 9,15 ----
  use WeakMap;
  use Webman\Context;
  use Workerman\Coroutine\Pool;
+ use Workerman\Timer;
  
  class RedisManager extends \Illuminate\Redis\RedisManager
  {
***************
*** 60,70 ****
                  Context::set($key, $connection);
              } finally {
                  Context::onDestroy(function () use ($connection, $name) {
!                     try {
!                         $connection && static::$pools[$name]->put($connection);
!                     } catch (Throwable) {
!                         // ignore
!                     }
                  });
              }
          }
--- 61,73 ----
                  Context::set($key, $connection);
              } finally {
                  Context::onDestroy(function () use ($connection, $name) {
!                     $connection && Timer::delay(0, function () use ($connection, $name) {
!                         try {
!                             static::$pools[$name]->put($connection);
!                         } catch (Throwable) {
!                             // ignore
!                         }
!                     });
                  });
              }
          }

[hightman]

查了一下 github 上的相关讨论很多，目前在 8.4 中确实对此进行了修改，允许在析构函数切换 fiber 了，参见：

php-src:3c56af9

[xpader]

amphp 的 redis 和 mysql 是自带连接池的。

[hightman]

amphp 的 redis 和 mysql 是自带连接池的。

mysql 带了，redis 没有