1. 为什么需要MySQL连接池如果你写过需要频繁操作数据库的C后台服务肯定遇到过这样的场景每次处理用户请求都要创建新的数据库连接操作完再关闭。在高并发环境下这种频繁创建和销毁连接的操作会成为性能瓶颈。我去年优化过一个在线交易系统就是因为这个原因导致TPS始终上不去。连接池的核心思想很简单预先创建一批连接放在池子里需要时取出来用用完放回去而不是销毁。这就像去图书馆借书每次都办新卡借书再退卡肯定效率低下不如办一张卡反复使用。实测下来使用连接池后系统吞吐量提升了3倍以上。具体优势体现在降低连接创建开销TCP三次握手和MySQL权限验证只需在初始化时完成一次资源复用避免频繁malloc/free带来的内存碎片可控的连接数防止突发流量导致连接数爆炸统一的连接管理超时检测、心跳维护等集中处理2. 基础封装MysqlConn类实现2.1 类设计思路我们先从最基础的数据库连接封装开始。这个MysqlConn类需要完成三件事建立/关闭连接执行SQL语句管理查询结果集class MysqlConn { public: MysqlConn(); // 初始化 ~MysqlConn(); // 释放资源 bool connect(string user, string passwd, string dbName, string host, unsigned short port 3306); bool update(string sql); // 增删改 bool query(string sql); // 查询 bool next(); // 遍历结果集 string value(int index); // 获取字段值 private: void freeResult(); // 释放结果集 MYSQL* m_conn; // 连接句柄 MYSQL_RES* m_result; // 结果集 MYSQL_ROW m_row; // 当前行数据 };2.2 连接管理的坑点在实现connect()方法时有几个细节需要特别注意bool MysqlConn::connect(string user, string passwd, string dbName, string host, unsigned short port) { m_conn mysql_init(nullptr); // 必须设置字符集否则中文乱码 mysql_options(m_conn, MYSQL_SET_CHARSET_NAME, utf8mb4); // 实际连接超时设置为3秒 unsigned int timeout 3; mysql_options(m_conn, MYSQL_OPT_CONNECT_TIMEOUT, timeout); return mysql_real_connect(m_conn, host.c_str(), user.c_str(), passwd.c_str(), dbName.c_str(), port, nullptr, 0); }踩坑经验字符集一定要用utf8mb4而不是utf8否则无法存储emoji等4字节字符必须设置连接超时否则网络异常时会长时间阻塞密码等敏感信息建议使用后立即从内存清除2.3 查询结果处理处理查询结果时最容易出现内存泄漏来看正确做法bool MysqlConn::query(string sql) { freeResult(); // 先释放之前的结果集 if (mysql_query(m_conn, sql.c_str())) { return false; } m_result mysql_store_result(m_conn); return m_result ! nullptr; } string MysqlConn::value(int index) { unsigned long length mysql_fetch_lengths(m_result)[index]; return string(m_row[index], length); // 指定长度构造string } void MysqlConn::freeResult() { if (m_result) { mysql_free_result(m_result); m_result nullptr; } }关键点每次新查询前必须释放旧结果集mysql_fetch_lengths获取字段真实长度避免二进制数据截断使用RAII思想在析构函数中自动释放资源3. 连接池核心实现3.1 数据结构设计连接池需要维护两个集合空闲连接队列立即可用忙碌连接映射正在使用class ConnectionPool { public: static ConnectionPool* getInstance(); // 单例模式 shared_ptrMysqlConn getConnection(); // 获取连接 private: ConnectionPool(); // 私有化构造 void produceConnection(); // 生产连接 void recycleConnection(); // 回收连接 void scanConnection(); // 扫描超时连接 queueMysqlConn* m_freeConn; // 空闲连接 mapMysqlConn*, time_t m_busyConn; // 忙碌连接 mutex m_mutex; // 互斥锁 condition_variable m_cond; // 条件变量 string m_user, m_passwd, m_dbName, m_host; unsigned short m_port; int m_minSize; // 最小连接数 int m_maxSize; // 最大连接数 int m_timeout; // 超时时间(秒) int m_maxIdleTime; // 最大空闲时间(秒) };3.2 智能指针自动回收使用shared_ptr自定义删除器实现连接自动回收shared_ptrMysqlConn ConnectionPool::getConnection() { unique_lockmutex lock(m_mutex); while (m_freeConn.empty()) { if (m_curSize m_maxSize) { m_cond.wait_for(lock, chrono::milliseconds(500)); } else { produceConnection(); } } auto conn m_freeConn.front(); m_freeConn.pop(); m_busyConn[conn] time(nullptr); // 自定义删除器 auto deleter [this](MysqlConn* conn) { lock_guardmutex lock(this-m_mutex); this-m_busyConn.erase(conn); conn-refreshAliveTime(); this-m_freeConn.push(conn); this-m_cond.notify_one(); }; return shared_ptrMysqlConn(conn, deleter); }这样当shared_ptr离开作用域时连接会自动返回到空闲队列无需手动调用释放方法。3.3 超时连接清理需要定时扫描并清理无效连接void ConnectionPool::scanConnection() { while (!m_stop) { this_thread::sleep_for(chrono::seconds(10)); lock_guardmutex lock(m_mutex); while (m_freeConn.size() m_minSize) { auto conn m_freeConn.front(); if (conn-getAliveTime() m_maxIdleTime) { m_freeConn.pop(); delete conn; --m_curSize; } else { break; } } } }判断条件包括连接空闲时间超过阈值默认30分钟当前连接数大于最小连接数连接ping不通MySQL服务器4. 实战优化技巧4.1 参数调优建议根据线上经验推荐这些参数配置参数推荐值说明minSizeCPU核心数避免频繁扩容maxSizeminSize*2突发流量缓冲timeout3秒网络超时maxIdleTime1800秒防止占用资源reconnecttrue自动重连// 示例配置 pool-setConfig(8, 16, 3, 1800, true);4.2 事务处理要点在连接池中使用事务需要特别注意{ auto conn pool-getConnection(); conn-transaction(); // 开始事务 try { conn-update(UPDATE account SET balance balance - 100 WHERE id 1); conn-update(UPDATE account SET balance balance 100 WHERE id 2); conn-commit(); // 提交事务 } catch (...) { conn-rollback(); // 回滚 throw; } } // 连接自动回收关键原则整个事务必须使用同一个连接异常时一定要回滚事务不宜过长建议1秒4.3 连接泄漏检测我们可以在调试阶段添加检测代码~ConnectionPool() { m_stop true; if (m_scanThread.joinable()) { m_scanThread.join(); } if (!m_busyConn.empty()) { cerr 警告有连接未释放数量 m_busyConn.size() endl; } while (!m_freeConn.empty()) { delete m_freeConn.front(); m_freeConn.pop(); } }5. 性能对比测试我用JMeter做了组对比测试100并发指标无连接池有连接池提升QPS128421329%平均耗时782ms237ms70%CPU占用89%63%-内存波动频繁平稳-测试中发现的几个现象连接池在突发流量下表现更稳定无连接池时MySQL会出现大量Too many connections错误连接数并非越多越好超过阈值后性能反而下降这个连接池实现已经用在我的多个生产项目中包括一个日活百万的电商系统。代码虽然简单但要注意的细节很多比如线程安全、异常处理、资源释放等。建议大家在理解原理的基础上根据实际需求调整实现。
