当前位置：首页 > news >正文

django中配置使用websocket终极解决方案

news 2025/8/25 11:05:18

django ASGI/Channels 启动和 ASGI/daphne的区别

Django ASGI/Channels 是 Django 框架的一个扩展，它提供了异步服务器网关接口（ASGI）协议的支持，以便处理实时应用程序的并发连接。ASGI 是一个用于构建异步 Web 服务器和应用程序的规范。

在以前的版本中，Django 使用的是 WSGI（Web 服务器网关接口）协议，该协议是一种同步的协议，只能处理一个请求-响应周期。这意味着在处理长轮询、WebSocket 及其他类似的实时应用程序时，传统的 Django 无法提供良好的性能和扩展性。

与传统的 Django 不同，使用 Django ASGI/Channels 可以构建具有实时功能的异步应用程序，例如聊天应用、通知系统等。Channels 提供了一个消息队列来处理异步任务，并且可以与 WebSocket、长轮询等技术结合使用。

ASGI/daphne 是一个符合 ASGI 规范的异步 Web 服务器，能够处理 ASGI 应用程序的并发连接。它是 Channels 官方推荐的生产级服务器，并提供高性能和可靠的连接管理。你可以将 ASGI/daphne 与 Django ASGI/Channels 一起使用，以部署具有实时功能的 Django 应用程序。

总结来说，Django ASGI/Channels 是 Django 的一个扩展，使其能够处理实时应用程序的并发连接。而 ASGI/daphne 则是一个符合 ASGI 规范的异步 Web 服务器，用于处理 ASGI 应用程序的并发连接。两者结合使用可以构建高性能、具有实时功能的 Django 应用程序。

文件类比

daphne 启动命令

daphne 你的工程项目名称.asgi:application

python本身只支持http协议使用websocket需要下载第三方库

pip install -U channels

需要在seting.py里配置，将我们的channels加入INSTALLED_APP里。

INSTALLED_APPS = (
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.sites',
    ...
    'channels',
)

尾行添加

ASGI_APPLICATION = 'bug_Project_name.asgi.application'

修改asgi.py文件

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

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

from django.urls import re_path
from web import consumers

websoctet_urlpatterns = [
re_path('ws/(?P<group>\w+)/$',consumers.ChatConsumer.as_asgi()),
]

在web.views中创建consumers.py

# -*- coding:UTF-8 -*-

# author:Administrator
# contact: 913632472@qq.com
# datetime:2022/1/10 11:55
# software: PyCharm

"""
文件说明：
"""

from channels.generic.websocket import WebsocketConsumer
from channels.exceptions import StopConsumer

class ChatConsumer(WebsocketConsumer):

    def websocket_connect(self,message):
        # 有客户端来向后端发送websocket连接请求时,自动触发
        # 后端允许客户端创建连接
        print('有人来了')
        self.accept()
        #给客户端发送小时
        self.send("欢迎啊")

    def websocket_receive(self, message):
        # 浏览器基于websocket向后端发送数据,自动触发接受消息
        text = message['text']
        print("接受到消息-->", text)
        res = "{}SB".format(text)
        if text == "关闭":
            # 客户端通过发送命令主动断开连接
            self.close()
            print('通过命令关闭')
            raise StopConsumer # 如果服务端断开连接,执行StopConsumer异常那么websocket_disconnect不会执行
        self.send(res)
        # self.close() #后端主动断开websocket

    def websocket_disconnect(self, message):
        # 客户端与服务端断开连接,自动触发
        print("客户端断开连接")
        raise StopConsumer

django中需要了解的

wsgi，只支持http请求
asgi，wsgi+异步+websockt

settings.py的installed_apps中的首行

简单使用前端页面测试websocket

<html lang="en">
<head>
<meta charset="UTF-16">
<title>title</title>
<style>
     .message{
         height: 300px;
         border: 1px solid #dddddd;
         width: 100%;
     }
</style>
</head>
</html>
<div class="message" id="message"></div>
<div>
<input type="text" placeholder="请输入" id="txt">
<input type="button" value="发送" οnclick="sendMessage()">
</div>

<script>
socket = new WebSocket("ws://127.0.0.1:8000/room/123/")
//创建好连接后触发
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);
}

function sendMessage(){
     let tag = document.getElementById("txt");
     socket.send(tag.value);
}

function closeConn() {
     socket.close(); //服务端发送断开请求

}
</script>

websocket介绍：

channels 4.0之后默认不带Daphne服务器了。

解决方案可以有两种：
1.指定channels的版本为3.x；
2.安装时使用pip3 install -U channels[“daphne”]

当前问题不管高版本还是低版本老是报如下问题

之后找到老师获取课程中的源代码笔者使用教程中的代码跑通了

还是回到这个问题

这个坑废了我2天时间

ValueError: No application configured for scope type 'websocket'

经过课程中的代码和笔者的代码来回对比多次测试

这里应该是websocket 而缺少了e字母应该是写项目的时候复制csdn参考源码网友留的坑

而后将项目依赖全部升级为最新版本完全可以跑通！

效果图

小结

基于django实现websocket请求但只能对某个人进行处理

群聊（二）

基于channels中提供channel layers来实现。

setting中配置。

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

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()
# 获取群号，获取路由匹配中的group = self.scope['url_route']['kwargs'].get("group")
# 将这个客户端的连接对象加入到某个地方（内存 or redis）async_to_sync(self.channel_layer.group_add)(group, self.channel_name)
def websocket_receive(self, message):group = self.scope['url_route']['kwargs'].get("group")
# 通知组内的所有客户端，执行 xx_oo 方法，在此方法中自己可以去定义任意的功能。async_to_sync(self.channel_layer.group_send)(group, {"type": "xx.oo", 'message': message})
def xx_oo(self, event):text = event['message']['text']self.send(text)
def websocket_disconnect(self, message):group = self.scope['url_route']['kwargs'].get("group")
async_to_sync(self.channel_layer.group_discard)(group, self.channel_name)raise StopConsumer()

总结

b站演示地址 https://b23.tv/UZvBFy3

websocket是什么？协议。
django中实现websocket，channels组件。
- 单独连接和收发数据。
- 手动创建列表 & channel layers。

【全网最详细Django的websocket 通信原理，聊天室，实战案例-哔哩哔哩】http:// https://b23.tv/os2enKj

参考链接http://t.csdn.cn/RyrcC

备用链接django中配置websocket_基于wsgi创建的项目怎么实现websocket_qq_36606793的博客-CSDN博客

django中配置使用websocket终极解决方案

django ASGI/Channels 启动和 ASGI/daphne的区别 Django ASGI/Channels 是 Django 框架的一个扩展，它提供了异步服务器网关接口（ASGI）协议的支持，以便处理实时应用程序的并发连接。ASGI 是一个用于构建异步 Web 服务器和应用程序…...

编程日记 2023/9/5 0:59:32

敦煌网、Jumia等跨境电商平台怎么测评（补单）留评？

评论的重要性是众所周知的，对于想要做卖家运营的人来说，它直接影响着产品的销量和排名那么如何通过自养号测评来提升销量和排名呢？ 我相信大家对这个问题已经有了一定的了解，拥有大量自养号可以通过这些号来通过关键词搜索、浏…...

编程日记 2023/9/5 0:58:30

uni-app之android离线打包

一 AndroidStudio创建项目 1.1，上一节演示了uni-app云打包，下面演示怎样androidStudio离线打包。在AndroidStudio里面新建空项目 1.2，下载uni-app离线SDK，离线SDK主要用于App本地离线打包及扩展原生能力，SDK下载链接h…...

编程日记 2023/9/5 0:57:28

【传输层】TCP -- 三次握手四次挥手 | 可靠性与提高性能策略

超时重传机制连接管理机制三次握手四次挥手滑动窗口拥塞控制延迟应答捎带应答面向字节流粘包问题TCP异常情况TCP小结基于TCP应用层协议理解 listen 的第二个参数超时重传机制主机A发送数据给B之后，可能因为网络拥堵等原因，数据无法到达主机B&#xff1…...

编程日记 2023/9/5 0:56:28

前端将UTC时间格式转化为本地时间格式～～uniapp写法

UTC时间格式是什么首先我们先简单的了解一下：UTC时间（协调世界时，Coordinated Universal Time）使用24小时制，以小时、分钟、秒和毫秒来表示时间 HH:mm:ss.SSSHH 表示小时，取值范围为00到23。mm 表示分钟…...

编程日记 2023/9/5 0:55:27

说说Kappa架构

分析&回答对于实时数仓而言，Lmabda架构有很明显的不足，首先同时维护两套系统，资源占用率高，其次这两套系统的数据处理逻辑相同，代码重复开发。能否有一种架构，只需要维护一套系统，就可以…...

编程日记 2023/9/5 0:54:25

项目介绍：《Online ChatRoom》网页聊天室 — Spring Boot、MyBatis、MySQL和WebSocket的奇妙融合

在当今数字化社会，即时通讯已成为人们生活中不可或缺的一部分。为了满足这一需求，我开发了一个名为"WeTalk"的聊天室项目，该项目基于Spring Boot、MyBatis、MySQL和WebSocket技术，为用户提供了一个实时交流的平台。在本…...

编程日记 2023/9/5 0:53:22

Vue3 学习组合式API setup语法糖响应式指令 DIFF（一）

文章目录前言一、Composition Api二、setup语法糖三、响应式refreactive 四、其他一些关键点v-prev-oncev-memov-cloak 五、虚拟Dom五、diff算法前言本文用于记录学习Vue3的过程一、Composition Api 我觉得首先VUE3最大的改变就是对于代码书写的改变，从原来选择…...

编程日记 2023/9/5 0:52:21

一文轻松入门DeepSort

1.背景 Deepsort是目标检测任务的后续任务，得益于Yolo系列的大放异彩，DeepSort目标追踪任务的精度也不断提高，同时，DeepSort属于目标追踪任务中的多目标追踪，即MOT（Multiple Object Tracking，M…...

编程日记 2023/9/5 0:51:20

关于linux openssl的自签证书认证与nginx配置

自签文档链接重点注意这块，不能写一样的，要是一样的话登录界面锁会报不安全域名这块跟最后发布的一致 nginx配置的话 server {listen 443 ssl; //ssl 说明为https 默认端口为443server_name www.skyys.com; //跟openssl设置的域名保持一致s…...

编程日记 2023/9/5 0:50:19

Mybatis--关联关系映射

目录： 1.什么是关联关系映射： 一对一和多对多的区别 2.mybaits中的一对一&一对多关联关系配置配置generatoeConfig文件插件自动生成编辑写sql语句创建 Ordermapper类编写接口类编辑编写接口实现类编写测试类测试结果一对…...

编程日记 2023/9/5 0:49:18

Golang基本的网络编程

Go语言基本的Web服务器实现 Go 语言中的 http 包提供了创建 http 服务或者访问 http 服务所需要的能力，不需要额外的依赖。 Go语言在Web服务器中主要使用到了 “net/http” 库函数，通过分析请求的URL来实现参数的接收。下面介绍了http 中Web应用的基本…...

编程日记 2023/9/5 0:48:17

Postgresql的一个bug_涉及归档和pg_wal

故障描述： 服务器ocmpgdbprod1，是流复制主节点，它的从节点是ocmpgdbprod2，两个节点的Postgresql数据库版本都是PostgreSQL 11.6，主节点ocmpgdbprod1配置了pg_wal归档，从节点ocmpgdbprod2没有配置pg_wal归档…...

编程日记 2023/9/5 0:47:16

轻量、便捷、高效—经纬恒润AETP助力车载以太网测试

随着自动驾驶技术和智能座舱的不断发展，高宽带、高速率的数据通信对主干网提出了稳定、高效的传输要求，CAN(FD)、LIN已无法充分满足汽车的通信需求。车载以太网作为一种快速且扩展性好的网络技术，已经逐步成为了汽车主干网的首选。此外&…...

编程日记 2023/9/5 0:46:13

【跟小嘉学 Rust 编程】二十四、内联汇编(inline assembly)

系列文章目录【跟小嘉学 Rust 编程】一、Rust 编程基础【跟小嘉学 Rust 编程】二、Rust 包管理工具使用【跟小嘉学 Rust 编程】三、Rust 的基本程序概念【跟小嘉学 Rust 编程】四、理解 Rust 的所有权概念【跟小嘉学 Rust 编程】五、使用结构体关联结构化数据【跟小嘉学…...

编程日记 2023/9/5 0:45:12

综合实训-------成绩管理系统 V1.1

综合实训-------成绩管理系统 V1.1 1、一维数组数据double 2、我们用元素的位置来当学号。 1、录入数据【5个数据】或【通过文件的方式取数据】 2、显示数据 3、添加一条记录 4、修改一条记录 5、删除一条记录 6、查找一条记录。【输入学号，显示成绩】 7、统计。【…...

编程日记 2023/9/5 0:44:09

13.108.Spark 优化、Spark优化与hive的区别、SparkSQL启动参数调优、四川任务优化实践：执行效率提升50%以上

13.108.Spark 优化 1.1.25.Spark优化与hive的区别 1.1.26.SparkSQL启动参数调优 1.1.27.四川任务优化实践：执行效率提升50%以上 13.108.Spark 优化： 1.1.25.Spark优化与hive的区别先理解spark与mapreduce的本质区别，算子之间（…...

编程日记 2023/9/5 0:43:08

这里写自定义目录标题 KeywordsBackgroud for LLMsTechnical Evolution of GPT-series ModelsResearch of OpenAI on LLMs can be roughly divided into the following stagesEarly ExplorationsCapacity LeapCapacity EnhancementThe Milestones of Language Models Resources…...

编程日记 2023/9/5 0:42:07

树的介绍（C语言版）

前言在数据结构中树是一种很重要的数据结构，很多其他的数据结构和算法都是通过树衍生出来的，比如：堆，AVL树，红黑色等本质上都是一棵树，他们只是树的一种特殊结构，还有其他比如linux系统的文件系…...

编程日记 2023/9/5 0:41:05

Android studio实现圆形进度条

参考博客效果图 MainActivity import androidx.appcompat.app.AppCompatActivity; import android.graphics.Color; import android.os.Bundle; import android.widget.TextView;import java.util.Timer; import java.util.TimerTask;public class MainActivity extends App…...

编程日记 2023/9/5 0:40:04

定时器任务——若依源码分析

分析util包下面的工具类schedule utils： ScheduleUtils 是若依中用于与 Quartz 框架交互的工具类，封装了定时任务的创建、更新、暂停、删除等核心逻辑。 createScheduleJob createScheduleJob 用于将任务注册到 Quartz，先构建任务的 JobD…...

编程新知 2025/8/21 18:40:12

【git】把本地更改提交远程新分支feature_g

创建并切换新分支 git checkout -b feature_g 添加并提交更改 git add . git commit -m “实现图片上传功能” 推送到远程 git push -u origin feature_g...

编程新知 2025/8/15 18:53:03

无人机侦测与反制技术的进展与应用

国家电网无人机侦测与反制技术的进展与应用引言随着无人机（无人驾驶飞行器，UAV）技术的快速发展，其在商业、娱乐和军事领域的广泛应用带来了新的安全挑战。特别是对于关键基础设施如电力系统，无人机的“黑飞”&…...

编程新知 2025/8/22 5:43:03

wpf在image控件上快速显示内存图像

wpf在image控件上快速显示内存图像https://www.cnblogs.com/haodafeng/p/10431387.html 如果你在寻找能够快速在image控件刷新大图像（比如分辨率3000*3000的图像）的办法，尤其是想把内存中的裸数据（只有图像的数据，不包…...

编程新知 2025/8/22 5:19:10

Spring Security 认证流程——补充

一、认证流程概述 Spring Security 的认证流程基于过滤器链（Filter Chain），核心组件包括 UsernamePasswordAuthenticationFilter、AuthenticationManager、UserDetailsService 等。整个流程可分为以下步骤： 用户提交登录请求拦…...

编程新知 2025/8/19 11:26:16