博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
第五十四节,socketserver通讯模块实现并发操作,真多线程并发
阅读量:6174 次
发布时间:2019-06-21

本文共 2308 字,大约阅读时间需要 7 分钟。

socketserver通讯模块实现并发操作,基于select、epoll、socket、多线程,实现的正真多线程多并发

socketserver通讯模块底层调用的socket模块,只是它作了处理基于lo多路复用加多线程,能实现并发操作,1

SocketServer内部使用 IO多路复用 以及 “多线程” 和 “多进程” ,从而实现并发处理多个客户端请求的Socket服务端。即:每个客户端请求连接到服务器时,Socket服务端都会在服务器是创建一个“线程”或者“进程” 专门负责处理当前客户端的所有请求。

 

通讯模块实现并发操作服务端,2

1,import socketserver #导入模块,3

2,必须创建一个类来,继承两个类socketserver和BaseRequestHandler,注意必须创建一个类来继承这两个模块内部指定的类4

  socketserver,创建类模块指定继承类名称5

  BaseRequestHandler,创建类模块指定继承类名称6

  注意:这个类对象里自动封装了3个普通字段分别为,self.request(客户端连接对象),self.client_address(客户端IP和端口),self.server(服务端对象)7

  self.request(客户端连接对象)8

  self.client_address(客户端IP和端口)9

  self.server(服务端对象)10

3,创建的类里必须创建一个handle()方法,当客户端连接后就会执行这个handle()方法,所以各种发送数据和接收数据都是写在这个方法里11

  在这个方法里通过对象普通字段的self.request(客户端连接对象)来做通讯操作12

  handle()客户端连接后自动执行方法13

4,ocketserver.ThreadingTCPServer(元祖类型IP端口, 创建的类名称)设置服务端的IP和端口,并且把创建的类传进去给模块14

  使用方法:定义变量 = ocketserver.ThreadingTCPServer(元祖类型IP端口, 创建的类名称)15

  如:shezhi = socketserver.ThreadingTCPServer(('127.0.0.1', 9999,), bf)16

5,serve_forever() 执行模块,循环等待客户端连接,能处理并发操作,一旦有客户端连接就会执行创建类里的handle方法17

  使用方法:设置服务端的IP和端口变量.serve_forever() 18

  如:shezhi.serve_forever()19

 

并发操作服务端代码20

 

#!/usr/bin/env python# -*- coding:utf8 -*-"""创建并发服务端"""import socketserver #导入模块"""创建类"""class bf(socketserver.BaseRequestHandler): #创建一个类,继承两个类socketserver和BaseRequestHandler,注意必须创建一个类来继承这两个模块内部指定的类     """定义方法"""     def handle(self):         #对象自动封装了(客户端连接对象),(客户端IP和端口),(服务端对象)         # print self.request(客户端连接对象),self.client_address(客户端IP和端口),self.server(服务端对象)         b = self.request #客户端连接对象         b.sendall(bytes("你好欢迎你",encoding='utf-8')) #根据accept()接收到客户端连接对象信息,向客户端发送信息         while True: #当客户端连接成功后,进入循环,保持与客户端的通讯            j = b.recv(1024)#接收客户端发来的信息            j2 = str(j, encoding='utf-8') #将接收到的客户端信息转换成字符串            if j2 == "q": #判断客户端输入q,表示不再与服务端通讯,跳出循环,不在保持客户端的通讯                break            b.sendall(bytes(j2+"好",encoding='utf-8')) #将接收到客户端的信息加上一个好字,在发送给客户端"""设置服务端IP端口,并且把创建类传入socketserver模块"""shezhi = socketserver.ThreadingTCPServer(('127.0.0.1', 9999,), bf) #设置服务端的IP和端口,并且把创建的类传进去"""执行socketserver模块"""shezhi.serve_forever() #执行模块,循环等待客户端连接,能处理并发操作,一旦有客户端连接就会执行创建类里的handle方法

 

并发操作服务端流程图21

 

重点:注意传输数据时的粘包问题22

粘包就是一端发了两次信息或数据,第一次发的有可能计算机缓冲区还没发出去,第二次的信息就发到了缓冲区,这样两次的信息粘在一起发出去了,为了避免粘包问题,在第一次发送后接收一下另外一端是否接收到第一次发的信息,如果接收到才发第二次,如果没接收到就不发用,recv()阻塞,

 

转载地址:http://bnqba.baihongyu.com/

你可能感兴趣的文章
红帽云套件新增QuickStart Cloud Installer,加快私有云部署
查看>>
MapXtreme 2005 学习心得 一些问题(八)
查看>>
流量精细化运营时代,营销SaaS之使命——流量掘金
查看>>
雅虎同意出售核心资产
查看>>
Win10大丰收的节奏 微软收编iOS全部150万应用
查看>>
智慧城市要除“城市病” 中兴通讯开辟新增长极
查看>>
Opera已确认解散iOS开发团队
查看>>
DevOps:新的业务浪潮
查看>>
CERT:启用EMET的Windows 7比Windows 10更加安全
查看>>
LINE上市:一场迟到、勇敢又无奈的IPO
查看>>
OA选型:OA系统工作流是核心
查看>>
如何发现“利用DNS放大攻击”的服务器
查看>>
《Arduino开发实战指南:LabVIEW卷》——第2章 Arduino软件
查看>>
京津冀大数据走廊起笔谋篇
查看>>
WIFI连网一“吻”通 黑科技让无线路由器更智能
查看>>
Ovum光器件首席分析师:硅光子不是唯一解决方案
查看>>
大数据发展进入快车道 未来会呈现高速增长
查看>>
JVM基础:JVM内存组成及分配
查看>>
数据库锁和数据库隔离级别
查看>>
Linux下的内核测试工具——perf使用简介
查看>>