C# 高效能非同步 Socket 接收器框架（五）：會話狀態機、三階段清理與系統級優化總結

會話狀態機設計

enum TSessionState {
    Normal,      // 正常通訊
    NoReply,     // 標記待關閉（逾時/異常）
    Closing,     // Shutdown 執行中
    Closed       // Close 完成，待移除
}

enum TDisconnectType {
    Normal, Timeout, Exception, ServerShutdown
}

三階段清理機制：安全釋放資源

private void CheckClientState(object state) {
    while (!_stopReceiver) {
        DateTime now = DateTime.Now;
        // 1. 建立副本，避免長時間持有鎖
        Hashtable snapshot;
        lock (_sessionTable) {
            snapshot = new Hashtable(_sessionTable);
        }

        foreach (TSession session in snapshot.Values) {
            Monitor.Enter(session);
            try {
                switch (session.State) {
                    case TSessionState.NoReply:
                        // 階段 1：Shutdown 觸發 EndReceive 完成
                        session.State = TSessionState.Closing;
                        session.ClientSocket?.Shutdown(SocketShutdown.Both);
                        break;

                    case TSessionState.Closing:
                        // 階段 2：Close 釋放控制代碼
                        session.State = TSessionState.Closed;
                        session.ClientSocket?.Close();
                        break;

                    case TSessionState.Closed:
                        // 階段 3：從表移除，觸發事件
                        lock (_sessionTable) {
                            _sessionTable.Remove(session.ID);
                            Interlocked.Decrement(ref _clientCount);
                        }
                        OnClientChanged();
                        session.ClearBuffer();
                        break;

                    case TSessionState.Normal:
                        // 逾時檢測
                        if ((now - session.LastActivity).TotalSeconds > _maxIdleSeconds) {
                            session.DisconnectType = TDisconnectType.Timeout;
                            session.State = TSessionState.NoReply;
                        }
                        break;
                }
            } finally {
                Monitor.Exit(session);
            }
        }
        Thread.Sleep(_scanIntervalMs); // 降低 CPU 佔用
    }
}

關鍵設計決策

系統級效能數據（2005 年測試環境）

• 硬體：P4 2.0GHz、普通 PC
• 穩定性：連續運行 30+ 天零故障
• 吞吐：0.5 秒處理 1 個封包（含解析、驗證、入庫）
• 優化空間：程式碼優化 + 伺服器級硬體可大幅提升

完整系統架構

接收服務僅為核心子系統，完整省級公路交通流量資料中心包含：

1. 接收服務（本框架）
2. 轉發服務（上傳交通部）
3. 遠端查詢客戶端
4. 綜合報表處理系統
5. 線上發布系統
6. 運行監控系統

總程式碼 60K+ 行，接收服務核心 3K+ 行。

原始碼下載

帶詳細註釋的完整原始碼：下載連結（原文連結已失效，此為示意）

遷移至現代 .NET 建議

1. SocketAsyncEventArgs → ValueTask/SocketTaskExtensions：.NET Core 2.1+ 內建高效能非同步 API
2. Hashtable → ConcurrentDictionary：無鎖執行緒安全集合
3. Manual Monitor → SemaphoreSlim/ReaderWriterLockSlim：更精確的同步控制
4. ThreadPool → Task/Channel：現代非同步流程控制
5. 自訂框架 → Kestrel/ASP.NET Core/gRPC：生產級基礎設施

總結

本框架展示了 多執行緒 + 非同步 Socket + 狀態機驅動清理 的經典高效能伺服器模式。雖然技術棧已演進，但核心設計思想——細粒度鎖、快照隔離、狀態機資源管理、被動逾時清理——在現代高併發系統設計中依然具有指導意義。