高性能PHP框架webman协程Redis动态连接池

composer require workbunny/webman-coroutine

# composer require workbunny/webman-coroutine
./composer.json has been updated
Running composer update workbunny/webman-coroutine
Loading composer repositories with package information
Updating dependencies
Lock file operations: 0 installs, 1 update, 0 removals
  - Upgrading workbunny/webman-coroutine (1.1.4 => 1.2.1)
Writing lock file
Installing dependencies from lock file (including require-dev)
Package operations: 4 installs, 0 updates, 1 removal
  - Downloading tinywan/exception-handler (v1.5.4)
  - Downloading workbunny/webman-coroutine (1.2.1)
> support\Plugin::uninstall
  - Removing openspout/openspout (v4.26.0)
  - Installing composer/semver (3.4.3): Extracting archive
  - Installing swow/swow (v1.5.3): Extracting archive
  - Installing tinywan/exception-handler (v1.5.4): Extracting archive
  - Installing workbunny/webman-coroutine (1.2.1): Extracting archive
> support\Plugin::install
> support\Plugin::install
> support\Plugin::install
> support\Plugin::install
Create config/plugin/workbunny/webman-coroutine
Generating autoload files
55 packages you are using are looking for funding.
Use the `composer fund` command to find out more!
No security vulnerability advisories found.
Using version ^1.2 for workbunny/webman-coroutine

composer require swow/swow

 vendor/bin/swow-builder --rebuild --install
> cd /var/www/demo.webman.tinywan.com/vendor/swow/swow/ext && \
phpize --clean
Cleaning..
✅ Clean done

> cd /var/www/demo.webman.tinywan.com/vendor/swow/swow/ext && \
phpize && \
./configure
Configuring for:
PHP Api Version:         20230831
Zend Module Api No:      20230831
Zend Extension Api No:   420230831
checking for grep that handles long lines and -e... /bin/grep

Directive => Local Value => Master Value
swow.enable => On => On
swow.async_threads => 0 => 0
swow.async_file => On => On
swow.async_tty => On => On

> cd /var/www/demo.webman.tinywan.com/vendor/swow/swow/ext && \
make install
Installing shared extensions:     /usr/local/lib/php/extensions/no-debug-non-zts-20230831/
✅ Install done

🚀🚀🚀 All tasks have been completed 🚀🚀🚀

'event_loop' => \Workbunny\WebmanCoroutine\event_loop(),

<?php
return [
    // 其他配置
    \app\common\CoroutinePool::class
];

<?php
/**
 * @desc CoroutinePool.php 描述信息
 * @author Tinywan(ShaoBo Wan)
 */
declare(strict_types=1);

namespace app\common;

use Webman\Bootstrap;
use Workbunny\WebmanCoroutine\Utils\Pool\Pool;
use Workerman\Worker;

class CoroutinePool implements Bootstrap
{
    /***
     * @desc start
     * @param Worker|null $worker
     * @author Tinywan(ShaoBo Wan)
     */
    public static function start(?Worker $worker)
    {
        /** 为redis占位 */
        Pool::init('redis',false);
    }
}

<?php
/**
 * @author Tinywan(ShaoBo Wan)
 * @date 2024/10/17 23:37
 */
declare(strict_types=1);

namespace app\controller;

use Illuminate\Redis\Connections\Connection;
use support\Response;
use Workbunny\WebmanCoroutine\Utils\Pool\Pool;

class CoroutineController
{
    /***
     * @desc Redis 连接池
     * @author Tinywan(ShaoBo Wan)
     */
    public function pool(): Response
    {
        /** 获取redis占位 */
        $pools = Pool::get('redis', null);
        /** 根据配置池大小判断是否需要追加，假设你存在这样的配置 */
        if (count($pools) < config('redis.pool_size')) {
            /** 新建redis连接 */
            $config = config('redis');
            $redis = new \Illuminate\Redis\RedisManager('', 'phpredis', $config);
            /** 追加一个redis连接对象，资源类型不用clone */
            Pool::append('redis', (int)array_key_last($pools) + 1, $redis, false);
        }

        $start = microtime(true);
        /** 等待闲置redis */
        $redis = Pool::waitForIdle('redis', function (Pool $pool): \Redis {
            /** @var  Connection $connection */
            $connection = $pool->getElement();
            /** 获取redis连接  */
            return $connection->client();
        });
        /** 执行Redis命令  */
        $res = $redis->lPush('webman:coroutine:key', '开源技术小栈' . date('Y-m-d H:i:s'));
        $time = (string)(microtime(true) - $start);
        return json(['time' => $time, 'res' => $res]);
    }
}

php -d extension=swow webman start

# php -d extension=swow webman start
Workerman[webman] start in DEBUG mode
---------------------------------------------------- WORKERMAN -----------------------------------------------------
Workerman version:4.1.15          PHP version:8.3.9           Event-Loop:Workbunny\WebmanCoroutine\Events\SwowEvent
----------------------------------------------------- WORKERS ------------------------------------------------------
proto   user            worker                       listen                      processes    status
tcp     root            webman                       http://0.0.0.0:8217         8             [OK] 
tcp     root            monitor                      none                        1             [OK] 
tcp     root            plugin.saiadmin.task         none                        1             [OK] 
tcp     root            plugin.saiadmin.websocket    websocket://0.0.0.0:9527    1             [OK] 
--------------------------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.

{
  "time": "0.069719791412354",
  "res": 1
}