本文實例為大家分享了python實現TCP文件接收發送的具體代碼，供大家參考，具體內容如下
下一篇分享：udp收發的實現
先運行服務器端打開接收，在運行客服端發送文件
還有記得改一下ip喲
1、發送
根據自己需求修改，簡單局域網下完成文件收發
客戶端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
# 由客戶端向服務器傳數據，文件import socketimport tqdmimport osdef send(filename): # 傳輸數據間隔符 SEPARATOR = '<SEPARATOR>' # 服務器信息 host = '127.0.0.1' port =1234 # 文件緩沖區 Buffersize = 4096*10 # 傳輸文件名字 filename = filename # 文件大小 file_size = os.path.getsize(filename) # 創建socket鏈接 s = socket.socket() print(f'服務器連接中{host}:{port}') s.connect((host, port)) print('與服務器連接成功') # 發送文件名字和文件大小，必須進行編碼處理 s.send(f'{filename}{SEPARATOR}{file_size}'.encode()) # 文件傳輸 progress = tqdm.tqdm(range(file_size), f'發送{filename}', unit='B', unit_divisor=1024) with open(filename,'rb') as f : # 讀取文件 for _ in progress: bytes_read = f.read(Buffersize) if not bytes_read: break # sendall 確保網絡忙碌的時候，數據仍然可以傳輸 s.sendall(bytes_read) progress.update(len(bytes_read)) # 關閉資源 s.close()if __name__ == '__main__': filename = input('請輸入文件名：') send(filename) |
2、接收
服務器端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
import socketimport tqdmimport osimport threadingdef received(): # 設置服務器的ip和 port # 服務器信息 sever_host = '127.0.0.1' sever_port =1234 # 傳輸數據間隔符 SEPARATOR = '<SEPARATOR>' # 文件緩沖區 Buffersize = 4096*10 s = socket.socket() s.bind((sever_host, sever_port)) # 設置監聽數 s.listen(128) print(f'服務器監聽{sever_host}:{sever_port}') # 接收客戶端連接 client_socket, address = s.accept() # 打印客戶端ip print(f'客戶端{address}連接') # 接收客戶端信息 received = client_socket.recv(Buffersize).decode() filename ,file_size = received.split(SEPARATOR) # 獲取文件的名字,大小 filename = os.path.basename(filename) file_size = int(file_size) # 文件接收處理 progress = tqdm.tqdm(range(file_size), f'接收{filename}', unit='B', unit_divisor=1024, unit_scale=True) with open('8_18_'+filename,'wb') as f: for _ in progress: # 從客戶端讀取數據 bytes_read = client_socket.recv(Buffersize) # 如果沒有數據傳輸內容 if not bytes_read: break # 讀取寫入 f.write(bytes_read) # 更新進度條 progress.update(len(bytes_read)) # 關閉資源 client_socket.close() s.close()if __name__ == '__main__': received() |
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/JSSQSC/article/details/120040566
