本文實例為大家分享了python多線程實現(xiàn)TCP服務(wù)端的具體代碼,供大家參考,具體內(nèi)容如下
需求
1.創(chuàng)建一個TCP服務(wù)器接收服務(wù)端發(fā)送的信息并給予答復(fù)
2.以多線程方式實現(xiàn)接收客戶端信息
3.間客戶端發(fā)送的信息解碼輸出
思路分析
1.創(chuàng)建一個TCP客戶端套接字
2.寫一個接收消息的方法,可以接收客戶端消息并解碼輸出
3.客戶端被動監(jiān)聽,每有一個客戶端連接就創(chuàng)建一個子線程執(zhí)行接收消息方法
代碼實現(xiàn)
# 導(dǎo)入模塊 import socket import threading # 接收消息 def recv(client_socket, ip_port): while True: client_text = client_socket.recv(1024) # 如果接收的消息長度不為0,則將其解碼輸出 if client_text: print("[客戶端消息]", ip_port, ":", client_text.decode("gbk")) # 給客戶端響應(yīng) client_socket.send("收到\n".encode()) # 當(dāng)客戶端斷開連接時,會一直發(fā)送''空字符串,所以長度為0已下線 else: print("客戶端", ip_port, "已下線") client_socket.close() break # 程序主入口 def main(): # 創(chuàng)建TCP套接字 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 設(shè)置端口復(fù)用 tcp_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) # 綁定端口 tcp_socket.bind(("", 8080)) # 設(shè)置為被動監(jiān)聽狀態(tài),128表示大連接數(shù) tcp_socket.listen(128) while True: # 等待客戶端連接 client_socket, ip_port = tcp_socket.accept() print("[新客戶端]:", ip_port, "已連接") # 有客戶端連接后,創(chuàng)建一個線程將客戶端套接字,IP端口傳入recv函數(shù), t1 = threading.Thread(target=recv, args=(client_socket, ip_port)) # 設(shè)置線程守護 t1.setDaemon(True) # 啟動線程 t1.start() if __name__ == '__main__': main()
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
分享文章:python多線程實現(xiàn)TCP服務(wù)端-創(chuàng)新互聯(lián)
轉(zhuǎn)載來于:http://jinyejixie.com/article18/dcjcgp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供云服務(wù)器、網(wǎng)站設(shè)計公司、建站公司、營銷型網(wǎng)站建設(shè)、域名注冊、品牌網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容