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

Python实现WebSocket通信

news 2025/11/7 3:49:17

WebSocket是一种在单个TCP连接上进行全双工通信的协议,位于 OSI 模型的应用层。

与传统的HTTP请求-响应模型不同，WebSocket的最大特点就是，服务器可以主动向客户端推送信息，客户端也可以主动向服务器发送信息，实现实时性和互动性。

WebSocket关键特点：
  • 双向通信：WebSocket提供了全双工通信，允许服务器和客户端同时发送和接收数据。相比起传统的HTTP请求-响应模型，WebSocket使得服务器可以主动推送数据给客户端，而不需要客户端首先发起请求。
  • 持久连接：与HTTP请求不同，WebSocket连接是持久的，即一旦建立连接，它将保持打开状态，直到其中一方关闭连接或发生错误。
  • 轻量级协议：WebSocket使用简单的消息传递协议，在传输数据时减少了额外的开销。它采用二进制帧格式或文本帧格式来发送数据。
  • 跨域支持：WebSocket支持跨域通信，允许在不同域名或端口之间建立连接和交换数据。

WebSocket在许多场景下非常有用，特别是实时通信和实时数据更新方面。

常见的编程语言和框架提供了对WebSocket的支持，可以使用WebSocket API来建立WebSocket连接，并使用WebSocket的事件和方法来处理连接的打开、关闭、错误和消息等操作。

前端demo.html
<!DOCTYPE html>
<html>
<head lang="en"><meta charset="UTF-8"><script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.5.1/jquery.min.js"></script>
</head>
<body>
<ul id="content"></ul>
<form class="form"><input type="button" value="连接" id="connect" class="connect"/><br/><input type="text" placeholder="请输入发送的消息" class="message" id="message"/><input type="button" value="发送" id="send" class="connect"/>
</form><script type="text/javascript">var oUl=document.getElementById('content');var oConnect=document.getElementById('connect');var oSend=document.getElementById('send');var websocket=null;oConnect.onclick=function(){websocket=new WebSocket('ws://127.0.0.1:10083');<!--客户端链接后触发-->websocket.onopen=function(){oUl.innerHTML+="<li>客户端已连接</li>";}<!--收到消息后触发-->websocket.onmessage=function(evt){oUl.innerHTML+="<li>"+evt.data+"</li>";}<!--关闭后触发-->websocket.onclose=function(){oUl.innerHTML+="<li>客户端已断开连接</li>";};<!--出错后触发-->websocket.onerror=function(evt){oUl.innerHTML+="<li>"+evt.data+"</li>";};};oSend.onclick=function(){if(websocket){websocket.send($("#message").val())}}
</script>
</body>
</html>
后端main.py
import socket, struct, hashlib, base64
import threading# 获取请求头部数据,并将请求头转换为字典
def get_headers(data):headers = {}data = str(data, encoding="utf-8")header, body = data.split("\r\n\r\n", 1)header_list = header.split("\r\n")for i in header_list:i_list = i.split(":", 1)if len(i_list) >= 2:headers[i_list[0]] = "".join(i_list[1::]).strip()else:i_list = i.split(" ", 1)if i_list and len(i_list) == 2:headers["method"] = i_list[0]headers["protocol"] = i_list[1]print("请求类型: {} 请求协议: {}".format(i_list[0],i_list[1]))return headers# 接收数据时的解码过程
def parse_payload(payload):payload_len = payload[1] & 127if payload_len == 126:mask = payload[4:8]decoded = payload[8:]elif payload_len == 127:mask = payload[10:14]decoded = payload[14:]else:mask = payload[2:6]decoded = payload[6:]# 将所有数据全部收集起来，对所有字符串编码bytes_list = bytearray()for i in range(len(decoded)):chunk = decoded[i] ^ mask[i % 4]bytes_list.append(chunk)body = str(bytes_list, encoding='utf-8')return body# 封装并发送数据到浏览器
def send_msg(conn, msg_bytes):# 接收的第一个字节都是x81不变first_byte = b"\x81"length = len(msg_bytes)if length < 126:first_byte += struct.pack("B", length)elif length <= 0xFFFF:first_byte += struct.pack("!BH", 126, length)else:first_byte += struct.pack("!BQ", 127, length)msg = first_byte + msg_bytesconn.sendall(msg)return True# 从浏览器中接收数据
def recv_msg(conn):data_recv = conn.recv(8096)if data_recv[0:1] == b"\x81":data_parse = parse_payload(data_recv)return data_parsereturn False# 建立握手流程并创建 handler_msg 完成数据收发
def handler_accept(sock):while True:conn, addr = sock.accept()data = conn.recv(8096)headers = get_headers(data)# 对请求头中的sec-websocket-key进行加密response_tpl = "HTTP/1.1 101 Switching Protocols\r\n" \"Upgrade:websocket\r\n" \"Connection: Upgrade\r\n" \"Sec-WebSocket-Accept: %s\r\n" \"WebSocket-Location: ws://%s\r\n\r\n"# 加盐操作,此处是H5规范定义好的magic_string = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'if headers.get('Sec-WebSocket-Key'):value = headers['Sec-WebSocket-Key'] + magic_string# 对数据进行加解密ac = base64.b64encode(hashlib.sha1(value.encode('utf-8')).digest())response_str = response_tpl % (ac.decode('utf-8'), headers.get("Host"))# 相应握手包数据conn.sendall(bytes(response_str, encoding="utf-8"))t = threading.Thread(target=handler_msg, args=(conn, ))t.start()# 主函数,用于实现数据交互
def handler_msg(connect):with connect as connect_ptr:while True:try:recv = recv_msg(connect_ptr)msg_str = "接收数据: {}".format(recv)print(msg_str)send_msg(connect_ptr, bytes(msg_str, encoding="utf-8"))except Exception:exit(0)if __name__ == "__main__":sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)sock.bind(("127.0.0.1", 10083))sock.listen(5)print("Start Server ws://127.0.0.1:10083")t = threading.Thread(target=handler_accept(sock))t.start()

主要功能包括：

  • get_headers(data): 从请求数据中获取请求头部信息，并将其转换为字典格式。
  • parse_payload(payload): 对接收到的数据进行解码，还原出原始消息。
  • send_msg(conn, msg_bytes): 封装并发送数据到浏览器。
  • recv_msg(conn): 从浏览器中接收数据，并解析出原始消息。
  • handler_accept(sock): 建立握手流程，处理与客户端的连接和握手过程。在握手完成后，创建一个新的线程来处理与客户端的数据交互。
  • handler_msg(connect): 处理与客户端的数据交互。通过循环不断接收客户端发送的消息，并发送一个固定的回复消息。

相关文章：

Python实现WebSocket通信

WebSocket是一种在单个TCP连接上进行全双工通信的协议,位于 OSI 模型的应用层。 与传统的HTTP请求-响应模型不同&#xff0c;WebSocket的最大特点就是&#xff0c;服务器可以主动向客户端推送信息&#xff0c;客户端也可以主动向服务器发送信息&#xff0c;实现实时性和互动性…...

编程日记 2024/3/27 1:33:41

MATLAB 自定义生成直线点云（详细介绍） （47）

MATLAB 自定义生成直线点云 （详细介绍）（47） 一、算法介绍二、具体步骤二、算法实现1.代码2.效果一、算法介绍 通过这里的直线生成方法，可以生成模拟直线的点云数据，并通过调整起点、终点、数量和噪声水平等参数来探索不同类型的直线数据。这种方法可以用于测试、验证和开…...

编程日记 2024/3/27 1:32:39

UniTask 异步任务

文章目录 前言一、UniTask是什么&#xff1f;二、使用步骤三、常用的UniTask API和示例1.编写异步方法2.处理异常3.延迟执行4.等待多个UniTask或者一个UniTas完成5.异步加载资源示例6.手动控制UniTask的完成状态7.UniTask.Lazy延迟任务的创建8.后台线程切换Unity主线程9.不要返…...

编程日记 2024/3/27 1:31:38

【git分支管理策略】如何高效的管理好代码版本

目录 1.分支管理策略 2.我用的分支管理策略 3.一些常见问题 1.分支管理策略 分支管理策略就是一些经过实践后总结出来的可靠的分支管理的办法&#xff0c;让分支之间能科学合理、高效的进行协作&#xff0c;帮助我们在整个开发流程中合理的管理好代码版本。 目前有两套Git…...

编程日记 2024/3/27 1:28:35

css的transition详解

CSS的transition属性是一个简写属性&#xff0c;用于设置四个过渡效果属性&#xff0c;以在元素的状态改变时创建平滑的动画效果。这四个属性分别是&#xff1a; transition-property&#xff1a; 定义应用过渡效果的CSS属性名称。当指定的CSS属性改变时&#xff0c;过渡效果将…...

编程日记 2024/3/27 1:27:34

agent利用知识来做规划：《KnowAgent: Knowledge-Augmented Planning for LLM-Based Agents》笔记

文章目录 简介KnowAgent思路准备知识Action Knowledge的定义Planning Path Generation with Action KnowledgePlanning Path Refinement via Knowledgeable Self-LearningKnowAgent的实验结果 总结参考资料 简介 《KnowAgent: Knowledge-Augmented Planning for LLM-Based Age…...

编程日记 2024/3/27 1:25:32

01 React新建开发环境

https://create-react-app.dev/docs/getting-started npx create-react-app my-appJSX使用表达式嵌入 function App() {const count 100;function getSelfName() {return "SelfName"}return (<div>Hello World!<div>{This is Javascript message~!}&l…...

编程日记 2024/3/27 1:24:30

nginx--解决响应头带Set-Cookie导致的验证失败

解决响应头带Set-Cookie导致的验证失败 前言给nginx.conf 设置Secure配置完成后会发现cookie就不会发生变化了 前言 在用nginx做代理的时候&#xff0c;会发现nginx在访问不同ip请求的时候会带setCookie 导致后端就是放开cookie验证&#xff0c;在访问玩这个链接他更新了cooki…...

编程日记 2024/3/27 1:23:29

InstructGPT的流程介绍

1. Step1&#xff1a;SFT&#xff0c;Supervised Fine-Tuning&#xff0c;有监督微调。顾名思义&#xff0c;它是在有监督&#xff08;有标注&#xff09;数据上微调训练得到的。这里的监督数据其实就是输入Prompt&#xff0c;输出相应的回复&#xff0c;只不过这里的回复是人工…...

编程日记 2024/3/27 1:16:24

docker容器下部署hbase并在springboot中通过jdbc连接

我在windows的docker中部署了一个hbase服务&#xff0c;然后用springboot连接到此服务并访问数据。 详情可参考项目中的README.md。项目中提供了用于构建镜像的dockerfile&#xff0c;以及测试代码。 项目连接&#xff1a; https://gitee.com/forgot940629/hbase_phoenix_sprin…...

编程日记 2024/3/27 1:15:23

Qt——智能指针实战

目录 前言正文一、理论介绍1、QPointer2、QScopedPoint3、QSharedPoint4、QWeakPoint 二、实战演练1、QPoint2、QScopedPoint3、QSharedPointa、示例一b、示例二 4、QWeakPoint END、总结的知识与问题 参考 前言 智能指针的使用&#xff0c;对很多程序员来说&#xff0c;都算是…...

编程日记 2024/3/27 1:12:21

Unity Mobile Notifications推送问题

1.在部分机型点击通知弹窗进不去游戏 把这里改成自己的Activity 2.推送的时候没有横幅跟icon红点 主要是第一句话 注册的时候选项可以选择 defaultNotificationChannel new AndroidNotificationChannel(“default_channel”, “Default Channel”, “For Generic notifica…...

编程日记 2024/3/27 1:08:17

C++_回文串

目录 回文子串 最长回文子串 分割回文串 IV 分割回文串 II 最长回文子序列 让字符串成为回文串的最少插入次数 回文子串 647. 回文子串 思路&#xff0c;i j表示改范围内是否为回文串&#xff0c; ②倒着遍历是为了取出dp[i 1][j - 1] ③i j 只有一对&#xff0c;不会重复…...

编程日记 2024/3/27 1:05:13

【阅读论文】When Large Language Models Meet Vector Databases: A Survey

摘要 本调查探讨了大型语言模型&#xff08;LLM&#xff09;和向量数据库&#xff08;VecDB&#xff09;之间的协同潜力&#xff0c;这是一个新兴但迅速发展的研究领域。随着LLM的广泛应用&#xff0c;出现了许多挑战&#xff0c;包括产生虚构内容、知识过时、商业应用成本高昂…...

编程日记 2024/3/27 1:04:12

兼职副业大揭秘：六个潜力满满的赚钱途径

亲爱的朋友&#xff0c;你对兼职副业充满好奇与期待&#xff0c;这非常好&#xff01;在此&#xff0c;我将为你分享一些能够助你赚取额外收入的兼职副业建议。以下是六个颇具潜力的兼职副业方向&#xff0c;希望能为你的探索之路提供些许启发。 1&#xff0c;网络调查与市场洞…...

编程日记 2024/3/27 1:02:08

C++ Qt开发：QUdpSocket实现组播通信

Qt 是一个跨平台C图形界面开发库&#xff0c;利用Qt可以快速开发跨平台窗体应用程序&#xff0c;在Qt中我们可以通过拖拽的方式将不同组件放到指定的位置&#xff0c;实现图形化开发极大的方便了开发效率&#xff0c;本章将重点介绍如何运用QUdpSocket组件实现基于UDP的组播通信…...

编程日记 2024/3/27 1:01:06

excel 表中有图片并在筛选特定行时，只显示该行的图片

建议&#xff1a;选中excel 表中某张图片&#xff0c;CtrlA&#xff0c;选中所有图片。再右键&#xff0c;在菜单中选设置对象格式 在属性里按下图设置&#xff0c; 生效之后&#xff0c;筛选某个产品的时候&#xff0c;就不会显示其他的不符合筛选条件的产品的图片了。...

编程日记 2024/3/27 1:00:05

【QA】MySQL多表查询详解

文章目录 前言关系型数据库中数据表之间的关系数据准备数据内容表间关系 基础查询 | 全部查询多表查询分类1 | 连接查询内连接外连接 | 左外连接外连接 | 右外连接自连接 | 自连接自连接 | 联合查询 分类2 | 子查询返回结果分类 | 标量子查询返回结果分类 | 列子查询返回结果分…...

编程日记 2024/3/27 0:53:57

【Entity Framework】 EF三种开发模式

【Entity Framework】 EF三种开发模式 文章目录 【Entity Framework】 EF三种开发模式一、概述二、DataBase First2.1 DataBase First简介2.2 DataBase First应用步骤2.3 DataBase First总结 三、Model First3.1 Model First简介3.2 Model First实现步骤 四、Code First4.1 Cod…...

编程日记 2024/3/27 0:52:56

数据分析---SQL(5)

目录 子查询单行子查询多行子查询视图（View）创建视图使用视图更新视图视图的优缺点存储过程存储过程的创建存储过程的参数存储过程的优缺点可能导致性能问题避免存储过程引入性能问题子查询 子查询是指在一个查询语句中嵌套另一个查询语句，内部的查询语句称为子查询，外部的…...

编程日记 2024/3/27 0:50:54

盘古信息PCB行业解决方案：以全域场景重构，激活智造新未来

一、破局&#xff1a;PCB行业的时代之问 在数字经济蓬勃发展的浪潮中&#xff0c;PCB&#xff08;印制电路板&#xff09;作为 “电子产品之母”&#xff0c;其重要性愈发凸显。随着 5G、人工智能等新兴技术的加速渗透&#xff0c;PCB行业面临着前所未有的挑战与机遇。产品迭代…...

编程新知 2025/11/4 3:17:48

【Linux】C语言执行shell指令

在C语言中执行Shell指令 在C语言中&#xff0c;有几种方法可以执行Shell指令&#xff1a; 1. 使用system()函数 这是最简单的方法&#xff0c;包含在stdlib.h头文件中&#xff1a; #include <stdlib.h>int main() {system("ls -l"); // 执行ls -l命令retu…...

编程新知 2025/10/22 23:35:38

工程地质软件市场：发展现状、趋势与策略建议

一、引言 在工程建设领域&#xff0c;准确把握地质条件是确保项目顺利推进和安全运营的关键。工程地质软件作为处理、分析、模拟和展示工程地质数据的重要工具&#xff0c;正发挥着日益重要的作用。它凭借强大的数据处理能力、三维建模功能、空间分析工具和可视化展示手段&…...

编程新知 2025/10/6 6:10:29

三体问题详解

从物理学角度&#xff0c;三体问题之所以不稳定&#xff0c;是因为三个天体在万有引力作用下相互作用&#xff0c;形成一个非线性耦合系统。我们可以从牛顿经典力学出发&#xff0c;列出具体的运动方程&#xff0c;并说明为何这个系统本质上是混沌的&#xff0c;无法得到一般解…...

编程新知 2025/10/19 5:14:05

Rapidio门铃消息FIFO溢出机制

关于RapidIO门铃消息FIFO的溢出机制及其与中断抖动的关系&#xff0c;以下是深入解析&#xff1a; 门铃FIFO溢出的本质 在RapidIO系统中&#xff0c;门铃消息FIFO是硬件控制器内部的缓冲区&#xff0c;用于临时存储接收到的门铃消息&#xff08;Doorbell Message&#xff09;。…...

编程新知 2025/11/2 0:32:25

视频行为标注工具BehaviLabel（源码+使用介绍+Windows.Exe版本）

前言&#xff1a; 最近在做行为检测相关的模型&#xff0c;用的是时空图卷积网络&#xff08;STGCN&#xff09;&#xff0c;但原有kinetic-400数据集数据质量较低&#xff0c;需要进行细粒度的标注&#xff0c;同时粗略搜了下已有开源工具基本都集中于图像分割这块&#xff0c…...

编程新知 2025/11/6 16:27:34

CVE-2020-17519源码分析与漏洞复现(Flink 任意文件读取)

漏洞概览 漏洞名称&#xff1a;Apache Flink REST API 任意文件读取漏洞CVE编号&#xff1a;CVE-2020-17519CVSS评分&#xff1a;7.5影响版本&#xff1a;Apache Flink 1.11.0、1.11.1、1.11.2修复版本&#xff1a;≥ 1.11.3 或 ≥ 1.12.0漏洞类型&#xff1a;路径遍历&#x…...

编程新知 2025/11/3 9:50:37

MySQL 8.0 事务全面讲解

以下是一个结合两次回答的 MySQL 8.0 事务全面讲解&#xff0c;涵盖了事务的核心概念、操作示例、失败回滚、隔离级别、事务性 DDL 和 XA 事务等内容&#xff0c;并修正了查看隔离级别的命令。 MySQL 8.0 事务全面讲解 一、事务的核心概念&#xff08;ACID&#xff09; 事务是…...

编程新知 2025/9/19 22:12:36

Golang——6、指针和结构体

指针和结构体 1、指针1.1、指针地址和指针类型1.2、指针取值1.3、new和make 2、结构体2.1、type关键字的使用2.2、结构体的定义和初始化2.3、结构体方法和接收者2.4、给任意类型添加方法2.5、结构体的匿名字段2.6、嵌套结构体2.7、嵌套匿名结构体2.8、结构体的继承 3、结构体与…...

编程新知 2025/10/29 18:22:23

【LeetCode】算法详解#6 ---除自身以外数组的乘积

1.题目介绍 给定一个整数数组 nums&#xff0c;返回 数组 answer &#xff0c;其中 answer[i] 等于 nums 中除 nums[i] 之外其余各元素的乘积 。 题目数据 保证 数组 nums之中任意元素的全部前缀元素和后缀的乘积都在 32 位 整数范围内。 请 不要使用除法&#xff0c;且在 O…...

编程新知 2025/11/2 9:18:28