服务器之家

服务器之家 > 正文

python单线程文件传输的实例(C/S)

时间:2021-05-27 00:40     来源/作者:远行的风

客户端代码:

python" id="highlighter_561495">
?
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
58
59
60
61
62
63
64
#-*-encoding:utf-8-*-
 
import socket
import os
import sys
import math
import time
 
def progressbar(cur, total):
 percent = '{:.2%}'.format(float(cur) / float(total))
 sys.stdout.write('\r')
 sys.stdout.write("[%-50s] %s" % (
       '=' * int(math.floor(cur * 50 / total)),
       percent))
 sys.stdout.flush()
 
def getfilesize(file):
 file.seek(0, os.seek_end)
 filelength = file.tell()
 file.seek(0, 0)
 return filelength
 
def getfilename(filefullpath):
 index = filefullpath.rindex('\\')
 if index == -1:
  return filefullpath
 else:
  return filefullpath[index+1:]
 
def transferfile():
 filefullpath = r"%s" % raw_input("file path: ").strip("\"")
 if os.path.exists(filefullpath):
  timestart = time.clock()
  file = open(filefullpath, 'rb')
  filesize = getfilesize(file)
  client = socket.socket(socket.af_inet, socket.sock_stream)
  client.connect((targethost, targetport))
  # send file size
  client.send(str(filesize))
  response = client.recv(1024)
  # send file name
  client.send(getfilename(filefullpath))
  response = client.recv(1024)
  # send file content
  sentlength = 0
  while sentlength < filesize:
   buflen = 1024
   buf = file.read(buflen)
   client.send(buf)
   sentlength += len(buf)
   process = int(float(sentlength) / float(filesize) * 100)
   progressbar(process, 100)
  client.recv(1024)
  file.close()
  timeend = time.clock()
  print "\r\nfinished, spent %d seconds" % (timeend - timestart)
 else:
  print "file doesn't exist"
 
targethost = raw_input("server ip address: ")
targetport = int(raw_input("server port: "))
 
while true:
 transferfile()

服务器端代码:

?
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
#-*-encoding:utf-8-*-
 
import socket
import threading
import os
import sys
import math
 
bindip = "0.0.0.0"
bindport = 9999
 
server = socket.socket(socket.af_inet, socket.sock_stream)
server.bind((bindip, bindport))
server.listen(1)
print "listening on %s:%d" % (bindip, bindport)
 
def progressbar(cur, total):
 percent = '{:.2%}'.format(float(cur) / float(total))
 sys.stdout.write('\r')
 sys.stdout.write("[%-50s] %s" % (
       '=' * int(math.floor(cur * 50 / total)),
       percent))
 sys.stdout.flush()
 
def checkfilename(originalfilename):
 extensionindex = originalfilename.rindex(".")
 name = originalfilename[:extensionindex]
 extension = originalfilename[extensionindex+1:]
 
 index = 1
 newnamesuffix = "(" + str(index) + ")"
 finalfilename = originalfilename
 if os.path.exists(finalfilename):
  finalfilename = name + " " + newnamesuffix + "." + extension
 while os.path.exists(finalfilename):
  index += 1
  oldsuffix = newnamesuffix
  newnamesuffix = "(" + str(index) + ")"
  finalfilename = finalfilename.replace(oldsuffix, newnamesuffix)
 return finalfilename
 
def handleclient(clientsocket):
 # receive file size
 filesize = int(clientsocket.recv(1024))
 # print "[<==] file size received from client: %d" % filesize
 clientsocket.send("received")
 # receive file name
 filename = clientsocket.recv(1024)
 # print "[<==] file name received from client: %s" % filename
 clientsocket.send("received")
 filename = checkfilename(filename)
 file = open(filename, 'wb')
 # receive file content
 print "[==>] saving file to %s" % filename
 receivedlength = 0
 while receivedlength < filesize:
  buflen = 1024
  if filesize - receivedlength < buflen:
   buflen = filesize - receivedlength
  buf = clientsocket.recv(buflen)
  file.write(buf)
  receivedlength += len(buf)
  process = int(float(receivedlength) / float(filesize) * 100)
  progressbar(process, 100)
 
 file.close()
 print "\r\n[==>] file %s saved." % filename
 clientsocket.send("received")
 
while true:
 client, addr = server.accept()
 print "[*] accepted connection from: %s:%d" % (addr[0], addr[1])
 
 clienthandler = threading.thread(target=handleclient, args=(client,))
 clienthandler.start()

运行结果示例:

服务器端:

python单线程文件传输的实例(C/S)

客户端(服务器端做了端口映射:59999->9999):

python单线程文件传输的实例(C/S)

以上这篇python单线程文件传输的实例(c/s)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持服务器之家。

原文链接:https://blog.csdn.net/qwertyupoiuytr/article/details/65667552

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021德云社封箱演出完整版 2021年德云社封箱演出在线看
2021德云社封箱演出完整版 2021年德云社封箱演出在线看 2021-03-15
返回顶部