位置：首页-资讯-后端开发

python3-socketserver

2023-01-31 02:18

短信预约 -IT技能 免费直播动态提醒

socketserver模块

基于TCP链接的简单并发程序

基于UDP无链接的简单并发程序

错误笔记：

ConnectionAbortedError: [WinError 10053] 你的主机中的软件中止了一个已建立的连接。

ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝，无法连接。

模块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)