php connection pool,swoole协程中使用数据库连接池库open-smf/connection-pool
1.通过composer 安装库
$ composer require "open-smf/connection-pool:~1.0"
# 该包库只能在swoole 的协程环境下使。
2.引用connection-pool并配置ConnectionPool.php步骤:
use Smf\ConnectionPool\ConnectionPool;
use Smf\ConnectionPool\Connectors\CoroutineMySQLConnector;
use Smf\ConnectionPool\Connectors\PhpRedisConnector;
use Swoole\Coroutine\MySQL;
/**
* 该连接池类 只能在 swoole的协程中使用
*/
trait ConnectionPool
{
use ConnectionPoolTrait;
/**
* 启动mysql连接池对象
*/
public function startMysqlPool(int $minActive=10,int $maxActive=30){
$pool = new ConnectionPool([
'minActive' => $minActive,
'maxActive' => $maxActive,
'maxWaitTime' => 5,
'maxIdleTime' => 20,
'idleCheckInterval' => 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,
]
);
$pool->init();
$this->addConnectionPool("mysql", $pool);
}
/**
* 启动redis连接池
*/
public function startRedisPool(int $minActive=5,int $maxActive=20){
$pool = new ConnectionPool(
[
'minActive' => $minActive,
'maxActive' => $maxActive,
],
new PhpRedisConnector,
[
'host' => '127.0.0.1',
'port' => '6379',
'database' => 0,
'password' => null,
]);
$pool->init();
$this->addConnectionPool("redis",$pool);
}
/**
* 获取mysql 连接实例
*/
public function getMysqlPool():ConnectionPool{
return $this->getConnectionPool("mysql");
}
/**
* 获取redis 连接实例
*/
public function getMysqlPool():ConnectionPool{
return $this->getConnectionPool("redis");
}
/**
* 关闭连接池
*/
public function closePool(){
$this->closeConnectionPools();
}
}
2.在swoole中的使用思路讲解
use Swoole\Websocket\Server;
use \ConnectionPool;
use Swoole\Coroutine\MySQL;
use Swoole\Http\Request;
use Swoole\Http\Response;
class WsServer
{
1 . 设置Server开启协程
2. 在workerStart 事件中，启动连接池
$this->startMysqlPool();
$this-> startRedisPool();
3. workerStop 和 workerError 事件中 关闭连接池
$this->closePool();
4 . 在其他业务事件中
$pool = $this-> getMysqlPool(); // 获取mysql连接池操作对象
$mysql = $pool->borrow();// 获取mysql操作对象
$status = $mysql->query("sql语句");
$pool->return($mysql); // 操作完成后归还mysql连接
$pool = $this->getRedisPool(); // 获取redis连接对象
$redis = $pool->borrow(); // 得到redis操作对象
$redis->set("name","test");
$pool->return($redis); // 操作完成后归还redis连接
}