socket是編程語言對(duì)tcp/ip協(xié)議的封裝，使用其可以在兩個(gè)主機(jī)之間傳輸文件，下面直接進(jìn)入主題，下面示例是最簡單的tcp傳輸代碼示例，先啟動(dòng)server再啟動(dòng)client。需要注意python3socket只能傳輸byte類型，具體如何轉(zhuǎn)換可以復(fù)習(xí)字符編碼章節(jié)相關(guān)知識(shí)

sever端代碼

# -*- coding:utf-8 -*-import socketserver = socket.socket()server.bind(('0.0.0.0', 8888))server.listen(10)while True: #循環(huán)監(jiān)聽連接過來的客戶端 conn,addr = server.accept() while True: #每個(gè)客戶端連接過來以后持續(xù)交互，當(dāng)客戶端端斷開后在和下一個(gè)客戶端交互 try: rec_data = conn.recv(4096) #4096接收緩沖區(qū)大小 if len(rec_data) == 0:break print('rec_data:', rec_data.decode(encoding='utf-8')) conn.send(rec_data.upper()) except ConnectionResetError as e: print('一個(gè)客戶端關(guān)閉了連接') breakserver.close()

client端代碼

import socketclient = socket.socket()client.connect(('127.0.0.1', 8888))while True: msg = input() if len(msg) == 0: continue client.send(msg.encode(encoding='utf-8')) #如果發(fā)送中文需要對(duì)其進(jìn)行encode，接收也需要decode；英文前面直接加b指定類型 client_rec = client.recv(4096) print('client_rec:', client_rec)client.close()

粘包解決方法：對(duì)于兩條緊挨的send語句，會(huì)存在上一條send的內(nèi)容與下一條send的內(nèi)容混在一起的情況，這個(gè)是因?yàn)閟end只是將數(shù)據(jù)發(fā)送給os，具體os如何發(fā)送數(shù)據(jù)無法控制，使用下面方法能夠解決兩條send語句之間發(fā)送報(bào)文粘包問題

server端代碼

import socket, osserver = socket.socket()server.bind(('0.0.0.0', 8888))server.listen(10)while True: #循環(huán)監(jiān)聽連接過來的客戶端 conn,addr = server.accept() while True: #收到客戶端發(fā)過來的get filename如果filename存在就將文件發(fā)出否則返回文件不存在 try: rec_data = conn.recv(1024) #4096接收緩沖區(qū)大小 if len(rec_data) == 0:break rec_str_list = rec_data.decode(encoding='utf-8').split(' ') filename = rec_str_list[-1] if os.path.isfile(filename):#判斷文件在當(dāng)前路徑下存在句將文件傳給客戶端file_data = open(filename,encoding='utf-8').read()conn.send(str(len(file_data)).encode(encoding='utf-8')) #將文件長度傳給客戶端print(conn.recv(1024).decode(encoding='utf-8')) #客戶端收到文件長度返回確認(rèn)信息，server收到確認(rèn)信息后再開始傳送數(shù)據(jù)conn.sendall(file_data.encode(encoding='utf-8'))#將數(shù)據(jù)全部發(fā)個(gè)客戶端，客戶端判斷數(shù)據(jù)接收完成后發(fā)送接收完成的信息print(conn.recv(1024).decode(encoding='utf-8')) #接收客戶端接收完成的確認(rèn)指令，避免兩個(gè)send直接連在一起產(chǎn)生粘包 else:#如果文件名不存在則返回文件不存在conn.send(b'file is not exit') except ConnectionResetError as e: print('一個(gè)客戶端關(guān)閉了連接') breakserver.close()

client端代碼

import socket, os#輸入get 文件名，當(dāng)文件存在server家目錄下則返回文件，客戶端將接收文件內(nèi)容并打印，client = socket.socket()client.connect(('127.0.0.1', 8888))while True: msg = input() if len(msg) == 0: continue client.send(msg.encode(encoding='utf-8')) #如果發(fā)送中文需要對(duì)其進(jìn)行encode，接收也需要decode；英文前面直接加b指定類型 client_rec = client.recv(1024).decode(encoding='utf-8') print('client_rec', client_rec) if client_rec == 'file is not exit': #如果文件不存在則用戶打印文件不存在，用戶繼續(xù)輸入 print(client_rec) continue client.send(client_rec.encode(encoding='utf-8'))#文件存在則將文件大小發(fā)回去 rec_len = int(client_rec) print('rec_len', rec_len) file_len = 0 new_file = open('new_file','a',encoding='utf-8') while file_len < rec_len:#開始循環(huán)接收文件直到接收的文件大小與server端發(fā)過來的大小一樣,將接收到的數(shù)據(jù)寫入新文件 rec_data_tmp = client.recv(1024) file_len += len(rec_data_tmp) print('receive date len', file_len) new_file.write(rec_data_tmp.decode(encoding='utf-8')) client.send('receive all'.encode(encoding='utf-8'))client.close()

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。