Django Channels收到新消息时如何删除历史消息 仅推送最新消息

首先明确核心逻辑：默认配置下Django Channels本身不会持久化存储任何历史消息，你当前客户端展示所有历史记录的问题，99%是前端WebSocket接收逻辑将所有收到的消息累加渲染导致，和后端Consumer代码无直接关联。

前端修复（优先处理） #

直接修改前端的消息渲染逻辑即可：

• 原错误逻辑大概率为收到新消息后向页面列表追加内容，示例（JS伪代码）：

// 错误写法：累加所有历史
ws.onmessage = function(event) {
  const msg = JSON.parse(event.data)
  const msgItem = document.createElement('div')
  msgItem.innerText = msg.message
  document.getElementById('msg-list').appendChild(msgItem)
}

• 改为直接替换页面的消息展示内容，永远仅显示最新一条：

// 正确写法：仅保留最新
ws.onmessage = function(event) {
  const msg = JSON.parse(event.data)
  document.getElementById('latest-msg-container').innerText = msg.message
}

如果前端有本地存储（localStorage/sessionStorage）缓存历史消息的逻辑，直接删除对应缓存逻辑即可。

后端可选优化（如需严格控制消息有效性） #

如果需要从后端层面确保不会推送任何历史消息、仅保留最新一条，可以增加缓存层做控制，修改后的Consumer代码如下：

# chat/consumers.py
import json
from channels.generic.websocket import AsyncWebsocketConsumer
from django.core.cache import cache

class ProjectConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        parameter = self.scope['url_route']['kwargs']["project_key"]
        print("url_parameter ",parameter)
        
        self.room_name = parameter

        # Join room group
        await self.channel_layer.group_add(
            self.room_name,
            self.channel_name
        )

        await self.accept()

        # 可选：新连接建立时主动推送当前房间最新一条消息
        latest_msg = cache.get(f"latest_msg_{self.room_name}")
        if latest_msg:
            await self.send(text_data=json.dumps(latest_msg))

    async def disconnect(self, close_code):
        # Leave room group
        await self.channel_layer.group_discard(
            self.room_name,
            self.channel_name
        )

    # Receive message from WebSocket
    async def receive(self, text_data):
        text_data_json = json.loads(text_data)

        instance_user = text_data_json['instance_user']
        sender = text_data_json['sender']
        receiver =  text_data_json['receiver']
        message = text_data_json['message']

        msg_object = {
            'sender':sender,
            'receiver':receiver,
            'message':message,
        }
        # 更新缓存：仅存当前房间最新一条消息，过期时间可自定义
        cache.set(f"latest_msg_{self.room_name}", msg_object, timeout=86400)
        # Send message to room group
        await self.channel_layer.group_send(
            self.room_name,
            {
                'type': 'sent',
                'object': msg_object
            }
        )

    # Receive message from room group
    async def sent(self, event):
        sender = event['object']["sender"]
        receiver = event['object']["receiver"]
        message = event['object']["message"]

        # Send message to WebSocket
        await self.send(text_data=json.dumps({
            'sender':sender,
            'receiver':receiver,
            'message':message,
        }))

额外配置说明：如果你使用Redis作为Channel Layer后端，确保配置中没有开启持久化存储消息的参数，默认的RedisChannelLayer配置仅会将消息放在临时队列中，超时自动清理，不会遗留历史消息。

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