189 8069 5689
这篇文章给大家分享的是有关swoole的MySQL连接池怎么弄的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。
创新互联专注于西充企业网站建设,响应式网站建设,商城网站开发。西充网站建设公司,为西充等地区提供建站服务。全流程定制设计，专业设计，全程项目跟踪，创新互联专业和态度为您提供的服务
传统的nginx+FPM模式的PHP程序而言，每次请求FPM的worker都会连接一次mysql，然后请求结束便会断开连接。对于并发小的应用来说这不会有什么问题，但是对于高并发的应用来说，频繁建立连接Connect和销毁连接Close，数据库便会成为瓶颈，相信不少人也遇到过to many connection的mysql报错吧。
连接池采用的是长连接模式，会一直保持与MySQL的连接，用完后会重新放回连接池，从而节省了建立连接和断开连接的消耗，大大降低了系统IO的消耗，一定程度上提高了程序的并发性能。如果连接池空闲，就从连接池分配一个连接，否则，请求将被加入到等待队列中。
我们采用swoole实现mysql连接池
pool)) {
$this->config = $config;
$this->pool = new \Swoole\Coroutine\Channel($config['pool_size']);
for ($i = 0; $i < $config['pool_size']; $i++) {
\go(function() use ($config) {
$mysql = new MysqlDB();
$res = $mysql->connect($config['mysql']);
if ($res === false) {
throw new RuntimeException("Failed to connect mysql server");
} else {
$this->pool->push($mysql);
}
});
}
}
}
public function get()
{
if ($this->pool->length() > 0) {
$mysql = $this->pool->pop($this->config['pool_get_timeout']);
if (false === $mysql) {
throw new RuntimeException("Pop mysql timeout");
}
return $mysql;
} else {
throw new RuntimeException("Pool length <= 0");
}
}
public function recycle(MysqlDB $mysql){
$this->pool->push($mysql);
}
/**
* 获取连接池长度
* @return mixed
*/
public function getPoolSize(){
return $this->pool->length();
}}connect($config);
if ($res === false) {
throw new RuntimeException($connection->connect_error, $connection->errno);
} else {
$this->connection = $connection;
}
return $res;
}
public function query($sql){
$result = $this->connection->query($sql);
return $result;
}}5,
'pool_get_timeout'=>1,
'timeout'=>1,
'charset'=>'utf8',
'strict_type'=>false,
'fetch_mode'=>true,
'mysql'=>[
'host'=>'127.0.0.1',
'port'=>'3306',
'user'=>'homestead',
'password'=>'secret',
'database'=>'blog',
]
]);
$server->handle('/', function ($request, $response) use ($pool){
$mysql = $pool->get();
$res = $mysql->query("select id,phone,username from user limit 1");
var_dump($res);
$pool->recycle($mysql);
$response->end("Test
");
});
$server->handle('/test', function ($request, $response) {
$response->end("Test
");
});
$server->handle('/stop', function ($request, $response) use ($server) {
$response->end("Stop
");
$server->shutdown();
});
$server->start();});感谢各位的阅读！关于“swoole的mysql连接池怎么弄”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！