### 如何在 Django 中集成和使用 WebSocket 实现实时通信 #### 创建 WebSocket 消费者 (Consumer) 为了使 Django 应用能够处理 WebSocket 连接，需要定义一个或多个消费者类。这些消费者负责监听并响应来自客户端的 WebSocket 请求。 ```python from channels.generic.websocket import AsyncWebsocketConsumer import json class ChatConsumer(AsyncWebsocketConsumer): async def connect(self): await self.accept() async def disconnect(self, close_code): pass async def receive(self, text_data=None, bytes_data=None): text_data_json = json.loads(text_data) message = text_data_json['message'] # 发送消息给 WebSocket 客户端 await self.send(text_data=json.dumps({ 'message': message })) ``` 此代码片段展示了 `ChatConsumer` 类是如何继承自 `AsyncWebsocketConsumer` 并实现了三个主要方法：`connect()`、`disconnect()` 和 `receive()`. 当新的 WebSocket 链接建立时会调用 `connect()` 方法；当链接断开时则触发 `disconnect()` 方法；而每当服务器收到来自客户端的数据包就会执行 `receive()` 函数[^2]. #### 前端 JavaScript 与 WebSocket 的交互 为了让浏览器能同上述后端逻辑互动，在 HTML 页面里需加入一段简单的 JS 脚本来初始化 Web Socket 对象并与之通讯： ```html <script> const socket = new WebSocket('ws://' + window.location.host + '/ws/chat/'); // 监听消息接收事件 socket.onmessage = function(e) { const data = JSON.parse(e.data); console.log('Message from server ', data.message); }; // 向服务端发送消息 function sendMessage(message){ socket.send(JSON.stringify({ 'message': message })); } </script> ``` 这段脚本首先创建了一个指向特定 URL 的 WebSocket 实例，并设置了回调函数用于处理从服务器传来的信息。另外还有一个辅助性的 `sendMessage` 函数用来向服务器推送新消息. #### 使用路由配置将请求导向至相应的 Consumer 最后一步是在项目的根目录下找到名为 `routing.py` 文件（如果没有的话就新建），然后添加如下所示的内容以便把所有匹配路径 `/ws/chat/` 的 WebSocket 请求都交给之前定义好的 `ChatConsumer`. ```python from django.urls import re_path from .consumers import ChatConsumer websocket_urlpatterns = [ re_path(r'ws/chat/$', ChatConsumer.as_asgi()), ] ``` 以上就是关于如何在 Django 中设置 WebSocket 功能的一个基本指南[^1].