python3-socketserver
- 2020 年 1 月 9 日
- 筆記
socketserver模块
模块socketserver是标准库提供的服务器框架基础.
这个框架包括了BaseHTTPServer , SimpleHTTPServer , CGIHTTPServer , SimpleXMLRPCServer , DocXMLRPCServer
等服务器，他们在基本服务器的基础上添加了各种功能。
socketserver包含了4个基本的服务器：
1.TCPServer（支持TCP套接字流）
2.UDPServer（支持UDP数据报套接字）
3.UnixStreamServer和UnixDatagramServer
编写服务端底层流程：
服务器接受客户端连接请求——》实例话一个请求处理程序——》根据服务器类和请求处理程序类，调用处理方法。
例如：
基本请求程序类（BaseRequestHandler）调用方法 handle 。此方法通过属性 self.request 来访问客户端套接字、
StreamRequestHandler类（处理流），通过属性self.rfile（用于读取）和self.wfile（用于写入），进行与客户端通信
基于tcp的socketserver，自定义类中：
conn,client_addr=socket(AF_INET,SOCK_STREAM)
- self.server即套接字对象 <socketserver.ThreadingTCPServer object at 0x000001DA1221FB00>
- self.request即一个链接 self.request = conn ; 如： <socket.socket fd=472, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080), raddr=('127.0.0.1', 59405)>
- self.client_address即客户端地址 self.client_address = client_addr ; ('127.0.0.1', 59405)
基于udp的socketserver，自定义类中：
- self.request是一个元组（第一个元素是客户端发来的数据，第二部分是服务端的udp套接字对象） 如：(b'adsf', <socket.socket fd=200, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
- self.client_address即客户端地址 ('127.0.0.1', 50323)
基于TCP链接的简单并发程序
服务端：
import socketserver # 自定义类来实现通信循环 class MyTCPHandler(socketserver.BaseRequestHandler): # 必须写入handle方法，建立链接时会自动执行handle方法 def handle(self): while True: try: data = self.request.recv(1024) if not data: break print('->client:', data) self.request.send(data.upper()) except ConnectionResetError: break self.request.close() if __name__ == '__main__': server = socketserver.ThreadingTCPServer(('127.0.0.1', 8080), MyTCPHandler) server.serve_forever() # 链接循环
客户端1/2/3/4……
import socket client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) client.connect(('127.0.0.1',8080)) while True: client.send('hello'.encode('utf-8')) data = client.recv(1024) print(data)
基于UDP无链接的简单并发程序
服务端：
import socketserver # 自定义类来实现通信循环 class MyUDPHander(socketserver.BaseRequestHandler): def handle(self): data,sock = self.request sock.sendto(data.upper(),self.client_address) if __name__ == '__main__': server = socketserver.ThreadingUDPServer(('127.0.0.1', 8080), MyUDPHander) server.serve_forever() # 链接循环
客户端1/2/3/4……：
from socket import * client = socket(AF_INET,SOCK_DGRAM) while True: client.sendto(b'hello',('127.0.0.1',8080)) data,server_add = client.recvfrom(1024) print(data)
错误笔记：
ConnectionAbortedError: [WinError 10053] 你的主机中的软件中止了一个已建立的连接。
– 服务端代码错误
– 解决方法：自定义handler类内必须写入handle方法
ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝，无法连接。
– 解决方法：kill相关进程重新启动
