1.基于線程池實現并發套接字通訊：因為套接字涉及地是I/O密集模型，因此使用多線程會有高效率

'''
服務器
'''#基于線程池完成并發的套接字通訊
from socket import *
from threading import Thread
from concurrent.futures import ThreadPoolExecutordef communicate(conn):while True:try:data = conn.recv(1024)#1024表示接收的字節最大量是1024bytesprint('這是客戶端的請求數據',data)conn.send(data.upper())except ConnectionResetError:breakdef connect(ip,port):phone = socket(AF_INET,SOCK_STREAM)phone.bind((ip,port))phone.listen(5)while True:res = phone.accept()conn,client_addr = rest = Thread(target=communicate,args=(conn,))t.start()phone.close()if __name__ == '__main__':pool = ThreadPoolExecutor(5)pool.submit(connect,'127.0.0.1',8081)'''
客戶端
'''import socketdef client(ip,port):phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)phone.connect((ip,port))while True:cmd = input("請輸入命名：")if not cmd:continuephone.send(cmd.encode('utf-8'))res = phone.recv(1024)#接收小于1024bytes的數據print('服務器返回來的數據：',res.decode('gbk'))print('*'*50)#5、關閉套接字phonephone.close()if __name__ == '__main__':client('127.0.0.1',8081)

2.基于gevent協程實現并發套接字通訊

'''
服務器
'''#基于gevent完成并發的套接字通訊
from socket import *
from threading import Thread
from gevent import spawn,monkeymonkey.patch_all()
def communicate(conn):while True:try:data = conn.recv(1024)#1024表示接收的字節最大量是1024bytesprint('這是客戶端的請求數據',data)conn.send(data.upper())except ConnectionResetError:breakdef connect(ip,port):phone = socket(AF_INET,SOCK_STREAM)phone.bind((ip,port))phone.listen(5)while True:res = phone.accept()conn,client_addr = resspawn(communicate,conn).join()if __name__ == '__main__':g = spawn(connect,'127.0.0.1',8090)g.join()'''
客戶端
'''
import socket
from threading import currentThread,Threaddef client():phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)phone.connect(('127.0.0.1',8090))while True:# cmd = input("請輸入命名：")# cmd =# if not cmd:continuephone.send(('%s hello'%currentThread().getName()).encode('utf-8'))res = phone.recv(1024)#接收小于1024bytes的數據print('服務器返回來的數據：',res.decode('gbk'))print('*'*50)#5、關閉套接字phonephone.close()if __name__ == '__main__':for i in range(500):t = Thread(target=client)t.start()

?