您的位置：首页 > 脚本大全 > > 正文

python 并发传输文件（python单线程文件传输的实例C/S）

更多 时间：2022-03-29 10:44:24 类别：脚本大全 浏览量：440

python 并发传输文件

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

客户端代码：

  • ?
  • 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 并发传输文件（python单线程文件传输的实例C/S）

    客户端（服务器端做了端口映射：59999->9999）：

    python 并发传输文件（python单线程文件传输的实例C/S）

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

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

    标签：Python 文件传输 单线程
  • 上一篇：docker启动nginx容器命令（Docker安装Nginx教程实现图例讲解）
  • 下一篇：css3动画效果图（css3实现波纹特效、H5实现动态波浪效果）
    • 您可能感兴趣
    首页 编程学习 Web前端 数据库 软件设计
    开心学习 ©2013-2021 保留所有权利