即時(shí)通訊架構(gòu)

1、即時(shí)通訊架構(gòu)“社交，是人們運(yùn)用一定的方式(工具)傳遞信息，交流思想，以達(dá)到某種目的的社會活動(dòng)?！背Ｒ娪诩磿r(shí)通訊，私信應(yīng)用 游戲服務(wù)器 長連接信息推送通訊服務(wù)器組成iOSAndroid客戶端WPConnector連接集群LVSLogic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)IM數(shù)據(jù)層消息中轉(zhuǎn)LogicSession ClusterMessage ClusterUser A1Connector2345User B6ConnectorLogic“對安全性、高可用、擴(kuò)展性的要求越高，架構(gòu)的變化越大。”iOSAndroid客戶端WPIMLVSConnector連接集群Logic邏輯集群

2、服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)據(jù)層連接層1. 連接層的作用 2. “允許隨時(shí)重啟更新/只允許晚上重啟/不允許重啟斷線” 3. 總的來說簡單/異步陌陌連接層總連接數(shù) 1200萬+ 單臺服務(wù)器壓測70萬連接，一般使用50%(主流配置)AndroidWP客戶端IMiOSConnector連接集群LVSLogic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)據(jù)層邏輯層1.2.3.4.用戶會話驗(yàn)證 消息存取 異步隊(duì)列 隨時(shí)重啟AndroidWP客戶端IMiOSConnector連接集群LVSLogic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)據(jù)層通訊協(xié)議“

3、 安全性要求 流量要求 傳輸要求可靠&高效 ”通訊協(xié)議常見協(xié)議XMPP/SIP 缺點(diǎn)：1.流量大 2.不可靠 3.交互復(fù)雜ClientServerWIFI/2G/3G/地鐵/電梯10ms/200ms/12s/TCP half-closed通信協(xié)議設(shè)計(jì)目標(biāo)： 高效：弱網(wǎng)絡(luò)快速的收發(fā) 可靠：不會丟消息 易于擴(kuò)展FlagLength DataFlagLength DataFlagLength Datamsg:協(xié)議格式良好的協(xié)議可以： 簡化系統(tǒng)設(shè)計(jì) 提供可靠個(gè)高效的消息傳輸 易于擴(kuò)展需求REDIS協(xié)議CR LF$bytes of argument 1bytes of argument 2bytes o

4、f argument 3CR LFCR LFCR LFdatadatadataCR LFCR LFCR LFRedis協(xié)議* number of argumentsSET name latermoon * 3 $ 3 SET $ 4 name $ 9 latermoon下面都用Redis協(xié)議來描述邏輯READ REDIS COMMANDFIFOmsg6msg5msg4msg3msg2msg1基于隊(duì)列的消息協(xié)議S:msg-send msg1 C:msg-recv 1 S:msg-send msg2 C:msg-recv 2 S:msg-send msg3 msg4 msg 5 msg 6 C:m

5、sg-recv 3 4 5 6Redis List:Clientmsg-sendmsg-recvmsg-sendmsg-recvmsg-sendmsg-recvList Base基于隊(duì)列的交互Server 傳統(tǒng)的IM協(xié)議 前提是基于網(wǎng)線、WIFI，網(wǎng)絡(luò)延遲極小 移動(dòng)網(wǎng)絡(luò)下，交互極其費(fèi)時(shí)，服務(wù)器要維護(hù)每個(gè)狀態(tài)容易出錯(cuò)“通訊協(xié)議優(yōu)化，盡量減少一次交互中數(shù)據(jù)往返的次數(shù)。”VersionMessage106msg105msg104msg103msg102msg101msg基于版本號的消息協(xié)議Redis Sorted Set:S:msg-psh C:msg-sync S:msg v 101 msg S:msg v 102 msg S:msg v 103 msg S:msg v 104 msg C:msg-fin v 104基于版本號的交互ClientServermsg-pshmsg-syncmsg-sendmsg-sendmsg-sendmsg-sendmsg-finSorted Set Base針對弱網(wǎng)絡(luò)的優(yōu)化協(xié)議 消息通過版本號維護(hù)順序 新消息到達(dá)，Server只負(fù)責(zé)push通知 Client收到輕量的msg-psh后發(fā)出同步請求 Server按照版本號連續(xù)發(fā)送m