扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >djangochannels使用和配置及实现群聊
  • 334

0
分享到

djangochannels使用和配置及实现群聊

2024-04-02 19:04:59 334人浏览 泡泡鱼

Python 官方文档：入门教程 => 点击学习

摘要

目录1.1websocket原理1.2Django框架小结2.0 实现群聊2.1 群聊（一）2.2 群聊（二）1.1WEBSocket原理 Http协议 连接数据传输断开连接 web

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 os
from django.core.asgi import get_asgi_application
from 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 WebsocketConsumer
from 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 WebsocketConsumer
from 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 WebsocketConsumer
from channels.exceptions import StopConsumer
from 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 官方文档 -- Tutorial - 守护窗明守护爱 - 博客园

django channels - 武沛齐 - 博客园

到此这篇关于django channels使用和配置及实现群聊的文章就介绍到这了,更多相关django channels配置内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

--结束END--

本文标题: djangochannels使用和配置及实现群聊

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

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

猜你喜欢
  • djangochannels使用和配置及实现群聊
    目录1.1WebSocket原理1.2django框架小结2.0 实现群聊2.1 群聊（一）2.2 群聊（二）1.1WebSocket原理 http协议 连接数据传输断开连接 web...
    99+
    2024-04-02
  • django channels使用、配置及实现群聊的方法
    这篇文章主要介绍“django channels使用、配置及实现群聊的方法”，在日常操作中，相信很多人在django channels使用、配置及实现群聊的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法...
    99+
    2023-06-30
  • Java使用MulticastSocket实现群聊应用程序
    本文实例为大家分享了Java使用MulticastSocket实现群聊应用程序的具体代码，供大家参考，具体内容如下 在这篇文章中，讨论了一个使用 MulticastSocket (J...
    99+
    2024-04-02
  • 使用springboot整合websocket实现群聊教程
    目录先上效果图：先来准备工作导入依赖导入依赖后扫描启用接收前端传回数据其中重点就是4个注解**@OnOpen，@OnClose，@OnMessage，@OnError**前端页面代码...
    99+
    2024-04-02
  • Android中使用WebSocket实现群聊和消息推送功能(不使用WebView)
    WebSocket protocol 是HTML5一种新的协议。它实现了浏览器与服务器全双工通信(full-duplex)。WebSocket是Web2.0时代的新产物，用于弥...
    99+
    2022-06-06
    websocket webview Android
  • Java怎么使用MulticastSocket实现群聊应用程序
    这篇文章主要介绍“Java怎么使用MulticastSocket实现群聊应用程序”，在日常操作中，相信很多人在Java怎么使用MulticastSocket实现群聊应用程序问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对...
    99+
    2023-06-30
  • 集群Cluster MySQL的安装配置和使用
    MySQL Cluster MySQL集群基本概念：“NDB” 是一种“内存中”的存储引擎，它具有可用性高和数据一致性好的特点。 MySQL Cluster 能够使用多种故障切换和负载平衡选项配置NDB存储...
    99+
    2024-04-02
  • 使用socket实现网络聊天室和私聊功能
    使用socket技术实现网络聊天室和私聊功能，具体内容如下话不多说先上图：聊天室群聊页面在线用户的联系人列表socket连接页面私聊页面项目介绍与服务端实现socket连接：每个客户端连接到服务器的时候，服务器会将每个连接的socket保存...
    99+
    2023-05-30
    socket 聊天室 私聊
  • Jenkins实现集群化管理以及流水线项目配置
    目录一、Jenkins Cluster 简介1.配置 Jenkins 实现集群功能2.使用 Jenkins 配置流水线项目一、Jenkins Cluster 简介 首先在这里说一下单...
    99+
    2024-04-02
  • Quartz集群怎么配置和应用
    配置和应用Quartz集群需要以下步骤：1. 配置数据库：Quartz集群需要使用数据库来存储调度信息和任务状态。你可以使用任何支持...
    99+
    2023-08-16
    Quartz
  • Weblogic如何实现多机群集配置
    这篇文章主要介绍Weblogic如何实现多机群集配置，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！把管理服务器上创建的域文件夹同步到其他所有节点2、把管理服务器上的/opt/BEA/weblogic92/common...
    99+
    2023-06-03
  • go使用consul实现服务发现及配置共享实现详解
    目录使用consul四大特性通过docker安装consul实现代码运行结果使用consul四大特性 1. 服务发现：利用服务注册，服务发现功能来实现服务治理。 2. 健康检查：利用...
    99+
    2024-04-02
  • RHCS集群套件之用Luci/Ricci实现Web集群的详细配置
        RHCS集群介绍请看http://11107124.blog.51cto.com/11097124/1884048    在RH...
    99+
    2024-04-02
  • 聊聊SpringBoot使用Nacos进行服务注册发现与配置管理问题
    前提 最近由于业务发展，需要调研一套完善和主流的基础架构，进行中台化（微服务）的实施，考虑到技术栈切换到SOFAStack。既然整个体系都切换到蚂蚁金服的技术栈，那么自然考虑一些基础...
    99+
    2024-04-02
  • Log4j.properties配置及其使用
    目录一、log4j简介1、Loggers2、Appenders3、Layouts二、配置详解1、配置根Logger：2、配置日志信息输出目的地（appender）：2.1Consol...
    99+
    2024-04-02
  • Android lint配置及使用
    关于作者：CSDN内容合伙人、技术专家， 从零开始做日活千万级APP。 专注于分享各领域原创系列文章 ，擅长java后端、移动开发、商业变现、人工智能等，希望大家多多支持。 目录 一、导...
    99+
    2023-09-10
    android 面试 lint 优化 瘦身
  • SpringCloud：Feign的使用及配置
    目录 Feign的使用及配置 1、Feign替代RestTemplate 2、使用Fegin步骤 3、自定义配置 4、Feign使用优化 5、Feign的最佳实践方式 Feign的使用及配置 1、Feign替代RestTemplate...
    99+
    2023-09-18
    spring cloud java spring boot
  • Jenkins怎么实现集群化管理以及流水线项目配置
    本文小编为大家详细介绍“Jenkins怎么实现集群化管理以及流水线项目配置”，内容详细，步骤清晰，细节处理妥当，希望这篇“Jenkins怎么实现集群化管理以及流水线项目配置”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知...
    99+
    2023-06-29
  • 怎么使用Python工厂模式实现封装Webhook群聊机器人
    本文小编为大家详细介绍“怎么使用Python工厂模式实现封装Webhook群聊机器人”，内容详细，步骤清晰，细节处理妥当，希望这篇“怎么使用Python工厂模式实现封装Webhook群聊机器人”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢...
    99+
    2023-07-05
  • ASP.NET Core 配置和使用环境变量的实现
    前言 通常在应用程序开发到正式上线，在这个过程中我们会分为多个阶段，通常会有 开发、测试、以及正式环境等。每个环境的参数配置我们会使用不同的参数，因此呢，在ASP.NET C...
    99+
    2022-06-07
    ASP.NET 环境 环境变量 net core ASP 变量
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作