''' 基于socket實(shí)現(xiàn)的多任務(wù)版TCP服務(wù)端 ''' import socket import threadingdef client_task(client_socket,ip_port):print(ip_port,'加入連接')# 持續(xù)接收客戶端的消息while True:data=client_socket.recv(1024).decode('gbk')if len(data)!=0:print(f'客戶端{(lán)ip_port[0]}發(fā)來(lái)的信息是{data}')else:print(f'客戶端{(lán)ip_port[0]}已經(jīng)斷開(kāi)連接')breaksend_data=('Hello--'+data).encode('gbk')client_socket.send(send_data)if __name__ == '__main__':server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,True)server_socket.bind(('',7777))server_socket.listen(128)# 循環(huán)接收客戶連接while True:client_socket,ip_port=server_socket.accept() # 會(huì)一直等待接收連接t_client=threading.Thread(target=client_task,args=(client_socket,ip_port))t_client.setDaemon(True)t_client.start()

面向?qū)ο蟀姹?/p> ''' 基于socket實(shí)現(xiàn)的多任務(wù)版TCP服務(wù)端（面向?qū)ο?#xff09; '''import socket import threadingclass SocketServer(object):def __init__(self, port):self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)self.server_socket.bind(('', port))self.server_socket.listen(128)def start(self):# 循環(huán)接收客戶連接while True:client_socket, ip_port = self.server_socket.accept() # 會(huì)一直等待接收連接t_client = threading.Thread(target=self.client_task, args=(client_socket, ip_port))t_client.setDaemon(True)t_client.start()def client_task(self,client_socket, ip_port):print(ip_port, '加入連接')# 持續(xù)接收客戶端的消息while True:data = client_socket.recv(1024).decode('gbk')if len(data) != 0:print(f'客戶端{(lán)ip_port[0]}發(fā)來(lái)的信息是{data}')else:print(f'客戶端{(lán)ip_port[0]}已經(jīng)斷開(kāi)連接')breaksend_data = ('Hello--' + data).encode('gbk')client_socket.send(send_data)if __name__ == '__main__':server_socket=SocketServer(7777)server_socket.start()

總結(jié)

以上是生活随笔為你收集整理的Python基于socket实现的多任务版TCP服务端的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。