Django 频道实时聊天保存发送的消息

Posted 2023-03-14

【中文标题】Django 频道实时聊天保存发送的消息

【英文标题】：Django channels live chat save sent messages

【发布时间】：2020-10-10 03:32:14

【问题描述】：

所以我有一个 Django 应用程序，我在其中使用频道来实现实时聊天。我的消费者看起来像这样：

导入 json 从 asgiref.sync 导入 async_to_sync 从 channels.generic.websocket 导入 WebsocketConsumer

class ChatConsumer(WebsocketConsumer):
    def connect(self):
        self.room_name = self.scope['url_route']['kwargs']['room_name']
        self.room_group_name = 'chat_%s' % self.room_name
        # Join room group
        async_to_sync(self.channel_layer.group_add)(
            self.room_group_name,
            self.channel_name
        )

        self.accept()

    def disconnect(self, close_code):
        # Leave room group
        async_to_sync(self.channel_layer.group_discard)(
            self.room_group_name,
            self.channel_name
        )

    # Receive message from WebSocket
    def receive(self, text_data):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']
        username = self.scope["user"]
        # Send message to room group
        async_to_sync(self.channel_layer.group_send)(
            self.room_group_name,
            
                'type': 'chat_message',
                'message': message,
                'user': username.username
            
        )

    # Receive message from room group
    def chat_message(self, event):
        message = event['message']
        user=event['user']
        print(user)
        # Send message to WebSocket
        self.send(text_data=json.dumps(
            'message': message,
            'user':user
        ))

所以我正在寻找一种方法来保存已发送的消息（因为目前它们在刷新时会丢失）。我创建了一个 Messages 模型，其中有一个用于消息文本的 CharField。如果我在我的 chat_message 函数中这样做，我想我可以保存新消息：

new_message=Messages(text=message)
new_nessage.save()

我的问题是如何在用户连接到聊天时预加载最后 10 条消息？

【问题讨论】：

我建议在建立连接后创建一个 ajax 调用。还存储新消息的时间戳，然后在使用 Messages.objects.filter()[:10] 之类的过滤器时对最后十个进行切片。

我对一般的编码真的很陌生。我已经考虑过最后 10 条消息的切片，并且我想使用 Messages.objects.order_by(*我要添加到模型中的日期字段)[:10] 来完成它。但是，您能否解释另一部分 - ajax 调用（当然，如果您有空闲时间）。如果您没有时间解释，也非常感谢您提供有关此 ajax 调用的教程链接！

您在模板中定义 WebSocket 的位置。创建一个函数 socket.addEventListener('open', function (event) （此处为文档 - developer.mozilla.org/en-US/docs/Web/API/WebSocket/onopen）。然后在函数内部创建一个使用通道组 id (WebSocket.url) 回调到服务器的 ajax。然后在您的views.py 中过滤您的消息并返回JSONResponse。如何做 AJAX 在这里 (simpleisbetterthancomplex.com/tutorial/2016/08/29/…)。然后可以将ajax成功的数据加载到您的html中。

嘿。所以我现在有一个新问题。在 chat_message 函数中，我正在执行以下操作： new_message=Message(sender=myUser, rec=otherUser, text=message, room=getIDS) new_message.save() 但是现在每条消息都会保存两次 - 聊天室中的每个用户保存 1 次.我该如何解决这个问题？

没关系，修复它 - 只是将代码移动到接收函数

【参考方案1】：

因此，为了做到这一点，我最终在“接收”功能中将我的消息保存到数据库中（因为如果你将它保存在 chat_message 中，它会为每个活动用户保存 1 次）。然后为了预加载消息，我每次打开 websocket 时都使用 AJAX 调用，以便使用 python 函数获取 10 条最新消息，然后我将消息作为 JsonResponse 传回（https://simpleisbetterthancomplex.com/tutorial/2016/08/29/how-to-work-with-ajax-request-with-django.html 向下滚动到 AJAX 请求本文的一部分，并按此顺序查看 signup.html、urls.py 和 views.py 文件以供参考）。

【讨论】：

不错！ blog.heroku.com/… 有一个很好的例子来说明如何做到这一点。