扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 精选 >django channels使用、配置及实现群聊的方法
  • 282

0
分享到

django channels使用、配置及实现群聊的方法

2023-06-30 17:06:31 282人浏览 八月长安
摘要

这篇文章主要介绍“Django channels使用、配置及实现群聊的方法”，在日常操作中，相信很多人在djanGo channels使用、配置及实现群聊的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法

这篇文章主要介绍“Django channels使用、配置及实现群聊的方法”，在日常操作中，相信很多人在djanGo channels使用、配置及实现群聊的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”django channels使用、配置及实现群聊的方法”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

1.1websocket原理

Http协议

  • 连接

  • 数据传输

  • 断开连接

WEBSocket协议，是建立在http协议之上的。

  • 连接，客户端发起。

  • 握手（验证），客户端发送一个消息，后端接收到消息再做一些特殊处理并返回。 服务端支持websocket协议。

1.2django框架

django默认不支持websocket，需要安装组件：

pip install channels

配置：

注册channels

INSTALLED_APPS = [    'django.contrib.admin',    'django.contrib.auth',    'django.contrib.contenttypes',    'django.contrib.sessions',    'django.contrib.messages',    'django.contrib.staticfiles',    'channels',]

在settings.py中添加 asgi_application

ASGI_APPLICATION = "ws_demo.asgi.application"

修改asgi.py文件

import osfrom django.core.asgi import get_asgi_applicationfrom channels.routing import ProtocolTypeRouter, URLRouter from . import routing os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'ws_demo.settings') # application = get_asgi_application() application = ProtocolTypeRouter({    "http": get_asgi_application(),    "websocket": URLRouter(routing.websocket_urlpatterns),})

在settings.py的同级目录创建 routing.py

from django.urls import re_path from app01 import consumers websocket_urlpatterns = [    re_path(r'ws/(?P<group>\w+)/$', consumers.ChatConsumer.as_asgi()),]

在app01目录下创建 consumers.py，编写处理处理websocket的业务逻辑。

from channels.generic.websocket import WebsocketConsumerfrom channels.exceptions import StopConsumer  class ChatConsumer(WebsocketConsumer):    def websocket_connect(self, message):        # 有客户端来向后端发送websocket连接的请求时，自动触发。        # 服务端允许和客户端创建连接。        self.accept()     def websocket_receive(self, message):        # 浏览器基于websocket向后端发送数据，自动触发接收消息。        print(message)        self.send("不要回复不要回复")        # self.close()     def websocket_disconnect(self, message):        # 客户端与服务端断开连接时，自动触发。        print("断开连接")        raise StopConsumer()

小结

基于django实现websocket请求，但现在为止只能对某个人进行处理。

2.0 实现群聊

2.1 群聊（一）

前端：

<!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="sendMessage()">    <input type="button" value="关闭连接" onclick="closeConn()"></div> <script>     socket = new WebSocket("ws://127.0.0.1:8000/room/123/");     // 创建好连接之后自动触发（ 服务端执行self.accept() )    socket.onopen = function (event) {        let tag = document.createElement("div");        tag.innerText = "[连接成功]";        document.getElementById("message").appendChild(tag);    }     // 当websocket接收到服务端发来的消息时，自动会触发这个函数。    socket.onmessage = function (event) {        let tag = document.createElement("div");        tag.innerText = event.data;        document.getElementById("message").appendChild(tag);    }     // 服务端主动断开连接时，这个方法也被触发。    socket.onclose = function (event) {        let tag = document.createElement("div");        tag.innerText = "[断开连接]";        document.getElementById("message").appendChild(tag);    }     function sendMessage() {        let tag = document.getElementById("txt");        socket.send(tag.value);    }     function closeConn() {        socket.close(); // 向服务端发送断开连接的请求    } </script> </body></html>

后端：

from channels.generic.websocket import WebsocketConsumerfrom channels.exceptions import StopConsumer CONN_LIST = []  class ChatConsumer(WebsocketConsumer):    def websocket_connect(self, message):        print("有人来连接了...")        # 有客户端来向后端发送websocket连接的请求时，自动触发。        # 服务端允许和客户端创建连接（握手）。        self.accept()         CONN_LIST.append(self)     def websocket_receive(self, message):        # 浏览器基于websocket向后端发送数据，自动触发接收消息。        text = message['text']  # {'type': 'websocket.receive', 'text': '阿斯蒂芬'}        print("接收到消息-->", text)        res = "{}SB".fORMat(text)        for conn in CONN_LIST:            conn.send(res)     def websocket_disconnect(self, message):        CONN_LIST.remove(self)        raise StopConsumer()

2.2 群聊（二）

第二种实现方式是基于channels中提供channel layers来实现。（如果觉得复杂可以采用第一种）

setting中配置 。

CHANNEL_LAYERS = {    "default": {        "BACKEND": "channels.layers.InMemoryChannelLayer",    }}

如果是使用的redis 环境

pip3 install channels-Redis
CHANNEL_LAYERS = {    "default": {        "BACKEND": "channels_redis.core.RedisChannelLayer",        "CONFIG": {            "hosts": [('10.211.55.25', 6379)]        },    },}

consumers中特殊的代码。

from channels.generic.websocket import WebsocketConsumerfrom channels.exceptions import StopConsumerfrom asgiref.sync import async_to_sync  class ChatConsumer(WebsocketConsumer):    def websocket_connect(self, message):        # 接收这个客户端的连接        self.accept()         # 将这个客户端的连接对象加入到某个地方（内存 or redis）1314 是群号这里写死了        async_to_sync(self.channel_layer.group_add)('1314', self.channel_name)     def websocket_receive(self, message):        # 通知组内的所有客户端，执行 xx_oo 方法，在此方法中自己可以去定义任意的功能。        async_to_sync(self.channel_layer.group_send)('1314', {"type": "xx.oo", 'message': message})         #这个方法对应上面的type，意为向1314组中的所有对象发送信息    def xx_oo(self, event):        text = event['message']['text']        self.send(text)     def websocket_disconnect(self, message):        #断开链接要将这个对象从 channel_layer 中移除        async_to_sync(self.channel_layer.group_discard)('1314', self.channel_name)        raise StopConsumer()

到此，关于“django channels使用、配置及实现群聊的方法”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！

--结束END--

本文标题: django channels使用、配置及实现群聊的方法

本文链接: https://lsjlt.com/news/330519.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • django channels使用、配置及实现群聊的方法
    这篇文章主要介绍“django channels使用、配置及实现群聊的方法”，在日常操作中，相信很多人在django channels使用、配置及实现群聊的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法...
    99+
    2023-06-30
  • djangochannels使用和配置及实现群聊
    目录1.1WebSocket原理1.2django框架小结2.0 实现群聊2.1 群聊（一）2.2 群聊（二）1.1WebSocket原理 http协议 连接数据传输断开连接 web...
    99+
    2024-04-02
  • 怎么在Django中使用channels和websocket实现一个在线聊天室
    本篇文章为大家展示了怎么在Django中使用channels和websocket实现一个在线聊天室，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。Channels是Django团队研发的一个给Djan...
    99+
    2023-06-15
  • Django使用redis配置缓存的方法
    目录前言django应用redis缓存1.settings配置2.全站缓存3.视图函数缓存4.低级缓存5.session缓存对于非经常更新的服务器数据，若每次都从硬盘读取一次，会浪费...
    99+
    2024-04-02
  • Django路径配置及渲染的方法
    这篇文章主要介绍“Django路径配置及渲染的方法”，在日常操作中，相信很多人在Django路径配置及渲染的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Django路径...
    99+
    2024-04-02
  • Django 中的并发请求处理：使用 channels 实现实时通信。
    Django 是一个广受欢迎的 Python Web 框架，它为开发人员提供了一个强大的工具箱，使他们可以轻松地构建高效、可扩展的 Web 应用程序。然而，对于那些需要实现实时通信的应用程序来说，Django 的默认请求处理方式并不是最佳的...
    99+
    2023-08-09
    并发 apache django
  • Sentinel实现动态配置的集群流控的方法
    介绍 为什么要使用集群流控呢？ 相对于单机流控而言，我们给每台机器设置单机限流阈值，在理想情况下整个集群的限流阈值为机器数量✖️单机阈值。不过实际情况下流...
    99+
    2024-04-02
  • django认证类配置实现方法是什么
    这篇文章主要介绍“django认证类配置实现方法是什么”，在日常操作中，相信很多人在django认证类配置实现方法是什么问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”django认证类配置实现方法是什么”的疑...
    99+
    2023-06-25
  • Quartz集群原理以及配置应用的方法详解
    Quartz是一个开源的任务调度框架，用于在Java应用程序中实现定时任务的调度和执行。Quartz集群是指多个Quartz实例组成...
    99+
    2023-08-15
    Quartz
  • Log4j properties的配置及其使用方法
    这篇文章主要讲解了“Log4j properties的配置及其使用方法”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Log4j properties的配置及其使用方法”吧！目录一、log4j...
    99+
    2023-06-20
  • 使用pyinstaller打包django的方法实现
    目录Step 1: 生成spec文件Step 2: 使用pyinstaller 构建可执行文件虽然django项目我们一般通过部署服务器进行发布，但是也有些情况，可能就是一个小小的数...
    99+
    2024-04-02
  • Vue3axios配置以及cookie的使用方法实例演示
    调用验证码方法 在Request.js也就是axios中添加切换验证码方法 // 请求后拦截 instants.interceptors.response.use( ...
    99+
    2023-02-18
    Vue3 axios配置方法 Vue3 cookie使用方法 Vue3 cookie使用实例
  • vue使用vite配置跨域及环境配置的方法
    这篇文章主要介绍“vue使用vite配置跨域及环境配置的方法”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“vue使用vite配置跨域及环境配置的方法”文章能帮助大家解决问题。如何配置跨域，代理域名不...
    99+
    2023-07-02
  • django中资源文件夹的引入及配置方法
    Django 是一个由 Python 编写的一个开放源代码的 Web 应用框架。 Django简介 使用 Django，只要很少的代码，Python 的程序开发人员就可以轻松地完成一...
    99+
    2024-04-02
  • Spring Security的相关配置方法及功能实现
    本篇内容介绍了“Spring Security的相关配置方法及功能实现”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够...
    99+
    2024-04-02
  • Linux测试工具route的配置及实现方法
    本篇内容主要讲解“Linux测试工具route的配置及实现方法”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Linux测试工具route的配置及实现方法”吧!本文是介绍管理Linux系统网络性能...
    99+
    2023-06-16
  • linux系统下vnc的配置及使用方法
    这篇文章主要讲解了“linux系统下vnc的配置及使用方法”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“linux系统下vnc的配置及使用方法”吧！VNC基本上是由两部分组成：一部分是客户端...
    99+
    2023-06-10
  • Spark SQL配置及使用的方法是什么
    本篇内容介绍了“Spark SQL配置及使用的方法是什么”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！XY个人记SparkSQL是...
    99+
    2023-06-21
  • .eslintrc配置目录及配置项的使用方式
    目录.eslintrc文件配置介绍规则文档eslint问题如下还有相关的案例说明今天在运行antd-design-vue的源代码项目时，发现vscode有很多eslint的报错，原因...
    99+
    2022-11-13
    eslintrc配置目录 eslintrc配置项 eslintrc配置
  • HDFS垃圾回收站的配置及使用方法
    本篇内容介绍了“HDFS垃圾回收站的配置及使用方法”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！ ...
    99+
    2024-04-02
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作