Muduo網絡編程示例之七：多路複用連接服務器與自動化測試

需求：串並轉換

將多個客戶端連線（Client Connections）多工為單一後端連線（Backend Connection），使後端邏輯服務器無需處理併發，專注業務。類似數位電路的 Multiplexer（資料選擇器）。

核心事件處理

1. 客戶端連線/斷開：分配/回收整數 ID（用隊列管理 Free ID 避免快速復用導致串話），通知後端。
2. 客戶端資料到達：攜帶 Connection ID 轉發給後端。
3. 後端資料到達：解析 ID，路由至對應客戶端。
4. 後端斷開：關閉所有客戶端連線（假設客戶端會自動重試）。

關鍵技術點

TcpConnection::context 與 boost::any

每個 TcpConnection 內建 boost::any context_，可存放任意綁定資料（如 Connection ID、最後活躍時間、用戶名）。無需繼承 TcpConnection 即可擴展狀態：

void onClientConnection(const TcpConnectionPtr& conn)
{
    if (conn->connected())
    {
        int id = allocateId();
        conn->setContext(id); // 存入 ID
        notifyBackendClientUp(id);
    }
    else
    {
        if (!conn->getContext().empty())
        {
            int id = boost::any_cast<int>(conn->getContext());
            releaseId(id);
            notifyBackendClientDown(id);
        }
    }
}

void onClientMessage(const TcpConnectionPtr& conn, Buffer* buf, Timestamp)
{
    if (!conn->getContext().empty())
    {
        int id = boost::any_cast<int>(conn->getContext());
        sendToBackend(id, buf);
    }
    else buf->retrieveAll();
}

生命週期管理：shared_ptr

TcpConnection 採用 boost::shared_ptr 管理，確保後端發送資料時對象仍存活。參考《當析構函數遇到多線程》一文。

自動化測試：Test Harness

首個具非平凡業務邏輯的示例，編寫 Java + Netty 實現的測試套件，扮演 Clients 與 Backend。結構：

• 事件匯聚到 BlockingQueue，測試案例操作 Harness 發起連線、發送資料、驗證接收。
• 支援 Groovy 動態腳本，無需重啟即可新增測試案例。
• 具備回歸測試能力，未來可安全重構（如改為多線程版本）、壓力測試。

未來改進方向

• 增加「後端指令斷開指定客戶端」功能
• 多線程重寫，驗證測試穩定性
• 擴展為壓力測試工具