首先講講IM(即時通訊)技術(shù)可以用來做什么:
可以說幾乎所有高實時性的應(yīng)用場景都需要用到IM技術(shù)囱桨。
本篇將帶大家從零開始搭建一個輕量級的IM服務(wù)端,麻雀雖小嗅绰,五臟俱全舍肠,我們搭建的IM服務(wù)端實現(xiàn)以下功能:
一對一的文本消息、文件消息通信
每個消息有“已發(fā)送”/“已送達(dá)”/“已讀”回執(zhí)
存儲離線消息
支持用戶登錄窘面,好友關(guān)系等基本功能翠语。
能夠方便地水平擴(kuò)展
通過這個項目能學(xué)到什么?
這個項目涵蓋了很多后端必備知識:
rpc通信
數(shù)據(jù)庫
緩存
消息隊列
分布式民镜、高并發(fā)的架構(gòu)設(shè)計
docker部署
消息通信
文本消息
我們先從最簡單的特性開始實現(xiàn):一個普通消息的發(fā)送
我們現(xiàn)在有兩個用戶:Alice和Bob連接到了服務(wù)器啡专,當(dāng)Alice發(fā)送消息message(hello)給Bob,服務(wù)端接收到消息制圈,根據(jù)消息的destId進(jìn)行轉(zhuǎn)發(fā)们童,轉(zhuǎn)發(fā)給Bob。即時通訊開發(fā)咨詢小藍(lán)豆
發(fā)送回執(zhí)
那我們要怎么來實現(xiàn)回執(zhí)的發(fā)送呢鲸鹦?
我們定義一種回執(zhí)數(shù)據(jù)格式ACK慧库,MsgType有三種,分別是sent(已發(fā)送),delivered(已送達(dá)), read(已讀):
在服務(wù)器這里不區(qū)分ChatMsg和AckMsg馋嗜,處理過程都是一樣的:解析消息的destId并進(jìn)行轉(zhuǎn)發(fā)齐板。
水平擴(kuò)展
當(dāng)用戶量越來越大,必然需要增加服務(wù)器的數(shù)量葛菇,用戶的連接被分散在不同的機(jī)器上甘磨。此時,就需要存儲用戶連接在哪臺機(jī)器上眯停。
我們引入一個新的模塊來管理用戶的連接信息济舆。
這樣我們就能夠?qū)τ脩暨B接狀態(tài)進(jìn)行管理了,具體的實現(xiàn)應(yīng)考慮服務(wù)的用戶量莺债、期望性能等進(jìn)行實現(xiàn)滋觉。
此處我們使用redis來實現(xiàn)签夭,將userId和connectorId的關(guān)系以key-value的形式存儲。
消息轉(zhuǎn)發(fā)
除此之外椎侠,還需要一個模塊在不同的機(jī)器上轉(zhuǎn)發(fā)消息第租,
此時我們的服務(wù)被拆分成了connector和transfer兩個模塊,connector模塊用于維持用戶的長鏈接我纪,而transfer的作用是將消息在多個connector之間轉(zhuǎn)發(fā)慎宾。
現(xiàn)在Alice和Bob連接到了兩臺connector上,那么消息要如何傳遞呢宣羊?
1.Alice上線璧诵,連接到機(jī)器[1]上時
將Alice和它的連接存入內(nèi)存中。
調(diào)用user status的online方法記錄Alice上線仇冯。
2.Alice發(fā)送了一條消息給Bob
機(jī)器[1]收到消息后之宿,解析destId,在內(nèi)存中查找是否有Bob苛坚。
如果沒有比被,代表Bob未連接到這臺機(jī)器,則轉(zhuǎn)發(fā)給transfer泼舱。
3.transfer調(diào)用user status的getConnectorId(Bob)方法找到Bob所連接的connector等缀,返回機(jī)器[2],則轉(zhuǎn)發(fā)給機(jī)器[2]娇昙。