冯仁亮和孙祥老婆,艾克洛索的毒液,伴我纵横主题曲
基于tcp的套接字,关键就是两个循环,一个链接循环,一个通信循环
socketserver模块中分两大类:server类(解决链接问题)和request类(解决通信问题)
server类:
request类:
继承关系:
以下述代码为例,分析socketserver源码:
ftpserver=socketserver.ThreadingTCPServer(('127.0.0.1',8080),FtpServer)
ftpserver.serve_forever()
查找属性的顺序:ThreadingTCPServer->ThreadingMixIn->TCPServer->BaseServer
源码分析总结:
基于tcp的socketserver我们自己定义的类中的
基于udp的socketserver我们自己定义的类中的
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/05/04 15:11 # @Author : MJay_Lee # @File : server.py # @Contact : limengjiejj@hotmail.com import socketserver # 通信循环 class MytcpHandler(socketserver.BaseRequestHandler): def handle(self): print(self) print(self.request) while True: try: data = self.request.recv(1024) if not data: break self.request.send(data.upper()) except ConnectionResetError: break self.request.close() if __name__ == '__main__': # 接收连接,(来一个连接,就创造一个线程对象并调该对象下的handle方法去服务此客户) server = socketserver.ThreadingTCPServer(('127.0.0.1',8080),MytcpHandler) # print(server) # <socketserver.ThreadingTCPServer object at 0x000000132630C0B8> # print(server.server_address) # ('127.0.0.1', 8080) # print(server.RequestHandlerClass) # <class '__main__.MytcpHandler'> # print(server.socket) # <socket.socket fd=380, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080)> server.serve_forever()
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/05/04 15:11 # @Author : MJay_Lee # @File : client.py # @Contact : limengjiejj@hotmail.com import os import socket client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) client.connect(('127.0.0.1',8080)) while True: msg = '%s is running' % os.getpid() client.send(msg.encode('utf-8')) reply_msg = client.recv(1024) print(reply_msg.decode('utf-8'))
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/05/04 17:40 # @Author : MJay_Lee # @File : server.py # @Contact : limengjiejj@hotmail.com import socketserver # 通信循环 class MyudpHandler(socketserver.BaseRequestHandler): def handle(self): # print(self) # print(self.request) # 区别于tcp,此处self.request接收到的内容为元组 # (b'4208 is running', <socket.socket fd=360, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>) msg = self.request[0] print('client发送来的数据',msg.decode('utf-8')) self.request[1].sendto(msg.upper(),self.client_address) if __name__ == '__main__': # 接收连接,(来一个连接,就创造一个线程对象并调该对象下的handle方法去服务此客户) server = socketserver.ThreadingUDPServer(('127.0.0.1', 8080), MyudpHandler) # print(server) # <socketserver.ThreadingUDPServer object at 0x00000021E29AA198> # print(server.server_address) # ('127.0.0.1', 8080) # print(server.RequestHandlerClass) # <class '__main__.MyudpHandler'> # print(server.socket) # <socket.socket fd=368, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)> server.serve_forever()
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/05/04 17:41 # @Author : MJay_Lee # @File : client.py # @Contact : limengjiejj@hotmail.com import os import socket client = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) client.connect(('127.0.0.1',8080)) while True: msg = '%s is running' % os.getpid() client.sendto(msg.encode('utf-8'),('127.0.0.1',8080)) reply_msg = client.recv(1024) print(reply_msg.decode('utf-8'))
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Python 实现将numpy中的nan和inf,nan替换成对应的均值
python爬虫把url链接编码成gbk2312格式过程解析
网友评论