失眠网,内容丰富有趣,生活中的好帮手!
失眠网 > swoole实现数据库连接池

swoole实现数据库连接池

时间:2019-08-14 20:54:34

相关推荐

swoole实现数据库连接池

独角兽企业重金招聘Python工程师标准>>>

原生 PHP CURD

让我们来回顾一下PHP中数据库的使用

<?php# curd.php$id = 1;$dbh = new PDO();$stmt = $dbh->prepare('SELECT * FROM `user` WHERE `id`=:id');$stmt ->bindValue(':id', $id);$user = $stmt->fetch();var_dump($user);

上述代码, 本身是没有任何问题。这里我们也不是来挑出问题的,只是以一位多年PHPer的经验与大家交流下。

上面程序执行过程是什么样子的呢?

_______________________| |[浏览器请求] ==> [mod_php/php-fpm] || |||| |||| \/|| [curd.php]|| |||| |||| \/|| [PDO::_construct] | <== 请求的开销| |||| |||| \/|[Response] <==[PDO::CURD]|| |||| |||| \/|| [PDO::close] ||_______________________|

Swoole PHP CURD

Java应用中,大家在进行数据库CURD的时候,会维护一个数据库连接池。在PHP的世界中,要想做连接池挺困难的:

PHP web应用不可长驻运行

不可借助第三方服务如KV转存句柄

而在Swoole中我们就可以实现连接池了!

<?php$http = new swoole_http_server('0.0.0.0', 80, SWOOLE_BASE);$http->db->dbh = new PDO();$http->on('request', function(swoole_http_request $req, swoole_http_response $res) use($http) {$id = 1;$stmt = $http->db->dbh->prepare('SELECT * FROM `user` WHERE `id`=:id');$stmt ->bindValue(':id', $id);$user = $stmt->fetch();$res->end(var_export($user, true));unset($stmt);});

执行流程

[php app.php]||||\/[PDO::__construct]||____________||________________| \/|[浏览器请求] ==> [ ->onRequest(\Closure) ] || |||| ||| <== 请求开销| \/|[Response] <==[PDO::CURD] ||____________||________________|||\/[PDO::close]

分析上面流程, Swoole不用再每次请求时去建立数据库连接, 既避免了给数据库过多压力, 也更迅速的处理核心业务逻辑. 也许你觉得这优势不明显, 但是在c10k问题(Connections over 10,000)场景中, 优势就非常明显了吧?当然, 上面的demo只是抛砖引玉, 没有实现multi connections pool, 如果大家要做生产化代码, 务必实现连接池, idle连接数按照业务需要, 比如80%的时间连接数200, 设置200个idle的连接池是最优的.

PHP有了连接池,我们的应用就可以不用再在收到请求时去创建数据库连接了。

试试上面的代码,与曾经碰到过3000+数据库连接的烦恼bye bye吧~

[本节完, 文字未校对, 程序未测试]

如果觉得《swoole实现数据库连接池》对你有帮助,请点赞、收藏,并留下你的观点哦!

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。