mysql連接池實例,mysql連接池實現

本文目錄一覽：

• 1、MySQL與Redis資料庫連接池介紹（圖示+源碼+代碼演示）
• 2、mysql的數據連接池怎麼配置文件
• 3、如何實現python的mysql連接池並加入緩存過期

MySQL與Redis資料庫連接池介紹（圖示+源碼+代碼演示）

資料庫連接池（Connection pooling）是程序啟動時建立足夠的資料庫連接，並將這些連接組成一個連接池，由程序動態地對池中的連接進行申請，使用，釋放。

簡單的說：創建資料庫連接是一個很耗時的操作，也容易對資料庫造成安全隱患。所以，在程序初始化的時候，集中創建多個資料庫連接，並把他們集中管理，供程序使用，可以保證較快的資料庫讀寫速度，還更加安全可靠。

不使用資料庫連接池

如果不使用資料庫連接池，對於每一次SQL操作，都要走一遍下面完整的流程：

1.TCP建立連接的三次握手（客戶端與 MySQL伺服器的連接基於TCP協議）

2.MySQL認證的三次我收

3.真正的SQL執行

4.MySQL的關閉

5.TCP的四次握手關閉

可以看出來，為了執行一條SQL，需要進行大量的初始化與關閉操作

使用資料庫連接池

如果使用資料庫連接池，那麼會 事先申請（初始化）好 相關的資料庫連接，然後在之後的SQL操作中會復用這些資料庫連接，操作結束之後資料庫也不會斷開連接，而是將資料庫對象放回到資料庫連接池中

資源重用：由於資料庫連接得到重用，避免了頻繁的創建、釋放連接引起的性能開銷，在減少系統消耗的基礎上，另一方面也增進了系統運行環境的平穩性（減少內存碎片以及資料庫臨時進程/線程的數量）。

更快的系統響應速度：資料庫連接池在初始化過程中，往往已經創建了若干資料庫連接置於池中備用。 此時連接的初始化工作均已完成。對於業務請求處理而言，直接利用現有可用連接，避免了從資料庫連接初始化和釋放過程的開銷，從而縮減了系統整體響應時間。

統一的連接管理，避免資料庫連接泄露：在較為完備的資料庫連接池實現中，可根據預先的連接佔用超時設定，強制收回被佔用連接。從而避免了常規資料庫連接操作中可能出現的資源泄露。

如果說你的伺服器CPU是4核i7的，連接池大小應該為((4*2)+1)=9

相關視頻推薦

90分鐘搞懂資料庫連接池技術|linux後台開發

《tcp/ip詳解卷一》： 150行代碼拉開協議棧實現的篇章

學習地址：C/C++Linux伺服器開發/後台架構師【零聲教育】-學習視頻教程-騰訊課堂

需要C/C++ Linux伺服器架構師學習資料加qun 812855908 獲取（資料包括 C/C++，Linux，golang技術，Nginx，ZeroMQ，MySQL，Redis，fastdfs，MongoDB，ZK，流媒體，CDN，P2P，K8S，Docker，TCP/IP，協程，DPDK，ffmpeg 等），免費分享

源碼下載

下載方式：（Github中下載）

db_pool目錄下有兩個目錄，mysql_pool目錄為MySQL連接池代碼，redis_pool為redis連接池代碼

下面介紹mysql_pool

CDBConn解析

概念： 代表一個數據連接對象實例

相關成員：

m_pDBPool：該資料庫連接對象所屬的資料庫連接池

構造函數： 綁定自己所屬於哪個資料庫連接池

Init()函數： 創建資料庫連接句柄

CDBPool解析

概念：代表一個資料庫連接池

相關成員：

Init()函數：常見指定數量的資料庫實例句柄，然後添加到m_free_list中，供後面使用

GetDBConn()函數： 用於從空閑隊列中返回可以使用的資料庫連接句柄

RelDBConn()函數： 程序使用完該資料庫句柄之後，將句柄放回到空閑隊列中

測試之前，將代碼中的資料庫地址、埠、賬號密碼等改為自己的（代碼中有好幾處）

進入MySQL， 創建mysql_pool_test資料庫

進入到mysql_pool目錄下， 創建一個build目錄並進入 ：

然後輸入如下的命令進行編譯

之後就會在目錄下生成如下的可執行文件

輸入如下兩條命令進行測試： 可以看到不使用資料庫連接池，整個操作耗時4秒左右；使用連接池之後，整個操作耗時2秒左右，提升了一倍

源碼下載

下面介紹redis_pool

測試

進入到redis_pool目錄下， 創建一個build目錄並進入 ：

然後輸入如下的命令進行編譯

之後就會在目錄下生成如下的可執行文件

輸入如下的命令進行測試： 可以看到不使用資料庫連接池，整個操作耗時182ms；使用連接池之後，整個操作耗時21ms，提升了很多

進入redis，可以看到我們新建的key：

mysql的數據連接池怎麼配置文件

mysql的數據連接池怎麼配置文件

連接先建立一些連接，並且這些連接允許共享，因此這樣就節省了每次連接的時間開銷。Mysql資料庫為例，連接池在Tomcat中的配置與使用。

1、創建資料庫Student,表student

2、配置server.xml文件。Tomcat安裝目錄下conf中server.xml文件。

GlobalNamingResources

Resource

name=”jdbc/DBPool”

type=”javax.sql.DataSource”

password=””

driverClassName=”com.mysql.jdbc.Driver”

maxIdle=”2″

maxWait=”5000″

username=”root”

url=”jdbc:mysql://localhost:3306/student”

maxActive=”3″

/

/GlobalNamingResources

name:指定連接池的名稱

type:指定連接池的類，他負責連接池的事務處理

url:指定要連接的資料庫

driverClassName:指定連接資料庫使用的驅動程序

username:資料庫用戶名

password:資料庫密碼

maxWait:指定最大建立連接等待時間，如果超過此時間將接到異常

maxIdle:指定連接池中連接的最大空閑數

maxActive:指定連接池最大連接數

3、配置web.xml文件。

web-app

resource-ref

descriptionmysql資料庫連接池配置/description

res-ref-namejdbc/DBPool/res-ref-name

res-typejavax.sql.DataSource/res-type

res-authContainer/res-auth

res-sharing-scopeShareable/res-sharing-scope

/resource-ref

/web-app

4、配置context.xml文件

與server.xml文件所在的位置相同。

Context

ResourceLink

name=”jdbc/DBPool”

type=”javax.sql.DataSource”

global=”jdbc/DBPool”

/

/Context

5、測試

DataSource pool = null;

Context env = null;

Connection conn = null;

Statement st = null;

ResultSet rs = null;

try{

env = (Context)new InitialContext().lookup(“java:comp/env”);

//檢索指定的對象，返回此上下文的一個新實例

pool = (DataSource)env.lookup(“jdbc/DBPool”);

//獲得資料庫連接池

if(pool==null){out.printl(“找不到指定的連接池！”);}

con = pool.getConnection();

st = con.createStatement();

rs = st.executeQuery(“select * from student”);

}catch(Exception ex){out.printl(ne.toString());}

如何實現python的mysql連接池並加入緩存過期

import MySQLdb

import time

import string

import redis

class PooledConnection:

#構建連接池實例

def __init__(self, maxconnections, connstr,dbtype):

from Queue import Queue

self._pool = Queue(maxconnections) # create the queue

self.connstr = connstr

self.dbtype=dbtype

self.maxconnections=maxconnections

#根據你給數目來創建鏈接，並且寫入剛才創建的隊列裡面。

try:

for i in range(maxconnections):

self.fillConnection(self.CreateConnection(connstr,dbtype))

except Exception,e:

raise e

def fillConnection(self,conn):

try:

self._pool.put(conn)

except Exception,e:

raise “fillConnection error:”+str(e)

def returnConnection(self, conn):

try:

self._pool.put(conn)

except Exception,e:

raise “returnConnection error:”+str(e)

def getConnection(self):

try:

return self._pool.get()

except Exception,e:

raise “getConnection error:”+str(e)

def ColseConnection(self,conn):

try:

self._pool.get().close()

self.fillConnection(self.CreateConnection(connstr,dbtype))

except Exception,e:

raise “CloseConnection error:”+str(e)

def CreateConnection(self,connstr,dbtype):

if dbtype==’xxx’:

pass

elif dbtype==’mysql’:

try:

db_conn = connstr.split(“#”);

#conndb=MySQLdb.connect(db=conf.mydb,host=conf.dbip,user=conf.myuser,passwd=conf.mypasswd);

conndb=MySQLdb.connect(user=db_conn[0],passwd=db_conn[1],host=db_conn[2],port=string.atoi(db_conn[3]),db=db_conn[4]);

conndb.clientinfo = ‘datasync connection pool from datasync.py’;

conndb.ping();

except Exception, e:

raise ‘conn targetdb datasource Excepts,%s!!!(%s).’%(db_conn[2],str(e))

return None

#mysql如下創建連接池：

connstring=”xiaorui.cc#xiaoru.cc#xiaorui.cc#3306#dbname”;

mysqlpool=PooledConnection(10,connstring,”mysql”);

#獲取連接:

mysqlpool.getConnection()