成人在线亚洲_国产日韩视频一区二区三区_久久久国产精品_99国内精品久久久久久久

您的位置:首頁技術(shù)文章
文章詳情頁

flask - Python使用redis發(fā)布訂閱時,監(jiān)聽頻道時出現(xiàn)的問題?【一句話描述不清楚,請各位細看內(nèi)容】

瀏覽:120日期:2022-08-21 17:05:26

問題描述

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

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

flask - Python使用redis發(fā)布訂閱時,監(jiān)聽頻道時出現(xiàn)的問題?【一句話描述不清楚,請各位細看內(nèi)容】

ps.listen是用來監(jiān)聽頻道的,源碼中是一個while循環(huán),如下所示:

flask - Python使用redis發(fā)布訂閱時,監(jiān)聽頻道時出現(xiàn)的問題?【一句話描述不清楚,請各位細看內(nèi)容】

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

flask - Python使用redis發(fā)布訂閱時,監(jiān)聽頻道時出現(xiàn)的問題?【一句話描述不清楚,請各位細看內(nèi)容】

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

問題二:我的SSE規(guī)范的代碼在message.html中寫的,訪問路由如下【hello_world只是示例】:flask - Python使用redis發(fā)布訂閱時,監(jiān)聽頻道時出現(xiàn)的問題?【一句話描述不清楚,請各位細看內(nèi)容】

總感覺訪問’/message’的時候特別卡,這是怎么回事,是跟線程有關(guān)系嗎?

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

問題解答

回答1:

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

標簽: Python 編程