Django Channels问题：循环调用Group.send()时客户端仅收到一条消息

我之前也碰到过一模一样的坑！咱们一步步拆解问题、解决它：

你遇到的情况大概率是事件循环被阻塞或者Channels API使用方式不对，导致循环里的消息要么堆积到最后才一次性发送，要么被覆盖只留下最后一条。下面是针对性的解决方案：

1. 先纠正Group发送的API用法（Channels 3.x+版本） #

如果你用的是较新的Channels版本，已经不再推荐直接使用Group.send()了，而是要用channel_layer.group_send，而且要确保异步调用的正确性：

正确的Consumer写法（异步版） #

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

class TestProgressConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        # 定义专属的进度通知群组
        self.progress_group = "test_execution_progress"
        
        # 将当前WebSocket连接加入群组
        await self.channel_layer.group_add(
            self.progress_group,
            self.channel_name
        )
        await self.accept()

    async def disconnect(self, close_code):
        # 断开连接时移除群组
        await self.channel_layer.group_discard(
            self.progress_group,
            self.channel_name
        )

    # 自定义消息处理方法，对应发送时的type字段
    async def send_progress_update(self, event):
        progress_data = event["data"]
        # 发送消息到客户端
        await self.send(text_data=json.dumps(progress_data))

2. 把测试任务从Consumer中剥离，用异步任务队列执行 #

绝对不要在Consumer里直接跑耗时的测试任务！这会完全阻塞Channels的事件循环，导致消息根本发不出去。建议用Celery（或者Django 4.2+的内置异步任务）来执行测试，在任务中实时发送进度：

测试任务中的进度发送逻辑 #

# tasks.py（假设用Celery）
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
import time

@shared_task
def run_selected_tests(selected_cases):
    channel_layer = get_channel_layer()
    total = len(selected_cases)
    completed = 0

    for case in selected_cases:
        # 执行单个测试用例
        execute_test_case(case)
        
        completed += 1
        progress = {
            "completed": completed,
            "total": total,
            "current_case": case.name,
            "status": "success"  # 可以根据测试结果动态修改
        }

        # 发送进度到群组
        async_to_sync(channel_layer.group_send)(
            "test_execution_progress",
            {
                "type": "send_progress_update",  # 对应Consumer里的方法名
                "data": progress
            }
        )
        # 给事件循环留处理时间，避免消息堆积
        time.sleep(0.1)

3. 前端确保正确接收所有消息 #

有时候不是后端没发，是前端处理逻辑有问题（比如每次收到消息都替换内容而不是追加）：

// 前端WebSocket代码
const socket = new WebSocket(`ws://${window.location.host}/ws/test-progress/`);

socket.onmessage = function(e) {
    const progress = JSON.parse(e.data);
    // 追加进度内容，而不是覆盖
    const progressElement = document.getElementById("progress-container");
    progressElement.innerHTML += `<p>已完成 ${progress.completed}/${progress.total}：${progress.current_case}</p>`;
};

关键注意事项 #

• 如果你用的是同步Consumer，一定要避免在里面做任何阻塞操作，所有耗时任务必须丢到异步队列。
• 发送消息时的type字段必须和Consumer中定义的方法名完全匹配（比如send_progress_update），否则消息会被忽略。
• 可以给每个用户创建独立的群组（比如用用户ID作为群组名），避免不同用户的进度消息互相干扰。

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