实现Django Channels用户专属消息：正确使用Group进行定向通信

import json
from channels.generic.websocket import AsyncWebsocketConsumer
from asgiref.sync import async_to_sync

class ChatGenericAsyncConsumer(AsyncWebsocketConsumer):
    """这是一个异步消费者，用于处理用户连接和消息。"""

    async def connect(self):
        self.user = self.scope["user"]

        if self.user.is_authenticated:
            print(f"认证成功，接受连接，用户：{self.user.username}")

            # 获取当前连接的用户名作为其专属组名
            self.username = str(self.user.username) 

            # 注意：self.channel_name 是由Channels自动分配的，不可手动设置。
            # 我们将这个自动生成的 channel_name 加入到以用户名为名的专属组中。
            # group_add 是异步方法，需要使用 await
            await self.channel_layer.group_add(
                self.username,  # 使用用户名作为组名
                self.channel_name # 将当前连接的 channel_name 加入该组
            )

            await self.accept()
        else:
            print("认证失败，连接关闭")
            await self.close(code=4001) # 使用更标准的错误码，如 4001 表示认证失败

    async def receive(self, text_data=None, bytes_data=None):
        # 此处可以处理接收到的消息，例如转发给其他用户或群组
        pass

    async def disconnect(self, code):
        # 用户断开连接时，将其 channel_name 从其专属组中移除
        await self.channel_layer.group_discard(
            self.username,
            self.channel_name
        )
        print(f"用户 {self.username} 断开连接，代码：{code}")
        # disconnect 方法中通常不需要再次调用 close，Channel Layer 会自动处理连接关闭

    # 这个方法是 'chat.message' 事件的处理函数
    async def chat_message(self, event):
        """
        处理从 channel layer 接收到的 'chat.message' 事件，
        并将消息发送给客户端。
        """
        print(f"收到事件: {event['data']}")
        await self.send(text_data=event["data"])

import json
from rest_framework.decorators import api_view, permission_classes
from rest_framework.permissions import AllowAny
from rest_framework.response import Response
from rest_framework import status
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

@api_view(["POST"])
@permission_classes([AllowAny])
def send_message_from_admin(request): # 移除 group_name 参数，因为我们按 username 发送
    try:
        message = request.data.get("message")
        username = request.data.get("username") # 目标用户的用户名

        if not username or not message:
            return Response(
                {"error": "Username and message are required."},
                status=status.HTTP_400_BAD_REQUEST
            )

        channel_layer = get_channel_layer()

        send_data = {"user": "Admin", "message": message}

        # 使用 channel_layer.group_send 向指定用户名的组发送消息
        async_to_sync(channel_layer.group_send)(
            username,  # 组名就是目标用户的用户名
            {"type": "chat.message", "data": json.dumps(send_data)}
        )

        return Response(
            {"message": f"消息已发送给用户: {username}"}, 
            status=status.HTTP_200_OK
        )

    except Exception as e:
        print(f"发送消息时发生异常: {e}")
        return Response({"error": str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)