文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

C++怎么实现数据库连接池

2023-07-05 15:19

关注

本文小编为大家详细介绍“C++怎么实现数据库连接池”,内容详细,步骤清晰,细节处理妥当,希望这篇“C++怎么实现数据库连接池”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。

项目背景

为了提高Mysql数据库的访问瓶颈,常用的方法有如下两个:

注:常见的MySQL、Oracle、SQLServer等数据库都是基于C/S架构设计的。

市面上主流的Mysql数据库连接池,对于短时间内的大量增删改查操作的性能提升很明显,但大多数都是Java实现的,该项目的开展就是为了提高Mysql Server的访问效率,实现基于C++代码的数据库连接池模块。

针对于系统启动时就创建一定数量的连接,用户一旦执行CURD操作,直接拿出一条连接即可,不需要TCP的连接过程和资源回收过程,使用完该连接后归还给连接池的连接队列,供之后使用。

功能点介绍

连接池一般包含了数据库连接所用的ip地址、port端口号、username用户名、password密码以及其他一些性能参数:比如初始连接量、最大连接量、最大空闲时间、连接超时时间等

本项目重点实现上述通用功能

1、初始连接量(initSize)

初始连接量表示连接池事先会和MySQL Server创建的initSize数量的Connection连接。在完成初始连接量之后,当应用发起MySQL访问时,不用创建新的MySQLServer连接,而是从连接池中直接获取一个连接,当使用完成后,再把连接归还到连接池中。

2、最大连接量(maxSize)

当并发访问MySQL Server的请求增加,初始连接量不够用了,此时会增加连接量,但是增加的连接量的上限就是maxSIze。因为每一个连接都会占用一个socket资源,一般连接池和服务器都是部署在一台主机上,如果连接池的连接数量过多,那么服务器就不能响应太多的客户端请求了。

3、最大空闲时间(maxIdleTime)

当高并发过去,因为高并发而新创建的连接在很长时间(maxIdleTime)内没有得到使用,那么这些新创建的连接处于空闲,并且占用着一定的资源,这个时候就需要将其释放掉,最终只用保存iniSize个连接就行。

4、连接超时时间(connectionTimeOut)

当MySQL的并发访问请求量过大,连接池中的连接数量已经达到了maxSize,并且此时连接池中没有可以使用的连接,那么此时应用阻塞connectionTimeOut的时间,如果此时间内有使用完的连接归还到连接池,那么他就可以使用,如果超过这个时间还是没有连接,那么它获取数据库连接池失败,无法访问数据库。

功能点实现的相关原理综述

图示如下:

C++怎么实现数据库连接池

关键技术点

1、MySql数据库编程

目的:在C++下输入Sql语句对数据库进行操作的代码封装

说明:这里的MYSQL的数据库编程直接采用oracle公司提供的C++客户端开发包 , 读者可以自己查阅资料或搜索官方文档自行学习相关API的使用方法。

Connection.h:

class Connection{public:// 初始化数据库连接Connection();// 释放数据库连接资源~Connection();// 连接数据库bool connect(string ip,unsigned short port,string user,string password,string dbname);// 更新操作 insert、delete、updatebool update(string sql);// 查询操作 selectMYSQL_RES* query(string sql);// 刷新一下连接的起始的空闲时间点void refreshAliveTime() { _alivetime = clock(); }// 返回存活的时间clock_t getAliveeTime()const { return clock() - _alivetime; }private:MYSQL* _conn; // 表示和MySQL Server的一条连接clock_t _alivetime; // 记录进入空闲状态后的起始存活时间};

Connection.cpp:

Connection::Connection(){// 初始化数据库连接_conn = mysql_init(nullptr);}Connection::~Connection(){// 释放数据库连接资源if (_conn != nullptr)mysql_close(_conn);}bool Connection::connect(string ip, unsigned short port,string username, string password, string dbname){// 连接数据库MYSQL* p = mysql_real_connect(_conn, ip.c_str(), username.c_str(),password.c_str(), dbname.c_str(), port, nullptr, 0);return p != nullptr;}bool Connection::update(string sql){// 更新操作 insert、delete、updateif (mysql_query(_conn, sql.c_str())){LOG("更新失败:" + sql);return false;}return true;}MYSQL_RES* Connection::query(string sql){// 查询操作 selectif (mysql_query(_conn, sql.c_str())){LOG("查询失败:" + sql);return nullptr;}return mysql_use_result(_conn);}

这里需要说明的是:在Windows上使用数据库需要进行相关配置

大致配置内容如下:

2、数据库连接池单例代码

连接池仅需要一个实例,同时服务器肯定是多线程的,必须保证线程安全,所以采用懒汉式线程安全的单例:

CommonConnectionPool.h: 部分代码

class ConnectionPool{public:// 获取连接池对象实例static ConnectionPool* getConnectionPool();// 给外部提供接口,从连接池中获取一个可用的空闲连接shared_ptr<Connection> getConnection();private:// 单例#1 构造函数私有化ConnectionPool();};

CommonConnectionPool.cpp: 部分代码

// 线程安全的懒汉单例函数接口ConnectionPool* ConnectionPool::getConnectionPool(){static ConnectionPool pool; //静态对象初始化由编译器自动进行lock和unlockreturn &pool;}

3、queue队列容器

连接池的数据结构是queue队列,最早生成的连接connection放在队头,此时记录一个起始时间,这一点在后面最大空闲时间时会发挥作用:如果队头都没有超过最大空闲时间,那么其他的一定没有

CommonConnectionPool.cpp 的连接池构造函数:

// 连接池的构造ConnectionPool::ConnectionPool(){// 加载配置项了if (!loadConfigFile()){return;}// 创建初始数量的连接for (int i = 0; i < _initSize; ++i){Connection* p = new Connection();//创建一个新的连接p->connect(_ip, _port, _username, _password, _dbname);p->refreshAliveTime(); // 刷新一下开始空闲的起始时间_connectionQue.push(p);_connectionCnt++;}}

连接数量没有到达上限,继续创建新的连接

if (_connectionCnt < _maxSize){Connection* p = new Connection();p->connect(_ip, _port, _username, _password, _dbname);p->refreshAliveTime(); // 刷新一下开始空闲的起始时间_connectionQue.push(p);_connectionCnt++;}

扫描整个队列,释放多余的连接(高并发过后,新建的连接超过最大超时时间时)

unique_lock<mutex> lock(_queueMutex);while (_connectionCnt > _initSize){Connection* p = _connectionQue.front();if (p->getAliveTime() >= (_maxIdleTime * 1000)){_connectionQue.pop();_connectionCnt--;// 调用~Connection()释放连接delete p;}else{// 如果队头的连接没有超过_maxIdleTime,其他连接肯定没有break;}}

4、多线程编程

为了将多线程编程的相关操作应用到实际,也为了进行压力测试,用结果证明使用连接池之后对数据库的访问效率确实比不使用连接池的时候高很多,使用了多线程来进行数据库的访问操作,并且观察多线程下连接池对于性能的提升。

代码如下:

int main(){thread t1([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "991205", "chat");conn.update(sql);}});thread t2([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "991205", "chat");conn.update(sql);}});thread t3([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "991205", "chat");conn.update(sql);}});thread t4([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "male");conn.connect("127.0.0.1", 3306, "root", "991205", "chat");conn.update(sql);}});t1.join();t2.join();t3.join();t4.join();return 0;}

5、线程互斥、线程同步通信(生产者-消费者模型)、unique_lock

连接池中连接队列的连接的生产和消费需要保证其线程安全,于是我们需要引入互斥锁mutex,线程同步通信确保执行顺序,以及唯一锁。

代码如下:

class ConnectionPool{private:// 设置条件变量,用于连接生产线程和连接消费线程的通信condition_variable cv;// 维护连接队列的线程安全互斥锁mutex _queueMutex;};for (;;){unique_lock<mutex> lock(_queueMutex);while (!_connectionQue.empty()){// 队列不为空,此处生产线程进入等待状态cv.wait(lock);}// 连接数量没有达到上限,继续创建新的连接if (_connectionCnt < _maxSize){Connection* p = new Connection();p->connect(_ip, _port, _username, _password, _dbname);// 刷新一下开始空闲的起始时间p->refreshAliveTime();_connectionQue.push(p);_connectionCnt++;}// 通知消费者线程,可以消费连接了cv.notify_all();}
// 启动一个新的线程,作为连接的生产者 linux thread => pthread_createthread produce(std::bind(&ConnectionPool::produceConnectionTask, this));produce.detach();// 启动一个新的定时线程,扫描超过maxIdleTime时间的空闲连接,进行对于的连接回收thread scanner(std::bind(&ConnectionPool::scannerConnectionTask, this));scanner.detach();

6、CAS原子操作

对于连接池内的连接数量,生产者和消费者线程都会去改变其值,那么这个变量的修改就必须保证其原子性,于是使用C++11中提供的原子类:atomic_int

atomic_int _connectionCnt; // 记录连接所创建的connection连接的总数量 // 生产新连接时:_connectionCnt++;// 当新连接超过最大超时时间后被销毁时_connectionCnt--;

7、shared_ptr及lambda表达式

对于使用完成的连接,不能直接销毁该连接,而是需要将该连接归还给连接池的队列,供之后的其他消费者使用,于是我们使用智能指针,自定义其析构函数,完成放回的操作:

shared_ptr<Connection> sp(_connectionQue.front(),[&](Connection* pcon) {// 这里是在服务器应用线程中调用的,所以一定要考虑队列的线程安全操作unique_lock<mutex> lock(_queueMutex);pcon->refreshAliveTime();_connectionQue.push(pcon);});

8、压力测试

测试添加连接池后效率是否提升:

未使用连接池

单线程

int main(){clock_t begin = clock();for (int i = 0; i < 1000; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "123456", "chat");conn.update(sql);}clock_t end = clock();cout << (end - begin) << "ms" << endl;return 0;}

运行时间如下:

C++怎么实现数据库连接池

多线程

int main(){Connection conn;conn.connect("127.0.0.1", 3306, "root", "991205", "chat");clock_t begin = clock();thread t1([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "123456", "chat");conn.update(sql);}});thread t2([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "123456", "chat");conn.update(sql);}});thread t3([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "123456", "chat");conn.update(sql);}});thread t4([]() {for (int i = 0; i < 250; ++i){Connection conn;char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");conn.connect("127.0.0.1", 3306, "root", "123456", "chat");conn.update(sql);}});t1.join();t2.join();t3.join();t4.join();clock_t end = clock();cout << (end - begin) << "ms" << endl;return 0;}

运行时间如下:

C++怎么实现数据库连接池

使用连接池

单线程

int main(){clock_t begin = clock();ConnectionPool* cp = ConnectionPool::getConnectionPool();for (int i = 0; i < 1000; ++i){shared_ptr<Connection> sp = cp->getConnection();char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");sp->update(sql);}clock_t end = clock();cout << (end - begin) << "ms" << endl;return 0;}

运行时间如下

C++怎么实现数据库连接池

多线程

int main(){clock_t begin = clock();thread t1([]() {ConnectionPool* cp = ConnectionPool::getConnectionPool();for (int i = 0; i < 250; ++i){char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");shared_ptr<Connection> sp = cp->getConnection();sp->update(sql);}});thread t2([]() {ConnectionPool* cp = ConnectionPool::getConnectionPool();for (int i = 0; i < 250; ++i){char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");shared_ptr<Connection> sp = cp->getConnection();sp->update(sql);}});thread t3([]() {ConnectionPool* cp = ConnectionPool::getConnectionPool();for (int i = 0; i < 250; ++i){char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");shared_ptr<Connection> sp = cp->getConnection();sp->update(sql);}});thread t4([]() {ConnectionPool* cp = ConnectionPool::getConnectionPool();for (int i = 0; i < 250; ++i){char sql[1024] = { 0 };sprintf(sql, "insert into user(name,age,sex) values('%s',%d,'%s')","zhang san", 20, "M");shared_ptr<Connection> sp = cp->getConnection();sp->update(sql);}});t1.join();t2.join();t3.join();t4.join();clock_t end = clock();cout << (end - begin) << "ms" << endl;return 0;}

C++怎么实现数据库连接池

比较

在使用了连接池之后,性能确实提升了不少

读到这里,这篇“C++怎么实现数据库连接池”文章已经介绍完毕,想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会,如果想了解更多相关内容的文章,欢迎关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯