快捷導(dǎo)航

python cs架構(gòu)實(shí)現(xiàn)簡單文件傳輸

更新時(shí)間：2020年03月20日 14:28:04 作者：AbnerKou

這篇文章主要為大家詳細(xì)介紹了python cs架構(gòu)實(shí)現(xiàn)簡單文件傳輸，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文為大家分享了python cs架構(gòu)實(shí)現(xiàn)簡單文件的傳輸代碼，供大家參考，具體內(nèi)容如下

要實(shí)現(xiàn)簡單文件的傳輸我們必須考慮這些問題：

1.什么是c/s架構(gòu)？

顧名思義，就是客戶端端/服務(wù)器架構(gòu)。不同的人可能回答不一，但是有一點(diǎn)是相同的：服務(wù)器是一個(gè)軟件或硬件，用于向一個(gè)或多個(gè)客戶端提供所需要的服務(wù)，服務(wù)器存在的唯一目的就是等待客戶的請求，給這些客戶服務(wù)，然后等待其他的請求。

2.客戶端與服務(wù)端如何通信？

其實(shí)說白了就是互聯(lián)網(wǎng)中兩個(gè)主機(jī)該如何通信，首先我們用ip地址可以標(biāo)示一臺(tái)主機(jī)，這樣就可以通信了么？當(dāng)然也不行，我們還得標(biāo)示主機(jī)中的進(jìn)程，當(dāng)然協(xié)議也是不可或缺的，是udp報(bào)文協(xié)議還是tcp數(shù)據(jù)流協(xié)議，這的看你個(gè)人的需求。用套介子來作為一個(gè)標(biāo)示符，唯一標(biāo)識(shí)網(wǎng)絡(luò)進(jìn)程。

想明白這兩個(gè)問題我覺得這個(gè)問題有三分之一已經(jīng)解決了，接下來呢我選擇tcp協(xié)議來傳輸。

服務(wù)端：

采用socket()函數(shù) 定義socket描述字

bind()函數(shù)來把地址族中一個(gè)特定地址賦給socket，簡單來說就是把一個(gè)ipv4/ipv6地址+端口號組合賦給socket

listen()函數(shù)把socket變成被動(dòng)類型的，等待客戶連接請求。

當(dāng)客戶端發(fā)來消息時(shí)用accept()函數(shù)來接受請求，同時(shí)給服務(wù)端返回客戶端的socket描述字，接下來服務(wù)端以接收到的描述字來向客戶端發(fā)送信息以及接受信息。

我們這個(gè)程序是實(shí)現(xiàn)文件傳輸，我的想法是類似于ftp程序接受客戶上傳下載文件的需求。服務(wù)端啟動(dòng)后監(jiān)聽端口（我用的9500）等待客戶連接?？蛻舳巳挝帐纸⑦B接后，客戶輸入命令來向客戶端發(fā)起請求，輸入‘ls'命令可以查看服務(wù)端可下載的文件，輸入‘put 文件名'，‘get 文件名'可以上傳下載文件。上傳文件時(shí)客戶端打開本地文件以二進(jìn)制方式讀取文件內(nèi)容并同時(shí)調(diào)用send()函數(shù)發(fā)送文件內(nèi)容，服務(wù)端以寫方式打開文件并將客戶端上傳內(nèi)容寫入文件，實(shí)現(xiàn)文件的上傳。下載文件與此類似，客戶端上傳送‘get 文件名'命令同時(shí)以寫方式打開文件，服務(wù)端收到命令以讀方式打開文件，并發(fā)送給服務(wù)端。

tcp三次握手建立連接：

當(dāng)客戶端調(diào)用connect時(shí)，觸發(fā)了連接請求，向服務(wù)器發(fā)送了SYN J包，這時(shí)connect進(jìn)入阻塞狀態(tài)；服務(wù)器監(jiān)聽到連接請求，即收到SYN J包，調(diào)用accept函數(shù)接收請求向客戶端發(fā)送SYN K ，ACK J+1，這時(shí)accept進(jìn)入阻塞狀態(tài)；客戶端收到服務(wù)器的SYN K ，ACK J+1之后，這時(shí)connect返回，并對SYN K進(jìn)行確認(rèn)；服務(wù)器收到ACK K+1時(shí)，accept返回，至此三次握手完畢，連接建立。

tcp四次揮手?jǐn)嚅_連接：

某個(gè)應(yīng)用進(jìn)程首先調(diào)用close主動(dòng)關(guān)閉連接，這時(shí)TCP發(fā)送一個(gè)FIN M；另一端接收到FIN M之后，執(zhí)行被動(dòng)關(guān)閉，對這個(gè)FIN進(jìn)行確認(rèn)。它的接收也作為文件結(jié)束符傳遞給應(yīng)用進(jìn)程，因?yàn)镕IN的接收意味著應(yīng)用進(jìn)程在相應(yīng)的連接上再也接收不到額外數(shù)據(jù)；一段時(shí)間之后，接收到文件結(jié)束符的應(yīng)用進(jìn)程調(diào)用close關(guān)閉它的socket。這導(dǎo)致它的TCP也發(fā)送一個(gè)FIN N；接收到這個(gè)FIN的源發(fā)送端TCP對它進(jìn)行確認(rèn)。

服務(wù)端代碼：

#!/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()

運(yùn)行截圖：

服務(wù)端：