消息系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)「上篇」

v1 發(fā)布于2019-08-19 17:52 / 2514人閱讀

摘要：原文鏈接消息系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)上篇由于文章篇幅較長，而作者精力有限，不希望這么早就精盡人亡，故分成上下篇來寫消息系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn)。更新于關(guān)聯(lián)文章消息系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)下篇如果本文對您有用請不要吝嗇你們的與這會大大支持我們繼續(xù)創(chuàng)作

原文鏈接：Bluesun | 消息系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)「上篇」
由于文章篇幅較長，而作者精力有限，不希望這么早就精盡人亡，故分成上下篇來寫消息系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn)。上篇主要講的是一些概念，搞清楚我們要做的這個(gè)消息系統(tǒng)的主要內(nèi)容。而下篇主要講具體的實(shí)現(xiàn)，會包括架構(gòu)設(shè)計(jì)，數(shù)據(jù)庫設(shè)計(jì)，業(yè)務(wù)流程詳細(xì)的實(shí)現(xiàn)等。
整個(gè)系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn)，并非我一人之力就可以完成的。這其中是同事們大家一起討論與商討的結(jié)果，而我只是把它細(xì)化，呈現(xiàn)出來。
我只是一個(gè)會思考的idea搬運(yùn)工。

產(chǎn)品分析

首先我們來看一下市場上關(guān)于消息的實(shí)現(xiàn)是怎么樣的。

簡書

簡書的消息系統(tǒng)主要分了兩種

簡信

提醒

簡信
簡信的性質(zhì)其實(shí)跟私信是一樣的，是用戶發(fā)送給用戶的一則消息，有具體的信息內(nèi)容。

提醒
而提醒，則是系統(tǒng)發(fā)送的一則消息，其文案格式是固定的，并且對特殊對象一般擁有超鏈接。

知乎

知乎跟簡書一樣，主要分了兩種：

私信

消息

私信
跟簡書一樣，使用戶發(fā)送給用戶的一則消息，也可以是管理員發(fā)送給用戶的消息。

消息
知乎的消息比簡書的提醒有過之而無不及，知乎會對多條相似的消息進(jìn)行聚會，以達(dá)到減輕用戶閱讀壓力的體驗(yàn)。

消息的三種分類

通過兩種產(chǎn)品的簡單分析，得出他們的消息有兩種分類，在這基礎(chǔ)上，我們再加上一種：公告。
公告的主要性質(zhì)是系統(tǒng)發(fā)送一則含有具體內(nèi)容的消息，站內(nèi)所有用戶都能讀取到這條消息。
所以，消息有三種分類：

公告 Announce

提醒 Remind

私信 Message

提醒的語言分析

我們從簡書取一組提醒樣本：

3dbe1bd90774 關(guān)注了你

magicdawn 喜歡了你的文章《單點(diǎn)登錄的三種實(shí)現(xiàn)方式》

無良程序喜歡了你的文章《基于RESTful API 怎么設(shè)計(jì)用戶權(quán)限控制？》

alexcc4 喜歡了你的文章《在Nodejs中貫徹單元測試》

你在《基于RESTful API 怎么設(shè)計(jì)用戶權(quán)限控制？》中收到一條 cnlinjie 的評論

你的文章《Session原理》已被加入專題《ios開發(fā)》

分析句子結(jié)構(gòu)，提醒的內(nèi)容無非就是

「誰對一樣屬于誰的事物做了什么操作」

「someone do something in someone"s something」

someone = 提醒的觸發(fā)者，或者發(fā)送者，標(biāo)記為sender
do something = 提醒的動作，評論、喜歡、關(guān)注都屬于一個(gè)動作，標(biāo)記為action
something = 提醒的動作作用對象，這就具體到是哪一篇文章，標(biāo)記為target
someone"s = 提醒的動作作用對象的所有者，標(biāo)記為targetOwner

這就清楚了，sender和targetOwner就是網(wǎng)站的用戶，而target是具體到哪一篇文章，如果提醒的對象不僅僅局限于文章，還有其他的話，就需要增加一項(xiàng)targetType，來標(biāo)記目標(biāo)是文章還是其他的什么。而action，則是固定的，整個(gè)網(wǎng)站會觸發(fā)提醒的動作可能就只有那幾樣：評論、喜歡、關(guān)注.....（或者其他業(yè)務(wù)需要提醒的動作）

消息的兩種獲取方式

推 Push

拉 Pull

以知乎為例
推的比較常見，需要針對某一個(gè)問題維護(hù)著一張關(guān)注者的列表，每當(dāng)觸發(fā)這個(gè)問題推送的條件時(shí)（例如有人回答問題），就把這個(gè)通知發(fā)送給每個(gè)關(guān)注者。

拉的相對麻煩一點(diǎn)，就是推的反向，例如每個(gè)用戶都有一張關(guān)注問題的列表，每當(dāng)用戶上線的時(shí)候，對每個(gè)問題進(jìn)行輪詢，當(dāng)問題的事件列表出現(xiàn)了比我原本時(shí)間戳大的信息就進(jìn)行拉取。

而我們則根據(jù)消息的不同分類采用不同的獲取方式：
通告和提醒，適合使用拉取的方式，消息產(chǎn)生之后，會存在消息表中，用戶在某一特定的時(shí)間根據(jù)自己關(guān)注問題的表進(jìn)行消息的拉取，然后添加到自己的消息隊(duì)列中，

信息，適合使用推的方式，在發(fā)送者建立一條信息之后，同時(shí)指定接收者，把消息添加到接收者的消息隊(duì)列中。

根據(jù)提醒使用拉取的方式，需要維護(hù)一個(gè)關(guān)注某一事物的列表。
這種行為，我們稱之為：「訂閱」Subscribe

一則訂閱有以下三個(gè)核心屬性：

訂閱的目標(biāo) target

訂閱的目標(biāo)類型 targetType

訂閱的動作 action

比如我發(fā)布了一篇文章，那么我會訂閱文章《XXX》的評論動作，所以文章《XXX》每被人評論了，就需要發(fā)送一則提醒告知我。

訂閱的規(guī)則還可以擴(kuò)展
我喜歡了一篇文章，和我發(fā)布了一篇文章，訂閱的動作可能不一樣。
喜歡了一篇文章，我希望我訂閱這篇文章更新、評論的動作。
而發(fā)布了一篇文章，我希望我只是訂閱這篇文章的評論動作。

這時(shí)候就需要多一個(gè)參數(shù)：subscribReason
不同的subscribReason，對應(yīng)著一個(gè)動作數(shù)組，
subscribReason = 喜歡，對應(yīng)著 actions = [更新，評論]
subscribReason = 發(fā)布，對應(yīng)著 actions = [評論]

訂閱的規(guī)則還還可以擴(kuò)展
用戶可能會有一個(gè)自己的訂閱設(shè)置，比如對于所有的喜歡的動作，我都不希望接收。
比如Knewone的提醒設(shè)置

所以我們需要再維護(hù)一個(gè)表：SubscriptionConfig，來存放用戶的提醒設(shè)置。
并且，當(dāng)用戶沒有提醒設(shè)置的時(shí)候，可以使用系統(tǒng)提供的一套默認(rèn)設(shè)置：defaultSubscriptionConfig

聚合

如果我發(fā)布了一篇文章《XXX》，在我不在線的時(shí)候，被評論了10遍，當(dāng)我一上線的時(shí)候，應(yīng)該是收到十條信息類似于：「誰誰誰評論了你的文章《XXX》」?
還是應(yīng)該收到一條信息：「甲、乙、丙、丁...評論了你的文章《XXX》」?

知乎在聚合上做的很優(yōu)秀，要知道他們要實(shí)現(xiàn)這個(gè)還是挺有技術(shù)的：
知乎的消息機(jī)制，在技術(shù)上如何設(shè)計(jì)與規(guī)劃？
網(wǎng)站的消息（通知）系統(tǒng)一般是如何實(shí)現(xiàn)的？

關(guān)于這部分功能，我們還沒有具體的實(shí)現(xiàn)方法，暫時(shí)也無法講得更加詳細(xì)。⊙﹏⊙

五個(gè)實(shí)體

通過上面的分析，大概知道做這個(gè)消息系統(tǒng)，需要哪些實(shí)體類：

用戶消息隊(duì)列 UserNotify

用戶 User

訂閱 Subscription

訂閱設(shè)置 SubscriptionConfig

消息 Notify

通告 Announce

提醒 Remind

信息 Message

行為分解

說了這么多，整理一下整個(gè)消息流程的一些行為：

系統(tǒng)或者管理員，創(chuàng)建消息

createNotify (make announce | remind | message)

用戶，訂閱消息，取消訂閱

subscribe, cancelSubscription

用戶管理訂閱設(shè)置

getSubscriptionConfig, updateSubscriptionConfig

用戶，拉取消息

pullNotify (pull announce | remind | message | all)

用戶，查詢消息隊(duì)列

getUserNotify(get announce | remind | message | all)

用戶閱讀消息

read

在本文的「下篇」我們來探討一下：模型怎么做、數(shù)據(jù)庫怎么設(shè)計(jì)、代碼結(jié)構(gòu)怎么來、一些邏輯上的時(shí)序圖應(yīng)該是怎么樣的。

---------------------- 更新于 2015/11/15 -----------------------

關(guān)聯(lián)文章：消息系統(tǒng)設(shè)計(jì)與實(shí)現(xiàn)「下篇」

如果本文對您有用
請不要吝嗇你們的Follow與Start
這會大大支持我們繼續(xù)創(chuàng)作

「Github」
MZMonster ：@MZMonster
JC_Huang ：@JerryC8080

GPU云服務(wù)器云服務(wù)器基于webrtc的視頻會議系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn) linux操作系統(tǒng)的web服務(wù)器的設(shè)計(jì)與實(shí)現(xiàn) 數(shù)據(jù)倉庫設(shè)計(jì)與實(shí)現(xiàn) linux內(nèi)核設(shè)計(jì)與實(shí)現(xiàn)