关于Django Channels实现一对一用户私聊的技术咨询

无需创建群组的直接一对一对话 #

完全可以不依赖群组实现一对一对话，核心是通过用户唯一标识绑定专属WebSocket通道，定向发送消息：

• 用户连接时，将其通道与自身ID关联：
  在WebSocket消费者的connect方法中，把当前用户的channel_name加入以用户ID命名的专属组（仅该用户可加入）：

  from channels.layers import get_channel_layer
  from asgiref.sync import async_to_sync
  import json
  
  class ChatConsumer(AsyncWebsocketConsumer):
      async def connect(self):
          self.user = self.scope['user']
          if self.user.is_authenticated:
              self.user_group_name = f"user_{self.user.id}"
              # 将当前通道加入用户专属组
              await self.channel_layer.group_add(
                  self.user_group_name,
                  self.channel_name
              )
              await self.accept()
  
      async def disconnect(self, close_code):
          # 用户断开时移除组关联
          await self.channel_layer.group_discard(
              self.user_group_name,
              self.channel_name
          )
  

• 定向发送消息给目标用户：
  发送时直接指定目标用户的专属组名，调用group_send推送消息，只有该用户在线时能收到：

  async def send_private_message(self, target_user_id, content):
      target_group_name = f"user_{target_user_id}"
      await self.channel_layer.group_send(
          target_group_name,
          {
              'type': 'private_message',
              'content': content,
              'sender_id': self.user.id
          }
      )
  
  async def private_message(self, event):
      # 将消息推送到前端
      await self.send(text_data=json.dumps({
          'content': event['content'],
          'sender_id': event['sender_id']
      }))
  

这种方式相当于给每个用户创建了一个"隐形专属群"，仅本人能加入，无需对方主动操作，直接实现定向对话。

群组方案的优化（解决权限与主动加入问题） #

如果想用群组，可通过权限校验限制成员，且无需对方主动申请加入：

• 创建对话模型记录双方：
  先定义一个Dialog模型存储对话双方：

  from django.db import models
  from django.contrib.auth.models import User
  
  class Dialog(models.Model):
      user1 = models.ForeignKey(User, on_delete=models.CASCADE, related_name='dialogs_as_user1')
      user2 = models.ForeignKey(User, on_delete=models.CASCADE, related_name='dialogs_as_user2')
  

• 连接时校验成员身份：
  在WebSocket连接时，通过URL参数获取对话ID，校验当前用户是否为对话成员，仅允许成员加入群组：

  async def connect(self):
      self.user = self.scope['user']
      self.dialog_id = self.scope['url_route']['kwargs']['dialog_id']
      dialog = await sync_to_async(Dialog.objects.get)(id=self.dialog_id)
      
      # 仅对话双方可加入群组
      if self.user in [dialog.user1, dialog.user2]:
          self.dialog_group_name = f"dialog_{self.dialog_id}"
          await self.channel_layer.group_add(
              self.dialog_group_name,
              self.channel_name
          )
          await self.accept()
      else:
          await self.close()
  

当user2打开该对话页面时，会自动加入对应群组，你发送消息到这个群组，只有对方能收到，且其他人无法加入。

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