Python socket处理client连接过程解析
本文解析Python中Socket处理客户端连接的机制。指出原生Socket仅支持单连接,需使用SocketServer实现并发。通过ThreadingTCPServer多线程示例,展示服务端接收、转换并返回数据,以及客户端发送与接收响应的完整流程,帮助开发者掌握Python网络编程基础。
Python Socket并发处理概述
原生Socket模块默认仅能处理单个客户端连接。若需实现多客户端并发交互,应引入socketserver模块。以下提供相关代码示例及详细注释说明。
服务端实现逻辑如下:
服务端SocketServer实现
import socketserver
#之前的socket只能同时处理一个客户端,当需要并发处理client发送的信息是需要使用到socketserver,下面创建一个类,继承socketserver其对应实例就有并发能力
class My_Tcp_Handler(socketserver.BaseRequestHandler):
#下面的handler是自己定义的server与client交互的过程,所有交互过程都在此方法内部实现.方法名handle是固定的
def handle(self):
while True:
try:
#下面将收到的数据打印并且大写后发回给客户端
self.data = self.request.recv(1024)
print(self.data.decode(encoding="utf-8"))
self.send_data = self.data.decode(encoding="utf-8").upper().encode(encoding="utf-8")
self.request.sendall(self.send_data)
except ConnectionResetError as e:
print("一个客户端关闭了连接")
break
#实例化socketserver
My_server = socketserver.ThreadingTCPServer(("0.0.0.0", 8888), My_Tcp_Handler) #ThreadingTCPServer是使用多线程,ForkingTCPServer是使用多进程处理并发
#启动实例
My_server.serve_forever()
客户端连接与通信代码如下:
客户端连接与通信示例
import socket
client = socket.socket()
client.connect(("127.0.0.1", 8888))
while True:
msg = input()
if len(msg) == 0:
continue
client.send(msg.encode(encoding="utf-8")) #如果发送中文需要对其进行encode,接收也需要decode;英文前面直接加b指定类型
client_rec = client.recv(1024).decode(encoding="utf-8")
print("client_rec:", client_rec)
client.close()
以上内容涵盖了Python Socket并发处理的核心要点,旨在辅助读者理解相关技术原理。欢迎持续关注本站以获取更多技术分享。
免责声明:本文内容仅供参考,不代表本站观点。转载或引用请注明出处。









