1. 程式人生 > >基於tcp的socketserver,即tcp的多線程

基於tcp的socketserver,即tcp的多線程

握手 for 數據 ket 函數 線程 listen utf-8 thread

tcp是數據流式的,它的收發信息,是通過管道的.在進行鏈接時,必須雙方同時答應,故有三次握手,四次斷開機制
服務端
import socketserver #用於進行都並發,即服務端能同時接收多個客戶端的鏈接通信
class My_server(socketserver.BaseRequestHandler): #通訊
def handle(self): #相當於conn,client_addr=phone.accept(),必須定義一個handle函數
print(‘========>‘,self)
print(self.request) #相當於conn
print(self.client_address) #相當於client_addr
while True: #通訊循環
data =self.request.recv(1024)#tcp是基於數據流的,收發的消息不能為空,
#在通訊循環中,發空消息,就會停到該處
print(data)
self.request.send(data.upper())


if __name__ == ‘__main__‘: #只在本腳本中執行
ip_port =(‘127.0.0.1‘,8083)
obj =socketserver.ThreadingTCPServer(ip_port,My_server) #通過tcp線程的實例化對象,實際上相當於完成了買手機,綁定電話卡
print(obj.server_address)
print(obj.RequestHandlerClass)
obj.serve_forever() #有一個循環,處於鏈接循環,相當於phone.listen(5),同時會執行handle方法

客戶端
import socket
phone =socket.socket(socket.AF_INET,socket.SOCK_STREAM)
ip_port =(‘127.0.0.1‘,8083)
phone.connect(ip_port)

while True:
msg =input(‘>>>: ‘).strip()
if not msg:continue
phone.send(msg.encode(‘utf-8‘))
data =phone.recv(1024)
print(data.decode(‘utf-8‘))

phone.close()

基於tcp的socketserver,即tcp的多線程