簡(jiǎn)介南京信息工程大學(xué)計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)套接字局域網(wǎng)通信軟件資源包面向高校網(wǎng)絡(luò)編程課程實(shí)踐者完整實(shí)現(xiàn)了基于TCP/IP的局域網(wǎng)一對(duì)一私聊、群聊與文件傳輸三大功能。項(xiàng)目采用客戶端/服務(wù)器架構(gòu)服務(wù)器端負(fù)責(zé)監(jiān)聽(tīng)連接、維護(hù)在線客戶端并處理收發(fā)數(shù)據(jù)客戶端則發(fā)起連接與消息交互一對(duì)一套接字連接隔離保障私密性群聊通過(guò)線程池管理并發(fā)連接并向在線成員廣播文件發(fā)送經(jīng)歷分包、傳輸、重組和保存流程還需考慮網(wǎng)絡(luò)帶寬與丟包重傳等問(wèn)題。壓縮包約5.09MB內(nèi)含可運(yùn)行的程序源代碼與配套課程設(shè)計(jì)報(bào)告報(bào)告覆蓋需求分析、系統(tǒng)設(shè)計(jì)、編碼實(shí)現(xiàn)、測(cè)試調(diào)試及性能優(yōu)化建議能夠幫助讀者掌握套接字接口、多線程編程和文件流操作等核心知識(shí)點(diǎn)。資源已有335人學(xué)習(xí)下載適合需要完成同類課程設(shè)計(jì)或希望深入理解局域網(wǎng)通信原理的本科生與開(kāi)發(fā)者。1. 為什么課程設(shè)計(jì)選Socket局域網(wǎng)通信從一對(duì)一到群聊一次把TCP的賬算清拿到“南京信息工程大學(xué)計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)”里的這個(gè)題目很多人第一反應(yīng)是“做個(gè)聊天窗口”。真正動(dòng)手才發(fā)現(xiàn)界面反而是最簡(jiǎn)單的一層卡人的是消息邊界、多客戶端并發(fā)、文件傳輸完整性這些計(jì)算機(jī)網(wǎng)絡(luò)課本里反復(fù)講、但代碼里很容易翻車的東西。Socket局域網(wǎng)通信軟件的核心不是花哨按鈕而是把TCP連接模型和協(xié)議設(shè)計(jì)做扎實(shí)。這套方案適合集中在實(shí)驗(yàn)室里驗(yàn)收的課程設(shè)計(jì)場(chǎng)景也適合第一次寫(xiě)socket編程的工程新手。代碼基于Python標(biāo)準(zhǔn)庫(kù)socket不需要第三方框架網(wǎng)絡(luò)包里的每一步都能在抓包工具里看到。本文給出一條從協(xié)議到代碼再到報(bào)告的完整路線照著做能在一周內(nèi)跑通一對(duì)一、群聊和文件傳輸并且能在報(bào)告里把設(shè)計(jì)理由寫(xiě)清楚而不是只貼代碼。2. 先畫(huà)協(xié)議再寫(xiě)代碼消息幀設(shè)計(jì)、連接管理和狀態(tài)機(jī)2.1 消息幀格式為什么不能用裸字符串直接傳socket編程里最容易踩的第一個(gè)坑就是把TCP當(dāng)成UDP來(lái)用覺(jué)得send(hello)之后對(duì)端就該一次性recv(hello)。但TCP是字節(jié)流協(xié)議沒(méi)有消息邊界。局域網(wǎng)內(nèi)延遲低小消息偶爾還能一次收到一旦消息變多一次recv(1024)可能返回半條消息也可能返回兩條半消息這就是粘包和半包。網(wǎng)絡(luò)編程里沒(méi)有“后悔藥”唯一可靠的做法是在應(yīng)用層自定義幀格式。發(fā)送端按照固定的頭部結(jié)構(gòu)把長(zhǎng)度和類型組裝好接收端嚴(yán)格按長(zhǎng)度讀取才能保證“收完一條再處理下一條”。import struct HEADER_STRUCT struct.Struct(!2sBBII) MAGIC bNJ # type: 0login 1chat 2file_meta 3file_data 4logout 5ack def build_frame(msg_type: int, sender: int, target: int, body: bytes) - bytes: header HEADER_STRUCT.pack(MAGIC, msg_type, sender, target, len(body)) return header body def parse_frame(data: bytes): if len(data) HEADER_STRUCT.size: return None magic, msg_type, sender, target, body_len HEADER_STRUCT.unpack_from(data) if magic ! MAGIC or len(data) HEADER_STRUCT.size body_len: return None body data[HEADER_STRUCT.size:HEADER_STRUCT.size body_len] return msg_type, sender, target, body!2sBBII表示網(wǎng)絡(luò)字節(jié)序大端2字節(jié)magic1字節(jié)type1字節(jié)sender編號(hào)1字節(jié)target編號(hào)4字節(jié)body長(zhǎng)度。magic用來(lái)做最基礎(chǔ)的校驗(yàn)防止把意外連進(jìn)來(lái)的非協(xié)議連接當(dāng)成正常消息。sender和target用1字節(jié)最多支持255個(gè)在線用戶課程設(shè)計(jì)規(guī)模完全夠用如果以后要擴(kuò)展超過(guò)255人可以把這兩處改成H2字節(jié)頭部結(jié)構(gòu)同步調(diào)整。body長(zhǎng)度用4字節(jié)無(wú)符號(hào)整數(shù)理論上最大4GB但實(shí)際不能把一個(gè)超大文件塞進(jìn)單條幀。后面?zhèn)鬏斘募r(shí)會(huì)對(duì)body再做分塊每塊的body大小控制在幾千字節(jié)避免單幀占用過(guò)多內(nèi)存。2.2 連接管理與狀態(tài)機(jī)一對(duì)一、群聊對(duì)TCP連接模型的不同要求一對(duì)一通信只需要兩個(gè)socket連接服務(wù)端和客戶端各持一端。群聊則必須引入中心服務(wù)器所有客戶端先連接服務(wù)器再由服務(wù)器做消息路由。不要嘗試在客戶端之間做點(diǎn)對(duì)點(diǎn)直連雖然局域網(wǎng)內(nèi)理論上可行但每臺(tái)機(jī)器防火墻的入站規(guī)則會(huì)讓第二臺(tái)、第三臺(tái)客戶端很難建立新連接。中心服務(wù)器只需要開(kāi)放一個(gè)端口所有入站流量都走那里管理和排錯(cuò)都更簡(jiǎn)單。一個(gè)TCP連接從accept到關(guān)閉應(yīng)該用狀態(tài)機(jī)管理。很多課設(shè)代碼只維護(hù)一個(gè)socket字典不記錄客戶端是否發(fā)了登錄包結(jié)果廣播時(shí)把未登錄的客戶端也算進(jìn)去在線列表永遠(yuǎn)不對(duì)。from enum import Enum class ClientState(Enum): INIT 0 # TCP已a(bǔ)ccept還未登錄 ONLINE 1 # 已登錄可收發(fā)消息 SHUTTING 2 # 正在關(guān)閉等待殘留數(shù)據(jù)發(fā)完 class ClientSession: def __init__(self, conn, addr): self.conn conn self.addr addr self.state ClientState.INIT self.username None self.recv_buffer bytearray()為什么不能accept之后立刻把連接加入廣播列表因?yàn)檫€不知道這個(gè)客戶端是誰(shuí)別人在在線列表里看到的是一個(gè)無(wú)名連接根本無(wú)法發(fā)起私聊。所以登錄包必須是連接建立后客戶端發(fā)送的第一條消息包含用戶名或編號(hào)。服務(wù)端收到后把session從INIT改為ONLINE再把用戶名寫(xiě)入映射表。狀態(tài)遷移里最容易被忽略的是異常斷開(kāi)。TCP連接異常斷開(kāi)時(shí)服務(wù)端的recv會(huì)返回空字節(jié)如果不清理session在線列表里會(huì)留下一個(gè)幽靈用戶其他人給他發(fā)私聊消息在服務(wù)器里積壓甚至觸發(fā)緩沖區(qū)寫(xiě)滿。2.3 為什么要一個(gè)獨(dú)立的recv_exact函數(shù)它是一切聊天不串包的前提socket.recv(1024)最多返回1024字節(jié)但實(shí)際可能少于這個(gè)數(shù)。如果把一次recv的結(jié)果當(dāng)成完整消息去解析只要一次收到兩條消息就會(huì)錯(cuò)位。正確做法是“先收固定長(zhǎng)度頭部再按頭部里的body長(zhǎng)度收正文”并且把“必須收滿N字節(jié)”的邏輯獨(dú)立出來(lái)。def recv_exact(conn, n: int) - bytes: chunks [] remain n while remain 0: data conn.recv(remain) if not data: raise ConnectionError(socket closed unexpectedly) chunks.append(data) remain - len(data) return b.join(chunks) def read_frame(conn): header recv_exact(conn, HEADER_STRUCT.size) magic, msg_type, sender, target, body_len HEADER_STRUCT.unpack(header) if magic ! MAGIC: raise ValueError(bad magic) body recv_exact(conn, body_len) return msg_type, sender, target, body注意recv()的參數(shù)是“剩余需要讀取的字節(jié)數(shù)”不是固定緩沖區(qū)大小。每次循環(huán)只取本次收到的長(zhǎng)度去扣減最終把所有分片拼起來(lái)保證不會(huì)多讀下一個(gè)幀的數(shù)據(jù)。這樣就不會(huì)出現(xiàn)“為什么socket接收到奇數(shù)字節(jié)、后面會(huì)補(bǔ)一個(gè)隨機(jī)數(shù)”的現(xiàn)象——那不是系統(tǒng)補(bǔ)的是你多讀了下一幀的頭部把它當(dāng)成了隨機(jī)數(shù)據(jù)。網(wǎng)絡(luò)框架里常見(jiàn)的no more data from socket錯(cuò)誤本質(zhì)也是對(duì)端關(guān)閉連接后你又調(diào)用recv用read_frame里的空字節(jié)判斷就能主動(dòng)識(shí)別。3. 用Python的socket庫(kù)跑通一對(duì)一的完整鏈路客戶端與服務(wù)端最小實(shí)現(xiàn)3.1 服務(wù)端綁定、監(jiān)聽(tīng)、accept循環(huán)先把一對(duì)一的鏈路跑起來(lái)再逐步加功能。這里用線程處理每個(gè)客戶端連接雖然一對(duì)一場(chǎng)景用不到多線程但為后面的群聊留好骨架。import socket import threading HOST 0.0.0.0 PORT 8888 server socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) server.bind((HOST, PORT)) server.listen(5) print(flistening on {HOST}:{PORT}) def handle(conn: socket.socket, addr): print(connected, addr) try: while True: data conn.recv(1024) if not data: break conn.sendall(back: data) except ConnectionResetError: pass finally: conn.close() print(closed, addr) while True: conn, addr server.accept() threading.Thread(targethandle, args(conn, addr), daemonTrue).start()bind的IP地址必須用0.0.0.0而不是127.0.0.1。127.0.0.1只監(jiān)聽(tīng)本機(jī)回環(huán)網(wǎng)卡同一局域網(wǎng)內(nèi)其他電腦連不進(jìn)來(lái)0.0.0.0表示監(jiān)聽(tīng)所有網(wǎng)卡既能本機(jī)測(cè)試也能跨機(jī)聯(lián)調(diào)。SO_REUSEADDR是為了在調(diào)試時(shí)快速重啟服務(wù)端否則端口可能因?yàn)門IME_WAIT狀態(tài)被占用報(bào)Address already in use。listen(5)是內(nèi)核accept隊(duì)列的長(zhǎng)度課程設(shè)計(jì)里10個(gè)客戶端以內(nèi)5已經(jīng)夠用。每個(gè)連接一個(gè)線程線程設(shè)置daemonTrue這樣服務(wù)端主程序CtrlC退出時(shí)不會(huì)因?yàn)槟硞€(gè)阻塞的recv線程而掛住。3.2 客戶端連接、收發(fā)與優(yōu)雅關(guān)閉客戶端代碼更簡(jiǎn)單但有一個(gè)參數(shù)值得注意connect只接受元組不接受字符串拼接。import socket SERVER_IP 192.168.1.100 PORT 8888 client socket.socket(socket.AF_INET, socket.SOCK_STREAM) client.settimeout(5.0) client.connect((SERVER_IP, PORT)) client.sendall(bhello from client) reply client.recv(1024) print(reply) client.close()settimeout(5.0)很關(guān)鍵。如果服務(wù)端不存在或端口不通客戶端會(huì)一直阻塞在connect上界面像死了一樣。設(shè)了超時(shí)后5秒內(nèi)連不上會(huì)拋socket.timeout至少能拿到一個(gè)可讀的報(bào)錯(cuò)。跨機(jī)測(cè)試時(shí)把SERVER_IP改成服務(wù)端的局域網(wǎng)IP只在本機(jī)驗(yàn)證時(shí)寫(xiě)127.0.0.1就好。sendall和send的區(qū)別經(jīng)常被忽略。send只負(fù)責(zé)向內(nèi)核緩沖區(qū)提交數(shù)據(jù)可能只發(fā)送一部分就返回sendall會(huì)循環(huán)調(diào)用直到整個(gè)字節(jié)串都進(jìn)入內(nèi)核緩沖異常時(shí)才拋錯(cuò)。課程設(shè)計(jì)中無(wú)條件用sendall比send省心得多。3.3 先本機(jī)后跨機(jī)的聯(lián)調(diào)步驟第一步在終端啟動(dòng)服務(wù)端看到listening on 0.0.0.0:8888。第二步新開(kāi)一個(gè)終端運(yùn)行客戶端服務(wù)端打印connected 127.0.0.1:xxxx客戶端打印back:hello from client本機(jī)鏈路就通了?？鐧C(jī)驗(yàn)證時(shí)先查服務(wù)端機(jī)器的局域網(wǎng)IP。Windows用ipconfigLinux/macOS用ifconfig或ip addr。然后在客戶端機(jī)器上先ping 服務(wù)端IP能通再改代碼里的SERVER_IP。如果ping不同優(yōu)先檢查兩臺(tái)機(jī)器是否在同一網(wǎng)段再檢查防火墻是否放行Python進(jìn)程和TCP 8888端口。這一步最快的驗(yàn)證工具是telnet 服務(wù)端IP 8888能看到端口開(kāi)放說(shuō)明網(wǎng)絡(luò)通路沒(méi)問(wèn)題。如果是連接成功但馬上斷開(kāi)多數(shù)是服務(wù)端線程里沒(méi)做好循環(huán)或客戶端沒(méi)給服務(wù)端留出發(fā)送數(shù)據(jù)的時(shí)間。4. 加群聊和文件傳輸數(shù)據(jù)分發(fā)策略與粘包處理4.1 群聊的數(shù)據(jù)分發(fā)廣播與私聊的消息路由群聊要求所有客戶端都連接到服務(wù)端服務(wù)端維護(hù)兩張映射表用戶名到連接、連接到用戶名。收到消息后根據(jù)type字段決定是廣播還是私聊。廣播需要遍歷在線列表給除發(fā)送者之外的所有客戶端轉(zhuǎn)發(fā)私聊則根據(jù)target編號(hào)找到對(duì)應(yīng)連接只發(fā)給一個(gè)人。conn_to_id {} id_to_conn {} lock threading.Lock() def broadcast(msg_type, sender_id, body): frame build_frame(msg_type, sender_id, 0, body) with lock: for cid, conn in list(id_to_conn.items()): if cid ! sender_id: try: conn.sendall(frame) except OSError: pass def unicast(msg_type, sender_id, target_id, body): frame build_frame(msg_type, sender_id, target_id, body) with lock: conn id_to_conn.get(target_id) if conn: conn.sendall(frame)lock必須包住遍歷和send的整個(gè)過(guò)程否則兩個(gè)線程同時(shí)給同一個(gè)socket發(fā)送數(shù)據(jù)可能出現(xiàn)字節(jié)交錯(cuò)接收端解析出來(lái)的幀全是亂的。list(id_to_conn.items())是為了在遍歷時(shí)允許字典被其他線程修改否則會(huì)拋dictionary changed size during iteration。try OSError也不能省?？蛻舳税尉W(wǎng)線或直接斷電時(shí)sendall會(huì)拋BrokenPipeError或ConnectionResetError這些都屬于OSError。如果不捕獲一個(gè)異常客戶端就會(huì)打斷整個(gè)廣播循環(huán)其他客戶端跟著掉線。4.2 發(fā)送文件先發(fā)元數(shù)據(jù)再分塊傳附MD5校驗(yàn)文件傳輸不能像聊天消息那樣一幀發(fā)完。文件可能幾十MB甚至更大必須分塊讀取、分塊發(fā)送。這里采用“先發(fā)元數(shù)據(jù)再發(fā)文件數(shù)據(jù)”的兩階段方式。import hashlib, json, os def send_file(sock, target_id, path): md5obj hashlib.md5() with open(path, rb) as f: while chunk : f.read(4096): md5obj.update(chunk) meta { name: os.path.basename(path), size: os.path.getsize(path), md5: md5obj.hexdigest(), } sock.sendall(build_frame(2, MY_ID, target_id, json.dumps(meta).encode())) with open(path, rb) as f: while chunk : f.read(4096): sock.sendall(build_frame(3, MY_ID, target_id, chunk)) sock.sendall(build_frame(3, MY_ID, target_id, b__END__))為什么要先讀一遍算MD5因?yàn)镸D5必須覆蓋整個(gè)文件內(nèi)容邊讀邊算最直接。先讀一遍再發(fā)送雖然文件被讀取兩次但課程設(shè)計(jì)場(chǎng)景下性能完全可接受換來(lái)的是接收端能校驗(yàn)文件完整性。接收端按幀讀取先收元數(shù)據(jù)幀再持續(xù)收文件數(shù)據(jù)幀。def recv_file(sock, save_dir.): msg_type, sender, target, body read_frame(sock) meta json.loads(body) total 0 md5obj hashlib.md5() save_path os.path.join(save_dir, meta[name]) with open(save_path, wb) as f: while True: msg_type, sender, target, body read_frame(sock) if msg_type ! 3: break if body b__END__: break f.write(body) md5obj.update(body) total len(body) if total ! meta[size]: raise ValueError(size mismatch) if md5obj.hexdigest() ! meta[md5]: raise ValueError(md5 mismatch)分塊大小4096是保守值可以調(diào)整到16384甚至65536。塊越大單位時(shí)間內(nèi)發(fā)送的次數(shù)越少CPU開(kāi)銷越低但單塊超過(guò)幾MB時(shí)接收端的內(nèi)存緩沖和重傳代價(jià)都會(huì)上升。文件傳輸失敗時(shí)先看MD5是哪個(gè)值對(duì)不上再用ls -l對(duì)比接收文件大小。如果size不對(duì)基本可以斷定粘包處理有問(wèn)題接收端把聊天消息或下一個(gè)文件的元數(shù)據(jù)也寫(xiě)進(jìn)了文件。4.3 帶序號(hào)的文件塊要不要做ACK和滑動(dòng)窗口上面這套方案已經(jīng)夠課程設(shè)計(jì)用但它有一個(gè)盲區(qū)如果發(fā)送端發(fā)出的某個(gè)塊在網(wǎng)絡(luò)上丟失接收端只會(huì)一直等等不到就報(bào)錯(cuò)不會(huì)自動(dòng)重傳。TCP本身有超時(shí)重傳機(jī)制在局域網(wǎng)里丟包率很低發(fā)送端不大可能遇到塊級(jí)丟失。但課程設(shè)計(jì)報(bào)告如果想拿高分建議討論一下帶序號(hào)的方案。在每塊文件數(shù)據(jù)前面加4字節(jié)序號(hào)接收端每收一塊回一個(gè)ACK幀發(fā)送端維護(hù)未確認(rèn)塊列表。這個(gè)設(shè)計(jì)很像簡(jiǎn)化版的滑動(dòng)窗口。# 發(fā)送第i塊 seq_body struct.pack(!I, i) chunk sock.sendall(build_frame(3, MY_ID, target_id, seq_body)) # 接收端解析后回ACK def parse_data_chunk(body): seq, data body[:4], body[4:] return struct.unpack(!I, seq)[0], data有了序號(hào)報(bào)告里可以寫(xiě)“當(dāng)連續(xù)3個(gè)ACK超時(shí)判定當(dāng)前塊丟失發(fā)送端重發(fā)”。實(shí)際驗(yàn)收時(shí)可以通過(guò)在發(fā)送循環(huán)里sleep(0.1)人為制造慢速發(fā)送觀察接收端序號(hào)是否連續(xù)這是報(bào)告里非常有說(shuō)服力的測(cè)試數(shù)據(jù)。5. 局域網(wǎng)聯(lián)調(diào)與常見(jiàn)問(wèn)題排查為什么本機(jī)能跑換臺(tái)電腦就翻車的避坑記錄5.1 現(xiàn)象本機(jī)用127.0.0.1連正常換局域網(wǎng)IP就連不上這是課程設(shè)計(jì)驗(yàn)收現(xiàn)場(chǎng)翻車率最高的問(wèn)題。原因有三個(gè)第一服務(wù)端bind了127.0.0.1只監(jiān)聽(tīng)回環(huán)口第二Windows防火墻默認(rèn)阻止Python進(jìn)程入站第三兩臺(tái)機(jī)器不在同一網(wǎng)段。解決方法是先確認(rèn)服務(wù)端代碼里寫(xiě)的是0.0.0.0再用管理員權(quán)限在Windows“高級(jí)安全Windows Defender防火墻”中新建入站規(guī)則允許TCP端口8888。很多同學(xué)把防火墻整個(gè)關(guān)掉雖然能通但報(bào)告里不好寫(xiě)而且有安全隱患。正確做法是只放行自己端口。然后檢查兩臺(tái)機(jī)器是否在同一局域網(wǎng)用ping驗(yàn)證。注意Wi-Fi環(huán)境下服務(wù)端連的是192.168.1.x客戶端卻連了手機(jī)熱點(diǎn)192.168.137.x這種情況下ping不通自然連不上。把兩臺(tái)設(shè)備放到同一個(gè)路由器或交換機(jī)下即可。5.2 現(xiàn)象聊天內(nèi)容串包兩個(gè)消息拼在一起文件傳完MD5不對(duì)原因非常明確客戶端或服務(wù)端用recv(1024)直接解析消息沒(méi)有按長(zhǎng)度前綴讀取。TCP是字節(jié)流一次recv可能返回多條消息也可能只返回一條消息的一半。解決方法是全局統(tǒng)一使用read_frame任何類型的消息都不直接調(diào)recv。文件傳輸?shù)慕邮斩艘惨胷ead_frame而不是自己再拼一次緩沖區(qū)。串包問(wèn)題只要協(xié)議做對(duì)了一次解決。血淚經(jīng)驗(yàn)是千萬(wàn)不要在recv之后手動(dòng)按\n去切字符串聊天內(nèi)容里只要含換行就會(huì)炸。5.3 現(xiàn)象為什么socket接收到的字節(jié)是奇數(shù)長(zhǎng)度后面還跟了一串隨機(jī)數(shù)這個(gè)問(wèn)題在socket編程的搜索里很常見(jiàn)。實(shí)際不是系統(tǒng)補(bǔ)了隨機(jī)數(shù)而是你的緩沖區(qū)里殘留了下一個(gè)消息的頭部或正文。比如消息A長(zhǎng)度是10字節(jié)一次recv返回了20字節(jié)你按固定的\n去截取前10字節(jié)給了A后10字節(jié)沒(méi)保存等下一輪recv時(shí)A后面的數(shù)據(jù)再拼上新的recv看起來(lái)就像尾部多了隨機(jī)字節(jié)。解決方法是把“多讀到的數(shù)據(jù)”留存在接收緩沖區(qū)里。最簡(jiǎn)單的方式就是不用裸recv而是用read_framerecv_exact每次只讀固定長(zhǎng)度不會(huì)多讀因此不會(huì)留下殘包。如果已經(jīng)寫(xiě)了buffer類要記得在解析完一幀后把剩余bytes挪到buffer頭部不能丟。5.4 現(xiàn)象多個(gè)客戶端同時(shí)收發(fā)時(shí)界面卡死服務(wù)端CPU占滿客戶端如果在Tkinter或PyQt的界面線程里調(diào)用recv只要socket沒(méi)數(shù)據(jù)整個(gè)窗口就會(huì)凍結(jié)。服務(wù)端CPU占滿則多是因?yàn)槟硞€(gè)連接進(jìn)入了死循環(huán)比如solve一個(gè)待處理消息時(shí)用了while True但沒(méi)有break?？蛻舳吮仨毎丫W(wǎng)絡(luò)收發(fā)放到后臺(tái)線程界面線程只通過(guò)隊(duì)列讀取消息。Python的queue.Queue是線程安全的適合做這個(gè)轉(zhuǎn)接。import queue import threading msg_q queue.Queue() def recv_worker(sock): while True: try: frame read_frame(sock) msg_q.put(frame) except (ConnectionError, OSError): break threading.Thread(targetrecv_worker, args(sock,), daemonTrue).start()界面線程每次只做msg_q.get()或msg_q.get(timeout100)不會(huì)阻塞在網(wǎng)絡(luò)操作上。服務(wù)端每個(gè)連接一個(gè)線程沒(méi)有問(wèn)題但所有sendall必須被同一個(gè)鎖保護(hù)否則字節(jié)交錯(cuò)。需要更高并發(fā)時(shí)再考慮select或asyncio課程設(shè)計(jì)不必一步到位。5.5 現(xiàn)象報(bào)錯(cuò)“no more data from socket”以及被誤認(rèn)為數(shù)據(jù)庫(kù)問(wèn)題的錯(cuò)誤no more data from socket常見(jiàn)于對(duì)端關(guān)閉后繼續(xù)讀取的場(chǎng)景。在文件傳輸中如果發(fā)送端沒(méi)有發(fā)送__END__標(biāo)記就異常退出接收端會(huì)一直卡在read_frame一旦底層連接超時(shí)或被重置就會(huì)看到這個(gè)錯(cuò)誤。解決方式是在接收循環(huán)里捕獲ConnectionError并在超時(shí)后做文件分塊重傳或整體重傳。另一個(gè)容易混淆的是搜socket時(shí)誤入數(shù)據(jù)庫(kù)坑。網(wǎng)上大量報(bào)錯(cuò)“error 2002 (HY000): cant connect to local MySQL server through socket /tmp/mysql.sock”這是MySQL客戶端把Unix domain socket和TCP socket搞混了。課程設(shè)計(jì)里的聊天軟件如果還要連MySQL做登錄注冊(cè)連接參數(shù)必須使用host和port例如host127.0.0.1, port3306不要寫(xiě)socket/tmp/mysql.sock。這兩套socket不是一個(gè)東西錯(cuò)一個(gè)半天查不出來(lái)。5.6 現(xiàn)象把Socket當(dāng)成WebSocket去查Spring Boot配置和跨域問(wèn)題看到“Socket”就去搜“spring boot集成web socket yml配置”“socket有跨域嗎”是方向性錯(cuò)誤。這門課程設(shè)計(jì)要的是操作系統(tǒng)提供的TCP socket接口由socket()函數(shù)創(chuàng)建數(shù)據(jù)在局域網(wǎng)內(nèi)按字節(jié)流傳輸。WebSocket則是在HTTP之上建立的雙向通信協(xié)議主要面向?yàn)g覽器端到服務(wù)器端的實(shí)時(shí)推送有跨域、握手、瀏覽器兼容等一堆額外問(wèn)題。如果你的課設(shè)是Python命令行或桌面窗口完全沒(méi)有必要引入WebSocket。報(bào)告里如果寫(xiě)“采用socket編程”就老老實(shí)實(shí)展示TCP三次握手和數(shù)據(jù)幀。引入WebSocket反而會(huì)讓評(píng)委質(zhì)疑你對(duì)計(jì)算機(jī)網(wǎng)絡(luò)底層概念的掌握程度。6. 讓課程設(shè)計(jì)報(bào)告拿得出手抓包驗(yàn)證、性能測(cè)試和三層實(shí)驗(yàn)結(jié)論6.1 Wireshark抓包驗(yàn)證三次握手和數(shù)據(jù)幀報(bào)告里貼一張抓包截圖能說(shuō)明你做的不是玩具。打開(kāi)Wireshark選客戶端所在網(wǎng)卡過(guò)濾器寫(xiě)tcp.port 8888然后啟動(dòng)客戶端連接服務(wù)端。第一條是客戶端發(fā)SYN第二條是服務(wù)端回SYNACK第三條是客戶端回ACK這就是TCP三次握手。再發(fā)一條聊天消息Wireshark會(huì)顯示PSH、ACK標(biāo)志位選中數(shù)據(jù)包可以在下方看到應(yīng)用層字節(jié)。對(duì)照你自己的協(xié)議設(shè)計(jì)前2字節(jié)是MAGIC第3字節(jié)是消息類型第4、5字節(jié)是sender和target后面是body長(zhǎng)度和內(nèi)容。報(bào)告里寫(xiě)“抓包結(jié)果與協(xié)議定義完全一致”這就是設(shè)計(jì)閉環(huán)。6.2 用并發(fā)腳本測(cè)出群聊的吞吐與成功率在服務(wù)端和客戶端跑通之后寫(xiě)一個(gè)并發(fā)腳本統(tǒng)計(jì)群聊場(chǎng)景下的平均響應(yīng)時(shí)間。代碼復(fù)用前面的build_frame、read_frame并發(fā)起5個(gè)客戶端每個(gè)客戶端連續(xù)發(fā)送50條群聊消息。import socket import threading import time import statistics import struct results [] def one_client(idx): sock socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.connect((192.168.1.100, 8888)) sock.sendall(build_frame(0, idx, 0, buser str(idx).encode())) time.sleep(0.2) t0 time.time() for i in range(50): sock.sendall(build_frame(1, idx, 0, fmsg{i}.encode())) read_frame(sock) dt time.time() - t0 results.append(dt) sock.close() threads [threading.Thread(targetone_client, args(i,)) for i in range(5)] for t in threads: t.start() for t in threads: t.join() print(avg response time:, statistics.mean(results))注意測(cè)試時(shí)把192.168.1.100換成你自己服務(wù)端IP。這個(gè)腳本會(huì)測(cè)量從發(fā)送到收到廣播回包的總耗時(shí)把客戶端數(shù)量從1調(diào)到5、10得到一組“用戶數(shù)—平均響應(yīng)時(shí)間”數(shù)據(jù)。課程設(shè)計(jì)報(bào)告中用一張折線圖展示比寫(xiě)一百句“性能良好”都管用。6.3 報(bào)告三層結(jié)論需求、設(shè)計(jì)、測(cè)試怎么串起來(lái)報(bào)告別按代碼順序抄要按“需求→設(shè)計(jì)→測(cè)試”三層來(lái)寫(xiě)。需求分析寫(xiě)清楚場(chǎng)景支持一對(duì)一會(huì)話、群聊廣播、文件傳輸?shù)卿浻脩羯舷?0人文件大小不超過(guò)200MB丟包率接近0。設(shè)計(jì)章節(jié)放協(xié)議幀結(jié)構(gòu)、狀態(tài)機(jī)、連接路由表和線程模型這是拿分重點(diǎn)每張圖都要對(duì)應(yīng)到代碼里的一個(gè)函數(shù)。測(cè)試章節(jié)放三種結(jié)果抓包驗(yàn)證的連接建立與幀格式、并發(fā)腳本得到的響應(yīng)時(shí)間曲線、文件傳輸前后的MD5對(duì)比。最后寫(xiě)一段話把三層串起來(lái)“協(xié)議中的長(zhǎng)度前綴解決了TCP粘包問(wèn)題因此文件傳輸在100輪測(cè)試中MD5全部一致線程鎖保證廣播在高并發(fā)下字節(jié)不交錯(cuò)客戶端數(shù)量從1增加到10時(shí)平均響應(yīng)時(shí)間從2ms上升到15ms但無(wú)丟包?！蹦悄晡易稣n設(shè)的時(shí)候自認(rèn)為把socket用明白了結(jié)果驗(yàn)收現(xiàn)場(chǎng)演示文件傳輸最后一塊數(shù)據(jù)沒(méi)收到文件打開(kāi)亂碼。后來(lái)加上長(zhǎng)度前綴和MD5校驗(yàn)才算真正踏實(shí)。希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取