我們說,要實現 Memcached 的 GET, SET, 和 DELETE 操作。我們僅僅關注這些,但 memcached 協議有一個通用的結構,只有少數參數改變為了改變一個請求或響應的意義。這意味著您可以輕松地擴展實現添加其他命令。一般協議有 24 字節頭用于請求和響應。這個頭可以分解如下表14.1中。
Table 14.1 Sample Memcached header byte structure
| Field | Byte offset | Value |
| --- | --- | --- |
| Magic | 0 | 0x80 用于請求 0x81 用于響應 |
| OpCode | 1 | 0x01...0x1A |
| Key length | 2 和 3 | 1...32,767 |
| Extra length | 4 | 0x00, x04, 或 0x08 |
| Data type | 5 | 0x00 |
| Reserved | 6 和 7 | 0x00 |
| 所有 body 的長度 | 8-11 | 所有 body 的長度 |
| Opaque | 12-15 | 任何帶帶符號的 32-bit 整數; 這個已將包含在響應中,因此更容易將請求映射到響應。 |
| CAS | 16-23 | 數據版本檢查 |
注意有多少字節用于每個部分。這告訴你以后你應該用什么數據類型。例如,如果一個字節抵消只使用 byte 0,然后使用一個 Java byte來表示它;如果它使用6和7(2字節),你使用一個Java short;如果它使用 12-15(4字節),你使用一個Java int,等等。
[](https://github.com/waylau/essential-netty-in-action/blob/master/images/Figure%2014.2%20Real-world%20Memcached%20request%20and%20response%20headers.jpg)
1. 請求(只有頭顯示)
2. 響應
Figure 14.2 Real-world Memcached request and response headers
在圖14.2中,高亮顯示的第一部分代表請求打到 Memcached (只顯示請求頭),在這種情況下是告訴 Memcached 來 SET 鍵是“a”而值是“abc”。第部分是響應。
突出顯示的部分中的每一行代表4個字節;因為有6行,這意味著請求頭是由24個字節,正如我們之前說的。回顧表14.1中,您可以頭在一個真正的請求中看到頭文件中的信息。現在,這是所有你需要知道的關于 Memcached 二進制協議。在下一節中,我們需要看看多么我們可以開始制作 Netty 這些請求。
- Introduction
- 開始
- Netty-異步和數據驅動
- Netty 介紹
- 構成部分
- 關于本書
- 第一個 Netty 應用
- 設置開發環境
- Netty 客戶端/服務端 總覽
- 寫一個 echo 服務器
- 寫一個 echo 客戶端
- 編譯和運行 Echo 服務器和客戶端
- 總結
- Netty 總覽
- Netty 快速入門
- Channel, Event 和 I/O
- 什么是 Bootstrapping 為什么要用
- ChannelHandler 和 ChannelPipeline
- 近距離觀察 ChannelHandler
- 總結
- 核心功能
- Transport(傳輸)
- 案例研究:Transport 的遷移
- Transport API
- 包含的 Transport
- Transport 使用情況
- 總結
- Buffer(緩沖)
- Buffer API
- ByteBuf - 字節數據的容器
- 字節級別的操作
- ByteBufHolder
- ByteBuf 分配
- 總結
- ChannelHandler 和 ChannelPipeline
- ChannelHandler 家族
- ChannelPipeline
- ChannelHandlerContext
- 總結
- Codec 框架
- 什么是 Codec
- Decoder(解碼器)
- Encoder(編碼器)
- 抽象 Codec(編解碼器)類
- 總結
- 提供了的 ChannelHandler 和 Codec
- 使用 SSL/TLS 加密 Netty 程序
- 構建 Netty HTTP/HTTPS 應用
- 空閑連接以及超時
- 解碼分隔符和基于長度的協議
- 編寫大型數據
- 序列化數據
- 總結
- Bootstrap 類型
- 引導客戶端和無連接協議
- 引導服務器
- 從 Channel 引導客戶端
- 在一個引導中添加多個 ChannelHandler
- 使用Netty 的 ChannelOption 和屬性
- 關閉之前已經引導的客戶端或服務器
- 總結
- 引導
- Bootstrap 類型
- 引導客戶端和無連接協議
- 引導服務器
- 從 Channel 引導客戶端
- 在一個引導中添加多個 ChannelHandler
- 使用Netty 的 ChannelOption 和屬性
- 關閉之前已經引導的客戶端或服務器
- 總結
- NETTY BY EXAMPLE
- 單元測試
- 總覽
- 測試 ChannelHandler
- 測試異常處理
- 總結
- WebSocket
- WebSocket 程序示例
- 添加 WebSocket 支持
- 測試程序
- 總結
- SPDY
- SPDY 背景
- 示例程序
- 實現
- 啟動 SpdyServer 并測試
- 總結
- 通過 UDP 廣播事件
- UDP 基礎
- UDP 廣播
- UDP 示例
- EventLog 的 POJO
- 寫廣播器
- 寫監視器
- 運行 LogEventBroadcaster 和 LogEventMonitor
- 總結
- 高級主題
- 實現自定義的編解碼器
- 編解碼器的范圍
- 實現 Memcached 編解碼器
- 了解 Memcached 二進制協議
- Netty 編碼器和解碼器
- 測試編解碼器
- EventLoop 和線程模型
- 線程模型的總覽
- EventLoop
- EventLoop
- I/O EventLoop/Thread 分配細節
- 總結
- 用例1:Droplr Firebase 和 Urban Airship
- 用例2:Facebook 和 Twitter