Apache Thrift - 傳輸和協議層

在 Apache Thrift 中，傳輸和協議層是提供客戶端和伺服器之間通訊的基本元件。

這些層管理資料如何傳輸和格式化，這直接影響基於 Thrift 的服務的效能和功能 -

傳輸層：定義客戶端和伺服器之間通訊的方法。
協議層：指定資料如何透過傳輸層進行編碼和解碼。

傳輸層

Thrift 中的傳輸層處理客戶端和伺服器之間的資料實際傳輸。它們確保訊息正確傳送和接收。

Thrift 提供了幾種傳輸型別，每種型別都適合不同的場景 -

TSocket 傳輸層

TSocket 是 Thrift 中最基本的傳輸層，提供了一種簡單的 TCP/IP 通訊方法。它使用 TCP（一種可靠的面向連線的協議）在客戶端和伺服器之間建立直接連線。

以下是“TSocket”傳輸層的特性 -

阻塞 I/O：操作等待資料可用或操作完成。這可以簡化處理，但如果網路緩慢可能會導致延遲。
簡單設定：易於配置和使用，使其適用於以簡單性和可靠性為關鍵的基本網路通訊場景。
示例用例：非常適合需要簡單性和可靠性的直接通訊場景，例如內部網路服務或基本的客戶端-伺服器互動。

示例

在此示例中，“TSocket.TSocket”設定了一個客戶端套接字，該套接字連線到在本地主機埠 9090 上執行的 Thrift 伺服器。“TTransport.TBufferedTransport”為套接字提供了緩衝，透過減少讀取和寫入操作次數來提高效能 -

from thrift.transport import TSocket, TTransport

# Create a socket transport
transport = TSocket.TSocket('localhost', 9090)
transport = TTransport.TBufferedTransport(transport)

THttpClient 傳輸層

THttpClient 傳輸層使 Thrift 服務可以透過 HTTP 訪問，從而能夠與基於 Web 的系統整合。它將 Thrift 訊息封裝在 HTTP 請求和響應中，使其與 HTTP 基礎設施相容。

以下是“THttpClient”傳輸層的特性 -

HTTP 協議：確保與 Web 協議和系統的相容性，使 Thrift 服務能夠在更廣泛的 HTTP 生態系統中執行。
非阻塞 I/O：通常用於 Web 環境，以有效地同時處理多個請求，而不會阻塞其他任務的處理。
示例用例：當將 Thrift 服務與 Web 應用程式整合或透過 HTTP 公開服務時，THttpClient 特別有用，從而可以更輕鬆地與 Web 客戶端和服務進行互動。

示例

在此示例中，“THttpClient.THttpClient”設定了一個客戶端 HTTP 傳輸，以連線到“https://:9090”上的 Thrift 伺服器。“TTransport.TBufferedTransport”用於緩衝資料，以提高通訊期間的效能 -

from thrift.transport import THttpClient, TTransport

# Create an HTTP transport
transport = THttpClient.THttpClient('https://:9090')
transport = TTransport.TBufferedTransport(transport)

TNonblockingSocket 傳輸層

TNonblockingSocket 傳輸層提供非阻塞 I/O 操作，允許伺服器同時處理多個請求。

它使用非阻塞操作，這意味著它不會等待 I/O 操作完成才繼續執行下一個任務，從而可以更好地處理多個同時連線。

以下是“TNonblockingSocket”傳輸層的特性 -

非阻塞 I/O：此功能顯著提高了效能和響應能力，尤其是在請求量大的場景中。它確保系統可以在等待 I/O 操作完成時繼續處理其他任務。
併發性：TNonblockingSocket 非常適合必須同時處理大量請求的環境，例如即時應用程式或大型 Web 服務。
示例用例：非常適合需要高效處理許多併發連線的高效能場景，例如大型 Web 服務、訊息傳遞平臺或即時資料處理系統。

示例

在此示例中，“TNonblockingSocket.TNonblockingSocket”設定了一個非阻塞套接字傳輸，該傳輸連線到本地主機埠 9090 上的 Thrift 伺服器。“TTransport.TBufferedTransport”添加了一個緩衝層，以提高通訊期間資料傳輸的效率 -

from thrift.transport import TNonblockingSocket, TTransport

# Create a non-blocking socket transport
transport = TNonblockingSocket.TNonblockingSocket('localhost', 9090)
transport = TTransport.TBufferedTransport(transport)

協議層

協議層定義資料如何透過傳輸層進行編碼和解碼。它們確保資料正確序列化和反序列化。

TBinaryProtocol 協議層

TBinaryProtocol 是 Apache Thrift 中的二進位制編碼協議，旨在快速序列化和反序列化資料。

它以二進位制格式編碼資料，使其在透過網路傳輸和接收器解析方面都非常高效。這種二進位制格式的可讀性較差，但優化了效能和頻寬使用率。

以下是“TBinaryProtocol”協議層的特性 -

緊湊格式：二進位制編碼最大程度地減少了傳輸資料的規模，這有助於減少頻寬消耗，尤其是在交換大量資料的情況下。
速度：由於其二進位制特性，TBinaryProtocol 提供了快速的序列化和反序列化，使其成為效能關鍵型應用程式的理想選擇。
示例用例：TBinaryProtocol 在效能和緊湊的資料表示至關重要的場景中特別有用，例如即時系統、高吞吐量服務或頻寬有限的應用程式。

示例

在此示例中，“TBinaryProtocol.TBinaryProtocolFactory”建立了一個工廠，該工廠生成 TBinaryProtocol 的例項，用於客戶端和伺服器配置。此設定確保資料將使用 TBinaryProtocol 提供的高效二進位制格式進行序列化和反序列化 -

from thrift.protocol import TBinaryProtocol

# Create a binary protocol factory
pfactory = TBinaryProtocol.TBinaryProtocolFactory()

TJSONProtocol 協議層

TJSONProtocol 協議層以 JSON 格式編碼和解碼資料，使其既可讀又易於與 Web 技術整合。

它使用 JSON（JavaScript 物件表示法）格式來編碼資料，JSON 以其簡單性和可讀性而聞名。此格式有助於除錯，並且與本機支援 JSON 的 Web 技術和客戶端高度相容。

以下是“TJSONProtocol”協議層的特性 -

人類可讀：JSON 是一種易於閱讀和理解的文字格式，使其成為需要開發人員檢查或除錯資料的情況的理想選擇。
整合：使用 JSON 允許與依賴 JSON 進行資料交換的 Web 客戶端和其他系統（例如 RESTful API 和 Web 應用程式）無縫整合。
示例用例：當資料需要人類可讀或將 Thrift 服務與使用 JSON 的系統（例如 Web 應用程式或外部 API）整合時，TJSONProtocol 特別有用。

示例

在此示例中，“TJSONProtocol.TJSONProtocolFactory”建立了一個工廠，該工廠生成 TJSONProtocol 的例項。此設定確保資料以 JSON 格式進行編碼和解碼，使其可供 Web 技術訪問，並且開發人員易於閱讀 -

from thrift.protocol import TJSONProtocol

# Create a JSON protocol factory
pfactory = TJSONProtocol.TJSONProtocolFactory()

TCompactProtocol 協議層

TCompactProtocol 協議層是 Apache Thrift 中一種高效的編碼協議，旨在透過使用高度壓縮的二進位制格式來平衡緊湊性和速度。

與“TBinaryProtocol”相比，它提供了更緊湊的二進位制編碼，顯著減小了序列化資料的大小，同時保持了出色的效能。這使其成為資料效率和處理速度都很重要的場景的理想選擇。

以下是“TCompactProtocol”協議層的特性 -

緊湊高效：TCompactProtocol 比 TBinaryProtocol 更有效地減少了資料大小，使其成為頻寬受限的環境或儲存大量資料的理想選擇。
平衡效能：它在資料大小和序列化速度之間取得了良好的平衡，確保資料快速處理，而不會影響儲存效率。
示例用例：TCompactProtocol 在緊湊的資料表示和高效處理都很重要的應用程式中特別有用，例如移動應用程式、物聯網裝置或高吞吐量資料系統。

示例

在此示例中，“TCompactProtocol.TCompactProtocolFactory”設定了一個工廠，該工廠生成 TCompactProtocol 的例項。此配置確保資料將以緊湊的二進位制格式進行編碼，從而最佳化資料大小和序列化速度 -

from thrift.protocol import TCompactProtocol

# Create a compact protocol factory
pfactory = TCompactProtocol.TCompactProtocolFactory()

列印頁面