溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本文為大家分享了python cs架構實現簡單文件的傳輸代碼，供大家參考，具體內容如下
要實現簡單文件的傳輸我們必須考慮這些問題：
1.什么是c/s架構？
顧名思義，就是客戶端端/服務器架構。不同的人可能回答不一，但是有一點是相同的：服務器是一個軟件或硬件，用于向一個或多個客戶端提供所需要的服務，服務器存在的唯一目的就是等待客戶的請求，給這些客戶服務，然后等待其他的請求。
2.客戶端與服務端如何通信？
其實說白了就是互聯網中兩個主機該如何通信，首先我們用ip地址可以標示一臺主機，這樣就可以通信了么？當然也不行，我們還得標示主機中的進程，當然協議也是不可或缺的，是udp報文協議還是tcp數據流協議，這的看你個人的需求。用套介子來作為一個標示符，唯一標識網絡進程。
想明白這兩個問題我覺得這個問題有三分之一已經解決了，接下來呢我選擇tcp協議來傳輸。
服務端：
采用socket()函數 定義socket描述字
bind()函數來把地址族中一個特定地址賦給socket，簡單來說就是把一個ipv4/ipv6地址+端口號組合賦給socket
listen()函數把socket變成被動類型的，等待客戶連接請求。
當客戶端發來消息時用accept()函數來接受請求，同時給服務端返回客戶端的socket描述字，接下來服務端以接收到的描述字來向客戶端發送信息以及接受信息。
我們這個程序是實現文件傳輸，我的想法是類似于ftp程序接受客戶上傳下載文件的需求。服務端啟動后監聽端口（我用的9500）等待客戶連接。客戶端三次握手建立連接后，客戶輸入命令來向客戶端發起請求，輸入‘ls'命令可以查看服務端可下載的文件，輸入‘put 文件名'，‘get 文件名'可以上傳下載文件。上傳文件時客戶端打開本地文件以二進制方式讀取文件內容并同時調用send()函數發送文件內容，服務端以寫方式打開文件并將客戶端上傳內容寫入文件，實現文件的上傳。下載文件與此類似，客戶端上傳送‘get 文件名'命令同時以寫方式打開文件 ，服務端收到命令以讀方式打開文件，并發送給服務端。
tcp三次握手建立連接：
當客戶端調用connect時，觸發了連接請求，向服務器發送了SYN J包，這時connect進入阻塞狀態；服務器監聽到連接請求，即收到SYN J包，調用accept函 數接收請求向客戶端發送SYN K ，ACK J+1，這時accept進入阻塞狀態；客戶端收到服務器的SYN K ，ACK J+1之后，這時connect返回，并對SYN K進行確認；服務器收到ACK K+1時，accept返回，至此三次握手完畢，連接建立。
tcp四次揮手斷開連接：
某個應用進程首先調用close主動關閉連接，這時TCP發送一個FIN M；另一端接收到FIN M之后，執行被動關閉，對這個FIN進行確認。它的接收也作為文件結束符傳遞給應用進程，因為FIN的接收意味著應用進程在相應的連接上再也接收不到額外數據；一段時間之后，接收到文件結束符的應用進程調用close關閉它的socket。這導致它的TCP也發送一個FIN N；接收到這個FIN的源發送端TCP對它進行確認。
服務端代碼：
#!/usr/bin/env python
from socket import *
import time
import sys
import os
HOST = 'localhost'
PORT = 9500
BUFIZ = 1024
ADDR = (HOST,PORT)
def recvfile(filename):
print 'starting receive file...'
f = open(filename,'wb')
cliSockfd.send('no problem')
while True:
data = cliSockfd.recv(4096)
if data == 'EOF':
print 'recved file success!'
break
f.write(data)
f.close()
def sendfile(filename):
print 'starting send file...'
cliSockfd.send('no problem')
f = open(filename,'rb')
while True:
data = f.read(4096)
if not data:
break
cliSockfd.send(data)
f.close()
time.sleep(1)
cliSockfd.send('EOF')
print 'send file success!'
def handle1(act,filename):
if act == 'put':
print 'recving msg!'
recvfile(filename)
elif act == 'get':
print 'sending msg!'
sendfile(filename)
else:
print 'error!'
def handle2(act):
if act == 'ls':
path = sys.path[0]
every_file = os.listdir(path)
for filename in every_file:
cliSockfd.send(filename + ' ')
time.sleep(1)
cliSockfd.send('EOF')
print 'all filename has send to client success!'
else:
print 'command error'
sockfd = socket(AF_INET,SOCK_STREAM)
sockfd.bind(ADDR)
sockfd.listen(5)
while True:
print 'waiting for connection...'
cliSockfd,addr = sockfd.accept()
print '...connected from:',addr
while True:
msg = cliSockfd.recv(4096)
if msg == 'close':
print 'client closed'
break
info = msg.split()
if len(info) == 2:
handle1(*info)
elif len(info) == 1:
handle2(*info)
else:
print 'command error!'
break
客戶端代碼：
#!/usr/bin/env python
import sys
import socket
import time
HOST = 'localhost'
PORT = 9500
BUFSIZ = 1024
ADDR = (HOST,PORT)
cliSockfd = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
def recvfile(filename):
f = open(filename,'wb')
while True:
msg = cliSockfd.recv(4096)
if msg == 'EOF':
print 'recv file success!'
break
f.write(msg)
f.close
def sendfile(filename):
f = open(filename,'rb')
while True:
msg = f.read(4096)
if not msg:
break
cliSockfd.sendall(msg)
f.close()
time.sleep(1)
cliSockfd.sendall('EOF')
print 'send file success'
def confirm(cliSockfd,client_command):
cliSockfd.send(client_command)
msg = cliSockfd.recv(4096)
if msg == 'no problem':
return True
def handle1(act,filename):
if act == 'put':
if confirm(cliSockfd,client_command):
sendfile(filename)
else:
print 'server error1!'
elif act == 'get':
if confirm(cliSockfd,client_command):
recvfile(filename)
else:
print 'server error2!'
else:
print 'command error!'
def handle2(act):
if act == 'ls':
cliSockfd.send('ls')
while True:
msg = cliSockfd.recv(1024)
if msg == 'EOF':
break
print msg
else:
print 'command error'
try:
cliSockfd.connect(ADDR)
print 'connect to ',ADDR
while True:
client_command = raw_input('>>>')
if not client_command:
continue
msg = client_command.split()
if len(msg) == 2:
handle1(*msg)
elif len(msg) == 1 and msg != ['close']:
handle2(*msg)
elif len(msg) == 1 and msg == ['close']:
cliSockfd.send('close')
break
else:
print 'command error'
except socket.error,e:
print 'error:',e
finally:
cliSockfd.close()
運行截圖：
服務端：
客戶端：
歡迎各位大牛，多提寶貴意見。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
