首页 / MYSQL / Swoole MySQL 连接池的实现

Swoole MySQL 连接池的实现

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Swoole MySQL 连接池的实现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9800字，纯文字阅读大概需要15分钟。

内容图文

概述
代码
扩展
小结

概述

这是关于 Swoole 入门学习的第八篇文章：Swoole MySQL 连接池的实现。

第七篇：Swoole RPC 的实现
第六篇：Swoole 整合成一个小框架
第五篇：Swoole 多协议多端口的应用
第四篇：Swoole HTTP 的应用
第三篇：Swoole WebSocket 的应用
第二篇：Swoole Task 的应用
第一篇：Swoole Timer 的应用

收到读者的咨询，这情况大家可能也会有，所以就在这说说：

“亮哥，我今年30岁了，有点中年危机，最近有点焦虑，发现工作虽然很忙，但是没感觉能力有所提升，整天都有写不完的业务代码，时间紧有时代码质量也不怎么样，知道还有很多改进空间，但一直没时间改，主要是后面项目压着，马上又要进入开发了，这种情况怎么办？”

首先，我是菜鸡，观点不喜勿喷，那我就说下自己的看法：

上面的描述比较主观，人呀有时候发现不了自己的能力很正常，有时候有能力了并不是马上就能显现的，而是到了某个阶段后突然发现，哇塞，原来自己这么厉害。

当然能力也分很多种，比如专业能力，快速学习能力，进度把控能力，还有自信也是一种能力，不要脸是一种能力，坚持不要脸更是一种能力。

其实能力提升最快的还是靠工作实践，悄悄问问自己加入了很多大牛的微信群，能力提升了吗？看书自学不实践是不是吸收的也不多。

如果非要给一个具体的方案，那就是在团队内多分享吧，因为在分享前你会做充分的准备来避免分享时出丑，即使有时候自己知道，当讲出来的时候就不是那么回事了。

前期分享可以是看稿，后期练习无稿分享。

然后，再多说一点，30了给自己一个目标，不要盲目每天就是学学学，比如目标是技术专家，目标是业务专家，都很好呀，当然目标与自己性格有关也不是一成不变的。

围绕着目标设置一些计划，不要以为每天的学学学，就觉得其他的一切就自然而来，其中还有很多机遇和人脉的因素。

最后，如果实在感觉压得喘不过气，就换个环境吧，别和自己过不去。

开始今天的文章，这篇文章实现了 Swoole MySQL 连接池，代码是在《Swoole RPC 的实现》文章的基础上进行开发的。

先回顾上篇文章的内容：

实现了 HTTP / TCP 请求
实现了同步 / 异步请求
分享了 OnRequest.php、OnReceive.php 源码
业务逻辑 Order.php 中返回的是假数据

本篇文章主要的功能点：

业务逻辑 Order.php 中返回 MySQL 数据库中的数据。
Task 启用了协程
支持主/从数据库配置
实现数据库连接池
实现数据库 CURD

代码

Order.php

<?php

if (!defined('SERVER_PATH')) exit("No Access");

class Order
{
    public function get_list($uid = 0, $type = 0)
    {
        //TODO 业务代码

        $rs[0]['order_code'] = '1';
        $rs[0]['order_name'] = '订单1';

        $rs[1]['order_code'] = '2';
        $rs[1]['order_name'] = '订单2';

        $rs[2]['order_code'] = '3';
        $rs[2]['order_name'] = '订单3';

        return $rs;
    }
}

修改成：

class Order
{
    private $mysql;
    private $table;

    public function __construct()
    {
        $pool = MysqlPool::getInstance();
        $this->mysql = $pool->get();
        $this->table = 'order';
    }

    public function add($code = '', $name = '')
    {
        //TODO 验证
        return $this->mysql->insert($this->table, ['code' => $code, 'name' => $name]);
    }

    public function edit($id = 0,  $name='')
    {
        //TODO 验证
        return $this->mysql->update($this->table, ['name' => $name], ['id' => $id]);
    }

    public function del($id = 0)
    {
        //TODO 验证
        return $this->mysql->delete($this->table, ['id' => $id]);
    }

    public function info($code = '')
    {
        //TODO 验证
        return $this->mysql->select($this->table, ['code' => $code]);
    }
}

Task 启用协程

一、需要新增两项配置：

enable_coroutine      = true
task_enable_coroutine = true

二、回调参数发生改变

$serv->on('Task', function ($serv, $task_id, $src_worker_id, $data) {
   ...
});

修改成：

$serv->on('Task', function ($serv, $task) {
    $task->worker_id; //来自哪个`Worker`进程
    $task->id; //任务的编号
    $task->data; //任务的数据
});

数据库主/从配置

Mysql.php

<?php

if (!defined('SERVER_PATH')) exit("No Access");

$db['default']['pool_size']        = 3; //连接池个数
$db['default']['pool_get_timeout'] = 0.5; //获取连接池超时时间
$db['default']['timeout']          = 0.5; //数据库建立连接超时时间
$db['default']['charset']          = 'utf8'; //字符集
$db['default']['strict_type']      = false; //开启严格模式
$db['default']['fetch_mode']       = true; //开启fetch模式

$config['master']             = $db['default'];
$config['master']['host']     = '127.0.0.1';
$config['master']['port']     = 3306;
$config['master']['user']     = 'root';
$config['master']['password'] = '123456';
$config['master']['database'] = 'demo';

$config['slave']             = $db['default'];
$config['slave']['host']     = '127.0.0.1';
$config['slave']['port']     = 3306;
$config['slave']['user']     = 'root';
$config['slave']['password'] = '123456';
$config['slave']['database'] = 'demo';

数据库连接池

MysqlPool.php

<?php

if (!defined('SERVER_PATH')) exit("No Access");

class MysqlPool
{
    private static $instance;
    private $pool;
    private $config;

    public static function getInstance($config = null)
    {
        if (empty(self::$instance)) {
            if (empty($config)) {
                throw new RuntimeException("MySQL config empty");
            }
            self::$instance = new static($config);
        }
        return self::$instance;
    }

    public function __construct($config)
    {
        if (empty($this->pool)) {
            $this->config = $config;
            $this->pool = new chan($config['master']['pool_size']);
            for ($i = 0; $i < $config['master']['pool_size']; $i++) {
                go(function() use ($config) {
                    $mysql = new MysqlDB();
                    $res = $mysql->connect($config);
                    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['master']['pool_get_timeout']);
            if (false === $mysql) {
                throw new RuntimeException("Pop mysql timeout");
            }
            defer(function () use ($mysql) { //释放
                $this->pool->push($mysql);
            });
            return $mysql;
        } else {
            throw new RuntimeException("Pool length <= 0");
        }
    }
}

数据库 CURD

MysqlDB.php

<?php

if (!defined('SERVER_PATH')) exit("No Access");

class MysqlDB
{
    private $master;
    private $slave;
    private $config;

    public function __call($name, $arguments)
    {
        if ($name != 'query') {
            throw new RuntimeException($name."：This command is not supported");
        } else {
            return $this->_execute($arguments[0]);
        }
    }

    public function connect($config)
    {
        //主库
        $master = new Swoole\Coroutine\MySQL();
        $res = $master->connect($config['master']);
        if ($res === false) {
            throw new RuntimeException($master->connect_error, $master->errno);
        } else {
            $this->master = $master;
        }

        //从库
        $slave = new Swoole\Coroutine\MySQL();
        $res = $slave->connect($config['slave']);
        if ($res === false) {
            throw new RuntimeException($slave->connect_error, $slave->errno);
        } else {
            $this->slave = $slave;
        }

        $this->config = $config;
        return $res;
    }

    public function insert($table = '', $data = [])
    {
        $fields = '';
        $values = '';
        $keys = array_keys($data);
        foreach ($keys as $k) {
            $fields .= "`".addslashes($k)."`, ";
            $values .= "'".addslashes($data[$k])."', ";
        }
        $fields = substr($fields, 0, -2);
        $values = substr($values, 0, -2);
        $sql = "INSERT INTO `{$table}` ({$fields}) VALUES ({$values})";
        return $this->_execute($sql);
    }

    public function update($table = '', $set = [], $where = [])
    {
        $arr_set = [];
        foreach ($set as $k => $v) {
            $arr_set[] = '`'.$k . '` = ' . $this->_escape($v);
        }
        $set = implode(', ', $arr_set);
        $where = $this->_where($where);
        $sql = "UPDATE `{$table}` SET {$set} {$where}";
        return $this->_execute($sql);
    }

    public function delete($table = '', $where = [])
    {
        $where = $this->_where($where);
        $sql = "DELETE FROM `{$table}` {$where}";
        return $this->_execute($sql);
    }

    public function select($table = '',$where = [])
    {
        $where = $this->_where($where);
        $sql = "SELECT * FROM `{$table}` {$where}";
        return $this->_execute($sql);
    }

    private function _where($where = [])
    {
        $str_where = '';
        foreach ($where as $k => $v) {
            $str_where .= " AND `{$k}` = ".$this->_escape($v);
        }
        return "WHERE 1 ".$str_where;
    }

    private function _escape($str)
    {
        if (is_string($str)) {
            $str = "'".$str."'";
        } elseif (is_bool($str)) {
            $str = ($str === FALSE) ? 0 : 1;
        } elseif (is_null($str)) {
            $str = 'NULL';
        }
        return $str;
    }

    private function _execute($sql)
    {
        if (strtolower(substr($sql, 0, 6)) == 'select') {
            $db = $this->_get_usable_db('slave');
        } else {
            $db = $this->_get_usable_db('master');
        }
        $result = $db->query($sql);
        if ($result === true) {
            return [
                'affected_rows' => $db->affected_rows,
                'insert_id'     => $db->insert_id,
            ];
        }
        return $result;
    }

    private function _get_usable_db($type)
    {
        if ($type == 'master') {
            if (!$this->master->connected) {
                $master = new Swoole\Coroutine\MySQL();
                $res = $master->connect($this->config['master']);
                if ($res === false) {
                    throw new RuntimeException($master->connect_error, $master->errno);
                } else {
                    $this->master = $master;
                }
            }
            return $this->master;
        } elseif ($type == 'slave') {
            if (!$this->slave->connected) {
                $slave = new Swoole\Coroutine\MySQL();
                $res = $slave->connect($this->config['slave']);
                if ($res === false) {
                    throw new RuntimeException($slave->connect_error, $slave->errno);
                } else {
                    $this->slave = $slave;
                }
            }
            return $this->slave;
        }
    }
}

OnWorkerStart 中调用

try {
    MysqlPool::getInstance(get_config('mysql'));
} catch (\Exception $e) {
    $serv->shutdown();
} catch (\Throwable $throwable) {
    $serv->shutdown();
}

客户端发送请求

<?php

//新增
$demo = [
    'type'  => 'SW',
    'token' => 'Bb1R3YLipbkTp5p0',
    'param' => [
        'class'  => 'Order',
        'method' => 'add',
        'param' => [
            'code' => 'C'.mt_rand(1000,9999),
            'name' => '订单-'.mt_rand(1000,9999),
        ],
    ],
];

//编辑
$demo = [
    'type'  => 'SW',
    'token' => 'Bb1R3YLipbkTp5p0',
    'param' => [
        'class'  => 'Order',
        'method' => 'edit',
        'param' => [
            'id' => '4',
            'name' => '订单-'.mt_rand(1000,9999),
        ],
    ],
];

//删除
$demo = [
    'type'  => 'SW',
    'token' => 'Bb1R3YLipbkTp5p0',
    'param' => [
        'class'  => 'Order',
        'method' => 'del',
        'param' => [
            'id' => '1',
        ],
    ],
];


//查询
$demo = [
    'type'  => 'SW',
    'token' => 'Bb1R3YLipbkTp5p0',
    'param' => [
        'class'  => 'Order',
        'method' => 'info',
        'param' => [
            'code' => 'C4649'
        ],
    ],
];

$ch = curl_init();
$options = [
    CURLOPT_URL  => 'http://10.211.55.4:9509/',
    CURLOPT_POST => 1,
    CURLOPT_POSTFIELDS => json_encode($demo),
];
curl_setopt_array($ch, $options);
curl_exec($ch);
curl_close($ch);

扩展

官方协程 MySQL 客户端手册：

https://wiki.swoole.com/wiki/page/p-coroutine_mysql.html

大家可以尝试使用官方提供的其他方法。

小结

Demo 代码仅供参考，里面有很多不严谨的地方。

根据自己的需要进行修改，比如业务代码相关验证，CURD 方法封装 ...

推荐一个完善的产品，Swoole 开发的 MySQL 数据库连接池（SMProxy）：

https://github.com/louislivi/smproxy

上面的 Demo 需要源码的，加我微信。（菜单-> 加我微信-> 扫我）

本文欢迎转发，转发请注明作者和出处，谢谢！

Swoole MySQL 连接池的实现

标签：failed tle mysql 连接 exception call type sla update 比较

本文系统来源：https://www.cnblogs.com/xinliangcoder/p/10930035.html

内容总结

以上是互联网集市为您收集整理的Swoole MySQL 连接池的实现全部内容，希望文章能够帮你解决Swoole MySQL 连接池的实现所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/507635.html

来源：【匿名】

【上一篇】Mysql 基础【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【Swoole MySQL 连接池的实现】教程文章相关的互联网学习教程文章

如何用PHP使SWOOLE扩展实现定时同步MySQL数据【图】

本文给大家介绍的是一次比较特殊的任务，我们使用PHP SWOOLE 做一个异步的定时任务系统，具体如何来实现的呢，接下来来我们好好看下吧南宁公司和几个分公司之间都使用了呼叫系统，然后现在需要做一个呼叫通话数据分析，由于分公司的呼叫服务器是在内网，通过技术手段映射出来，分公司到南宁之间的网络不稳定，所以需要把分公司的通话数据同步到南宁。本身最简单的方法就是直接配置MySQL的主从同步就可以同步数据到南宁来了。但是销...

PHP使用SWOOLE扩展实现定时同步MySQL数据的方法【图】

php加swoole加mysql仿webqq及时聊天【图】

本篇文章的内容是php加swoole加mysql 仿webqq及时聊天，现在分享给大家，有需要的朋友可以参考一下一、效果图二、目录结构images : 存放图片js ： js文件swoole|----action.php 数据库操作类 |----config.php 数据库配置文件 |----websocket.php swoole创建websocket协议文件index.php : 聊天首页login.html : 登录页面webqq.sql : SQL数据库文件三、数据库结构四、代码部分4.1、config.php 数据库配置文件<?php $dat...

如何在请求中获取到swoole异步mysql的回调数据

1.查看swoole 文档只看到异步mysql的实现，但是没有看到具体应用，也可能是我没看到，就想问下在一个请求中我使用异步查询mysql，异步查询会调用callback，请问我应该怎么在这个请求里获取到这个callback的查询结果回复内容：1.查看swoole 文档只看到异步mysql的实现，但是没有看到具体应用，也可能是我没看到，就想问下在一个请求中我使用异步查询mysql，异步查询会调用callback，请问我应该怎么在这个请求里获取到这个callback的...

swoole学习之异步Mysql【代码】【图】

官方示例:$db = new swoole_mysql();$server = array(host => 127.0.0.1,port => 3306,user => test,password => test,database => test,charset => utf8, //指定字符集timeout => 2, // 可选：连接超时时间（非查询超时时间），默认为SW_MYSQL_CONNECT_TIMEOUT（1.0）);$db->connect($server, function ($db, $result) {if ($result === false) {var_dump($db->connect_errno, $db->connect_error);die;}$sql = show tables;$db-...

讲解swoole HTTP服务器中异步MySQL【代码】【图】

还是直接上代码：<?php$http = new swoole_http_server("0.0.0.0", 9501);$http->on(request, function($request, $response){$swoole_mysql1 = new Swoole\Coroutine\MySQL(); $swoole_mysql2 = new Swoole\Coroutine\MySQL(); $swoole_mysql1->connect([ host => 127.0.0.1, port => 3306, user => root, password => root, database => swoole,]); $swoole_mysql2->connect([ ...

详解基于swoole的mysql连接池实现【代码】【图】

swoole框架栏目介绍swoole实现mysql连接池的方法推荐（免费）：swoole框架前言传统的nginx+FPM模式的PHP程序而言，每次请求FPM的worker都会连接一次mysql，然后请求结束便会断开连接。对于并发小的应用来说这不会有什么问题，但是对于高并发的应用来说，频繁建立连接Connect和销毁连接Close，数据库便会成为瓶颈，相信不少人也遇到过to many connection的mysql报错吧。连接池的优势连接池采用的是长连接模式，会一直保持与MySQL的连...

swoole与mysql怎么用才好【代码】【图】

swoole与mysql怎么用才好 swoole异步操作MySQL比较好。使用异步mysql好处：防止代码阻塞，提高代码效率适用场合：1、不涉及共享资源，或对共享资源只读，即非互斥操作2、没有时序上的严格关系3、不需要原子操作，或可以通过其他方式控制原子性4、常用于IO操作等耗时操作，因为比较影响客户体验和使用性能5、不影响主线程逻辑推荐学习：MySQL视频教程代码示例：<?php class mysql {private $param;public $db;public function ...

swoole_mysql怎么应用【代码】【图】

Swoole在1.8.6版本提供了全新的异步MySQL客户端，底层自行实现了MySQL的通信协议，无需依赖其他第三方库，如libmysqlclient、mysqlnd、mysqli等。（推荐学习： swoole视频教程）从1.8.6版本开始Swoole\MySQL已内置到Swoole中，无需通过--enable-async-mysql编译参数开启。swoole_mysql->__construct 创建异步mysql客户端。使用实例$db = new swoole_mysql(); $server = array(host => 192.168.56.102,port =...

PHP使用SWOOLE扩展实现定时同步 MySQL 数据【图】

南宁公司和几个分公司之间都使用了呼叫系统，然后现在需要做一个呼叫通话数据分析，由于分公司的呼叫服务器是在内网，通过技术手段映射出来，分公司到南宁之间的网络不稳定，所以需要把分公司的通话数据同步到南宁。本身最简单的方法就是直接配置MySQL的主从同步就可以同步数据到南宁来了。但是销售呼叫系统那边的公司不给MySQL权限我们。所以这个方法只能放弃了。于是我们干脆的想，使用PHP来实现定时一个简易的PHP定时同步工具...

swoole项目思维转换 -- mysql server gone away

mysql做为php的黄金搭档和互联网上应用最广泛的数据库，免不了天天与之打交道，不少朋友在熟悉swoole的使用之后，也趟平了不少坑，准备实战了，终于上线了，正愉快的体验swoole带来的巨大改进，突然数据库操作bug了，大量报mysql server gone away, 于是swooler心里千万之草尼马奔腾而过，大骂，swoole误我～～～且慢！！！这真不是swoole的问题！！！！不是swoole的问题！！！！不是swoole的问题！！！！（重要的事情说三遍）原因...

swoole编译安装/数据库连接池/异步mysql客户端【代码】

一.编译安装php5.6 0.安装必要软件 http://www.cnblogs.com/itfenqing/p/6055138.html 1.下载php5.6.30 http://php.net/downloads.php 2.解压 3.编译时指定为mysqlnt,启用opcache./configure --prefix=/usr/local/php56 --enable-fpm --enable-mysqlnd --with-mysqli=mysqlnd --with-mysql=mysqlnd --with-pdo-mysql=mysqlnd --enable-debug --with-gd --with-jpeg-dir --with-png-dir --with-freetype-dir --enable-mbstr...

17.swoole学习笔记--异步mysql操作【图】

//异步mysql操作 $db=new swoole_mysql(); $config=[‘host‘=>‘192.168.10.31‘,‘user‘=>‘zouke‘,‘password‘=>‘zouke369189‘,‘database‘=>‘pro‘,‘charset‘=>‘utf8‘ ]; //连接数据库 $db->connect($config,function($db,$r){if($r===false){var_dump($db->connect_errno,$db->connect_error);die("连接失败");}//成功的逻辑$sql=‘show tables‘;$db->query($sql,function(swoole_mysql $db,$r){if($r===false){v...

Swoole 4.1.0 正式版发布，支持原生 Redis/PDO/MySQLi 协程化【代码】

重大新特性支持 Redis/PDO/MySQLi 从4.1.0版本开始支持了对PHP原生Redis、PDO、MySQLi协程化的支持。可使用Swoole\Runtime::enableCorotuine()将普通的同步阻塞Redis、PDO、MySQLi操作变为协程调度的异步非阻塞IOSwoole\Runtime::enableCoroutine();go(function () {$redis = new redis;$retval = $redis->connect("127.0.0.1", 6379);var_dump($retval, $redis->getLastError());var_dump($redis->get("key"));var_dump($redis-...