Python网络编程多线程实现异步服务端

在《Python中通过socketserver库创建服务端》中提到的使用socketserver库创建的服务端是同步服务端。当有多个客户端接入服务端时,必须接收了客户端A发送的数据之后,才会再接收客户端B的服务端。而如果客户端A连接服务端后,没有发送数据,此时服务端接收不到来自客户端B的数据。

通过socketserver模块的ThreadingTCPServer类可以实现异步服务端,即每个连入服务端的客户端之间互不影响,服务端可以随意接收来自客户端的数据。

1 ThreadingTCPServer类介绍

ThreadingTCPServer类会为每个连入服务端的客户端创建一个新的线程,在每个新线程中完成对客户端的操作,因此各个客户端之间互不影响,实现了异步服务器。

相关链接1 服务端的同步和异步:同步指的是必须完成一项操作之后才能继续下一项操作,比如必须接收了客户端A的数据之后才能接收客户端B的数据;而异步指的是多项操作可以同时进行,接收客户端A的数据和接收客户端B的数据可以同时进行。同步服务器可以看作是阻塞的,异步服务器可以看作是非阻塞的。

2 ThreadingTCPServer类的使用

实例化ThreadingTCPServer类时,需要Python中通过socketserver库创建服务端提到的socketserver.BaseRequestHandler类的派生类。

2.1 创建socketserver.BaseRequestHandler类的派生类

使用Python中通过socketserver库创建服务端中相同的代码,创建派生类MyTCPHandler。

2.2 设置主机IP地址和监听端口

设置主机IP地址和监听端口的代码如图1所示。

图1 服务端IP地址和监听端口号

2.3 创建ThreadingTCPServer类的实例

通过如图2所示的代码,创建ThreadingTCPServer类的实例。

图2 创建ThreadingTCPServer类的实例

其中,MyTCPHandler是“2.1 创建socketserver.BaseRequestHandler类的派生类”中创建的派生类。这样,BaseRequestHandler类就与ThreadingTCPServer类关联起来。

2.4 创建新线程处理客户端的请求

当有客户端连接服务端时,通过threading类创建ThreadingTCPServer类的实例server的新线程。

2.4.1 创建threading类的实例

通过如图3所示的代码创建threading类的实例。

图3 创建threading类的实例

其中,threading.Thread()方法的作用是创建threading类的实例,该函数的target参数指定了新线程对应的方法,server是“2.3 创建ThreadingTCPServer类的实例”中创建的ThreadingTCPServer类的实例,而serve_forever()方法是ThreadingTCPServer类父类socketserver的方法,该方法通过循环的方式用来处理客户端请求,直到调用了shutdown()时,该循环才会结束。

2.4.2 创建新线程

通过如图4所示的代码创建新线程。

图4 创建新线程

2.4.3 添加循环使得服务端不退出

为了等待客户端的连接,需要在服务端的主程序中添加while循环,使得服务端在等待客户端连接时不退出,代码如图5所示。

图5 while循环

注意1:因为使用了threading类,所以在程序起始位置处需要导入threading模块。

3 测试

3.1 测试1

运行服务端,在windows10中运行客户端1,客户端1只连接服务端,而不向服务端发送数据;在windows7中运行服务端2,服务端2连接服务端后,向服务端发送数据。此时,服务端的效果如图6所示。

图6 服务端效果

从图6中可以看出,即使客户端1没有向服务端发送数据,服务端依然能够处理客户端2的请求,这样就实现了异步的功能。

3.2 测试2

修改服务端代码,在“2.1 创建socketserver.BaseRequestHandler类的派生类”中提到的代码最后添加如图7所示的代码, 显示当前线程号。

图7 显示当前线程号

之后,在“2.4.3 添加循环使得服务端不退出”中提到的while语句前添加显示主线程号的代码,如图8所示。

图8 显示主线程号

最后,在windows10中运行客户端1,在windows7中运行客户端2,客户端1和客户端2都向服务端发送数据,此时服务端的效果如图9所示。

图9 服务端效果

从图9中可以看出,客户端的主线程是Thread-1;用于和Windows10客户端通信的线程是Thread-2;用于和Windows7客户端通信的线程是Thread-3。

4 完整代码

服务端完整代码如图10所示。

图10 服务端完整代码

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

三菱FX3U小项目—运料小车自动化

目录 一、项目描述 二、IO口分配 三、项目流程图 四、项目程序 五、总结 一、项目描述 设备如下图所示,其中启动按钮SB1用来开启运料小车,停止按钮SB2用来手动停止运料小车(其工作方式任务模式要求)。当小车在原点SQ1位置,按下启动按钮S…

RocketMQ(三):集成SpringBoot

RocketMQ系列文章 RocketMQ(一):基本概念和环境搭建 RocketMQ(二):原生API快速入门 RocketMQ(三):集成SpringBoot 目录 一、搭建环境二、不同类型消息1、同步消息2、异步消息3、单向消息4、延迟消息5、顺序消息6、带tag消息7、带key消息 一…

关于python中内存分配的问题,运行一些操作可能会导致为新结果分配内存,用Python的id()函数演示

一、考虑背景: 一般在python中不会考虑像C中的内存问题,但是在一些高级应用中会考虑,例如有一个特别特别大的矩阵,最好不要不断的赋值,导致内存问题产生。 二、python中的id: 在python中有个id&#xff…

内网渗透之信息收集

目录 本机信息收集 查看系统配置信息 查看系统服务信息 查看系统登录信息 自动信息收集 域内信息收集 判断是否存在域 本机信息收集 查看系统配置信息 查看系统服务信息 查看系统登录信息 自动信息收集 域内信息收集 查看机器相关信息 查看用户相关信息 powershel…

【Java 进阶篇】深入浅出:JQuery 事件绑定的奇妙世界

在前端的世界里,事件是不可或缺的一部分。用户的点击、输入、滚动等行为都触发着各种事件,而如何在代码中捕捉并处理这些事件是每位前端开发者必须掌握的技能之一。本文将带你深入浅出,探索 JQuery 中的事件绑定,为你揭开这个奇妙…

ke11..--2其他界面也要提取我的locatStarage

获取浏览器里面的本地缓存 localStorage就是我们的浏览器缓存在哪都可以用 下面代码是获取打印到我们的页面上 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>Title</title> </head> …

【杂谈】-蓝牙低功耗数据传输模式比较

蓝牙低功耗数据传输模式比较 文章目录 蓝牙低功耗数据传输模式比较1、无连接数据传输2、无连接数据传输的优点3、无连接数据传输的局限性 3、面向连接的数据传输4、面向连接模式的优点5、面向连接模式的局限性6、家庭自动化项目的性能观察 物联网&#xff08;IoT&#xff09;设…

端口映射软件

今天给大家介绍一个自己制作的工具&#xff0c;本工具可以把本地自己的项目映射到外网可以访问,自己有域名可以使用自己的,没有可以用软件自带的三级域名! Token获取 地址&#xff1a;传送 打开上面网址注册账号&#xff0c;然后点击验证&#xff0c;复制里面的值即可。 软件…

报错:HikariPool-1 - Exception during pool initialization.

问题发现&#xff1a; 原本可以运行的springboot2项目突然无法运行且报错&#xff0c;HikariPool-1 - Exception during pool initialization。 问题分析&#xff1a; 观察报错信息发现是JDBC连接失败&#xff0c;进而搜索HikariPool-1&#xff0c;搜索得知应该是applicatio…

为什么鸿蒙调用弹窗组件(CommonDialog )却不展示或闪退?

鸿蒙OS开发问题 1.效果展示2.问题代码3.问题分析4.完整代码 1.效果展示 1.为什么调用弹窗不展示会闪退? 2.问题代码 1.前端代码: <?xml version"1.0" encoding"utf-8"?> <DirectionalLayoutxmlns:ohos"http://schemas.huawei.com/res/…

01线性回归

目录 常规求解&#xff1a; 矩阵求解 sklean算法求解 # 二元一次方程 # x y 14 # 2x - y 10 常规求解&#xff1a; x np.array([[1,1],[2,-1]])print(x) # [[ 1 1] # [ 2 -1]]y np.array([14, 10])w np.linalg.solve(x, y)print(正常求救&#xff1a;)print(w) …

契约锁助力货物进出口全程无纸化,加速通关、降低贸易成本

我国作为全球最大的制造业国家和最大的货物贸易国家&#xff0c;政府始终注重引入数字化技术&#xff0c;创新管理和服务模式&#xff0c;帮助降低企业进出口成本&#xff0c;加速货物流通。 近年国家海关总署、商务部、税务总局及各地政府在进出口“报关”、“提货”、“收货备…

Redis持久化策略之RDB与AOF

文章目录 1.RDB1)基本介绍2)自动触发3)手动触发4)RDB文件5)优点缺点 2.AOF1)基本介绍2)使用方式3)工作流程4)重写机制5)AOF文件6)优点缺点 3.RDB AOF 我们都知道&#xff0c;redis 是一个基于内存的数据库。基于内存的好处是访问速度快&#xff0c;缺点是“不持久”——当数据…

golang标准库-crc32的使用

1.概述 crc32实现了32位循环冗余检测算法的实现。目前crc32内部提供 了三种常用的多项式,采用查表法来提高计算checksum的效率。通过crc32.MakeTable()可以获取对应的表&#xff0c;crc32提供了一个IEETABLE可以直接使用&#xff0c;官方链接如下&#xff1a;crc32 package - h…

录屏软件无水印免费的有哪些?我来告诉你!

在日常生活和工作中&#xff0c;我们经常需要使用录屏软件来记录屏幕活动。然而&#xff0c;许多免费录屏软件在录制视频时会添加水印&#xff0c;给用户带来不便。那录屏软件无水印免费的都有哪些呢&#xff1f;在本文中&#xff0c;我们将介绍三款无水印的免费录屏软件&#…

如果面试也能这样说HashMap,那么就不会有那么多遗憾!

&#x1f44f;作者简介&#xff1a;大家好&#xff0c;我是爱吃芝士的土豆倪&#xff0c;24届校招生Java选手&#xff0c;很高兴认识大家&#x1f4d5;系列专栏&#xff1a;Spring源码、JUC源码&#x1f525;如果感觉博主的文章还不错的话&#xff0c;请&#x1f44d;三连支持&…

jenkins清理缓存命令

def jobName "yi-cloud-operation" //删除的项目名称 def maxNumber 300 // 保留的最小编号&#xff0c;意味着小于该编号的构建都将被删除 Jenkins.instance.getItemByFullName(jobName).builds.findAll { it.number < maxNumber }.each { it.delet…

SourceTree修改Git密码

SourceTree用的好好的&#xff0c;无奈公司隔段时间强制更改电脑密码。更改完成后SourceTree无法使用&#xff0c;重新输入密码。VS的nuget也是。查资料虽然也能比较快的解决&#xff0c;但是。。。。在此转载记录下。 1. 找到 SourceTree 配置文件所在目录 ‘userhosts’ 目录…

锐捷OSPF认证

一、知识补充 1、基本概述 OSPF区域认证和端口认证是两种不同的认证机制&#xff0c;用于增强OSPF协议的安全性。 OSPF区域认证&#xff08;OSPF Area Authentication&#xff09;&#xff1a;这种认证机制是基于区域的。在OSPF网络中&#xff0c;每个区域都可以配置一个区域…

HCL设备启动失败——已经解决

摸索了一个多小时&#xff0c;终于搞定了&#xff0c;首先HCL这款软件是需要安装Oracle VM Visual Box的&#xff0c;小伙伴们安装的时候记得点击安装Visual Box&#xff1b; 安装完后显示设备不能启动&#xff0c;然后我根据这个 HCL模拟器中Server设备启动失败的解决办法_hc…
最新文章