异步信号链：基于Daphne的跨进程事件驱动架构

超越简单信号监听，讲解如何利用Django异步信号（async_signal）与Redis Pub/Sub构建分布式事件链，实现微服务间实时通知。 · 难度：入门 · +10XP

异步信号链：基于Daphne的跨进程事件驱动架构

Django内置信号是同步的，无法跨进程。本教程将展示如何通过重写Signal.disconnect和connect，包装成异步信号，再结合channels_redis的channel_layer实现跨worker通信。你将学会创建一条‘订单创建→库存锁定→邮件通知’的异步信号链，每个环节独立可重试，并支持死信队列。

from django.dispatch import Signal
import asyncio
async_signal = Signal()
async def async_send(signal, sender, **kwargs):
    for receiver in signal._receivers:
        if asyncio.iscoroutinefunction(receiver):
            await receiver(sender, **kwargs)
        else:
            loop = asyncio.get_event_loop()
            await loop.run_in_executor(None, receiver, sender, **kwargs)