python3基于TCP實(shí)現(xiàn)CS架構(gòu)文件傳輸
本文實(shí)例為大家分享了python3實(shí)現(xiàn)CS架構(gòu)文件傳輸?shù)木唧w代碼,供大家參考,具體內(nèi)容如下
1、目標(biāo):
基于tcp實(shí)現(xiàn)CS架構(gòu)的文件傳輸
指令列表:(1)get:從服務(wù)器端下載文件
(2)put:向服務(wù)器端上傳文件
(3)list:獲得服務(wù)器端的目錄
2、socket模塊函數(shù):
(1)send和sendall:send的作用是發(fā)送TCP數(shù)據(jù),返回發(fā)送的數(shù)據(jù)大小。send函數(shù)不保證將所有數(shù)據(jù)全部發(fā)送,因此可能需要重復(fù)多次才能完成所有數(shù)據(jù)的發(fā)送。sendall的作用是發(fā)送完整的TCP數(shù)據(jù),成功時(shí)返回None,失敗時(shí)拋出異常
(2)bind:在服務(wù)器端使用,用于將socket綁定在一個(gè)特定的ip地址和端口上。在《UNIX網(wǎng)絡(luò)編程》一書(shū)中提到,如果調(diào)用connect或者listen之前沒(méi)有bind一個(gè)特定的端口,內(nèi)核會(huì)為相應(yīng)的套接字分配一個(gè)隨機(jī)的端口。因此,在客戶端調(diào)用connect函數(shù)之前不需要bind
(3)listen:通過(guò)參數(shù)設(shè)定服務(wù)器端最多可以接受幾個(gè)客戶端的連接,但是只有在完成與第一個(gè)客戶端的傳送后才會(huì)進(jìn)行與第二個(gè)客戶端的傳送
3、代碼:
(1)服務(wù)器端:
import socket
import os
import sys
import time
Host = '127.0.0.1'
Port = 12000
Addr = (Host, Port)
sockListener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sockListener.bind(Addr)
sockListener.listen(5)
def recvfile(cliSocket):
print('start reveiving file...')
msg = 'no problem'
msg_utf8 = msg.encode(encoding="utf-8")
cliSocket.send(msg_utf8)
filename_utf8 = clientSocket.recv(4096)
filename = filename_utf8.decode()
f = open(filename, 'wb')
while True:
data_utf8 = cliSocket.recv(4096)
data = data_utf8.decode()
if data=='EOF':
print('received file successfully')
break
f.write(data_utf8)
f.close()
def sendfile(cliSocket):
print('start sending file...')
msg = 'no problem'
msg_utf8 = msg.encode(encoding="utf-8")
cliSocket.send(msg_utf8)
filename_utf8 = cliSocket.recv(4096)
filename = filename_utf8.decode()
f = open(filename, 'rb')
while True:
data = f.read(4096)
if not data:
break
cliSocket.sendall(data)
f.close()
time.sleep(1)
msg = 'EOF'
msg_utf8 = msg.encode(encoding="utf-8")
cliSocket.sendall(msg_utf8)
print('sent file successfully')
def getList(cliSocket):
path = sys.path[0]
every_file = os.listdir(path)
for filename in every_file:
pathmsg = filename + '\n'
pathmsg_utf8 = pathmsg.encode(encoding="utf-8")
cliSocket.sendall(pathmsg_utf8)
time.sleep(1)
msg = 'EOF'
msg_utf8 = msg.encode(encoding="utf-8")
cliSocket.sendall(msg_utf8)
print('all filenames have been send')
while True:
print('waiting for connection...')
clientSocket, addr = sockListener.accept()
print('... connection from:', addr)
while True:
msg_utf8 = clientSocket.recv(4096)
msg = msg_utf8.decode()
if msg=='exit':
print(addr, 'close the connection')
break
elif msg=='get':
sendfile(clientSocket)
elif msg=='put':
recvfile(clientSocket)
elif msg=='list':
getList(clientSocket)
else:
print('client error!')
break
(2)客戶端:
import socket
import time
Host = '127.0.0.1'
Port = 12000
Addr = (Host, Port)
clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
clientSocket.connect(Addr)
def recvfile(filename):
print('start receiving file...')
f = open(filename, 'wb')
filename_utf8 = filename.encode(encoding="utf-8")
clientSocket.sendall(filename_utf8)
while True:
data_utf8 = clientSocket.recv(4096)
data=data_utf8.decode()
if data=='EOF':
print('receive file successfully')
break
f.write(data_utf8)
f.close()
def sendfile(filename):
print('start sending file...')
f = open(filename, 'rb')
filename_utf8 = filename.encode(encoding="utf-8")
clientSocket.sendall(filename_utf8)
while True:
data = f.read(4096)
if not data:
break
clientSocket.sendall(data)
f.close()
time.sleep(1)
endmsg = 'EOF'
endmsg_utf8 = endmsg.encode(encoding="utf-8")
clientSocket.sendall(endmsg_utf8)
print('send file successfully')
def confirm(confirm_command):
confirm_command_utf8 = confirm_command.encode(encoding="utf-8")
clientSocket.sendall(confirm_command_utf8)
msg_utf8 = clientSocket.recv(4096)
msg = msg_utf8.decode()
print('reveive message:', msg)
if msg=='no problem':
return True
else:
return False
def operation1(filename):
if confirm('get'):
recvfile(filename)
else:
print('serve error!')
def operation2(filename):
if confirm('put'):
sendfile(filename)
else:
print('serve error!')
def operation3(act):
if act=='list':
act_utf8 = act.encode(encoding="utf-8")
clientSocket.sendall(act_utf8)
while True:
msg_utf8 = clientSocket.recv(1024)
msg = msg_utf8.decode()
if msg=='EOF':
break
print(msg)
else:
print('wrong command!')
try:
while True:
command = input('>>>')
if not command:
continue
elif command=='exit':
command_utf8 = command.encode(encoding="utf-8")
clientSocket.sendall(command_utf8)
print('the connection is closed')
break
msg = command.split()
if len(msg)==2 and msg[0]=='get':
operation1(msg[1])
elif len(msg)==2 and msg[0]=='put':
operation2(msg[1])
elif len(msg)==1:
operation3(msg[0])
else:
print('wrong command!')
except socket.error as e:
print('error:', e)
print('an error causes the connection to close!')
clientSocket.close()
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- python3.5基于TCP實(shí)現(xiàn)文件傳輸
- python使用tcp實(shí)現(xiàn)局域網(wǎng)內(nèi)文件傳輸
- Python實(shí)現(xiàn)基于HTTP文件傳輸實(shí)例
- Python實(shí)現(xiàn)的簡(jiǎn)單文件傳輸服務(wù)器和客戶端
- python實(shí)現(xiàn)的一個(gè)p2p文件傳輸實(shí)例
- python基于xmlrpc實(shí)現(xiàn)二進(jìn)制文件傳輸?shù)姆椒?/a>
- python cs架構(gòu)實(shí)現(xiàn)簡(jiǎn)單文件傳輸
- python 使用poster模塊進(jìn)行http方式的文件傳輸?shù)椒?wù)器的方法
- python實(shí)現(xiàn)TCP文件傳輸
相關(guān)文章
python執(zhí)行系統(tǒng)命令4種方法與比較
這篇文章主要介紹了python執(zhí)行系統(tǒng)命令4種方法與比較,需要的朋友可以參考下2021-04-04
python實(shí)現(xiàn)合并兩個(gè)排序的鏈表
這篇文章主要為大家詳細(xì)介紹了python實(shí)現(xiàn)合并兩個(gè)排序的鏈表,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-03-03
Python3 使用cookiejar管理cookie的方法
今天小編就為大家分享一篇Python3 使用cookiejar管理cookie的方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-12-12
關(guān)于Numpy中argsort()函數(shù)的用法解讀
Python進(jìn)階學(xué)習(xí)之帶你探尋Python類的鼻祖-元類
如何使用python爬取知乎熱榜Top50數(shù)據(jù)

