問題描述

我想在自己的flask應用中實現(xiàn)簡單的消息通知功能，例如管理員向全體用戶發(fā)公告，或者想某個用戶發(fā)出提醒等功能。

可是在實現(xiàn)過程中遇到了一個難題，情況具體描述如下：

我使用sse機制來使服務器向客戶端發(fā)送消息，可是這里出現(xiàn)了問題，就是發(fā)送消息的模塊并不知道什么時候應該發(fā)送消息，例如當用戶A評論了用戶B的博客時，這時就需要通知用戶B，我們此時需要通知發(fā)送模塊：“你該向B發(fā)送消息了”，如何通知發(fā)送模塊呢？

我想到的就是輪詢數據庫，但是感覺這樣太考驗服務器的抗壓了，百度到說：每當對應的數據表更新，就產生一個消息到Redis中，然后輪詢Redis。

這樣聽起來挺好，可是在實現(xiàn)中遇到了很多問題：

例如：（1）redis是key-value存儲，當管理員既要給A發(fā)消息，又要給B，C等發(fā)消息，此時用key該如何區(qū)分？

（2）假設現(xiàn)在要給用戶B發(fā)消息，那么會產生對應的消息存儲在redis中，如果此刻 用戶B并未登錄呢，難道用戶B一周不登錄，該消息就會在redis中一周嗎？ 【我對redis不太了解，知道是在緩存中存儲，所以感覺不可能在緩存中能存儲一周】

思考兩三天了，望各位前輩能夠指點一二

問題解答

redis pub/sub 訂閱/推送 ，是否考慮過使用這樣或者更高級的消息隊列中間件呢。

基本邏輯是這樣的，消息是需要緩存在數據庫或者其他nosql的。拆分出消息中心，使用redis的pub/sub體系或者list，其他需要發(fā)送消息的通過redis通知消息中心發(fā)送消息。消息中心檢查用戶是否在線，在線直接發(fā)送消息給用戶（通過websocket之類的，sse也可以），并標記已讀用戶在線是拉取全部未讀消息無論在不在線消息都要入庫。。。由于redis的value是字符串，要區(qū)分用戶，你只要、value是個json字符串就好了。

{ 'target':['a','b'], 'message':'我是要發(fā)送給用戶a和b的消息'}回答2：

key 放消息類型value放業(yè)務數據，比如序列化以后的dict，想要什么放什么，放多少都行，到時候取出來反序列化就可以直接用了