WCF 訊息壓縮傳輸：自訂 Message Encoder 實現透明 GZip 壓縮

痛點：大數據傳輸的頻寬瓶頸

分散式系統中，WCF 傳輸大量 XML/序列化資料時，網路頻寬常成瓶頸。理想方案是在通道層自動壓縮/解壓，對上層業務代碼完全透明，無需修改契約、序列化邏輯。本文詳細講解如何實現自訂 MessageEncoder 掛載到 WCF 通道堆疊，實現 GZip 壓縮傳輸。

架構原理：訊息編碼器在通道堆疊中的位置

發送端：業務對象 → 序列化 → XML/二進制 → 【壓縮編碼器】 → 位元組陣列 → 傳輸層 (TCP/HTTP)
接收端：傳輸層 → 位元組陣列 → 【解壓編碼器】 → XML/二進制 → 反序列化 → 業務對象

關鍵點：壓縮編碼器包裝內建編碼器 (如 BinaryMessageEncoder、TextMessageEncoder)，在 WriteMessage 時壓縮輸出緩衝區，ReadMessage 時解壓輸入緩衝區。

核心類別結構

關鍵實現：壓縮/解壓緩衝區

壓縮邏輯 (WriteMessage 內部調用)

private static ArraySegment<byte> CompressBuffer(ArraySegment<byte> buffer, BufferManager bufferManager, int messageOffset)
{
    // 1. 建立記憶體流，先寫入不壓縮的前綴 (如訊息版本標頭)
    var memoryStream = new MemoryStream();
    memoryStream.Write(buffer.Array, 0, messageOffset);

    // 2. GZip 壓縮訊息本體
    using (var gzStream = new GZipStream(memoryStream, CompressionMode.Compress, true))
        gzStream.Write(buffer.Array, messageOffset, buffer.Count - messageOffset);

    // 3. 轉換為位元組陣列，分配新緩衝區
    byte[] compressedBytes = memoryStream.ToArray();
    byte[] bufferedBytes = bufferManager.TakeBuffer(compressedBytes.Length);
    Array.Copy(compressedBytes, 0, bufferedBytes, 0, compressedBytes.Length);

    // 4. 釋放原緩衝區，返回新 ArraySegment
    bufferManager.ReturnBuffer(buffer.Array);
    return new ArraySegment<byte>(bufferedBytes, messageOffset, compressedBytes.Length - messageOffset);
}

解壓邏輯 (ReadMessage 內部調用)

private static ArraySegment<byte> DecompressBuffer(ArraySegment<byte> buffer, BufferManager bufferManager)
{
    // 1. 輸入緩衝區包含完整壓縮資料 (含前綴)
    var compressedStream = new MemoryStream(buffer.Array, buffer.Offset, buffer.Count);
    var decompressedStream = new MemoryStream();
    byte[] tempBuffer = bufferManager.TakeBuffer(1024);

    // 2. 串流式解壓
    using (var gzStream = new GZipStream(compressedStream, CompressionMode.Decompress)) {
        int bytesRead;
        while ((bytesRead = gzStream.Read(tempBuffer, 0, tempBuffer.Length)) > 0)
            decompressedStream.Write(tempBuffer, 0, bytesRead);
    }
    bufferManager.ReturnBuffer(tempBuffer);

    // 3. 組裝解壓後緩衝區 (保留前綴位移)
    byte[] decompressedBytes = decompressedStream.ToArray();
    byte[] resultBuffer = bufferManager.TakeBuffer(decompressedBytes.Length + buffer.Offset);
    Array.Copy(buffer.Array, 0, resultBuffer, 0, buffer.Offset); // 複製前綴
    Array.Copy(decompressedBytes, 0, resultBuffer, buffer.Offset, decompressedBytes.Length); // 複製解壓資料

    bufferManager.ReturnBuffer(buffer.Array);
    return new ArraySegment<byte>(resultBuffer, buffer.Offset, decompressedBytes.Length);
}

配置接入：app.config / web.config

伺服器端配置

<system.serviceModel>
  <services>
    <service name="Server.MyService">
      <!-- 關鍵：binding 改為 customBinding -->
      <endpoint address="net.tcp://localhost:1234/MyService"
                binding="customBinding"
                contract="Server.IMyService" />
    </service>
  </services>

  <bindings>
    <customBinding>
      <binding name="compactBinding">
        <!-- 壓縮編碼器包裝二進制編碼器 -->
        <compactMessageEncoding>
          <binaryMessageEncoding />
        </compactMessageEncoding>
        <tcpTransport />
      </binding>
    </customBinding>
  </bindings>

  <extensions>
    <bindingElementExtensions>
      <add name="compactMessageEncoding"
           type="Amib.WCF.CompactMessageEncodingElement, CompactMessageEncoder, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null" />
    </bindingElementExtensions>
  </extensions>
</system.serviceModel>

客戶端配置 (完全對稱)

<system.serviceModel>
  <client>
    <endpoint address="net.tcp://localhost:1234/MyService"
              binding="customBinding"
              bindingConfiguration="compactBinding"
              contract="Client.IMyService" />
  </client>

  <bindings>
    <customBinding>
      <binding name="compactBinding">
        <compactMessageEncoding>
          <binaryMessageEncoding />
        </compactMessageEncoding>
        <tcpTransport />
      </binding>
    </customBinding>
  </bindings>

  <extensions> ... (同伺服器端) ... </extensions>
</system.serviceModel>

效能分析與適用場景

⚠️ 關鍵限制

• 同機器通訊：Loopback 介面頻寬極高，壓縮 CPU 開銷反而降低效能，請僅在跨機器/跨網路場景啟用。
• 流式傳輸：TransferMode.Streamed 時，訊息編碼器不參與，需改用 Stream 包裝器 (另文介紹)。
• MTU 與分片：壓縮後封包變小，減少 IP 分片，間接提升可靠性。

進階擴展：動態壓縮閾值

// 在 CompactMessageEncodingBindingElement 擴展屬性
public int CompressionThreshold { get; set; } = 1024; // 預設 1KB

// CompactMessageEncoder.WriteMessage 判斷
if (buffer.Count - messageOffset > CompressionThreshold)
    return CompressBuffer(...);
else
    return base.WriteMessage(...); // 直接用內建編碼器

配置檔中即可調整：<compactMessageEncoding compressionThreshold="2048">...

總結

1. 自訂 MessageEncoder 是 WCF 透明壓縮的正規做法，核心在 WriteMessage/ReadMessage 緩衝區轉換。
2. 包裝內建編碼器 (binaryMessageEncoding) 保持序列化格式不變，僅壓縮位元組載荷。
3. BufferManager 正確管理緩衝區生命週期，避免記憶體洩漏與過度分配。
4. 僅在跨網路、大訊息、文本型載荷場景啟用，同機通訊請關閉。
5. 配置宣式化，部署零代碼變更，完美符合「透明壓縮」需求。