设为首页 收藏本站
查看: 1083|回复: 0

[经验分享] python网络编程之socketserver

[复制链接]

尚未签到

发表于 2018-8-4 09:06:49 | 显示全部楼层 |阅读模式
  防伪码:存在的,忘却了,红尘万丈,入眸幻灭
  在进行网络编程前我们先来说说在网络中服务器与客户端是如何交互的,也就是传说中的TCP三次握手。
DSC0000.png

  三次握手的目的是为了确认客户端与服务端都能接收到对方的信息,以下是三次握手的详细过程:
  第一次握手:客户端给服务端发送请求包
  此时服务端确认自己可以接收到客户端的请求包
  客户端无法确认服务端是否接收到了自己发的请求包
  第二次握手:服务端回复客户端
  此时客户端确认自己发的请求包已被服务端收到,也确认自己可以正常接收服务端发来的包
  服务端可以确认自己能接收到客户端的包,但不能确认客户端是否能收到自己发送的包
  第三次握手:客户端回复服务端
  此时客户端已无疑问
  服务端也确认刚刚客户端收到了自己的回复包。两边都没问题了,开始通信
  在python中提供了两个socket编程模块,分别是socket和socketserver。
  我们先来说说socket编程需要经历哪些步骤:
  客户端:
  1、创建socket客户端连接对象
  2、通过连接对象的connect()方法连接服务端
  3、通过连接对象的send()方法给服务端发送信息或指令
  4、通过连接对象的recv()方法接收服务端的返回信息
  5、通过连接对象的close()方法断开连接
  服务端:
  1、创建socket服务端连接对象
  2、通过连接对象的bind()方法绑定要监听的IP与端口
  3、通过连接对象的listen()方法来监听
  4、通过连接对象的accept()方法创建与客户端交互的子连接对象并等待客户端连接
  5、接收并处理客户端的请求
  6、将处理结果返回给客户端
  由于socket无法支持多用户,多并发。于是就有了socketserver
  socketserver最主要的作用就是实现并发处理。
  socketserver有以下几种类型:
  TCPServer:tcp协议
class socketserver.TCPServer(server_address,RequestHandlerClass,bind_and_activate=True)  ThreadingTCPServer:多线程,多并发的TCPServer
class socketserver.ThreadingTCPServer(server_address,RequestHandlerClass,bind_and_activate=True)  ForkingTCPServer:多进程,多并发的TCPServer#在windows中不能使用这个
class socketserver.ForkingTCPServer(server_address,RequestHandlerClass,bind_and_activate=True)  UDPServer:udp协议
class socketserver.UDPServer(server_address,RequestHandlerClass,bind_and_activate=True)  UnixStreamServer:tcp协议,Unix本机间不同进程间通信可以使用这个server
class socketserver.UnixStreamServer(server_address,RequestHandlerClass,bind_and_activate=True)  UnixDatagramServer:udp协议,Unix本机间不同进程间通信可以使用这个server
class socketserver.UnixDatagramServer(server_address,RequestHandlerClass,bind_and_activate=True)  BaseServer是所有Server类型的基类。
  TCPServer继承了BaseServer,UnixStreamServer继承了TCPServer。
  UDPServer继承了TCPServer,UnixDatagramServer继承了UDPServer。
  BaseServer有以下这些方法:
  fileno():返回文件描述符
  handle_request():处理单个请求
  serve_forever(poll_interval=0.5):处理多个请求
  poll_interval用来设置多长时间检查一下是否有收到shutdown()请求
  当收到shutdown()请求后,调用service_actions(),serve_forever将停止提供服务
  shutdown():告诉serve_forever()让其停掉
  server_close():关闭服务
  创建socketserver的步骤:
  1、创建一个BaseRequestHandlerclass的子类并在子类中重写handle()方法
  这个子类用来处理客户端的请求
  与客户端所有的交互都是在handle()方法中编写
  2、实例化一个server(如TCPServer)类,并且将Server_IP和上一步创建的子类传给这个实例化的类(此处是       TCPServer)作为参数
  3、调用第2步实例化出来的对象的方法,这里假定这个实例化出来的对象为server:
  server.handle_request():只处理一个请求,处理完后退出
  server.serve_forever():处理多个请求,永远执行
  4、调用close()方法关闭server
  重写BaseRequestHandlerclass类的handle()方法:
def handle(self):  
    #self.request is the TCP socket connected to the client
  
    self.data = self.request.recv(1024).strip()
  
    print("{} wrote:".format(self.client_address[0]))
  
    print(self.data)
  
    #just send back the same data,but upper-cased
  
    self.request.sendall(self.data.upper())
  
    #sendall其实就是重复调用send,在这里也可以用send

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-546252-1-1.html 上篇帖子: Python 中的tab补全 下篇帖子: python中assert断言的用法
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表