基于C++11的数据库连接池【C++/数据库/多线程/MySQL】

一、概述
概述：数据库连接池可提前把多个数据库连接建立起来，然后把它放到一个池子里边，就是放到一个容器里边进行维护。如许的话就可以大概避免数据库连接的频繁的创建和销毁，从而进步步调的效率。线程池实在也是同样的思绪，也是为了避免线程的重复的创建和销毁。

这个图模拟的是一个网络通信，在左侧有多个客户端，客户端给服务器发数据，发数据可以明白为就是发送一个请求，好比说请求登录，请求注册，请求下载或者上传某些文件。
我们还需要做身份的验证，或者说做数据的读和写操作，那这个数据在那里呢？ 

• 数据在一个数据库里边，这个数据库它实在位于服务器端。
  

在服务器端，实在并不是只有一个应用步调。和服务器端步调一块部署的还可以有其他模块，好比关系型数据库的服务器，非关系型数据库的服务器，或者说部署一些分布式的文件系统。
当客户端向服务器发起了某个请求之后，好比说它要登录，那么此时服务器就会连接数据库。从数据库里面去查询一下这个用户的数据是否存在。如果存在，答应它登录；如果不存在，就不答应它登录。所以在这个网络通信的服务器端可以看成是数据库的客户端。如果是多个客户端同时向服务器发起请求，此时服务器就需要建立多个连接去进行数据库的查询。当查询完之后，它需要断开这个连接。
小细节：这个连接一直保持着可以吗？

• 如果一直保持着这个数据库连接，但是你又不进行数据库操作，就浪费了资源。所以在服务器端在进行数据库操作的时间，一样平常的处理惩罚思绪就是用的时间去连接，用完了之后就把它销毁掉。
  
• 如果在网络通信的服务器端，频繁地进行数据库地连接和断开，这很显然好坏常的浪费时间以及浪费资源的，所以就可以在网络通信的服务器端去维护一个连接池。当需要连接数据库的时间，就从这个连接池中拿出一个连接，用完之后再把这个连接还给连接池。
  

有了数据库连接池的利益是什么？

• 就是避免了这个数据库连接的频繁创建和销毁，使用这种方式在访问量比较高的环境下，就可以大概节省一部门时间。如果访问量很少，有无连接池实在我们是看不到任何的区别的。
  
• 如果在高并发环境下，这些需要频繁处理惩罚的操作就会消耗很多的资源和时间。
  

涉及的技能点：
C++11新特性

• 多线程编程
  
• 线程同步（互斥锁的使用）
  
• 处理惩罚时间和日期的chrono库
  
• 条件变量
  
• 智能指针（帮我们开释一块内存）
  
• lambda表达式
  
• 使用=delete删除函数（在实现数据库连接池的时间，需要创建一个单例模式的类，某些函数是不答应存在的，好比说拷贝构造函数，还有=赋值操作符重载函数，可以用=delete删除，它们也就不答应使用了。如果不使用=delete删除，访问权限设置为私有也可以）
  

其他知识点：

• MYSQL数据库查询，主要是官方API的封装和使用
  
• 单例模式
  
• STL容器
  
• 生产者和消耗者模型
  
• Jsoncpp库的使用（解析设置文件中的数据库干系信息）
  

 二、Mysql API
MySQL API 使用详解 | 爱编程的大丙 (subingwen.cn)

https://subingwen.cn/mysql/mysql-api/VsCode + CMake构建项目 C/C++连接Mysql数据库 | 数据库增删改查C++封装 | 信息管理系统通用代码 ---- 课程条记-CSDN博客

https://blog.csdn.net/weixin_41987016/article/details/135668803?spm=1001.2014.3001.5501

• MysqlConn.h
  

1. #pragma once
2. #include <mysql.h>
3. #include <string>
4. #include <chrono>
5. using namespace std;
6. using namespace std::chrono;
7. class MysqlConn {
8. public:
9.     // 初始化数据库连接
10.     MysqlConn();
11.     // 释放数据库连接
12.     ~MysqlConn();
13.     // 连接数据库
14.     bool connect(string user, string passwd, string dbName, string ip, unsigned short port = 3306);
15.     // 更新数据库: select，update，delete
16.     bool update(string sql);
17.     // 查询数据库
18.     bool query(string sql);
19.     // 遍历查询得到的结果集
20.     bool next();
21.     // 得到结果集中的字段值
22.     string value(int index);
23.     // 事务操作
24.     bool transaction();
25.     // 提交事务
26.     bool commit();
27.     // 事务回滚
28.     bool rollback();
29.     // 刷新起始的空闲时间点
30.     void refreshAliveTime();
31.     // 计算连接存活的总时长
32.     long long getAliveTime();
33. private:
34.     void freeResult();
35.     MYSQL* m_conn = nullptr; // 数据库连接
36.     MYSQL_RES* m_result = nullptr;
37.     MYSQL_ROW m_row = nullptr;
38.     steady_clock::time_point m_aliveTime;
39. };

复制代码

•  MysqlConn.cpp
  

1. #include "MysqlConn.h"
3. // 初始化数据库连接
4. MysqlConn::MysqlConn() {
5.     m_conn = mysql_init(nullptr);
6.     mysql_set_character_set(m_conn, "GBK"); // 设置字符集
7. }
9. // 释放数据库连接
10. MysqlConn::~MysqlConn() {
11.     if (m_conn != nullptr) {
12.         mysql_close(m_conn);
13.     }
14.     freeResult();
15. }
17. // 连接数据库
18. bool MysqlConn::connect(string user, string passwd, string dbName, string ip, unsigned short port) {
19.     MYSQL* ptr = mysql_real_connect(m_conn, ip.c_str(), user.c_str(), passwd.c_str(), dbName.c_str(), port, nullptr, 0);
20.     return ptr != nullptr;
21. }
23. // 更新数据库:insert，update，delete
24. bool MysqlConn::update(string sql) {
25.     if (mysql_query(m_conn, sql.c_str())) {
26.         return false;
27.     }
28.     return true;
29. }
31. // 查询数据库
32. bool MysqlConn::query(string sql) {
33.     freeResult(); // 释放之前查询的结果集
34.     if (mysql_query(m_conn, sql.c_str())) {
35.         return false;
36.     }
37.     m_result = mysql_store_result(m_conn); // 获取查询结果
38.     return true;
39. }
41. // 遍历查询得到的结果集
42. bool MysqlConn::next() {
43.     if (m_result != nullptr) {
44.         m_row = mysql_fetch_row(m_result);
45.         if (m_row != nullptr) {
46.             return true;
47.         }
48.     }
49.     return false;
50. }
52. // 得到结果集中的字段值
53. string MysqlConn::value(int index) {
54.     int rowCount = mysql_num_fields(m_result);
55.     if (index >= rowCount || index < 0) {
56.         return string();
57.     }
58.     char* val = m_row[index];
59.     unsigned long length = mysql_fetch_lengths(m_result)[index];
60.     return string(val, length);
61. }
63. // 事务操作
64. bool MysqlConn::transaction() {
65.     return mysql_autocommit(m_conn, false);
66. }
68. // 提交事务
69. bool MysqlConn::commit() {
70.     return mysql_commit(m_conn);
71. }
73. // 事务回滚
74. bool MysqlConn::rollback() {
75.     return mysql_rollback(m_conn);
76. }
78. // 刷新起始的空闲时间点
79. void MysqlConn::refreshAliveTime() {
80.     // 这个时间戳就是某个数据库连接，它起始存活的时间点
81.     // 这个时间点通过时间类就可以得到了
82.     m_aliveTime = steady_clock::now();
83. }
85. // 计算连接存活的总时长
86. long long MysqlConn::getAliveTime() {
87.     nanoseconds duration = steady_clock::now() - m_aliveTime;
88.     milliseconds millsec = duration_cast<milliseconds>(duration);
89.     return millsec.count();
90. }
92. void MysqlConn::freeResult() {
93.     if (m_result != nullptr) {
94.         mysql_free_result(m_result);
95.         m_result = nullptr;
96.     }
97. }

复制代码

数据库操作类封装好了之后，看一下如何编写一个数据库连接池。
三、数据库连接池
关于数据库连接池，它主要是用在网络通信的服务器端，在网络通信的服务器端有可能同时接收多个客户端请求，并且客户端请求的数据它并不在服务器上，而是在服务器对应的那个数据库服务器上。
肯定要留意：网络通信的服务器端，它有可能部署了多个组件，数据库服务器是这多个组件里边的其中一个。又因为这个请求是多个客户端发送过来的，所以服务器端为了进步读取数据的效率，它需要通过多线程去访问数据库服务器。
在服务器端如果想要连接数据库服务器，需要做四步操作：

• 第一步：通过tcp进行三次握手。因为网络通信的服务器端实在就是数据库的客户端。数据库的客户端连接数据库的服务器端，实在是一个tcp通信，tcp通信的第一步就是需要进行三次握手。
  
• 第二步：数据库服务器的连接认证。当连接建立之后，数据库的服务器需要验证客户端的身份，就是验证用户名和密码。验证成功之后，数据库的客户端就可以通过sql语句去服务器端读取或者更新一些数据，
  
• 第三步：数据库服务器关闭连接时的资源接纳。当操作完成之后，客户端和服务器需要断开连接，在断开连接的时间需要进行资源的开释。
  
• 第四步：断开通信连接的TCP四次挥手。数据库资源开释完了之后，这个tcp通信还需要进行四次挥手。
  

把这四步操作做完了之后，数据库的客户端和数据库的服务器端，它们之间的通信也就竣事了。如果说这个客户端和服务器端需要频繁地进行这四步操作，很显然好坏常的浪费时间的，因此就提供了一个办理方案：使用数据库连接池。
在这个数据库连接池里边，我们需要事先和数据库的服务器建立多少个连接，当需要将进行数据库操作的时间，套接字通信的服务器端通过线程去连接池里取出一个可用的连接。取出这个连接之后，就可以和数据库的服务器直接通信了。通信竣事之后，这个连接是不需要进行断开的，网络通信的服务器端对应的这个线程，把这个数据库连接就还给数据库连接池。因此我们就可以实现数据库连接的复用。通过如许的操作，大大的低落了数据库连接的创建和销毁的次数，对应的时间也就被节省出来了。
如果要实现一个数据库连接池，它都需要有哪些组成部门？
这个数据库连接池，它在步调中对应的肯定是一个对象。那么这个数据库连接池的对象有一个照旧多个呢？很显然，一个就够了，因为在数据库连接池里边，它可以给我们提供多少个连接，只需要一个数据库连接池对象就可以把多个连接取出来，故这个对象一个就够。
因此，在编写数据库连接池对应的类的时间，这个类应该是一个单例模式的类。提供一个单例模式的类，可以避免出创建多个数据库连接池对象。
分析在这个单例模式的类里边，我们需要给数据库连接池提供哪些属性呢？

1. // 连接服务器所需信息
2. string m_ip;            // 数据库服务器ip地址
3. string m_user;          // 数据库服务器用户名
4. string m_dbName;        // 数据库服务器的数据库名
5. string m_passwd;        // 数据库服务器密码
6. unsigned short m_port;  // 数据库服务器绑定的端口

复制代码

数据库连接池里边，它存储的是数据库连接，如果我们要成功地建立一个数据库连接，那么就需要提供一系列的属性，这个属性包括数据库服务器对应的IP和它的端口Port。另外在连接数据库服务器的时间，需要提供数据库服务器对应的用户名和密码。因为在一个mysql数据库的服务器上，可以创建多个数据库，每个数据库都有对应的自己的名字，故还需要指定dbName。有了这些属性，就可以成功的去建立一个数据库连接，如果要建立多个数据库连接，那么这个连接是需要存储起来的。

1. // 连接池信息
2. queue<MysqlConn*> m_connQ;
3. unsigned int m_maxSize; // 连接数上限值
4. unsigned int m_minSize; // 连接数下限值
5. int m_timeout; // 连接超时时长
6. int m_maxIdleTime; // 最大的空闲时长
7. mutex m_mutexQ; // 独占互斥锁
8. condition_variable m_cond; // 条件变量

复制代码

在STL中我们可以选择队列，存储数据库连接对象。在这个队列里边存储连接的时间，是有上限的，故需要给这个队列存储的连接指定一个最大值。
如果服务器端对应的多个线程从数据库连接池里边取连接的时间，这个连接已经用完了，我们可以给这个线程指定一个超时的时长。如果没有连接了，可以等待肯定的时长。如果等待了肯定的时间长度还没有拿到可用的连接，有两种处理惩罚方式：

• 一种处理惩罚方式就是告诉这个线程已经没有可用的连接了。
  
• 另一种处理惩罚方式让这个线程继续等，直到这个数据库连接池里边有新连接了，那么把这个新连接给到对应的线程。
  

除此之外，还有一种环境就是这个数据库里边的空闲连接太多了，如果空闲的连接太多了，我们就需要销毁一部门，那么我们怎么知道要销毁哪些数据库连接呢？
办理方案：当我们创建出一个数据库之后，它肯定是空闲的，把这个时间点记录下来，给它一个时间戳，然后再提供一个线程专门的去检测这些数据库连接，它们都空闲了多长的时间，就是以现在的这个时间点减去对应的那个起始时间点，如果这个时间长度超过了我们规定的时长，那么就把对应的这个数据库连接给销毁掉。如果没有超过规定的时长，就让这个数据库连接继续存活。另外，在实现这个数据库连接池的时间，还涉及到一些线程干系的操作。因为多个线程它们需要访问这个数据库连接池，因此数据库连接池就是多个线程对应的共享资源。如果涉及到共享资源的访问，就需要使用互斥锁。
其中，共享资源就是数据库连接池队列，要使用互斥锁来保证连接池队列里边的数据不发生杂乱。

网络通信的服务器端，它提供的这多个线程在访问数据库连接池的时间，把可用的数据库连接从连接池里边拿出去。如果用完了，之后再把这个可用的连接还给数据库连接池。因此我们可以把这两部门（多线程和连接池->网络服务器）看成是一个生产者和消耗者模型。对应的消耗者就是网络通信的服务器端提供的这多个线程。生产者是我们在实现数据库连接的时间，提供的一个额外的线程，这个线程需要检测连接池里边的连接数量是否足够，如果说这个连接已经不敷了，这个线程它就去生成新的连接，如果说连接池里边的连接是足够的，专门用于生产数据库连接的线程就不工作了。如果它不工作了，就需要让线程壅闭。在C++11里边，让线程池壅闭需要用到条件变量。
超时时长就是让线程壅闭等待的时间长度，当线程等待了这个时间段之后，再让它实验去连接池里取出对应的连接。如果有就给它，如果没有，可以让它去等待，或者直接告诉它没有了。
在连接池队列里边，可用的有效连接太多了，大部门都处于空闲的状态，在这种环境下，可以销毁一部门有效的数据库连接。销毁哪一个呢？
那就看哪一个数据库连接它的空闲时长到了我们指定的时间长度。如果到了就把它关闭，相称于这个数据库连接就被我们认为开释了。故还需要在这个连接池里边给它添加两个属性，

• 一个是超时时长：m_timeout
  
• 一个是最大的空闲时长：m_maxIdleTime
  

>>界说数据库连接池

1. #pragma once
2. #include <queue>
3. #include <mutex>
4. #include <condition_variable>//条件变量
5. #include "MysqlConn.h"
6. using namespace std;
7. class ConnPool {
8. public:
9.     static ConnPool* getConnPool();// 获得单例对象
10.     ConnPool(const ConnPool& obj) = delete; // 删除拷贝构造函数
11.     ConnPool& operator=(const ConnPool& obj) = delete; // 删除拷贝赋值运算符重载函数
12.     shared_ptr<MysqlConn> getConn(); // 从连接池中取出一个连接
13.     ~ConnPool(); // 析构函数
14. private:
15.     ConnPool(); // 构造函数私有化
16.     bool parseJsonFile(); // 解析json格式文件
17.     void produceConn(); // 生产数据库连接
18.     void recycleConn(); // 销毁数据库连接
19.     void addConn(); // 添加数据库连接
21.     // 连接服务器所需信息
22.     string m_ip;            // 数据库服务器ip地址
23.     string m_user;          // 数据库服务器用户名
24.     string m_dbName;        // 数据库服务器的数据库名
25.     string m_passwd;        // 数据库服务器密码
26.     unsigned short m_port;  // 数据库服务器绑定的端口
28.     // 连接池信息
29.     queue<MysqlConn*> m_connQ;
30.     unsigned int m_maxSize; // 连接数上限值
31.     unsigned int m_minSize; // 连接数下限值
32.     int m_timeout; // 连接超时时长
33.     int m_maxIdleTime; // 最大的空闲时长
34.     mutex m_mutexQ; // 独占互斥锁
35.     condition_variable m_cond; // 条件变量
36. };

复制代码

>>单例类的构造函数处理惩罚
单例模式有两种实现：
（1）懒汉模式：在使用这个实例对象的时间，才去创建它。单例模式的类肯定是有且只有一个的。懒汉模式的实现方式有很多种方式：

• 使用静态的局部变量；（在C++11里边使用静态局部变量是没有线程安全问题的）
  
• 互斥锁（保证创建出来的实例对象有且仅有一个）
  
• call_once函数（C++11提供的），可以实现懒汉模式的单例类
  

（2）饿汉模式：不管我们用不用这个实例对象，只要这个类被创建出来了，那么对应的这个实例对象也就有了。饿汉模式是没有线程安全的问题的。因为当我们把这个饿汉模式的实例对象创建出来此时如果有多个线程来访问这个单例对象，不涉及到对象的创建。因此多线程在访问这个单例对象的时间，肯定也是线程安全的。

把构造函数设为私有的（private），那如果我们想要得到如许的一个类的实例对象，可以通过类名来获取到这个类的实例，它可以大概访问的肯定是静态的函数或者静态变量。所以可以给这个类添加一个静态方法getConnPool();

1. ConnPool* ConnPool::getConnPool() {
2.     static ConnPool pool;
3.     return &pool;
4. }

复制代码

在C++11中实现懒汉模式，在getConnPool()函数里使用静态的局部变量是安全的。
静态局部变量的访问范围为当前的函数，但生命周期有多长呢？应用步调竣事之后，pool指向的这块内存才可以大概被析构。不是每调用一次getConnPool函数，这个pool对象就会被创建一次。当第一次调用getConnPool函数的时间，这个静态的局部对象被创建出来了，第二次调用这个函数的时间，这个静态的局部对象它已经存在了。所以不管后边对这个函数调用多少次，和第一次调用的时间是一样的，得到的是同一块内存地址。只不过，这个ConnPool范例的对象的访问范例是受限的。只可以大概在当前的函数里边被访问。调用getConnPool函数，把这个pool地址返回给函数的调用者，就可以得到这个类唯一的实例。
另外，在实现一个单例类的时间，除了把构造函数设为私有的（private）。还有需要留意一点：通过拷贝构造函数也可以创建出对应的实例对象，所以应该把拷贝构造函数也设置成私有的（private）。或者说把这个拷贝构造函数直接删除掉。
如何删除拷贝构造函数呢？在C++11里边提供了=delete可以把对应的函数显示的删除。当把这个函数删除了，我们就不能在步调中再次使用这个函数了。
除了删除构造函数，还有一个需要删除的就是拷贝赋值运算符重载函数。如果我们创建一个类，在这个类里边实在是给我们提供了六个默认的函数:

• 无参的构造函数
  
• 析构函数
  
• 拷贝构造函数
  
• 移动构造函数
  
• 拷贝赋值运算符重载函数
  
• 移动赋值操作符重载
  

通过这个拷贝赋值运算符重载函数，也就是通过等号=,我们就可以大概创建出一个新的对象，实在和拷贝构造函数实现的功能是一样的。
移动赋值操作符重载，它的功能呢和移动构造函数是差不多的，移动赋值操作符重载函数，它重载的也是等号操作符，只不过它和赋值操作符重载的函数的参数是不一样的。移动赋值操作符重载和移动构造函数，它们实现的是资源的转移，而不是进行数据的拷贝。所以要把拷贝赋值运算符重载对应的等号操作符函数删除掉。实在设置为私有也可以防止对象的复制。

1. class ConnPool {
2. public:
3.     static ConnPool* getConnPool();// 获得单例对象
4.     ConnPool(const ConnPool& obj) = delete; // 删除拷贝构造函数
5.     ConnPool& operator=(const ConnPool& obj) = delete; // 删除拷贝赋值运算符重载函数
6. private:
7.     ConnPool(); // 构造函数私有化
8. };

复制代码

 >>添加息争析设置文件
jsoncpp的编译和使用 | 爱编程的大丙 (subingwen.cn)

https://www.subingwen.cn/cpp/jsoncpp/

1. bool parseJsonFile(); // 解析json格式文件

复制代码

1. ConnPool::ConnPool() {
2.     // 加载配置文件
3.     if (!parseJsonFile()) {
4.         std::cout << "加载配置文件失败！！！" << std::endl;
5.         return;
6.     }
7.     for (int i = 0; i < m_minSize; ++i) {
8.         addConn();
9.     }
10.     thread producer(&ConnPool::produceConn, this);// 生产连接
11.     thread recycler(&ConnPool::recycleConn, this);// 销毁连接
12.     producer.detach();
13.     recycler.detach();
14. }

复制代码

>>添加连接到连接池

1. void addConn(); // 添加数据库连接

复制代码

1. // 添加连接到连接池
2. void ConnPool::addConn() {
3.     MysqlConn* conn = new MysqlConn;
4.     conn->connect(m_user, m_passwd, m_dbName, m_ip, m_port);
5.     conn->refreshAliveTime();// 记录建立连接的时候的对应的时间戳
6.     m_connQ.push(conn);
7. }

复制代码

 >>单例类的构造函数处理惩罚
需要及时检测连接池里边的连接空闲数量是否太多了，如果太多了就需要销毁一部门。关于连接池里边的连接的创建和销毁需要交给两个线程行止置惩罚。通过这种方式，可以让数据库连接池里边的连接数量维持在一个公道的范围内。 

• 一个创建新的连接，一个销毁空闲的连接。
  
• 注：线程在壅闭的时间是不消耗CPU资源的。
  

1. ConnPool(); // 构造函数私有化

复制代码

1. ConnPool::ConnPool() {
2.     // 加载配置文件
3.     if (!parseJsonFile()) {
4.         std::cout << "加载配置文件失败！！！" << std::endl;
5.         return;
6.     }
7.     for (int i = 0; i < m_minSize; ++i) {
8.         addConn();
9.     }
10.     thread producer(&ConnPool::produceConn, this);// 生产连接
11.     thread recycler(&ConnPool::recycleConn, this);// 销毁连接
12.     producer.detach();
13.     recycler.detach();
14. }

复制代码

>>数据库连接池子线程使命函数的实现
(1)生产数据库连接

1. void produceConn(); // 生产数据库连接

复制代码

当连接池队列里边的这个连接的个数小于最小连接数的时间，连接不敷用了。因为连接池里边需要保持一个最小的连接数，当实际数量<最小连接数的时间，需要生产出新的连接。

• 当实际数量>=最小连接数的时间，生产连接的线程它就需要壅闭了。
  

1. void ConnPool::produceConn() {
2.     while (true) {  // 生产者线程不断生产连接，直到连接池达到最大值
3.         unique_lock<mutex> locker(m_mutexQ);  // 加锁，保证线程安全
4.         while (m_connQ.size() >= m_minSize) {
5.             m_cond.wait(locker);  // 等待消费者通知
6.         }
7.         addConn(); // 生产连接
8.         m_cond.notify_all();// 通知消费者(唤醒)
9.     }
10. }

复制代码

 (2)销毁数据库连接

1. void recycleConn(); // 销毁数据库连接

复制代码

1. // 回收数据库连接
2. void ConnPool::recycleConn() {
3.     while (true) {
4.         this_thread::sleep_for(chrono::milliseconds(500));// 每隔半秒钟检测一次
5.         lock_guard<mutex> locker(m_mutexQ);  // 加锁，保证线程安全
6.         while (m_connQ.size() > m_minSize) {  // 如果连接池中的连接数大于最小连接数，则回收连接
7.             MysqlConn* conn = m_connQ.front();  // 取出连接池中的连接
8.             if (conn->getAliveTime() >= m_maxIdleTime) {
9.                 m_connQ.pop();  // 回收连接
10.                 delete conn;  // 释放连接资源
11.             }
12.             else {
13.                 break;  // 如果连接的空闲时间小于最大空闲时间，则跳出循环
14.             }
15.         }
16.     }
17. }

复制代码

>>数据库连接的获取和接纳

1. shared_ptr<MysqlConn> getConn(); // 从连接池中取出一个连接

复制代码

1. // 从连接池中取出一个连接
2. shared_ptr<MysqlConn> ConnPool::getConn() {
3.     unique_lock<mutex> locker(m_mutexQ);
4.     while (m_connQ.empty()) {
5.         if (cv_status::timeout == m_cond.wait_for(locker, chrono::milliseconds(m_timeout))) {
6.             if (m_connQ.empty()) {
7.                 //return nullptr;
8.                 continue;
9.             }
10.         }
11.     }
12.     shared_ptr<MysqlConn>connptr(m_connQ.front(), [this](MysqlConn* conn) {
13.         lock_guard<mutex>locker(m_mutexQ); // 自动管理加锁和解锁
14.         conn->refreshAliveTime();// 更新连接的起始的空闲时间点
15.         m_connQ.push(conn); // 回收数据库连接，此时它再次处于空闲状态
16.         });// 智能指针
17.     m_connQ.pop();
18.     m_cond.notify_one(); // 本意是唤醒生产者
19.     return connptr;
20. }

复制代码

当对应的线程把连接conn拿走之后，操作完了。数据库需要把这个连接还返来，有两种办理方案：

• 提供一个额外的函数，给这个函数指定一个参数，当这个线程把数据库连接用完之后，它通过参数把这个连接传进来，那么我们再把这个连接存储到数据库连接池对应的队列里边。
  
• 使用智能指针，就不需要提供一个额外的函数了。直接通过getConn函数就可以大概实现数据库连接接纳这个功能了。
  

起首，把返回的指针通过智能指针管理起来，这个智能指针有两种：一种是共享的智能指针，还有一种是独占的智能指针。在本项目中这里就使用共享指针就可以了。
为了实现数据库连接的主动接纳，当共享的智能指针对应的对象析构的时间，它会先析构它管理的指针，而这个指针指向的连接我们不需要让它析构的，因为我们使用数据库连接池的目的是避免数据库连接的频繁创建和销毁，那怎么办呢？
由于当共享指针对象析构的时间，不需要把智能指针管理的连接（地址）析构，而是接纳。因此我们可以手动去指定这个共享的智能指针它的删除器对应的处理惩罚动作。 
在构造这个智能指针的时间，在它构造函数的第二个参数位置指定删除器，可以指定一个著名函数，也可以指定一个匿名函数。简单的方式就是写一个匿名函数。在匿名函数的中括号里边可以指定匿名函数内部它捕捉外部变量的方式 。如果指定this就在匿名函数内部可以使用当前类里边的所有的步调变量或者是步调函数。删除器的范例和它管理的这块内存地址的范例肯定是对应的。在匿名函数里边，并不是真正的要销毁这个指针指向的那块内存，而是要把它放到数据库连接池对应的队列里边。接纳数据库连接，此时它再次处于空闲状态，还需要更新连接的起始的空闲时间点。 
>>数据库连接池的资源开释

1. // 释放数据库连接
2. ~MysqlConn();

复制代码

1. // 释放数据库连接
2. MysqlConn::~MysqlConn() {
3.     if (m_conn != nullptr) {
4.         mysql_close(m_conn);
5.     }
6.     freeResult();
7. }

复制代码

>>测试数据库的数据插入和查询

1. int query() {
2.     MysqlConn conn;
3.     conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
4.     string sql = "insert into person values(6,35,'女','乌拉那拉皇后')";
5.     bool flag = conn.update(sql);
6.     if (flag) cout << "插入数据成功了！！！" << endl;
7.     else cout << "插入数据失败,耐心检查一下哪里有出差错喔！" << endl;
9.     sql = "select * from person";
10.     conn.query(sql);
11.     while (conn.next()) {
12.         cout << conn.value(0) << ", "
13.             << conn.value(1) << ", "
14.             << conn.value(2) << ", "
15.             << conn.value(3) << endl;
16.     }
17.     return 0;
18. }

复制代码

>>两个op函数，用于测试的

1. void op1(int begin, int end) {
2.     for (int i = begin; i < end; ++i) {
3.         MysqlConn conn;
4.         conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
5.         char sql[1024] = { 0 };
6.         sprintf(sql, "insert into person (id,age,sex,name) values(%d,%d,'%s','%s')",
7.             i, 6, "女", "胧月大魔王");
8.         conn.update(sql);
9.     }
10. }
12. void op2(ConnPool* pool, int begin, int end) {
13.     for (int i = begin; i < end; ++i) {
14.         shared_ptr<MysqlConn> conn = pool->getConn();
15.         char sql[1024] = { 0 };
16.         sprintf(sql, "insert into person (id,age,sex,name) values(%d,%d,'%s','%s')",
17.             i, 19, "女", "安陵容");
18.         conn->update(sql);
19.     }
20. }

复制代码

 >>单线程模式下连接池和非连接池测试

1. void test1() {
2. #if 1
3.     // 非连接池，单线程，用时：26276567700 纳秒, 26276 毫秒
4.     steady_clock::time_point begin = steady_clock::now();
5.     op1(0, 5000);
6.     steady_clock::time_point end = steady_clock::now();
7.     auto length = end - begin; // 计算时间差，得到操作耗时
8.     cout << "非连接池，单线程，用时：" << length.count() << " 纳秒,"
9.         << length.count() / 1000000 << " 毫秒" << endl;
10. #else
11.     //连接池，单线程，用时：6100671100 纳秒, 6100 毫秒
12.     ConnPool* pool = ConnPool::getConnPool();
13.     steady_clock::time_point begin = steady_clock::now();
14.     op2(pool, 0, 5000);
15.     steady_clock::time_point end = steady_clock::now();
16.     auto length = end - begin; // 计算时间差，得到操作耗时
17.     cout << "连接池，单线程，用时：" << length.count() << " 纳秒,"
18.         << length.count() / 1000000 << " 毫秒" << endl;
19. #endif
20. }

复制代码

>>双线程模式下连接池和非连接池测试

1. void test2() {
2. #if 0
3.     // 非连接池，多线程，用时：10107791500 纳秒,10107 毫秒
4.     MysqlConn conn;
5.     conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
6.     steady_clock::time_point begin = steady_clock::now();
7.     thread t1(op1, 0, 1000);
8.     thread t2(op1, 1000, 2000);
9.     thread t3(op1, 2000, 3000);
10.     thread t4(op1, 3000, 4000);
11.     thread t5(op1, 4000, 5000);
12.     t1.join();
13.     t2.join();
14.     t3.join();
15.     t4.join();
16.     t5.join();
17.     steady_clock::time_point end = steady_clock::now();
18.     auto length = end - begin; // 计算时间差，得到操作耗时
19.     cout << "非连接池，多线程，用时：" << length.count() << " 纳秒,"
20.         << length.count() / 1000000 << " 毫秒" << endl;
21. #else
22.     // 连接池，多线程，用时：2411691800 纳秒,2411 毫秒
23.     ConnPool* pool = ConnPool::getConnPool();
24.     steady_clock::time_point begin = steady_clock::now();
25.     thread t1(op2, pool, 0, 1000);
26.     thread t2(op2, pool, 1000, 2000);
27.     thread t3(op2, pool, 2000, 3000);
28.     thread t4(op2, pool, 3000, 4000);
29.     thread t5(op2, pool, 4000, 5000);
30.     t1.join();
31.     t2.join();
32.     t3.join();
33.     t4.join();
34.     t5.join();
35.     steady_clock::time_point end = steady_clock::now();
36.     auto length = end - begin; // 计算时间差，得到操作耗时
37.     cout << "连接池，多线程，用时：" << length.count() << " 纳秒,"
38.         << length.count() / 1000000 << " 毫秒" << endl;
39. #endif
40. }

复制代码

完整代码：

• main.cpp
  

1. #include <iostream>#include <memory>#include "MysqlConn.h"#include "ConnPool.h"using namespace std;// 1.单线程：使用/不适用连接池// 2.多线程：使用/不适用连接池void op1(int begin, int end) {
2.     for (int i = begin; i < end; ++i) {
3.         MysqlConn conn;
4.         conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
5.         char sql[1024] = { 0 };
6.         sprintf(sql, "insert into person (id,age,sex,name) values(%d,%d,'%s','%s')",
7.             i, 6, "女", "胧月大魔王");
8.         conn.update(sql);
9.     }
10. }
12. void op2(ConnPool* pool, int begin, int end) {
13.     for (int i = begin; i < end; ++i) {
14.         shared_ptr<MysqlConn> conn = pool->getConn();
15.         char sql[1024] = { 0 };
16.         sprintf(sql, "insert into person (id,age,sex,name) values(%d,%d,'%s','%s')",
17.             i, 19, "女", "安陵容");
18.         conn->update(sql);
19.     }
20. }// 压力测试void test1() {
21. #if 1
22.     // 非连接池，单线程，用时：26276567700 纳秒, 26276 毫秒
23.     steady_clock::time_point begin = steady_clock::now();
24.     op1(0, 5000);
25.     steady_clock::time_point end = steady_clock::now();
26.     auto length = end - begin; // 计算时间差，得到操作耗时
27.     cout << "非连接池，单线程，用时：" << length.count() << " 纳秒,"
28.         << length.count() / 1000000 << " 毫秒" << endl;
29. #else
30.     //连接池，单线程，用时：6100671100 纳秒, 6100 毫秒
31.     ConnPool* pool = ConnPool::getConnPool();
32.     steady_clock::time_point begin = steady_clock::now();
33.     op2(pool, 0, 5000);
34.     steady_clock::time_point end = steady_clock::now();
35.     auto length = end - begin; // 计算时间差，得到操作耗时
36.     cout << "连接池，单线程，用时：" << length.count() << " 纳秒,"
37.         << length.count() / 1000000 << " 毫秒" << endl;
38. #endif
39. }
40. void test2() {
41. #if 0
42.     // 非连接池，多线程，用时：10107791500 纳秒,10107 毫秒
43.     MysqlConn conn;
44.     conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
45.     steady_clock::time_point begin = steady_clock::now();
46.     thread t1(op1, 0, 1000);
47.     thread t2(op1, 1000, 2000);
48.     thread t3(op1, 2000, 3000);
49.     thread t4(op1, 3000, 4000);
50.     thread t5(op1, 4000, 5000);
51.     t1.join();
52.     t2.join();
53.     t3.join();
54.     t4.join();
55.     t5.join();
56.     steady_clock::time_point end = steady_clock::now();
57.     auto length = end - begin; // 计算时间差，得到操作耗时
58.     cout << "非连接池，多线程，用时：" << length.count() << " 纳秒,"
59.         << length.count() / 1000000 << " 毫秒" << endl;
60. #else
61.     // 连接池，多线程，用时：2411691800 纳秒,2411 毫秒
62.     ConnPool* pool = ConnPool::getConnPool();
63.     steady_clock::time_point begin = steady_clock::now();
64.     thread t1(op2, pool, 0, 1000);
65.     thread t2(op2, pool, 1000, 2000);
66.     thread t3(op2, pool, 2000, 3000);
67.     thread t4(op2, pool, 3000, 4000);
68.     thread t5(op2, pool, 4000, 5000);
69.     t1.join();
70.     t2.join();
71.     t3.join();
72.     t4.join();
73.     t5.join();
74.     steady_clock::time_point end = steady_clock::now();
75.     auto length = end - begin; // 计算时间差，得到操作耗时
76.     cout << "连接池，多线程，用时：" << length.count() << " 纳秒,"
77.         << length.count() / 1000000 << " 毫秒" << endl;
78. #endif
79. }int query() {
80.     MysqlConn conn;
81.     conn.connect("heheda", "123456", "test", "127.0.0.1", 3306);
82.     string sql = "insert into person values(6,35,'女','乌拉那拉皇后')";
83.     bool flag = conn.update(sql);
84.     if (flag) cout << "插入数据成功了！！！" << endl;
85.     else cout << "插入数据失败,耐心检查一下哪里有出差错喔！" << endl;
87.     sql = "select * from person";
88.     conn.query(sql);
89.     while (conn.next()) {
90.         cout << conn.value(0) << ", "
91.             << conn.value(1) << ", "
92.             << conn.value(2) << ", "
93.             << conn.value(3) << endl;
94.     }
95.     return 0;
96. }int main() {    //SetConsoleOutputCP(CP_UTF8);    //query();    //test1();    test2();    return 0;}

复制代码

• MysqlConn.h
  

1. #pragma once
2. #include <mysql.h>
3. #include <string>
4. #include <chrono>
5. using namespace std;
6. using namespace std::chrono;
7. class MysqlConn {
8. public:
9.     // 初始化数据库连接
10.     MysqlConn();
11.     // 释放数据库连接
12.     ~MysqlConn();
13.     // 连接数据库
14.     bool connect(string user, string passwd, string dbName, string ip, unsigned short port = 3306);
15.     // 更新数据库: select，update，delete
16.     bool update(string sql);
17.     // 查询数据库
18.     bool query(string sql);
19.     // 遍历查询得到的结果集
20.     bool next();
21.     // 得到结果集中的字段值
22.     string value(int index);
23.     // 事务操作
24.     bool transaction();
25.     // 提交事务
26.     bool commit();
27.     // 事务回滚
28.     bool rollback();
29.     // 刷新起始的空闲时间点
30.     void refreshAliveTime();
31.     // 计算连接存活的总时长
32.     long long getAliveTime();
33. private:
34.     void freeResult();
35.     MYSQL* m_conn = nullptr; // 数据库连接
36.     MYSQL_RES* m_result = nullptr;
37.     MYSQL_ROW m_row = nullptr;
38.     steady_clock::time_point m_aliveTime;
39. };

复制代码

• MysqlConn.cpp
  

1. #include "MysqlConn.h"
3. // 初始化数据库连接
4. MysqlConn::MysqlConn() {
5.     m_conn = mysql_init(nullptr);
6.     mysql_set_character_set(m_conn, "GBK"); // 设置字符集
7. }
9. // 释放数据库连接
10. MysqlConn::~MysqlConn() {
11.     if (m_conn != nullptr) {
12.         mysql_close(m_conn);
13.     }
14.     freeResult();
15. }
17. // 连接数据库
18. bool MysqlConn::connect(string user, string passwd, string dbName, string ip, unsigned short port) {
19.     MYSQL* ptr = mysql_real_connect(m_conn, ip.c_str(), user.c_str(), passwd.c_str(), dbName.c_str(), port, nullptr, 0);
20.     return ptr != nullptr;
21. }
23. // 更新数据库:insert，update，delete
24. bool MysqlConn::update(string sql) {
25.     if (mysql_query(m_conn, sql.c_str())) {
26.         return false;
27.     }
28.     return true;
29. }
31. // 查询数据库
32. bool MysqlConn::query(string sql) {
33.     freeResult(); // 释放之前查询的结果集
34.     if (mysql_query(m_conn, sql.c_str())) {
35.         return false;
36.     }
37.     m_result = mysql_store_result(m_conn); // 获取查询结果
38.     return true;
39. }
41. // 遍历查询得到的结果集
42. bool MysqlConn::next() {
43.     if (m_result != nullptr) {
44.         m_row = mysql_fetch_row(m_result);
45.         if (m_row != nullptr) {
46.             return true;
47.         }
48.     }
49.     return false;
50. }
52. // 得到结果集中的字段值
53. string MysqlConn::value(int index) {
54.     int rowCount = mysql_num_fields(m_result);
55.     if (index >= rowCount || index < 0) {
56.         return string();
57.     }
58.     char* val = m_row[index];
59.     unsigned long length = mysql_fetch_lengths(m_result)[index];
60.     return string(val, length);
61. }
63. // 事务操作
64. bool MysqlConn::transaction() {
65.     return mysql_autocommit(m_conn, false);
66. }
68. // 提交事务
69. bool MysqlConn::commit() {
70.     return mysql_commit(m_conn);
71. }
73. // 事务回滚
74. bool MysqlConn::rollback() {
75.     return mysql_rollback(m_conn);
76. }
78. // 刷新起始的空闲时间点
79. void MysqlConn::refreshAliveTime() {
80.     // 这个时间戳就是某个数据库连接，它起始存活的时间点
81.     // 这个时间点通过时间类就可以得到了
82.     m_aliveTime = steady_clock::now();
83. }
85. // 计算连接存活的总时长
86. long long MysqlConn::getAliveTime() {
87.     nanoseconds duration = steady_clock::now() - m_aliveTime;
88.     milliseconds millsec = duration_cast<milliseconds>(duration);
89.     return millsec.count();
90. }
92. void MysqlConn::freeResult() {
93.     if (m_result != nullptr) {
94.         mysql_free_result(m_result);
95.         m_result = nullptr;
96.     }
97. }

复制代码

• ConnPool.h
  

1. #pragma once
2. #include <queue>
3. #include <mutex>
4. #include <condition_variable>//条件变量
5. #include "MysqlConn.h"
6. using namespace std;
7. class ConnPool {
8. public:
9.     static ConnPool* getConnPool();// 获得单例对象
10.     ConnPool(const ConnPool& obj) = delete; // 删除拷贝构造函数
11.     ConnPool& operator=(const ConnPool& obj) = delete; // 删除拷贝赋值运算符重载函数
12.     shared_ptr<MysqlConn> getConn(); // 从连接池中取出一个连接
13.     ~ConnPool(); // 析构函数
14. private:
15.     ConnPool(); // 构造函数私有化
16.     bool parseJsonFile(); // 解析json格式文件
17.     void produceConn(); // 生产数据库连接
18.     void recycleConn(); // 销毁数据库连接
19.     void addConn(); // 添加数据库连接
21.     // 连接服务器所需信息
22.     string m_ip;            // 数据库服务器ip地址
23.     string m_user;          // 数据库服务器用户名
24.     string m_dbName;        // 数据库服务器的数据库名
25.     string m_passwd;        // 数据库服务器密码
26.     unsigned short m_port;  // 数据库服务器绑定的端口
28.     // 连接池信息
29.     queue<MysqlConn*> m_connQ;
30.     unsigned int m_maxSize; // 连接数上限值
31.     unsigned int m_minSize; // 连接数下限值
32.     int m_timeout; // 连接超时时长
33.     int m_maxIdleTime; // 最大的空闲时长
34.     mutex m_mutexQ; // 独占互斥锁
35.     condition_variable m_cond; // 条件变量
36. };

复制代码

• ConnPool.cpp
  

1. #include "ConnPool.h"#include <json/json.h>#include <fstream>#include <thread>#include <iostream>using namespace Json;ConnPool* ConnPool::getConnPool() {
2.     static ConnPool pool;
3.     return &pool;
4. }// 从连接池中取出一个连接
5. shared_ptr<MysqlConn> ConnPool::getConn() {
6.     unique_lock<mutex> locker(m_mutexQ);
7.     while (m_connQ.empty()) {
8.         if (cv_status::timeout == m_cond.wait_for(locker, chrono::milliseconds(m_timeout))) {
9.             if (m_connQ.empty()) {
10.                 //return nullptr;
11.                 continue;
12.             }
13.         }
14.     }
15.     shared_ptr<MysqlConn>connptr(m_connQ.front(), [this](MysqlConn* conn) {
16.         lock_guard<mutex>locker(m_mutexQ); // 自动管理加锁和解锁
17.         conn->refreshAliveTime();// 更新连接的起始的空闲时间点
18.         m_connQ.push(conn); // 回收数据库连接，此时它再次处于空闲状态
19.         });// 智能指针
20.     m_connQ.pop();
21.     m_cond.notify_one(); // 本意是唤醒生产者
22.     return connptr;
23. }ConnPool::~ConnPool() {    while (!m_connQ.empty()) {        MysqlConn* conn = m_connQ.front();        m_connQ.pop();        delete conn;    }}ConnPool::ConnPool() {
24.     // 加载配置文件
25.     if (!parseJsonFile()) {
26.         std::cout << "加载配置文件失败！！！" << std::endl;
27.         return;
28.     }
29.     for (int i = 0; i < m_minSize; ++i) {
30.         addConn();
31.     }
32.     thread producer(&ConnPool::produceConn, this);// 生产连接
33.     thread recycler(&ConnPool::recycleConn, this);// 销毁连接
34.     producer.detach();
35.     recycler.detach();
36. }bool ConnPool::parseJsonFile() {    ifstream ifs("dbconf.json");    Reader rd;    Value root;    rd.parse(ifs, root);    if (root.isObject()) {        std::cout << "开始解析设置文件..." << std::endl;        m_ip = root["ip"].asString();        m_port = root["port"].asInt();        m_user = root["userName"].asString();        m_passwd = root["password"].asString();        m_dbName = root["dbName"].asString();        m_minSize = root["minSize"].asInt();        m_maxSize = root["maxSize"].asInt();        m_maxIdleTime = root["maxIdleTime"].asInt();        m_timeout = root["timeout"].asInt();        return true;  // 解析成功返回true，否则返回false。    }    return false;}void ConnPool::produceConn() {
37.     while (true) {  // 生产者线程不断生产连接，直到连接池达到最大值
38.         unique_lock<mutex> locker(m_mutexQ);  // 加锁，保证线程安全
39.         while (m_connQ.size() >= m_minSize) {
40.             m_cond.wait(locker);  // 等待消费者通知
41.         }
42.         addConn(); // 生产连接
43.         m_cond.notify_all();// 通知消费者(唤醒)
44.     }
45. }// 回收数据库连接
46. void ConnPool::recycleConn() {
47.     while (true) {
48.         this_thread::sleep_for(chrono::milliseconds(500));// 每隔半秒钟检测一次
49.         lock_guard<mutex> locker(m_mutexQ);  // 加锁，保证线程安全
50.         while (m_connQ.size() > m_minSize) {  // 如果连接池中的连接数大于最小连接数，则回收连接
51.             MysqlConn* conn = m_connQ.front();  // 取出连接池中的连接
52.             if (conn->getAliveTime() >= m_maxIdleTime) {
53.                 m_connQ.pop();  // 回收连接
54.                 delete conn;  // 释放连接资源
55.             }
56.             else {
57.                 break;  // 如果连接的空闲时间小于最大空闲时间，则跳出循环
58.             }
59.         }
60.     }
61. }// 添加连接到连接池
62. void ConnPool::addConn() {
63.     MysqlConn* conn = new MysqlConn;
64.     conn->connect(m_user, m_passwd, m_dbName, m_ip, m_port);
65.     conn->refreshAliveTime();// 记录建立连接的时候的对应的时间戳
66.     m_connQ.push(conn);
67. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。