FastAPI 学习之路（五十二）WebSockets(八)接受/发送json格式消息
前面我们发送的大多数都是text类型的消息，对于text消息来说，后端处理出来要麻烦的多，那么我们可以不可以传递json格式的数据，对于前后端来说都比较友好，答案是肯定的，我们需要做下处理。
首先，我们在websocket管理器中增加处理json格式消息的方法：
from typing import List, Dictfrom starlette.websockets import WebSocketclass ConnectionManager:def __init__(self):"""存放链接"""self.active_connections: List[Dict[str, WebSocket]] = []async def connect(self, user: str, ws: WebSocket):"""链接"""await ws.accept()self.active_connections.append({"user": user, "ws": ws})async def disconnect(self, user: str, ws: WebSocket):"""断开链接，移除"""self.active_connections.remove({"user": user, "ws": ws})@staticmethodasync def send_personal_message(message: str, ws: WebSocket):"""发送所有人消息"""await ws.send_text(message)async def send_other_message(self, message: dict, user: str):"""发送个人消息"""for coon in self.active_connections:if coon["user"] == user:await coon["ws"].send_json(message)async def broadcast(self, data: str):"""广播"""for conn in self.active_connections:await conn["ws"].send_text(data)async def broadcast_json(self, data: dict):"""广播json数据"""for conn in self.active_connections:await conn["ws"].send_json(data)接口中如何接收json数据呢，新增接口如下：
@app.websocket("/ws/json/{user}")
async def websocket_json_data(websocket: WebSocket,user: str,cookie_or_token: str = Depends(get_cookie_or_token)
):"""发送接收json数据（前面一对一接口其实就是发送的json数据）"""await ws_manager.connect(user, websocket)try:while True:data = await websocket.receive_json()send_user = data["username"]if send_user:await ws_manager.send_other_message(data, send_user)else:await ws_manager.broadcast_json(data)except WebSocketDisconnect as e:await ws_manager.disconnect(user, websocket)
前端也要相对应的修改：
<!DOCTYPE html>
<html>
<head><title>Chat</title>
</head>
<body>
<h1>WebSocket 聊天</h1>
<form action="" onsubmit="sendMessage(event)"><input type="text" id="messageText" autocomplete="off"/><input type="text" id="username" autocomplete="off"/><button>Send</button>
</form>
<button onclick="logout()">退出</button>
<ul id='messages'>
</ul>
<script>var token=window.localStorage.getItem("token")if (token==null ){window.location.href="/login"}var ws = new WebSocket("ws://localhost:8000/ws/json/"+token+"?token="+token);ws.onmessage = function (event) {var messages = document.getElementById('messages')var message = document.createElement('li')let receiveJson = JSON.parse(event.data);console.log(receiveJson)var content = document.createTextNode(receiveJson.username+"说:"+receiveJson.messageText)message.appendChild(content)messages.appendChild(message)};function sendMessage(event) {var input = document.getElementById("messageText")var username = document.getElementById("username")let message = {messageText: input.value, username:username.value};let messageJson = JSON.stringify(message);ws.send(messageJson);// input.value = ''event.preventDefault()}function logout() {window.localStorage.removeItem("token")window.location.href='/login'}
</script></body></html>
部署看效果，因为发送给后端的数据格式是前端拼的json，所以页面上只需要填文本即可：
相关文章：
FastAPI 学习之路（五十二）WebSockets(八)接受/发送json格式消息
前面我们发送的大多数都是text类型的消息，对于text消息来说，后端处理出来要麻烦的多，那么我们可以不可以传递json格式的数据，对于前后端来说都比较友好，答案是肯定的，我们需要做下处理。 首先，…...
Go语言并发编程-案例_3
案例 并发目录大小统计 业务逻辑 统计目录的文件数量和大小（或其他信息）。示例输出： // 某个目录：2637 files 1149.87 MB 实现思路 给定一个或多个目录，并发的统计每个目录的size，最后累加到一起。 当…...
pikachu之跨站脚本攻击（x‘s‘s）
1get型 输入a看一下 接着输入<a> 发现<>没有被过滤当做标签处理了 尝试在表单提交的框里面，输入xss语句 尝试输入<script>alert(1)</script> 发现有长度限制 因为这里是get请求 get请求的特点是：传参是在url中的 所以我们可以在…...
Qt模型/视图架构——委托（delegate）
一、为什么需要委托 模型（model）用来数据存储，视图（view）用来展示数据。因此，模型/视图架构是一种将数据存储和界面展示分离的编程方法。具体如下图所示： 由图可知，模型向视图提供数…...
python3.11SSL: SSLV3_ALERT_HANDSHAKE_FAILURE
参考：python request包 版本不兼容 报错sslv3 alert handshake failure 解决方法-CSDN博客 修改：Python311\Lib\site-packages\urllib3\util\ssl_.py 新版本3.11里默认没有DEFAULT_CIPHERS 补回来: #__imported from 3.6.8 # A secure default. # So…...
[深度学习]基于yolov10+streamlit目标检测演示系统设计
YOLOv10结合Streamlit构建的目标检测系统，不仅极大地增强了实时目标识别的能力，还通过其直观的用户界面实现了对图片、视频乃至摄像头输入的无缝支持。该系统利用YOLOv10的高效检测算法，能够快速准确地识别图像中的多个对象，并标注…...
开源模型应用落地-FastAPI-助力模型交互-进阶篇（三）
一、前言 FastAPI 的高级用法可以为开发人员带来许多好处。它能帮助实现更复杂的路由逻辑和参数处理，使应用程序能够处理各种不同的请求场景，提高应用程序的灵活性和可扩展性。 在数据验证和转换方面，高级用法提供了更精细和准确的控制&#…...
机器人及其相关工科专业课程体系
机器人及其相关工科专业课程体系 前言传统工科专业机械工程自动化/控制工程计算机科学与技术 新兴工科专业智能制造人工智能机器人工程 总结Reference: 前言 机器人工程专业是一个多领域交叉的前沿学科，涉及自然科学、工程技术、社会科学、人文科学等相关学科的理论…...
C#数字医学影像系统（RIS/PACS）源码，Oracle数据库，C/S架构，运行稳定
数字医学影像系统（RIS/PACS）源码，三甲以下的医院都能满足。PACS 系统全套成品源码。 开发技术：C/S架构，C#开发语言，数据库服务器采用Oracle数据库。 医学影像存储与传输系统，融合了医学信息化…...
Spring-Boot基础--yaml
目录 Spring-Boot配置文件 注意： YAML简介 YAML基础语法 YAML:数据格式 YAML文件读取配置内容 逐个注入 批量注入 ConfigurationProperties 和value的区别 Spring-Boot配置文件 Spring-Boot中不用编写.xml文件，但是spring-Boot中还是存在.prope…...
C/C++蓝屏整人代码
文章目录 📒程序效果 📒具体步骤 1.隐藏任务栏 2.调整cmd窗口大小 3.调整cmd窗口屏幕颜色 4.完整代码 📒代码详解 🚀欢迎互三👉：程序猿方梓燚 💎💎 🚀关注博主&a…...
【Android安全】Ubuntu 下载、编译 、刷入Android-8.1.0_r1
0. 环境准备 Ubuntu 16.04 LTS（预留至少95GB磁盘空间，实测占94.2GB） Pixel 2 XL 要买欧版的，不要美版的。 欧版能解锁BootLoader、能刷机。 美版IMEI里一般带“v”或者"version"，这样不能解锁BootLoader、…...
HBuilder X3.4版本中使用uni-app自定义组件
HBuilder X3.4版本中使用uni-app自定义组件 这是我的小程序页面结构 方式一：导入components 1.创建componets文件，并编写你的组件页面 <template><view class"my-search-container"><!-- 使用 view 组件模拟 input 输入框的样…...
PHP基础语法（一）
一、初步语法 1、PHP代码标记：以 <?php 开始，以 ?> 结束； 2、PHP注释：行注释：//（双斜杠）或# 块注释：/* */ 3、PHP语句分隔符： 1）在PHP中&#…...
Python项目打包与依赖管理指南
在Python开发中，python文件需要在安装有python解释器的计算机的电脑上才能运行，但是在工作时，我们需要给客户介绍演示项目功能时并不一定可以条件安装解释器，而且这样做非常不方便。这时候我们可以打包项目，用于给客户…...
矿产资源潜力预测不确定性评价
研究目的： 不确定性评估： 到底什么叫不确定性，简单来说就是某区域内的矿产资源量，并不确定到底有多少，你需要给出一个评估或者分布。 研究方法： 1.以模糊集来表示某些量： 关于什么是模糊集&am…...
食堂采购系统开发：从需求分析到上线实施的完整指南
本篇文章，笔者将详细介绍食堂采购系统从需求分析到上线实施的完整过程，旨在为开发团队和管理者提供一个系统化的指南。 一、需求分析 1.用户需求 常见的需求包括： -采购计划管理 -供应商管理 -库存管理 -成本控制 -报表生成 2.系统功…...
C++ 数据结构
C 数据结构 引言 数据结构是计算机科学中的一个核心概念，它涉及到如何在计算机中组织和存储数据，以便高效地进行数据访问和修改。C作为一种高效的编程语言，提供了丰富的内置数据类型和库，支持各种复杂的数据结构实现。本文将探讨…...
Elasticsearch：评估搜索相关性 - 第 1 部分
作者：来自 Elastic Thanos Papaoikonomou, Thomas Veasey 这是一系列博客文章中的第一篇，讨论如何在更好地理解 BEIR 基准的背景下考虑评估你自己的搜索系统。我们将介绍具体的技巧和技术，以便在更好地理解 BEIR 的背景下改进你的搜索评估流程…...
超声波清洗机哪款好用？保姆级教学，教你手把手挑选适合自己的超声波清洗机
提及超声波清洗机，大家都不陌生，尤其是佩戴眼镜的小伙伴，眼镜的镜片长时间不清洁容易模糊不清，而超声波清洗机的出现，可以轻松清洗还不会损坏镜片，备受眼镜党喜爱。但由于现在市面上的超声波清洗机的款式太…...
基于云平台的智能客服系统实战：架构设计与性能优化指南
最近在负责一个面向多租户的智能客服项目，从零到一踩了不少坑。传统单体架构的客服系统，一到业务高峰期就卡顿、超时，扩容更是噩梦。经过一番折腾，我们最终基于云平台构建了一套相对稳定、可扩展的解决方案。今天就把整个架构设计…...
洛谷 P1145：[CERC 1995] 约瑟夫 ← 队列 + 优化
【题目来源】 https://www.luogu.com.cn/problem/P1145 【题目描述】 2k 个人站成一圈，从某个人开始数数，每次数到 m 的人就被杀掉，然后下一个人重新开始数，直到最后只剩一个人。现在有一圈人，k 个好人站在一起&#…...
Intel RealSense深度相机3D点云生成终极指南：从原理到实战
Intel RealSense深度相机3D点云生成终极指南：从原理到实战 【免费下载链接】librealsense Intel RealSense™ SDK 项目地址: https://gitcode.com/GitHub_Trending/li/librealsense 想要快速构建高质量的三维视觉应用？Intel RealSense深度相机为你…...
百川2-13B模型中文OCR增强：OpenClaw图片信息提取优化
百川2-13B模型中文OCR增强：OpenClaw图片信息提取优化 1. 为什么需要OCR增强的智能体 上个月在处理一份电子合同时，我遇到了一个典型问题：合同是扫描件图片格式，我需要从中提取关键条款、金额和日期等信息。手动录入不仅耗时&…...
深度分析俩款主流移动统计工具Appvue和openinstall
深度分析俩款主流移动统计工具Appvue和openinstall Appvue vs. Openinstall：移动统计渠道的技术创新 在移动应用增长领域，渠道追踪和安装来源分析一直是开发者面临的核心挑战。传统渠道包模式存在效率低下、维护困难等痛点，而新兴的动态参数注…...
实战演练：基于快马ai生成kafka实现用户行为日志实时收集与分析系统
今天想和大家分享一个最近用Kafka实现的实战项目——用户行为日志实时收集与分析系统。这个系统特别适合电商、内容平台这类需要实时了解用户行为的场景，下面我就把整个搭建过程拆解开来，希望能给有类似需求的同学一些参考。 系统架构设计思路 整个系统分…...
从FASTQ到VCF：一个完整生信分析流程中的文件格式演变全解析
从FASTQ到VCF：生物信息学分析流程中的文件格式演进与实战解析 引言：数据格式在生信分析中的核心地位 第一次接触高通量测序数据分析时，我面对各种文件格式感到无比困惑。为什么需要这么多不同的格式？它们之间如何衔接？…...
SAP选择屏幕下拉框实战：从VRM_SET_VALUES函数到完整配置流程
SAP选择屏幕下拉框实战：从VRM_SET_VALUES函数到完整配置流程 下拉框是SAP选择屏幕中最常用的交互元素之一，它能有效提升用户操作体验并减少输入错误。本文将深入解析如何利用VRM_SET_VALUES函数实现专业级下拉框功能，涵盖从基础配置到高级应用…...
基于ChatTTS .pt模型的AI辅助开发实战：从语音合成到生产环境部署
最近在做一个需要语音合成的项目，之前用了一些开源的TTS方案，总感觉差点意思：要么生成一句话要等好几秒，急死人；要么合成的语音听起来很“机械”，没有真人说话的那种起伏和情感；想支持点方言或者…...
Gigasoft ProEssentials 使AI助手能够通过实时访问API图表配置并提供支持答案
利用人工智能访问改进图表开发Gigasoft ProEssentials 使 AI 助手能够通过实时访问 API 生成精确的图表配置并提供支持答案。Gigasoft ProEssentials 是一款功能强大的 Windows 开发图表库，提供丰富的 2D 和 3D 图表类型。该产品提供了一套用途广泛的组件࿰…...