MySQL 查詢效能優化三部曲（三）：連接池模式 C++ 實現與線程安全設計

高併發 MySQL 訪問：連接池設計模式與 C++ 線程安全實現

在大量節點併發訪問 MySQL 時，頻繁建立/銷毀連接是效能殺手。連接池透過預建連接、線程安全借還、生命週期管理，大幅降低延遲並穩定資源消耗。本文給出生產級 C++ 連接池完整實現，含雙佇列架構、互斥鎖保護、RAII 資源管理。

連接池核心架構

• 空閒佇列：可用連接句柄池
• 忙碌佇列：正在使用的連接句柄
• 互斥鎖：保護佇列操作原子性
• 信號量/條件變量：空池等待、滿池阻塞（可選）

完整 C++ 實現

#include 
#include 
#include 
#include 
#include 

class CDBParameter {
public:
    std::string host, user, password, database;
    unsigned int port = 0;
    const char* unix_socket = nullptr;
    unsigned int client_flag = 0;
};

class CDBManager {
    using HandleList = std::list;
    using HandleIter = HandleList::iterator;

    HandleList m_idleList;      // 空閒連接
    HandleList m_busyList;      // 忙碌連接
    std::mutex m_mutex;         // 佇列鎖
    std::condition_variable m_cv; // 等待可用連接
    CDBParameter m_param;
    const size_t m_maxSize;

public:
    explicit CDBManager(const CDBParameter& param, size_t maxSize = 100)
        : m_param(param), m_maxSize(maxSize) {}

    ~CDBManager() { destroyAll(); }

    // 初始化：預建所有連接
    bool initialize() {
        std::lock_guard lock(m_mutex);
        for (size_t i = 0; i < m_maxSize; ++i) {
            MYSQL* handle = mysql_init(nullptr);
            if (!handle || !mysql_real_connect(handle, 
                m_param.host.c_str(), m_param.user.c_str(),
                m_param.password.c_str(), m_param.database.c_str(),
                m_param.port, m_param.unix_socket, m_param.client_flag)) {
                if (handle) mysql_close(handle);
                destroyAll();
                return false;
            }
            m_idleList.push_back(handle);
        }
        return true;
    }

    // 獲取空閒連接（阻塞直到可用或超時）
    MYSQL* acquire(std::chrono::milliseconds timeout = std::chrono::seconds(10)) {
        std::unique_lock lock(m_mutex);
        if (m_cv.wait_for(lock, timeout, [this]{ return !m_idleList.empty(); })) {
            MYSQL* handle = m_idleList.front();
            m_idleList.pop_front();
            m_busyList.push_back(handle);
            return handle;
        }
        return nullptr; // 超時
    }

    // 歸還連接
    void release(MYSQL* handle) {
        std::lock_guard lock(m_mutex);
        auto it = std::find(m_busyList.begin(), m_busyList.end(), handle);
        if (it != m_busyList.end()) {
            m_busyList.erase(it);
            m_idleList.push_back(handle);
            m_cv.notify_one();
        }
    }

    // RAII 守衛：自動歸還
    class ConnectionGuard {
        CDBManager& pool;
        MYSQL* handle;
    public:
        ConnectionGuard(CDBManager& p) : pool(p), handle(p.acquire()) {}
        ~ConnectionGuard() { if (handle) pool.release(handle); }
        MYSQL* operator->() { return handle; }
        operator MYSQL*() { return handle; }
        bool valid() const { return handle != nullptr; }
    };

    // 業務操作範例：按 SessionID 刪除
    bool deleteBySessionId(const std::string& sessionId) {
        ConnectionGuard conn(*this);
        if (!conn.valid()) return false;
        
        char sql[256];
        snprintf(sql, sizeof(sql), 
            "DELETE FROM HostCache WHERE SessionID = '%s'", 
            sessionId.c_str());
        return mysql_query(conn, sql) == 0;
    }

private:
    void destroyAll() {
        std::lock_guard lock(m_mutex);
        for (auto h : m_idleList) mysql_close(h);
        for (auto h : m_busyList) mysql_close(h);
        m_idleList.clear();
        m_busyList.clear();
    }
};

關鍵設計亮點

使用範例

int main() {
    CDBParameter param{"localhost", "app_user", "pass", "app_db"};
    CDBManager pool(param, 50);
    if (!pool.initialize()) return 1;

    // 併發任務模擬
    std::vector threads;
    for (int i = 0; i < 100; ++i) {
        threads.emplace_back([&pool, i] {
            char sid[32];
            snprintf(sid, sizeof(sid), "session_%d", i);
            if (pool.deleteBySessionId(sid)) {
                // 成功
            }
        });
    }
    for (auto& t : threads) t.join();
    return 0;
}

生產環境擴展建議

1. 連接健康檢查：定時 mysql_ping() 或 SELECT 1，失效重建
2. 監控指標：池使用率、等待時間、建立/銷毀頻率、錯誤率
3. 優雅關閉：停止接收新請求 → 等待忙碌連接歸還 → 關閉所有連接
4. 多主機支援：主從分離，讀寫連接池隔離
5. 替代方案：ProxySQL（中間件連接池）、HikariCP (JDBC)、PgBouncer (PostgreSQL)

連接池是高併發資料庫訪問的基石。C++ 實現雖繁瑣，但能精確控制資源生命週期，是效能敏感型系統的最佳選擇。

1. 上一篇文章： SQL 查詢排除週末的 N 個工作日前日期：日曆表法與算法解析
2. 下一篇文章： MySQL 查詢效能優化三部曲（二）：隨機抽樣查詢 LIMIT 優化實戰

MySQL 資料庫相關知識

MySQL LONGTEXT 存儲大文件（含二進制）：C 實現讀寫 650MB ISO 實測

利用 LONGTEXT（最大 4GB）配合 mysql_re

MySQL 數據導出必知：mysqldump 只能在系統命令行執行，不能在 MySQL 客戶端執行

核心誤區 大量開發者嘗試在 MySQL 交互式客戶端（ 提示

MySQL「Field doesn't have a default value」錯誤解決方案：NOT NULL 列缺失默認值與 sql_mode 嚴格模式應對

插入數據時提示 Field web_pic doesnt h

MySQL JDBC 連接完整指南：步驟、URL 參數與實戰代碼

JDBC 簡介 JDBC（Java Database Con