Django和websocket实现简单的多人聊天的示例代码
更新时间：2025年01月10日 10:02:28 作者：jjw_zyfx
本文主要介绍了使用Django和WebSocket实现一个简单的多人聊天应用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
1、版本及环境 python 为3.9.12, django为4.2详细信息如下：
asgiref 3.8.1
attrs 24.2.0
autobahn 24.4.2
Automat 24.8.1
cffi 1.17.1
channels 3.0.3
constantly 23.10.4
cryptography 44.0.0
daphne 3.0.2
Django 4.2
hyperlink 21.0.0
sqlparse 0.5.3
tomli 2.2.1
Twisted 24.11.0
txaio 23.1.1
typing_extensions 4.12.2
tzdata 2024.2
zope.interface 7.2
Django安装指定版本(上边的安装包也有可能安装多了，但必须要有python，Django, channels)
pip install django==4.2 -i https://pypi.tuna.tsinghua.edu.cn/simple
2、创建Django项目
django-admin startproject ws_demo python manage.py startapp app01
3、安装channels
pip install channels==3.0.3 -i -i https://pypi.tuna.tsinghua.edu.cn/simple
4、项目整体目录结构如下：
5、配置setting文件
INSTALLED_APPS = [
'django.contrib.admin',
'django.contrib.auth',
'django.contrib.contenttypes',
'django.contrib.sessions',
'django.contrib.messages',
'django.contrib.staticfiles',
"channels", # 添加channels
"app01.apps.App01Config" # 添加app01
]
# 在setting最后添加一个 "ws_demo.asgi.application" 意思是"项目名称.asgi文件.application变量名称"
ASGI_APPLICATION = "ws_demo.asgi.application"
6、asgi.py文件中的内容如下；
import os
from channels.routing import ProtocolTypeRouter, URLRouter
# from django.conf.urls import url
# from chat import consumers
from django.core.asgi import get_asgi_application
from . import routings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'ws_demo.settings')
# application = get_asgi_application()
application = ProtocolTypeRouter({
"http": get_asgi_application(),
'websocket': URLRouter(routings.websocket_urlpatterns)
})
7、新建routings.py文件，其内容如下：
from django.urls import re_path
from app01 import consumers
websocket_urlpatterns = [
# 示例 url ： xxxxx/room/x1/
re_path(r"room/(?P<group>\w+)/$", consumers.ChatConsumer.as_asgi())
]
8、ws_demo下的urls.py中的内容如下：
from django.contrib import admin
from django.urls import path
from app01 import views
urlpatterns = [
# path("admin/", admin.site.urls),
path('index/', views.index),
]
9、在app01应用下新建templates目录，并在其下新建index.html,其内容如下：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
<style>
.message {
height: 300px;
border: 1px solid #dddddd;
width: 100%;
}
</style>
</head>
<body>
<div class="message" id="message"></div>
<div>
<input type="text" placeholder="请输入" id="txt">
<input type="button" value="发送" onclick="sendMsg()">
<input type="button" value="关闭连接" onclick="closeConn()">
<input type="button" value="重新建立连接" onclick="connect()">
</div>
<script>
var socket = null;
function connect() {
socket = new WebSocket("ws:/127.0.0.1:8000/room/123/");
// 连接完成以后 客户端自动触发
socket.onopen = function (event) {
let tag = document.createElement("div")
tag.innerHTML = "连接已建立"
document.getElementById("message").appendChild(tag)
}
// 回调函数 当服务端有消息发送到时，自动触发
socket.onmessage = function (event) {
console.log(event.data);
let tag = document.createElement("div");
tag.innerText = event.data;
document.getElementById("message").appendChild(tag)
}
// 当连接关闭时，触发
socket.onclose = function (event) {
let tag = document.createElement("div")
tag.innerHTML = "连接已断开"
document.getElementById("message").appendChild(tag)
}
}
function sendMsg() {
let tag = document.getElementById("txt")
socket.send(tag.value)
}
function closeConn() {
// 向服务端发送断开连接
socket.close();
}
connect()
</script>
</body>
</html>
10、在app01应用下新建consumers.py文件其内容如下：
from channels.generic.websocket import WebsocketConsumer
from channels.exceptions import StopConsumer
# 简单版群聊就是定义个数组，并在连接时把对象添加到数组内，在断开链接时移除对象
CONN_LIST = []
class ChatConsumer(WebsocketConsumer): # 继承WebsocketConsumer
def websocket_connect(self, message):
print("有人进行连接了。。。。")
CONN_LIST.append(self)
# 有客户端向后端发送 WebSocket 连接的请求时，自动触发(握手)
self.accept()
def websocket_receive(self, message):
# 浏览器基于 WebSocket 向后端发送数据，自动触发接收消息
print(message)
# 一对一聊天
# if message["text"] == "close":
# self.send("服务端主动关闭连接")
# # 服务端主动关闭连接
# self.close()
# self.send(message["text"])
for conn in CONN_LIST:
conn.send(message["text"])
def websocket_disconnect(self, message):
# 客户端向服务端断开连接时，自动触发
CONN_LIST.remove(self)
print("连接断开！！")
raise StopConsumer()
11、运行项目 在项目根目录下执行：
python manage.py runserver
12、至此即可在浏览器中进行简单的多人聊天，结果如下：
到此这篇关于Django和websocket实现简单的多人聊天的示例代码的文章就介绍到这了,更多相关Django websocket多人聊天内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
很多小伙伴在提到python数据可视化的时候第一反应就是matplotlib库,但实际上python还有很多很好用的数据可视化的库,下面这篇文章主要给大家介绍了关于如何利用Python抓取数据并可视化的相关资料,需要的朋友可以参考下2022-05-05
Pandas是Python中用于数据分析和处理的强大库,它提供了丰富的功能,可以轻松地处理各种类型的数据,在实际应用中,我们经常需要对数据进行复杂的转换、计算或聚合操作,而这些操作往往不能仅靠Pandas内置的函数完成,这时,自定义函数就显得尤为重要2025-01-01
webargs是一个用于解析和验证HTTP请求对象的Python库，今天通过本文给大家介绍Python webargs 模块的安装使用，感兴趣的朋友一起看看吧2022-01-01
今天小编就为大家分享一篇用Python实现最速下降法求极值的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-07-07
MoviePy是一个基于Python的视频编辑库,它提供了创建、编辑、合并、剪辑和转换视频的功能,所以本文主要介绍如何使用moviepy来分割音频流并降低码率,感兴趣的可以了解下2023-08-08
这篇文章主要为大家详细介绍了python3中的类继承，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助2022-03-03
这篇文章主要介绍了 python 中的 module 和 package ，文章基于Python的相关资料展开对主题的详细介绍，具有一定的参考价值，需要的小伙伴可以参考一下2022-04-04
这篇文章主要为大家详细介绍了39条Python语句实现数字华容道，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-04-04
今天小编就为大家分享一篇Python+PyQT5的子线程更新UI界面的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-06-06
这篇文章主要介绍了python 画出使用分类器得到的决策边界，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-08-08
最新评论