摘要：連接池是一個(gè)基于的通用連接池，常被用作數(shù)據(jù)庫連接池。依賴依賴版本安裝通過安裝。使用更多示例。

open-smf/connection-pool 是一個(gè)基于Swoole的通用連接池，常被用作數(shù)據(jù)庫連接池。

通過Composer安裝。

composer require "open-smf/connection-pool:~1.0"

更多示例。

可用的連接器

基本用法

use SmfConnectionPoolConnectionPool;
use SmfConnectionPoolConnectorsCoroutineMySQLConnector;
use SwooleCoroutineMySQL;

go(function () {
    // MySQL連接數(shù)區(qū)間：[10, 30]
    $pool = new ConnectionPool(
        [
            "minActive"         => 10,
            "maxActive"         => 30,
            "maxWaitTime"       => 5,
            "maxIdleTime"       => 20,
            "idleCheckInterval" => 10,
        ],
        new CoroutineMySQLConnector, // 指明連接器實(shí)例，這里使用協(xié)程MySQL連接器，這樣就可以創(chuàng)建一個(gè)協(xié)程MySQL的數(shù)據(jù)庫連接池
        [
            "host"        => "127.0.0.1",
            "port"        => "3306",
            "user"        => "root",
            "password"    => "xy123456",
            "database"    => "mysql",
            "timeout"     => 10,
            "charset"     => "utf8mb4",
            "strict_type" => true,
            "fetch_mode"  => true,
        ]
    );
    echo "初始化連接池...
";
    $pool->init();
    defer(function () use ($pool) {
        echo "關(guān)閉連接池...
";
        $pool->close();
    });

    echo "從連接池中借出連接...
";
    /**@var MySQL $connection */
    $connection = $pool->borrow();
    
    // 執(zhí)行查詢語句
    $status = $connection->query("SHOW STATUS LIKE "Threads_connected"");
    
    echo "用完連接后，盡快歸還...
";
    $pool->return($connection);
    
    var_dump($status);
});

在Swoole Server中的用法

use SmfConnectionPoolConnectionPool;
use SmfConnectionPoolConnectionPoolTrait;
use SmfConnectionPoolConnectorsCoroutineMySQLConnector;
use SmfConnectionPoolConnectorsPhpRedisConnector;
use SwooleCoroutineMySQL;
use SwooleHttpRequest;
use SwooleHttpResponse;
use SwooleHttpServer;

class HttpServer
{
    use ConnectionPoolTrait;

    protected $swoole;

    public function __construct(string $host, int $port)
    {
        $this->swoole = new Server($host, $port);

        $this->setDefault();
        $this->bindWorkerEvents();
        $this->bindHttpEvent();
    }

    protected function setDefault()
    {
        $this->swoole->set([
            "daemonize"             => false,
            "dispatch_mode"         => 1,
            "max_request"           => 8000,
            "open_tcp_nodelay"      => true,
            "reload_async"          => true,
            "max_wait_time"         => 60,
            "enable_reuse_port"     => true,
            "enable_coroutine"      => true,
            "http_compression"      => false,
            "enable_static_handler" => false,
            "buffer_output_size"    => 4 * 1024 * 1024,
            "worker_num"            => 4, // 每個(gè)Worker持有一個(gè)獨(dú)立的連接池
        ]);
    }

    protected function bindHttpEvent()
    {
        $this->swoole->on("Request", function (Request $request, Response $response) {
            $pool1 = $this->getConnectionPool("mysql");
            /**@var MySQL $mysql */
            $mysql = $pool1->borrow();
            $status = $mysql->query("SHOW STATUS LIKE "Threads_connected"");
            // 用完連接后，盡快歸還
            $pool1->return($mysql);


            $pool2 = $this->getConnectionPool("redis");
            /**@var Redis $redis */
            $redis = $pool2->borrow();
            $clients = $redis->info("Clients");
            // 用完連接后，盡快歸還
           $pool2->return($redis);

            $json = [
                "status"  => $status,
                "clients" => $clients,
            ];
            // Other logic
            // ...
            $response->header("Content-Type", "application/json");
            $response->end(json_encode($json));
        });
    }

    protected function bindWorkerEvents()
    {
        $createPools = function () {
            // 所有的MySQL連接數(shù)區(qū)間：[4 workers * 2 = 8, 4 workers * 10 = 40]
            $pool1 = new ConnectionPool(
                [
                    "minActive" => 2,
                    "maxActive" => 10,
                ],
                new CoroutineMySQLConnector,
                [
                    "host"        => "127.0.0.1",
                    "port"        => "3306",
                    "user"        => "root",
                    "password"    => "xy123456",
                    "database"    => "mysql",
                    "timeout"     => 10,
                    "charset"     => "utf8mb4",
                    "strict_type" => true,
                    "fetch_mode"  => true,
                ]);
            $pool1->init();
            $this->addConnectionPool("mysql", $pool1);

            // 所有Redis連接數(shù)區(qū)間：[4 workers * 5 = 20, 4 workers * 20 = 80]
            $pool2 = new ConnectionPool(
                [
                    "minActive" => 5,
                    "maxActive" => 20,
                ],
                new PhpRedisConnector,
                [
                    "host"     => "127.0.0.1",
                    "port"     => "6379",
                    "database" => 0,
                    "password" => null,
                ]);
            $pool2->init();
            $this->addConnectionPool("redis", $pool2);
        };
        $closePools = function () {
            $this->closeConnectionPools();
        };
        // Worker啟動(dòng)時(shí)創(chuàng)建MySQL和Redis連接池
        $this->swoole->on("WorkerStart", $createPools);
        
        // Worker正常退出或錯(cuò)誤退出時(shí)，關(guān)閉連接池，釋放連接
        $this->swoole->on("WorkerStop", $closePools);
        $this->swoole->on("WorkerError", $closePools);
    }

    public function start()
    {
        $this->swoole->start();
    }
}

// 啟用協(xié)程Runtime來讓PhpRedis擴(kuò)展一鍵協(xié)程化
SwooleRuntime::enableCoroutine(true);
$server = new HttpServer("0.0.0.0", 5200);
$server->start();

本人已用于生產(chǎn)環(huán)境，表現(xiàn)穩(wěn)定

Github，歡迎 Star & PR。