workerman写mysql连接池的实例代码

首先要了解为什么用连接池，连接池能为你解决什么问题

连接池主要的作用：

1、减少与数据服务器建立TCP连接三次握手及连接关闭四次挥手的开销，从而降低客户端和mysql服务端的负载，缩短请求响应时间

2、减少数据库的并发连接数，即解决应用服务器过多导致的数据库 too many connections 问题

如果是为了解决问题1

则在workerman中数据库连接池不是最高效的方法，反而是自找麻烦的做法。由于PHP是单进程单线程的，使用PHP实现数据库连接池，肯定需要用单独的进程去做，那么就会涉及到进程间的通讯，使得原本和mysql直接通讯的过程变成 与连接池再到mysql的通讯，增加了应用端的负载。

解决问题1最高效的方法是为每个业务进程建立一个数据库单例（例如workerman提供的DB类），实现数据库长连接，这样每个进程的所有请求都使用自己的这一个数据库长连接，整个进程的生命周期只有一次TCP握手和断开连接挥手的开销，并且应用与mysql直接通讯，没有连接池那样中间一层进程间IPC通讯，性能是最高的，没有之一。

如果是为了问题2

首先看下自己到底有多少台应用服务器，每台服务器与mysql有多收并发连接。假如你只有10台应用服务器，每个服务器50个进程，每个进程1个数据库连接，那么到mysql服务端总共只有10*50=500个并发连接（并非活跃连接），500个并发连接对于mysql来说就是小菜一碟，为了解决问题2完全没有使用连接池的必要。

假如你有1000台应用服务器，那么连接池是有必要的，但是这个连接池不能是运行在本地应用服务器上的连接池，因为1000台应用服务器就有1000个连接池，即使每个连接池只开10个连接，那么数据库的连接数也会轻松打满。所以不要指望在当前服务器上开几个task进程实现的连接池就能解决这个问题。

1000台应用服务器的集群，每台服务器上搞几个进程实现连接池同样是不靠谱的方法。真正能够解决问题2的方法是建立一个独立的数据库连接池服务器或者说集群，全局管理所有的数据库链接。

综上所述，

如果单独是为了问题1实现php的mysql连接池，那么数据库单例是比所谓的连接池更简单更高效的做法。

如果是为了实现问题2，那么想必业务也有一定的规模了，如果真心是想用workerman做个单独的连接池集群，下面是大概简单的做法，建立一些task进程，每个进程创建一个数据库连接，task进程收到sql请求后发送给mysql服务器，mysql服务器返回后task进程再把结果发给sql发起者。

连接池代码类似如下 如果是多台服务器组成的连接池集群，前面最好加一个lvs：

// task worker，使用Text协议

$task_worker = new Worker('Text://0.0.0.0:1234');

$task_worker->count = 64;

$task_worker->name = 'MysqlTask';

$task_worker->onMessage = function($connection, $sql)

{

   // 执行sql.... 得到结果，这里省略....

   $sql_result = your_mysql_query($sql);

   // 发送结果

   $connection->send(json_encode($sql_result));

};

在workerman中调用：

use \Workerman\Connection\AsyncTcpConnection;

// 与远程连接池服务建立异步链接，ip为远程连接池服务的ip，如果是集群就是lvs的ip

$sql_connection = new AsyncTcpConnection('Text://ip:1234');

// 发送sql

$sql_connection->send("SELECT ... FROM .....");

// 异步获得sql结果

$sql_connection->onMessage = function($sql_connection, $sql_result)

{

   // 这里只是打印结果

   var_dump(json_decode($task_result));

};

// 执行异步链接

$sql_connection->connect();

以上就是本次介绍的workerman写mysql连接池全部知识点，有任何补充可以联系我们小编。

赞 (0)

相关推荐

  • workerman写mysql连接池的实例代码

    首先要了解为什么用连接池,连接池能为你解决什么问题 连接池主要的作用: 1.减少与数据服务器建立TCP连接三次握手及连接关闭四次挥手的开销,从而降低客户端和mysql服务端的负载,缩短请求响应时间 2.减少数据库的并发连接数,即解决应用服务器过多导致的数据库 too many connections 问题 如果是为了解决问题1 则在workerman中数据库连接池不是最高效的方法,反而是自找麻烦的做法.由于PHP是单进程单线程的,使用PHP实现数据库连接池,肯定需要用单独的进程去做,那么就会涉及

  • php实现mysql连接池效果实现代码

    循环从mysql连接池中获取连接,不需要重复创建新的连接. 参考配置修改:可以参考下面的文章 防止访问量过大,把连接数占满了 <?php /** * @author xuleyan * @title mysql类 */ class DbHelper{ //连接池 private $_pools = []; //连接池大小 const POOLSIZE = 5; const USERNAME = "root"; const PASSWORD = "root";

  • Node.js使用MySQL连接池的方法实例

    本文实例讲述了Node.js使用MySQL连接池的方法.分享给大家供大家参考,具体如下: Nodejs如何使用MySQL Nodejs要连接MySQL,可以使用Nodejs的MysQL驱动来实现.比如,我们这里使用"node-mysql"连接数据库.我们使用下面的方式来连接数据库: 首先,我们需要使用nodejs的包管理工具(npm)安装mysql的驱动.命令行如下: npm install musql 现在,要在js文件中使用mysql,添加下面的代码到你的文件中: var mysq

  • Node.js实现mysql连接池使用事务自动回收连接的方法示例

    本文实例讲述了Node.js实现mysql连接池使用事务自动回收连接的方法.分享给大家供大家参考,具体如下: var mysql = require('mysql'), Connection = require('mysql/lib/Connection.js'); var pool = mysql.createPool({ host: '127.0.0.1', database: 'myDB', port: 3306, user: 'root', password: 'root', debug

  • 用sqlalchemy构建Django连接池的实例

    都知道django每次请求都会连接数据库和释放数据库连接.Django为每个请求使用新的数据库连接.一开始这个方法行得通.然而随着服务器上的负载的增加,创建/销毁连接数据库开始花大量的时间.要避免这个,你可以使用数据库连接池,这里使用SQLAlchemy的连接池.使Django持久化数据库连接. 但这种方法会改变django的代码.对框架有侵入 方法 1 实现方法如下: 把django/db/backends/mysql文件夹全部拷贝出来,放在项目的一个libs/mysql下面,然后修改base

  • jdbc中自带MySQL 连接池实践示例

    jdbc中自带MySQL 连接池实践示例

    引言 在上期文章自定义 MySQL 连接池中,我提到了没找到一个特别合适的 MySQL 连接池实现,所以自己写了一个基于通用池化框架commons-pool2的 MySQL 连接池,并且模仿了 Go 语言的gorm框架设计思路,把借和还的操作不暴露给用户,只处理用户发来的 SQL 语句的思路,封装了一个com.funtester.db.mysql.MysqlPool. 可惜打脸的事情来的太快了,在录制视频的时候偶然发现了 Intellij 代码提示有个com.mysql.cj.jdbc.Mysq

  • mysql事务处理用法与实例代码详解

    MySQL的事务支持不是绑定在MySQL服务器本身,而是与存储引擎相关 1.MyISAM:不支持事务,用于只读程序提高性能 2.InnoDB:支持ACID事务.行级锁.并发 3.Berkeley DB:支持事务 一个事务是一个连续的一组数据库操作,就好像它是一个单一的工作单元进行.换言之,永远不会是完整的事务,除非该组内的每个单独的操作是成功的.如果在事务的任何操作失败,则整个事务将失败. 实际上,会俱乐部许多SQL查询到一个组中,将执行所有的人都一起作为事务的一部分. 事务的特性: 事务有以下

  • python3 实现mysql数据库连接池的示例代码

    python3 实现mysql数据库连接池的示例代码

    dbutils封装文件传送门 DBUtils是一套Python数据库连接池包,并允许对非线程安全的数据库接口进行线程安全包装.DBUtils来自Webware for Python. DBUtils提供两种外部接口: PersistentDB :提供线程专用的数据库连接,并自动管理连接. PooledDB :提供线程间可共享的数据库连接,并自动管理连接. 需要库 1.DBUtils pip install DBUtils 2.pymysql pip install pymysql/MySQLdb

  • 使用Python写一个贪吃蛇游戏实例代码

    我在程序中加入了分数显示,三种特殊食物,将贪吃蛇的游戏逻辑写到了SnakeGame的类中,而不是在Snake类中. 特殊食物: 1.绿色:普通,吃了增加体型 2.红色:吃了减少体型 3.金色:吃了回到最初体型 4.变色食物:吃了会根据食物颜色改变蛇的颜色 #coding=UTF-8 from Tkinter import * from random import randint import tkMessageBox class Grid(object): def __init__(self,

  • 用于App服务端的MySQL连接池（支持高并发）

    本文向大家介绍了简单的MySQL连接池,用于App服务端比较合适,分享给大家供大家参考,具体内容如下 /** * 连接池类 */ package com.junones.test; import java.sql.Connection; import java.sql.SQLException; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; import com.mysql.jdbc.jdb

随机推荐