服務端：多進程和多線程的開啟方式相同。

缺點：<1> 由于Cpython的GIL，導致同一時間無法運行多個線程；<2> 不可能無限開進進程或線程

解決辦法：多進程、concurrent.futures.ProcessPoolExecutor、線程池

import socketfrom multiprocessing import Processfrom threading import Threadclass MyTcpServer: def __init__(self, ip, port): self.ip = ip self.port = port self.server = socket.socket() self.server.bind((self.ip, self.port)) self.server.listen(5) def wait_accept(self): conn, addr = self.server.accept() return conn, addr def handle_request(self, conn): while 1: try:data = conn.recv(1024)if not data: breakconn.send(data.upper()) except Exception as e:print(e)break conn.close()if __name__ == ’__main__’: server = MyTcpServer(’127.0.0.1’, 8888) while 1: conn, addr = server.wait_accept() p = Process(target=server.handle_request, args=(conn, ))# 創(chuàng)建一個進程 p.start()# 告訴操作提供，開啟這個進程進程池&線程池

異步提交任務，支持異步接收返回結果(submit返回一個futures對象，調(diào)用add_done_callback方法)

import socketfrom concurrent.futures import ProcessPoolExecutor# from concurrent.futures import ThreadPoolExecutorclass MyTcpServer: def __init__(self, ip, port): self.ip = ip self.port = port self.server = socket.socket() self.server.bind((self.ip, self.port)) self.server.listen(5) def wait_accept(self): conn, addr = self.server.accept() return conn, addr def handle_request(self, conn): while 1: try:data = conn.recv(1024)if not data: breakconn.send(data.upper()) except Exception as e:print(e)break conn.close()if __name__ == ’__main__’: server = MyTcpServer(’127.0.0.1’, 8888) pool = ProcessPoolExecutor(5) # 5個進程一直服務 while 1: conn, addr = server.wait_accept() pool.submit(server.handle_request, conn)# 異步提交任務socketserver

優(yōu)點：簡化socket服務端創(chuàng)建流程。提供服務端串行和并發(fā)兩種服務模式（TCPServer，ThreadingTCPServer）缺點：windows上無法使用多進程實現(xiàn)并發(fā)

import socketserverclass MyTcpHandler(socketserver.BaseRequestHandler): def handle(self):# 通信循環(huán) while 1: try:data = self.request.recv(1024)if not data: breakself.request.send(data.upper()) except Exception as e:print(e)break self.request.close()if __name__ == ’__main__’: ip_port = ’127.0.0.1’, 8888 server = socketserver.ThreadingTCPServer(ip_port, MyTcpHandler) # 異步處理 server.serve_forever()# 連接循環(huán)

協(xié)程

優(yōu)點：單線程內(nèi)實現(xiàn)并發(fā)，代碼級別模擬IO切換，提高程序運行效率

from gevent import spawn, monkey;monkey.patch_all()# 猴子補丁，補丁:常規(guī)IOimport socketclass MyTcpServer: def __init__(self, ip, port, my_spawn): self.ip = ip self.port = port self.server = socket.socket() self.server.bind((self.ip, self.port)) self.server.listen(5) self.spawn = my_spawn# 保存spawn本地 def wait_accept(self): while 1: conn, addr = self.server.accept() self.spawn(self.handle_request, conn)# 檢測 handle_request的io def handle_request(self, conn): while 1: try:data = conn.recv(1024)if not data: breakconn.send(data.upper()) except Exception as e:print(e)break conn.close()if __name__ == ’__main__’: server = MyTcpServer(’127.0.0.1’, 8888, spawn) g1 = server.spawn(server.wait_accept)# 檢測wait_accept的io g1.join()# 等待g1運行結束，即一直在循環(huán)檢測io

以上就是python 實現(xiàn)socket服務端并發(fā)的四種方式的詳細內(nèi)容，更多關于python socket服務端并發(fā)的資料請關注好吧啦網(wǎng)其它相關文章！