Django Channels 自定义内存层与广播模式

不依赖 Redis，实现纯内存 Channel Layer 并构建实时聊天去中心化方案。 · 难度：入门 · +10XP

Django Channels 自定义内存层与广播模式

绝大多数 Channels 教程依赖 Redis 作为 channel layer，这增加了运维复杂度。本课教你基于 asgiref 的 ChannelLayer 接口，实现一个进程内内存层，适用于单进程或开发/测试环境。同时讲解 group_send 的广播原理，以及如何在不使用外部存储的情况下协调多个消费者实例。

# channel_layers.py
from channels.layers import BaseChannelLayer
class InMemoryLayer(BaseChannelLayer):
    def __init__(self, expiry=60, **kwargs):
        super().__init__(expiry=expiry)
        self.channels = {}
        self.groups = {}
    async def send(self, channel, message):
        self.channels.setdefault(channel, []).append(message)
    async def receive(self, channel):
        if channel in self.channels and self.channels[channel]:
            return self.channels[channel].pop(0)
        else:
            return None