LuckySheet协同编辑后端示例(Django+Channel,Websocket通信)

其他的配置不赘述了,直接网上搜一下django使用channel的配置方法

我初步研究通道先用的内存
在setting文件中
 

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

这里我重点说一下luckysheet源码的部分

首先是websocket,这部分代码在源码的server.js中,通过研究源码,才解决了问题

pako解压的问题尝试了很多次都没不太对,于是直接把pako部分的源码给注释掉了,直接传过去的就是json字符串

} else {// let msg = pako.gzip(encodeURIComponent(JSON.stringify(d)), {to: "string"});let msg = JSON.stringify(d);//console.info(msg);if (_this.websocket != null) {_this.websocket.send(msg);}}

后端的消费者类的主要代码如下

from channels.generic.websocket import AsyncJsonWebsocketConsumer
from urllib.parse import parse_qs
import jsonclass TableConsumer(AsyncJsonWebsocketConsumer):table = NonegridKey = Noneasync def connect(self):query = self.scope['query_string'].decode('utf-8')t = parse_qs(query)['t'][0]self.gridKey = parse_qs(query)['g'][0]await self.channel_layer.group_add(f'table_{self.gridKey}', self.channel_name)await self.accept()print('建立连接')async def disconnect(self, close_code):print('断开连接')await self.channel_layer.group_discard(f'table_{self.gridKey}', self.channel_name)async def receive(self, text_data=None, bytes_data=None):# 使用json.loads方法将JSON字符串解析为Python的字典对象if text_data !='rub':parsed_data = json.loads(text_data)print(parsed_data)# 这里构造要广播的数据broadcast_data = dict()broadcast_data['type'] = 3broadcast_data['data'] = text_databroadcast_data['username'] = 'test'broadcast_event = {"type": "broadcast_message","message": broadcast_data}# 向对应的组发送广播事件,触发broadcast_message方法来实际发送给组内成员await self.channel_layer.group_send(f'table_{self.gridKey}', broadcast_event)async def broadcast_message(self, event):message = event["message"]await self.send_json(message)

之前对websocket和channel不太了解,看了前端代码后把type和message给改了,后来多次尝试发现这个千万别改,他会在send的时候卡住而且不报任何错误(因为协程),如果是广播的话只需要修改broadcast_data的内容就行,通过解读前端的代码,在后端构建返回的json,成果把type=3的内容实现了,也就是鼠标移动的部分

else if(type == 3){ //多人操作不同选区("t": "mv")(用不同颜色显示其他人所操作的选区)let id = data.id;let username = data.username;let item = JSON.parse(data.data);let type = item.t,index = item.i,value = item.v;

剩余的部分我就先不写了,具体操作应该是根据前端过来的json内容来自行判断返回的type,然后进行消息的分发!!!!

重点:读源码读源码读源码!!!!!

又写了两种type,批量的没写到type=4的情况,因为他前端写的感觉有问题还造成了后端的麻烦,于是后端写成多个type=2了,增加了一点点服务器压力

from channels.generic.websocket import AsyncJsonWebsocketConsumer
from urllib.parse import parse_qs
import jsonfrom pyasn1_modules.rfc5639 import brainpoolP160r1class TableConsumer(AsyncJsonWebsocketConsumer):table = NonegridKey = Noneasync def connect(self):query = self.scope['query_string'].decode('utf-8')t = parse_qs(query)['t'][0]self.gridKey = parse_qs(query)['g'][0]await self.channel_layer.group_add(f'table_{self.gridKey}', self.channel_name)await self.accept()print('建立连接')async def disconnect(self, close_code):print('断开连接')await self.channel_layer.group_discard(f'table_{self.gridKey}', self.channel_name)async def receive(self, text_data=None, bytes_data=None):# 使用json.loads方法将JSON字符串解析为Python的字典对象if text_data !='rub':parsed_data = json.loads(text_data)print(parsed_data)if parsed_data['t'] == 'mv':# 这里构造要广播的事件数据,假设要原封不动广播接收到的数据,将其放入'message'字段broadcast_data = dict()broadcast_data['type'] = 3broadcast_data['data'] = text_databroadcast_data['username'] = 'test'broadcast_event = {"type": "broadcast_message","message": broadcast_data}# 向对应的组发送广播事件,触发broadcast_message方法来实际发送给组内成员await self.channel_layer.group_send(f'table_{self.gridKey}', broadcast_event)if parsed_data['t'] == 'v':# 这里构造要广播的事件数据,假设要原封不动广播接收到的数据,将其放入'message'字段broadcast_data = dict()broadcast_data['type'] = 2broadcast_data['data'] = text_databroadcast_data['username'] = 'test'broadcast_event = {"type": "broadcast_message","message": broadcast_data}# 向对应的组发送广播事件,触发broadcast_message方法来实际发送给组内成员await self.channel_layer.group_send(f'table_{self.gridKey}', broadcast_event)if parsed_data['t'] == 'rv':row = parsed_data['range']['row']column = parsed_data['range']['column']for j in range(column[0], column[1]+1):numj = j-column[0]for i in range(row[0], row[1] + 1):numi = i-row[0]try:broadcast_data = dict()broadcast_data['type'] = 2# data = list()broadcast_data['username'] = 'test'data = dict()data['t'] = 'v'data['i'] = 0data['v'] = parsed_data['v'][numi][numj]data['r'] = idata['c'] = jbroadcast_data['data'] = json.dumps(data)broadcast_event = {"type": "broadcast_message","message": broadcast_data}await self.channel_layer.group_send(f'table_{self.gridKey}', broadcast_event)except Exception as e:print(e)async def broadcast_message(self, event):message = event["message"]await self.send_json(message)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/61092.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ACE之单例

单例簇 使用双重锁检查优化 #mermaid-svg-RMOXQ0KMo0VnJe7V {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-RMOXQ0KMo0VnJe7V .error-icon{fill:#552222;}#mermaid-svg-RMOXQ0KMo0VnJe7V .error-text{fill:#552222…

delphi fmx android 离线人脸识别

搜遍全网都没有找到delphi android 能用的 离线人脸识别,无需注册什么开发者 有这方面需求的可以用fsdk 这边用的luxand.FSDK8.0 android下的注册号要自己找下 1,用老猫的工具将android 下的sdk,FSDK.java 编译成FSDK.jar 老猫的工具 2,用上面的工具将FSDK.jar 生成de…

RabbitMQ教程:工作队列(Work Queues)(二)

RabbitMQ教程:工作队列(Work Queues)(二) 一、引言 在快节奏的软件开发世界中,我们经常面临需要异步处理任务的场景,比如在Web应用中处理耗时的图片处理或数据分析任务。这些任务如果直接在用…

若依笔记(十一):芋道多租户限制与修改

目录 多租户实现 哪些表是多租户的? YudaoTenant自动装载类 租户隔离的sql在哪? 如何修改成无租户隔离 全局修改 表级别 请求RUL级别 实际需求 芋道比若依多了租户概念,这也是因为它增加很多业务系统,首先后台管理系统肯定是多租户的,这意味着如商城系统的产品管…

乐维网管平台(七):网络稳定与高效的“安全锦囊”

试想一下,你给电脑升级了一个软件,升级完成后发现有BUG,经常无故卡死,这时候想回退或重新安装旧版本…相对地,一家企业的网络管理员,在对公司的核心交换机进行复杂的配置调整时,一个小小的疏忽&…

时代变迁对传统机器人等方向课程的巨大撕裂

2020年之后,全面转型新质课程规划,传统课程规划全部转为经验。 农耕-代表性生产关系-封建分配制度主要生产力-人力工业-代表性生产关系-资本分配制度工业分为机械时代,电气时代,信息时代;主要生产力-人力转为人脑&…

Spring6 AOP 面向切面编程

1. 概念 面向切面编程:一种编程思想。proxy动态代理(实现了这种思想):在原方法执行时,给原方法的前面或着后面增加其他的方法。增加的方法并不会写在原方法中 原方法就是目标方法,增加的方法就是代理方法 …

计算机组成与原理(2) basic of computer architecture

Instruction Set Architecture (ISA) 和 Hardware System Architecture (HSA) 是计算机体系结构中两个重要的层次,它们各自的职责和作用如下: Instruction Set Architecture (ISA) 定义 ISA是指令集体系结构,是硬件和软件之间的接口。它定义…

优化需求类 Markdown 文件以提高 RAG 系统查询准确度

标题:优化需求类 Markdown 文件以提高 RAG 系统查询准确度 目录 概述示例 Markdown 文件处理步骤处理步骤代码详解 合并标题与内容丰富标题语义清洗文本生成摘要语义文本切分 综合处理向量化与存储检索示例总结 概述 处理需求类的 Markdown 文件时,由于…

leetcode 找不同

389. 找不同 已解答 简单 相关标签 相关企业 给定两个字符串 s 和 t ,它们只包含小写字母。 字符串 t 由字符串 s 随机重排,然后在随机位置添加一个字母。 请找出在 t 中被添加的字母。 示例 1: 输入:s "abcd"…

window的wsl(Ubuntu)安装kafka步骤

环境:Win11 WSL(Linux子系统Ubuntu) apache-zookeeper-3.9.3-bin kafka_2.12-3.8.1 思路:apache上分别下载zookeeper和kafka,在wsl环境安装。在kafka上创建消息的topic,发送消息,接受消息,验证是否安…

JavaScript 原型

JavaScript 的原型(Prototype)是其面向对象编程模型的核心概念之一,它决定了对象如何继承属性和方法。通过理解 JavaScript 的原型,你可以更好地理解对象之间的关系以及如何扩展对象功能。 核心概念 [[Prototype]](内部…

React中组件通信的几种方式

在构建复杂的React应用时,组件之间的通信是至关重要的。从简单的父子组件通信到跨组件状态同步,不同组件之间的通信方式多种多样。 1. 父子组件通信 父子组件通信是 React 中最基本的通信方式之一。在这种模式下,数据是从父组件通过 props …

数据结构树和二叉树知识点和递归序列

二叉树知识点 一.树的概念1.1关于树的名词解释 二.二叉树的概念1. 二叉树性质: 三.满二叉树与完全二叉树递归前序遍历递归中序遍历递归后续遍历 一.树的概念 树是一种非线性数据结构,它是由n个或大于n个的结点来组成具有层次关系的一个集合(…

速通前端篇 —— CSS

找往期文章包括但不限于本期文章中不懂的知识点: 个人主页:我要学编程程(ಥ_ಥ)-CSDN博客 所属专栏:速通前端 目录 CSS的介绍 基本语法规范 CSS选择器 标签选择器 class选择器 id选择器 复合选择器 通配符选择器 CSS常见样式 颜…

使用 Elastic 3 步实现基于 OTel 的原生 K8s 和应用可观测性

作者:来自 Elastic Bahubali Shetti Elastic 的 OpenTelemetry 发行版现已支持 OTel Operator,可使用 EDOT SDK 自动检测应用程序,并管理 EDOT OTel Collector 的部署和生命周期以实现 Kubernetes 可观察性。了解如何通过 3 个简单步骤进行配…

计算机视觉:赋予机器“看”的能力

引言 计算机视觉是一门科学,它试图使计算机能够像人类一样解释和理解视觉信息。这个领域结合了人工智能、机器学习、计算机科学和认知心理学等多个学科的知识,旨在创建能够“看”和“理解”图像和视频的系统。随着技术的进步,计算机视觉已经…

javaScript交互案例2

1、京东侧边导航条 需求: 原先侧边栏是绝对定位当页面滚动到一定位置,侧边栏改为固定定位页面继续滚动,会让返回顶部显示出来 思路: 需要用到页面滚动事件scroll,因为是页面滚动,所以事件源是document滚动…

stack、queue、priority_queue、deque的使用和模拟实现

目录 1.容器适配器 2.stack stack的常用接口及使用示例 stack的模拟实现 3.queue queue的常用接口及使用示例 queue的模拟实现 4.priority_queue priority_queue的常用接口及使用示例 priority_queue的模拟实现 5.deque 认识deque deque底层的数据结构 deque和ve…

Linux的cuDNN(cudnn)安装教程(CUDA(cuda\cuda toolkit))

CUDA(cuda\cuda toolkit)安装教程 https://blog.csdn.net/huiyayaya/article/details/143863835?spm1001.2014.3001.5502官网下载cudnn https://developer.nvidia.com/rdp/cudnn-archive这个下载到自己的电脑 下载到本地就好 复制到服务器 切换到cudnn文件所在目…