
一、系統(tǒng)目標(biāo)
使用netty搭建tcp服務(wù)器,支持長(zhǎng)連接,短連接模式。
使用protobuf作為主要的數(shù)據(jù)編碼手段
將數(shù)據(jù)傳輸隱藏在框架內(nèi),使得業(yè)務(wù)開發(fā)人員可直接關(guān)注業(yè)務(wù)實(shí)現(xiàn),無(wú)需關(guān)注通信,甚至無(wú)需關(guān)心多線程問題。
可擴(kuò)展的架構(gòu),方便接入其他中間件。
將編碼任務(wù)簡(jiǎn)單化。
二、系統(tǒng)分層


2.1 通信層
絕大部分的功能,netty已經(jīng)支持了。
2.1.1 通信協(xié)議
服務(wù)器在收到數(shù)據(jù)之后,需要進(jìn)行如下的過濾判斷:
a、數(shù)據(jù)是否合法
b、數(shù)據(jù)版本是否支持
c、如何解析客戶端數(shù)據(jù),客戶端數(shù)據(jù)類型是什么
d、客戶端期望服務(wù)端提供什么服務(wù)
數(shù)據(jù)包具體協(xié)議設(shè)計(jì)如下:
長(zhǎng)度(4字節(jié))| 時(shí)間戳(4字節(jié)) | 版本 (2字節(jié)) | 服務(wù)id (2字節(jié))| 數(shù)據(jù)(不定長(zhǎng))| 校驗(yàn)碼(2字節(jié))
2.1.2 Mapping
由上述協(xié)議傳輸?shù)臄?shù)據(jù)中的服務(wù)id,具體對(duì)應(yīng)到哪個(gè)類的哪個(gè)方法執(zhí)行
上傳數(shù)據(jù)如何解析由方法參數(shù)決定
下發(fā)數(shù)據(jù)如何解析由方法返回值決定
如返回值為void,且方法中帶異步回調(diào)參數(shù),則一般為異步執(zhí)行
如返回值不為void,則為同步執(zhí)行。
服務(wù)id計(jì)算,(65536上限,一般應(yīng)用足夠了):
所有Controller的method列表,使用字典順序排序的序號(hào),并持久化序號(hào)和method的對(duì)應(yīng)關(guān)系,新版本新的Controller的排序基數(shù)使用上個(gè)版本排序最大值。
2.1.3 通信用POJO
在網(wǎng)絡(luò)層為protobuf生成,.proto文件,可以根據(jù)method方法參數(shù)生成。
具體規(guī)則為:
int Calc.add(int a,int b);
則生成
syntax = "proto3";
package com.project.net.pojo;
message CalcAdd{
int32 a = 1;
int32 b=2;
}
void Articals.add(Artical a);
syntax = "proto3";
package com.project.net.pojo;
message ArticalsAdd{
//Artical字段
}
不支持Map或List<Map>作為參數(shù)
返回值規(guī)則:
返回值為簡(jiǎn)單型,則可使用通用的.proto文件
message IntResult{
int32 result =1 ;
}
message StringResult{
string result = 1;
}
客戶端解析規(guī)則:
在程序內(nèi)內(nèi)置服務(wù)id和.proto的對(duì)應(yīng)關(guān)系,并可在線更新或整體更新。
2.2 線程管理
可配置使用額外的線程管理,或是直接使用netty自己的工作線程。
額外的線程管理,設(shè)計(jì)如下:
2.2.1 邏輯線程
有必要將邏輯線程和工作線程分開
a、邏輯線程為單線程,整個(gè)服務(wù)器單元只有一個(gè)邏輯線程
b、原則上,邏輯線程只處理邏輯,不做重度任務(wù)處理
c、如涉及長(zhǎng)時(shí)間任務(wù),將任務(wù)投遞到工作線程上。
優(yōu)點(diǎn):無(wú)線程安全問題,可放心大膽使用hashmap、hashset等數(shù)據(jù)結(jié)構(gòu)。
2.2.2 任務(wù)線程
a、處理重任務(wù),如數(shù)據(jù)庫(kù)操作等
b、非線程安全,原則上不存放線程共享數(shù)據(jù)
c、框架應(yīng)提供齊全的工具類以規(guī)避線程安全問題,保證在開發(fā)人員水平參差不齊的情況下仍然不影響業(yè)務(wù)邏輯的開發(fā)。
d、將縮小異常范圍,以減少對(duì)整個(gè)系統(tǒng)的損害。
e、提供線程退出機(jī)制。
2.2.3 任務(wù)隊(duì)列
上述任務(wù)線程的共享的隊(duì)列。
2.2.4 異步回調(diào)機(jī)制
在工作線程中做完任務(wù)之后,可以將結(jié)果投遞邏輯線程
也可以直接與客戶端通信,并主動(dòng)關(guān)閉連接。
2.3. Controller層
設(shè)計(jì)思路可以參考spring mvc?;蛑苯诱蟬pring、jfinal等框架(待研究)。
2.3.1 java class
Controller可設(shè)計(jì)單例模式
2.3.2 method
可支持aop技術(shù)
2.3.3 參數(shù)解析、結(jié)果解析
參見2.1.3 節(jié)