详解基于swoole的mysql连接池实现_网络技术_宿州市腾雀网络科技有限公司

详解基于swoole的mysql连接池实现

发布时间 - 2020-12-25 00:00:00 点击率：次

swoole框架栏目介绍swoole实现mysql连接池的方法

推荐（免费）：swoole框架

前言

传统的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();
    }}

数据库DB类

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;
    }}

在HTTP协程服务器中创建连接池

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-pool

相关免费学习推荐：mysql视频教程

# swoole # 连接池 # 便会 # 的是 # 会有 # 将被 # 报错 # 后会 # 什么问题 # 用完 # 遇到过

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：猛鬼宿舍免费小游戏网页版入口_猛鬼宿舍电脑版抖音游戏直接玩

下一篇：jQuery插件MovingBoxes实现左右滑动中间放大图

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：猛鬼宿舍免费小游戏网页版入口_猛鬼宿舍电脑版抖音游戏直接玩

下一篇：jQuery插件MovingBoxes实现左右滑动中间放大图