django-generic-websocket-project

a generic websocket
一个非常通用的websocket项目

Install

# 默认使用内存 channel layer，不需要 redis server
git clone git@github.com:ramwin/django-generic-websocket-project.git
cd django-generic-websocket-project
pip3 install -r ./requirements.txt

channel layer（默认不需要 redis）

默认 CHANNEL_LAYER_BACKEND=memory（见 .env.shared），消息在当前进程内广播：不需要 redis 服务，也不需要 channels_redis，python3 manage.py runserver 7420 直接就能跑。

多实例部署（deploy/supervisor.conf 的 3 个 daphne、docker compose 扩副本）必须换成 redis，否则实例 A 推送的消息，连在实例 B 上的客户端收不到：

# .env 或 .env.shared（.env 优先级更高）
CHANNEL_LAYER_BACKEND=redis
WEBSOCKET_REDIS_HOST=localhost
WEBSOCKET_REDIS_PORT=6379

pip3 install channels_redis   # 需要同时安装这个包

其他说明：

启动了 memory 后端时，服务启动日志里会有一条 WARNING 提醒单进程限制
配置值只能是 memory 或 redis，写错了启动时会直接报 ImproperlyConfigured
项目里 .env / .env.shared 的优先级高于进程环境变量，Docker 的 environment 覆盖不生效

Usage

# in terminal 1
python3 manage.py runserver 7420

# in terminal 2
python3 test_send_message.py

# in terminal 3
python3 test_receive_message.py

浏览器里查看会话

# 终端 1：启动服务
python3 manage.py runserver 7420

# 浏览器打开（房间名跟推送时用的房间名保持一致）
# http://localhost:7420/ws/generic/room/room_123/

# 终端 2：用 HTTP 接口往这个房间推消息，页面上会立刻出现
curl -X POST http://localhost:7420/ws/generic/send-message/room_123/ \
     -H 'Content-Type: application/json' \
     -d '{"message": "hello"}'

页面里的输入框也可以发消息，会通过 WebSocket 广播给房间内的所有客户端
消息格式不限：有 message 字段就显示这个文本，其余字段以 JSON 附在下面；没有 message 字段就整体格式化输出
需要鉴权时把 token 放在页面地址上，会透传给 WebSocket：http://localhost:7420/ws/generic/room/room_123/?token=token123
房间名只能包含字母/数字/下划线（和 WebSocket 路由 (?P<room_name>\w+) 一致）
连接断开（比如服务重启）后页面会指数退避自动重连
页面模板：generic/templates/generic/room.html，HTML 和 JS 全部内联，不依赖静态文件服务

Deploy

change project/settings.py

DEBUG = False
ALLOWED_HOSTS = [<your hostname>]

run command

replace example.com with your hostname
daphne -b <example.com> -p <port> wsbackend.asgi:application

load balance

use deploy/supervisor.conf to run multi instance
use deploy/nginx/websocket.ramwin.com to loadbalance
多实例必须设置 CHANNEL_LAYER_BACKEND=redis 并安装 channels_redis，否则跨实例收不到消息

ramwin/django-generic-websocket-project