淺談flask的發布訂閱

發布-訂閱模式
首先 顧名思義 就像訂閱報紙一樣，出版社發布不同類型的報紙雜志不同的讀者根據不同的需求預定符合自己口味的的報紙雜志,付費之后由郵局安排人員統一派送

由上圖可卡因看到三個比較重要的點：
1.發布者：報社
2.訂閱者：讀者
3.調度中心: 郵局
不難看出上述過程中出版社和讀者完全沒有任何接觸,在他們沒有感知到對方的情況下通過郵局完成了整個流程,郵局就是傳說中的中介(Broker)

使用發布-訂閱模式的優點：
松耦合,可拓展性

Flask - Signals

說明
有了前面這個鋪墊，不難意識到 Flask 的 Singals 其實就是我們上面說的發布－訂閱模式的實現．官方文檔對 Signals 的介紹過于簡單，容易讓初學者直接忽略過去，但是實際上這知識點十分重要，尤其在開發比較復雜的系統中，正確地使用 Singals 能夠幫助我們實現系統的松耦合.
這種松耦合是通過某些行為被觸發時，自動發送定義好的一種信號，與這個信號綁定的一些業務邏輯或行為，接收到這個信號后，會自動執行各自相應的業務邏輯。這些行為的產生者就是我們在發布訂閱模式中發布者,通過調度中心,消息被轉發到相應的訂閱者,然后每個訂閱者執行自己的邏輯,互不干擾.
就像我們在發布-訂閱模式看到的那樣,我們可以隨時添加訂閱者. 同樣地,與該信號綁定的業務邏輯，可以是我們事先預定義好的，也可以是在后續開發中隨需求變動新增上去的. 在基于 Signals 的機制下,系統會更加穩定和可擴展，也使得系統的業務邏輯更加清晰.

例子

Signal 的創建
兩行代碼就可以創建

from blinker import signal test= signal('test')

不過Flask文檔有另一種寫法

from blinker import Namespace my_signals = Namespace() model_saved = my_signals.signal('model-saved')

兩者本質上是沒有任何區別的,原因我們可以看一下 blinker 的源碼

# https://github.com/jek/blinker/blob/master/blinker/base.py signal = Namespace().signal

很顯然從源碼看兩者基本上可以等價起來,前者只是幫助我們簡化了一個步驟

Signal 的發送
signal 創建好了之后,接下來就是使用了,使用很簡單通過調用 send() 函數.需要注意的是,官方文檔給了一個建議:
Try to always pick a good sender. If you have a class that is emitting a signal, pass self as sender. If you are emitting a signal from a random function, you can pass current_app._get_current_object() as sender.
也就說明我們在實際使用過程中,最好將 send() 函數的第一個參數為 signal 的發送者

1.在類中發送者(sender) 為 self

class Model(object):def save(self):model_saved.send(self)

1.在函數中發送者(sender) 為 current_app._get_current_object()

def save():model_saved.send(current_app._get_current_object())

發送完消息,消息需要有人看,自然需要訂閱者了.
Signal 的訂閱
訂閱指定的 signal 可以通過使用 connect() 函數,當通過 send() 發送 signal 時,會自動觸發這些訂閱者,然后執行相應邏輯,從而完成相應的功能. 使用起來很簡單,只需要給指定的函數加上一個 connect_via 或者 connect 的裝飾器就可以了

# connect_viafrom flask import Flask,current_app app = Flask(__name__)from blinker import Namespace my_signals = Namespace() test = my_signals.signal('test')@test.connect_via(app)def subscriber(sender,**kwargs):print(f'Got a signal sent by {sender},{kwargs}')@app.route('/')def hello_world():test.send(current_app._get_current_object(),data=3)test.send('test')return 'Hello, World!'if __name__ == '__main__':app.run()

讓我們執行一下然后看一下結果:

* Serving Flask app "test" (lazy loading)* Environment: productionWARNING: This is a development server. Do not use it in a production deployment.Use a production WSGI server instead.* Debug mode: on* Restarting with stat* Debugger is active!* Debugger PIN: 326-510-904* Running on http://127.0.0.1:5000/ (Press CTRL+C to quit) Got a signal sent by <Flask 'test'>,{'data': 3} 127.0.0.1 - - [24/Jun/2019 15:07:31] "GET / HTTP/1.1" 200 -

似乎少了依次輸出?別著急,我們修改一下這個例子,使用 connect

# connect@test.connectdef subscriber(sender,**kwargs):print(f'Got a signal sent by {sender},{kwargs}')

再次執行看一下結果

* Serving Flask app "test" (lazy loading)* Environment: productionWARNING: This is a development server. Do not use it in a production deployment.Use a production WSGI server instead.* Debug mode: on* Restarting with stat* Debugger is active!* Debugger PIN: 326-510-904* Running on http://127.0.0.1:5000/ (Press CTRL+C to quit) Got a signal sent by <Flask 'test'>,{'data': 3} Got a signal sent by test,{} 127.0.0.1 - - [24/Jun/2019 15:10:43] "GET / HTTP/1.1" 200 -

connect_via 和 connect
從上面最后一次輸出,不難發現輸出兩次了,為什么第一次的時候只輸出了一次呢? 很顯然這就是 connect_via 和 connect 的區別,從上面的例子,我們不難看到, connect_via 多了一個參數,這個參數就是 sender,使用 connect 的訂閱方式并不支持訂閱指定的發布者,如果我們需要訂閱指定的發布者需要使用 connect_via(sender)
最后
Signals 是個好東西,大家應該學會使用它.

總結

以上是生活随笔為你收集整理的浅谈flask的发布订阅的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。