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