快捷導(dǎo)航

深入理解Django的信號(hào)機(jī)制

更新時(shí)間：2023年02月08日 10:12:16 作者：eaglecolin

本文主要介紹了深入理解Django的信號(hào)機(jī)制，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

Django的信號(hào)

Django的信號(hào)機(jī)制不同于Linux的信號(hào)機(jī)制，Django 中的信號(hào)用于在框架執(zhí)行操作時(shí)解耦。當(dāng)某些動(dòng)作發(fā)生的時(shí)候，系統(tǒng)會(huì)根據(jù)信號(hào)定義的函數(shù)執(zhí)行相應(yīng)的操作

Django的信號(hào)主要包含以下三個(gè)要素：

發(fā)送者（sender）：信號(hào)的發(fā)出方。
信號(hào)（signal）：發(fā)送的信號(hào)本身。
接收者（receiver）：信號(hào)的接收者。

其中接受者就是回調(diào)函數(shù)，會(huì)把這個(gè)函數(shù)注冊(cè)到信號(hào)之上。當(dāng)特定事件發(fā)生之后，發(fā)送者發(fā)送信號(hào)，然后執(zhí)行回調(diào)函數(shù)。

Django信號(hào)的使用

查看Django Signal的源碼，看到Django的信號(hào)存在以下方法

除了上面的幾個(gè)方法，還有幾個(gè)屬性

lock
recievers
sender_receivers_cache
use_caching

根據(jù)第一趴介紹知道，要使用Django的信號(hào)，需要滿足三要素（發(fā)送者、接受者、和信號(hào)）

Django通過(guò)connect() 函數(shù)監(jiān)聽(tīng) 信號(hào)，接受發(fā)送者發(fā)送的信號(hào)，然后執(zhí)行接受者(回調(diào)函數(shù))

Signal.connect(receiver, sender=None, weak=True, dispatch_uid=None)

其中

recievers 是接受者，本質(zhì)就是一個(gè)回調(diào)函數(shù)
sender 是發(fā)送信號(hào)的主體，如果connect連接的時(shí)候，sender 是None（默認(rèn)也是None）代表該信號(hào)接受所有發(fā)送者發(fā)送的該信號(hào)；否則只接受具體的發(fā)送者（一個(gè)Python對(duì)象，比如Django的 Model對(duì)象）
weak – Django 默認(rèn)將信號(hào)處理程序存儲(chǔ)為弱引用。因此，如果你的接收器是本地函數(shù)，則可能會(huì)對(duì)其進(jìn)行垃圾回收。要防止這種情況發(fā)生，當(dāng)你要調(diào)用 connect() 方法時(shí)請(qǐng)傳入 weak=False。
dispatch_uid 在可能發(fā)送重復(fù)信號(hào)的情況下，信號(hào)接收器的唯一標(biāo)識(shí)符。

具體使用方式

1、需要定義一個(gè)回調(diào)函數(shù)

def my_callback(sender, **kwargs):
    print("Request finished!")

2、把回調(diào)函數(shù) 注冊(cè)到對(duì)應(yīng)的信號(hào)

from django.core.signals import request_finished
request_finished.connect(my_callback)

注意這里沒(méi)有指定sender，那么就是接受任意發(fā)送者哦

或者更簡(jiǎn)單的方式是使用 receiver 函數(shù)

from django.core.signals import request_finished
from django.dispatch import receiver

@receiver(request_finished)
def my_callback(sender, **kwargs):
    print("Request finished!")

或者指定具體的發(fā)送者

from django.core.signals import request_finished
from django.dispatch import receiver

@receiver(request_finished, sender="MyTagModel")
def my_callback(sender, **kwargs):
    print("Request finished!")

==> 劃重點(diǎn)

一般我們會(huì)把 回調(diào)函數(shù) 和 信號(hào)注冊(cè) 放到一個(gè)應(yīng)用的目錄下的 signals.py 文件中去

然后在該應(yīng)用的 apps.py 中應(yīng)用

from django.apps import AppConfig
from django.core.signals import request_finished

class MyAppConfig(AppConfig):
    ...

    def ready(self):
        # Implicitly connect signal handlers decorated with @receiver.
        from . import signals
        # Explicitly connect a signal handler.
        request_finished.connect(signals.my_callback)

這樣只要改應(yīng)用安裝在 INSTALLED_APPS 中去，那么Django就能識(shí)別到具體的信號(hào)（包括自定義的信號(hào)）以及進(jìn)行信號(hào)的處理（因?yàn)橐呀?jīng)自動(dòng)通過(guò) connect進(jìn)行監(jiān)聽(tīng) ）

為啥會(huì)自動(dòng)監(jiān)聽(tīng)呢，當(dāng)然是 Django的 AppConfig 下的 ready() 函數(shù)的作用

自定義信號(hào)

首先有個(gè)核心點(diǎn)需要明確

所有的信號(hào)都是 django.dispatch.Signal 的實(shí)例。

比如這里新增一個(gè)發(fā)送郵件的信號(hào)，每次新增Post之后，發(fā)送郵件給相關(guān)訂閱的人

# demoapp/signals.py
from django.db.models.signals import post_save
from django.dispatch import receiver

from .models import Post

@receiver(post_save, sender=Post)
def send_mail(sender, instance, created, **kwargs):
	if created:
		print(f"current instance {instance}")
		print("Try to send mail to subscriber")

然后把信號(hào)導(dǎo)入到 appConfig 的ready() 函數(shù)中去

# demoapp/apps.py

from django.apps import AppConfig


class DemoappConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'demoapp'

    def ready(self):
        import demoapp.signals

然后我們?cè)赼dmin注冊(cè)Post之后，新增Post，在命令行日志中就能看到

current instance DemoPost First One
Try to send mail to subscriber
[02/Feb/2023 13:47:29] "POST /admin/demoapp/post/add/ HTTP/1.1" 302 0

還有另外一個(gè) 主動(dòng)發(fā)送信號(hào)的方式

1、先定義回調(diào)函數(shù) callback_func

2、定義一個(gè)信號(hào) mail_send_signal = Signal()

3、回調(diào)函數(shù)注冊(cè)到信號(hào) mail_send_signal.connect(callback_func)

3、主動(dòng)發(fā)送信號(hào) mail_send_signal.send(sender=xxx, **kwargs)

具體的代碼實(shí)現(xiàn)，可以手動(dòng)嘗試哦，實(shí)踐出真知嘛~

擴(kuò)展：查看Django信號(hào)的接受者

Django內(nèi)置信號(hào)的reciever查看

(kfzops) [ 23-02-02 16:04 ] [ colinspace.com ] python manage.py shell
Python 3.9.6 (default, Jul 16 2021, 13:41:17)
[Clang 12.0.5 (clang-1205.0.22.11)] on darwin
Type "help", "copyright", "credits" or "license" for more information.
(InteractiveConsole)
>>> from django.db.models.signals import post_migrate
>>> post_migrate.receivers
[(('django.contrib.auth.management.create_permissions', 4304618416), <weakref at 0x10232b310; to 'function' at 0x10231d1f0 (create_permissions)>), ((4331786592, 4304618416), <weakref at 0x102581e00; to 'function' at 0x10231d160 (create_contenttypes)>)]