swoole2-mysqlpool：基于 Swoole 2 协程特性实现的 MySQL 连接池

Posted 2021-04-06 PHP技术大全

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了swoole2-mysqlpool：基于 Swoole 2 协程特性实现的 MySQL 连接池相关的知识，希望对你有一定的参考价值。

若文章排版不清或需要查看文中链接，请点击文章左下角的“阅读原文”

基于Swoole2协程特性实现的mysql连接池

使用Swoole2的SwooleCoroutineMySQL创建连接，通过静态类和静态成员属性维护连接池，不同协程可以共享该连接池。

排队机制（先进先出）使用协程的特殊功能实现：

SwooleCoroutine::resume($name) ：从$name队列中恢复一个挂起的协程执行；
SwooleCoroutine::suspend($name) ：将当前协程挂起到$name队列上。

限制

每个worker都有各自的MySQL连接池，且不同worker之间无法共享彼此的MySQL连接池；
可能存在各个worker进程连接池利用率不同（依赖业务实现）。

优点

与独立的连接池（worker进程间可共享的连接池实现）对比，无进程间通信开销；
独立的连接池需要增加运维成本。

使用方法

/**
 * 初始化连接池
 *
 * @param array $connsConfig 配置数组
 *	 [
 *		 'connName1' => [
 *			'serverInfo' => ['host' => '127.0.0.1', 'user' => 'test', 
'password' => 'pass', 'database' => 'tt', 'charset' => 'utf8'], 
//SwooleCoroutineMySQL的connect参数
 *			'maxSpareConns' => 5, //最大空闲连接数
 *			'maxConns' => 10, //最大连接数
 *		 ],
 *		 'connName2' => [
 *			'serverInfo' => ['host' => '127.0.0.2',
 'user' => 'test', 'password' => 'pass', 'database' => 'tt', 'charset' => 'utf8'], 
 //SwooleCoroutineMySQL的connect参数
 *			'maxSpareConns' => 5, //最大空闲连接数
 *			'maxConns' => 10, //最大连接数
 *		 ],
 *	 ]
 */
SwooleCoroutinePoolMySQLPool::init(array $connsConfig)

/**
 * 回收连接，该连接必须是从连接池中获取的连接
 *
 * @param SwooleCoroutineMySQL $conn 从连接池中获取的连接
 */
SwooleCoroutinePoolMySQLPool::recycle(SwooleCoroutineMySQL $conn)

/**
 * 从连接池中获取一条连接
 *
 * @param string $connName init时配置的连接，根据连接名称获取对应的连接
 * @return SwooleCoroutineMySQL 返回一个连接实例
 */
SwooleCoroutinePoolMySQLPool::fetch($connName)

使用示例

<?php

require 'MySQLPool.php';use SwooleCoroutinePoolMySQLPool;

$server = new SwooleHttpServer("127.0.0.1", 9502, SWOOLE_BASE);
$server->set([        'worker_num' => 1,
]);
$server->on('Request', function($request, $response) {
        MySQLPool::init([                'test' => [ 
'serverInfo' => ['host' => '192.168.244.128', 
'user' => 'mha_manager', 'password' => 'mhapass',
 'database' => 'tt', 'charset' => 'utf8'],       
  'maxSpareConns' => 5,  
  'maxConns' => 10
                ],
        ]);
        $swoole_mysql = MySQLPool::fetch('test');
        $ret = $swoole_mysql->query('select sleep(1)');
        MySQLPool::recycle($swoole_mysql);
        $response->end('Test End');
});
$server->start();