Django Channels如何避免RuntimeError: Task关联不同事件循环异常？

问题场景 #

使用Django Channels搭配RedisChannelLayer实现实时消息推送，通过post_save信号触发推送逻辑。首次消息可成功发送并在前端JS控制台接收，但后续Socket连接会断开，抛出异常：

RuntimeError: Task got Future attached to a different loop

异常堆栈指向redis/asyncio/connection.py:831。项目同时集成DRF、Celery（基于Redis）、Redis及Daphne服务器，当前在Debug=True模式下测试。

问题原因 #

核心问题是模块级别提前初始化的channel_layer实例绑定了固定事件循环。当信号被Celery worker或其他异步进程触发时，当前执行环境的事件循环与channel_layer实例绑定的初始循环不一致，导致异步任务执行时出现循环不匹配错误。

原代码中在signals.py模块加载时就调用get_channel_layer()获取全局实例，这个实例会绑定模块加载时的事件循环；而信号可能在不同线程/进程中触发，使用的是全新的事件循环，两者冲突引发异常。

解决方法 #

将channel_layer的获取从模块级别移到信号处理函数内部，每次触发信号时动态获取实例，确保实例绑定当前执行环境的事件循环。

修正后代码 #

signals.py（修正版） #

# signals.py
from django.db.models.signals import post_save
from django.dispatch import receiver
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
from .models import Like

@receiver(post_save, sender=Like)
def new_like(sender, instance, **kwargs):
    # 每次触发信号时动态获取channel_layer，绑定当前事件循环
    channel_layer = get_channel_layer()
    async_to_sync(channel_layer.group_send)(
        'likes',
        {
            "type": "chat_message", 
            "message": f"{instance.user.username} 点赞了内容ID: {instance.content.id}"
        }
    )

consumers.py（无需修改） #

# consumers.py
import json
from channels.generic.websocket import AsyncWebsocketConsumer

class LikeConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.room_group_name = "likes"
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )
        await self.accept()
    
    async def chat_message(self, event):
        message = event['message']
        await self.send(text_data=json.dumps({
            'type': 'chat',
            'message': message
        }))

script.js（无需修改） #

// script.js
const likeSocket = new WebSocket(url);
likeSocket.onmessage = function(e) {
  let data = JSON.parse(e.data);
  console.log(data);
};

额外注意事项 #

• 确保使用Daphne作为ASGI服务器启动项目，Debug模式下runserver可临时兼容，但生产环境必须使用Daphne
• Celery与Channels的Redis连接配置需保持一致，避免连接池冲突
• 多进程部署时，需为channel_layer配置唯一的Redis键前缀，防止不同进程的通道消息混淆

内容的提问来源于stack exchange，提问作者ruslanway