源碼分析系列之PomeloForEgret

在我上一個手游項目中，前端使用的是白鷺引擎，后端使用的框架是pomelo，前端使用的網絡庫是pomelo提供給白鷺的，可以在git上拿到這份源代碼，或者應該pomelo的官網也可以找到。

本文是對這份PomeloForEgret源碼的分析。一個完整的客戶端網絡庫應該包括初始化，握手，發送心跳包，協議數據的發送和接收。PomeloForEgret基于websocket，完整的包含了上述的功能，數據的發送和接收同時支持json數據和根據protobuf數據結構協議序列化的二進制數據。本文主要對協議數據的發送和接收的部分進行解讀。

先介紹下PomeloForEgret主要的包含的類：Pomelo，Package，Message，Protocol，Protobuf。Pomelo是跟外界交互的業務邏輯類，而Package，Message，Protocol和Protobuf類作為Pomelo的工具類。

Message的數據傳送類型包括TYPE_REQUEST，TYPE_NOTIFY，TYPE_RESPONSE，TYPE_PUSH。

Package的業務類型包括TYPE_HANDSHAKE，TYPE_HANDSHAKE，TYPE_HEARTBEAT，TYPE_DATA，TYPE_KICK。

一、 協議的數據發送數據
協議的數據發送需要經過以下3個流程：

1. Pomelo類的request方法。
   requet(route,msg,cg)有以下三個步驟：
   a. reqId++
   b. sendMessage(reqId,route,msg)
   c. callbacks[reqId]=cb，routeMap[reqId]=route，保存協議發送的回調，這個回調用來處理同一次同一個協議(路由)返回的數據。
2. Pomelo的sendMessage方法，就是上面的1.b方法。
   sendMessage(reqId,route,msg)有以下步驟：
   a. byte:egrete.ByteArray
   b. this._message.encode(reqId,route,msg)，利用Message工具類對發送的數據序列化成二進制數據(需要用到Protobuf工具類或Protocol工具類)。
   c. this._package.encode(Package.TYPE_DATA,byte)，利用Package工具類，加上Package的業務類型(見上)，后面加上2.b步驟的二進制數據，寫入字節流。
3. Pomelo的send方法。
   a． this.socket.writeByte(byte)
   b． this.socket.flush

特別的，上面的2.b和2.c的步驟具體如下：
2.b Message的encode方法將協議發送的數據進行序列化：
把Message的數據傳送類型(見上)寫入字節流。
把reqId寫入字節流。
把路由寫入字節流。
利用Protobuf或Protocol工具類把協議的數據寫入字節流，具體如下[tag,type][value] [tag,type][value] [tag,type][value]……。
所以message的字節流應該是這樣的：[傳送類型][reqId][route][protobuf序列化數據]
2.c Package的encode方法步驟如下：
寫入Package業務類型(見上)。
寫入2.b生成的二進制數據長度，占3個字節。
寫入2.b生成的二進制。

所以package的字節流應該這樣的：[業務類型][message的數據長度占3個字節][Message的數據]

2. 協議的數據接收。
   協議的數據接收主要包括以下的步驟：

3. this._package.decode(byte)：
   a． 讀取Package的業務類型(見上)。
   b． 讀取message的長度
   c． 讀取message。
   return {type:type，body:body，length:len}

4. this._message.decode(data)：
   a．Message的數據傳送類型(見上)。
   b．讀取reqId。
   c．讀取路由
   d．利用Protobuf或Protocol類將2.c的message數據轉化為對象或者所需的數據。

協議的數據發送和接受的流程是反過來一一對應的。

最后再貼下Protobuf類序列化和反序列化無符號int的寫法，感覺挺巧妙的：

完。