0x01.About

最近在處理系統訊息模組，查閱了很多實踐案例，各有針對性。

首先站內訊息主要包括：個人訊息（評論，點贊），系統訊息，訂閱訊息，私信。

其中，訂閱區分使用者群，即系統訊息是一個特殊的所有人訂閱的訂閱訊息，特點是一對多。

前三個實時性比較低，最後一個實時性高，離線狀態下是私信，如果雙方線上要轉為聊天室，特點是一對一。

那麼，接下來，該選個方案了，SQL or NoSQL?

0x02.Mysql實現

首先，對於個人訊息、私信("UserMessage")，一條訊息插一句，Mysql跑跑沒問題。

對於系統訊息或訂閱訊息，必然不可以，假如有10萬用戶，一次性那麼要插入10萬條訊息，Mysql必死。

那麼就是說，要設立一個系統庫（"SystemMessage"），每當使用者登入，就去跑跑系統庫("SystemMessage")，把未讀的系統庫跑到個人庫。

關於訂閱訊息就比較麻煩了，對使用者分組？對訊息分組？

關係型資料庫處理集合問題是比較麻煩的，目前想到的結論是建立一個表("RssMessage")儲存訊息型別，訊息索引。

下面列了大致的資料庫模型：

看完這個資料庫設計，我也覺得好難受，吐槽前先來想想為什麼吧。

UserSystemRelation表用於記錄使用者讀取到哪個位置的標記。

可以看到，UserMessage與SystemMessage表中，title、tid、ctime、type欄位冗餘了，好像也沒必要，

但是從使用者功能上看，當用戶登陸後，查詢自己站內訊息，必然要用到的有：status，必然要顯示的有：title、ctime，type作為使用者進入訊息面板後，要篩選的方式之一，這樣的話，Mysql就只要跑一個表就可以完成顯示給使用者的最新站內訊息了。

由於MessageText可能是一個大資訊通知，使用者檢視個人訊息時候，並未檢視MessageText內容，所以單獨放一張表。

相應處理流程

• 使用者登入後，先通過"UserSystemRelation"表查詢是否有新的系統訊息
• 如果"UserSystemRelation"，查詢到自身uid，同步系統訊息到個人訊息；如果"UserSystemRelation"未查詢到自身uid，直接插入"UserSystemRelation"，並讀取最近50條系統訊息。
• 使用者點選未讀訊息，獲取"MessageText""，並更新狀態(status)為已讀。
• 使用者通過"status"、"type"，可以篩選系統訊息。

0x03.Mysql+MongoDB實現

由於Mongodb是一種文件型的資料結構，所以，可以考慮把所有資料轉成json直接塞給Mongodb。

基於使用者的習慣，讀多寫少，大部分時候都是看到訊息，刪除、更新比較少，如果資料沒更新直接讀Mongodb，如果資料更新，直接刪除Mongodb的索引。

這個考慮是在，使用者數量很大的時候，要在"UserSystem"表裡查詢到使用者訊息比較慢的時候用，類似於吧Mongodb當快取。

0x04.Redis實現

看了Mysql下站內訊息的資料庫設計，我也覺得很蛋疼，臨時過渡沒事，但是還是NoSQL合適。

在下圖展示的這個 pubsub_channels 示例中， client2 、 client5 和 client1 就訂閱了 channel1 ， 而其他頻道也分別被別的客戶端所訂閱：

只要是訂閱了相應地頻道，就會收到頻道的訊息。

把使用者ID作為頻道，私信就是反向的頻道訂閱，系統訊息就是所有使用者的訂閱，那麼離線的訊息呢？

1、線上使用者

還是存在系統或個人的雜湊表裡，等上線後再去讀取。

在Python中，訂閱釋出訊息(Publish)如下：

import redis,time
queue = redis.StrictRedis(host='localhost', port=6379, db=0)
channel = queue.pubsub()

for i in range(100): 
    queue.publish("test", i)
    time.sleep(0.1)

Python中，訂閱監聽訊息(Subcribe)如下：

import redis,time
r = redis.StrictRedis(host='localhost', port=6379, db=0)
p = r.pubsub()
p.subscribe('test')

while True:
    message = p.get_message()
    if message:
        print "Subscriber: %s" % message['data']

這是線上使用者做法。

2、線下使用者

看過一種做法是建立一個Redis連結串列，儲存登陸使用者，當用戶登陸就直接傳送，沒登陸就暫存起來。

這裡的話，可以用WebSocket實時監聽，定期傳送心跳包，如果線上直接返回Redis自帶的訂閱系統。

系統訊息建立一個集合：

SADD system:2015-08-03 7 8 9 10 11

第一段標示系統資訊，第二段標示日期，後面的數字標示message id。

個人訊息建立一個集合：

SADD user:12345:read 1 2 3 4

第一段標示使用者資訊集合，第二段標示使用者id，下一段標示訊息型別為已讀，後面的數字標示message id。

關於訂閱訊息如下：

SADD rss:xiaocao 12 13 14 15

那麼你就收到小草的訂閱訊息，訊息ID分別是 12, 13, 14, 15

還有很重要的訊息資料儲存，

HMSET message:12 title 標題 content 內容 date 2015-08-03

Python建立資料庫的例子就是：

import redis,time,threading,random
pool = redis.ConnectionPool(host='localhost', port=6379, db=1)
rs = redis.Redis(connection_pool=pool)

rs.sadd("user:123:read", "1", "2")
rs.sadd("user:123:unread", "4", "5", "6")
rs.sadd("system:2015-08-03", "7", "8", "9", "10", "11")
rs.sadd("rss:xiaocao", "12", "13", "14", "15", "11")

for i in range(15):
    rs.hset("message:"+str(i), "title", "title=>"+str(random.uniform(1, 99999)))
    rs.hset("message:"+str(i), "content","content=>"+str(time.time()))
    rs.hset("message:"+str(i), "date", str(time.strftime("%Y-%m-%d %H:%M:%S", time.gmtime())))

參考：

-by小草