問題描述

我想在Flask應用中添加一個簡單的消息通知功能，查了很多資料，發現通知功能主要有兩個問題【這也只是個人愚見，請指正】1：服務器如何向客戶端發送消息？2：服務器如何知道何時該發送消息了？【例如，管理員想發個全站公告，這時就需要對應的模塊向客戶端發送通知，該如何通知該模塊呢？】

對于問題1：我使用H5推出的SSE規范，使得服務器可以單向向客戶端發送消息。對于問題2：我首先想到的是輪詢數據庫中的消息表，一旦發現有相應的消息插入，就向客戶端推送。但是感覺這樣太耗資源了。于是又詢問了網上的前輩，有人說使用redis做緩存。于是今天又仔細看了一天關于redis消息的發布/訂閱功能【比較愚笨】。于是我想到了下面的方法：每當消息表插入消息時，就向對應的頻道發布一條消息，內容主要是要發送消息的主要組成部分，然后對應的消息發送模塊已經訂閱了這個頻道，當然就能收到要發送的消息了。可是聽著簡單，我在實踐時又遇到了一個問題，具體的示例如下所示：問題一：這是SSE訪問的路由，在該路由中訂閱頻道

ps.listen是用來監聽頻道的，源碼中是一個while循環，如下所示：

如果頻道中有發布消息，那么for循環中就能取出data，然后返回，這樣看著挺好，但是SSE規范中，如果每隔一段時間服務器沒有發送數據的話，就會重新請求連接。我設置的時間是1分鐘【自我感覺已經夠長了】，可是如果10分鐘甚至更長時間頻道中都沒有消息，那么for循環就取不出data,’/sse’請求就會一直得不到響應，就會出現下面的情況：

這種情況應該也是很消耗資源的吧，請問該怎么解決這種情況呢？

問題二：我的SSE規范的代碼在message.html中寫的，訪問路由如下【hello_world只是示例】：

總感覺訪問’/message’的時候特別卡，這是怎么回事，是跟線程有關系嗎？

望各位前輩能夠指導下該怎么解決上述的問題。

問題解答

import redis, threadingr = redis.Redis(host=’127.0.0.1’, port=6379, db=3)def x(): while 1:time.sleep(3)r.publish('a', ’a_%s’% time.time())r.publish(’b’, ’b_%s’% time.time())xt = threading.Thread(target=x)xt.setDaemon(True)xt.start()ps = r.pubsub()ps.subscribe([’a’, ’b’])for item in ps.listen(): print item