即時通訊架構(gòu)

即時通訊架構(gòu)“社交，是?人們運?用?一定的?方式(?工具)傳遞信息，交流思想，以達到某種??目的的社會活動?！背?見于???即時通訊，私信應(yīng)?用游戲服務(wù)器?長連接信息推送通訊服務(wù)器組成iOSAndroid客戶端WPConnector連接集群LVS

Logic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)IM

數(shù)

據(jù)

層消息中轉(zhuǎn)LogicSession

ClusterMessage

ClusterUser

A

1

Connector2345User

B

6

ConnectorLogic“對安全性、?高可?用、擴展性的要求越?高，架構(gòu)的變化越?大。”iOSAndroid客戶端WPIMLVSConnector連接集群

Logic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)

據(jù)層連接層1.

連接層的作?用2.

“允許隨時重啟更新/

只允許晚上重啟/不允

許重啟斷線”3.

總的來說簡單/異步??

陌陌連接層總連接數(shù)

1200萬+單臺服務(wù)器壓測70萬連接，?一般使?用50%(主流配置)AndroidWP客戶端

IM

iOSConnector連接集群LVS

Logic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)

據(jù)層邏輯層1.2.3.4.?用戶會話驗證消息存取異步隊列隨時重啟AndroidWP客戶端

IM

iOSConnector連接集群LVSLogic邏輯集群服務(wù)化數(shù)據(jù)集群(Session/Message)數(shù)

據(jù)層通訊協(xié)議“安全性要求流量要求傳輸要求可靠&?高效”??

通訊協(xié)議常?見協(xié)議XMPP/SIP缺點：1.流量?大

2.不可靠

3.交互復(fù)雜ClientServer

WIFI/2G/3G/地鐵/電梯10ms/200ms/12s/TCP

half-closed通信協(xié)議設(shè)計??目標(biāo)：????高效：弱??網(wǎng)絡(luò)快速的收發(fā)可靠：不會丟消息易于擴展FlagLengthData…FlagLengthData…FlagLengthData…msg:協(xié)議格式

良好的協(xié)議可以：???簡化系統(tǒng)設(shè)計提供可靠個?高效的消息傳輸易于擴展需求REDIS協(xié)議CR

LF$$$bytes

of

argument

1bytes

of

argument

2bytes

of

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基于隊列的消息協(xié)議S:msg-send

msg1C:msg-recv

1S:msg-send

msg2C:msg-recv

2S:msg-send

msg3

msg4

msg

5

msg

6C:msg-recv

3

4

5

6Redis

List:Client

msg-send

msg-recv

msg-send

msg-recv

msg-send

msg-recvList

Base基于隊列的交互

Server

傳統(tǒng)的IM協(xié)議前提是基于??網(wǎng)線、WIFI，??網(wǎng)絡(luò)延遲極?小移動??網(wǎng)絡(luò)下，交互極其費時，服務(wù)器要維護每個狀態(tài)容易出錯“通訊協(xié)議優(yōu)化，盡量減少?一次交互中數(shù)據(jù)往返的次數(shù)?！盫ersionMessage106msg105msg104msg103msg102msg101msg基于版本號的消息協(xié)議Redis

Sorted

Set:S:msg-pshC:msg-syncS:msg

v

101

msgS:msg

v

102

msgS:msg

v

103

msgS:msg

v

104

msgC:msg-?n

v

104基于版本號的交互ClientServer

msg-psh

msg-sync

msg-send

msg-send

msg-send

msg-send

msg-?nSorted

Set

Base針對弱??網(wǎng)絡(luò)的優(yōu)化協(xié)議?????消息通過版本號維護順序新消息到達，Server只負(fù)責(zé)push通知Client收到輕量的msg-psh后發(fā)出同步請求Serv