信号驱动的消息中间件:解耦业务与通知
利用 Django 信号(Signal)设计一套松耦合的消息中间件,实现业务逻辑与邮件、短信、WebSocket 通知的完全分离。 · 难度:入门 · +10XP
信号驱动的消息中间件:解耦业务与通知
传统教程常将邮件发送直接写在视图里,导致业务与通知紧耦合。本教程将创建自定义信号(如 order_created),并实现一个消息中间件类,通过注册信号监听器统一处理邮件、短信、站内信等。重点讲解信号的安全使用、避免重复触发、以及如何在中间件中管理消息队列(使用内存队列或 Django 缓存)。最终实现:业务只需发送信号,所有通知行为自动执行。
# signals.py
from django.dispatch import Signal
order_created = Signal()
# handlers.py
def send_order_email(sender, **kwargs):
order = kwargs['order']
# send email logic
# apps.py
from django.apps import AppConfig
class ShopConfig(AppConfig):
def ready(self):
from . import handlers
from .signals import order_created
order_created.connect(handlers.send_order_email)