python怎么传送文件

python

python中传送文件的方法:1、将报头转换成字符串【json.dumps】, 再将字符串的长度打包;2、发送报头长度和报头内容,然后放真实内容;3、将报头长度解压,得到头部信息的大小,再接收头部信息,反序列化即可

思路: 

       #   先将报头转换成字符串(json.dumps), 再将字符串的长度打包
       #   发送报头长度,发送报头内容,最后放真实内容
       #   报头内容包括文件名,文件信息,报头
       #   接收时:先接收4个字节的报头长度,
       #   将报头长度解压,得到头部信息的大小,在接收头部信息, 反序列化(json.loads)
       #   最后接收真实文件

服务端

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# @File    : 文件传输-服务端.py

# @Software: PyCharmfrom socket import *import structimport jsonimport ostcp_server = socket(AF_INET, SOCK_STREAM)ip_port = (('127.0.0.1', 8080))buffsize = 1024

#   端口的重复利用

tcp_server.setsockopt(SOL_SOCKET, SO_REUSEPORT, 1)tcp_server.bind(ip_port)tcp_server.listen(5)print('还没有人链接')

while True:    

       '''链接循环'''

       conn, addr = tcp_server.accept()    

       print('链接人的信息:', addr)    

       while True:        

              if not conn:            

                    print('客户端链接中断')            

                    break             

               '''通信循环'''                

               filemesg = input('请输入要传送的文件名加后缀>>>').strip()             

               filesize_bytes = os.path.getsize(filemesg) # 得到文件的大小,字节               

               filename = 'new' + filemesg                

               dirc = {           

                       'filename': filename,       

                       'filesize_bytes': filesize_bytes,

                }               

                head_info = json.dumps(dirc)  # 将字典转换成字符串                

                head_info_len = struct.pack('i', len(head_info)) 

                #  将字符串的长度打包                

                #   先将报头转换成字符串(json.dumps), 再将字符串的长度打包                

                #   发送报头长度,发送报头内容,最后放真是内容                

                #   报头内容包括文件名,文件信息,报头                

                #   接收时:先接收4个字节的报头长度,                

                #   将报头长度解压,得到头部信息的大小,在接收头部信息, 反序列化(json.loads)                

                #   最后接收真实文件                

                conn.send(head_info_len)  # 发送head_info的长度                

                conn.send(head_info.encode('utf-8'))       

                #   发送真是信息                

                with open(filemesg, 'rb') as f:                       

                     data = f.read()                        

                     conn.sendall(data)      

                print('发送成功')

客户端

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# @File    : 文件传输_客户端.py

# @Software: PyCharmfrom socket import *

import struct

import json

import os

import sys

import time

from 进度条 import process_bar

tcp_client = socket(AF_INET, SOCK_STREAM) 

ip_port = (('127.0.0.1', 8080)) 

buffsize = 1024

tcp_client.connect_ex(ip_port)

print('等待链接服务端')

while True:

  

      head_struct = tcp_client.recv(4) # 接收报头的长度, 

      if head_struct:       

            print('已连接服务端,等待接收数据')

  

      head_len = struct.unpack('i', head_struct)[0] # 解析出报头的字符串大小

      data = tcp_client.recv(head_len)# 接收长度为head_len的报头内容的信息 (包含文件大小,文件名的内容)     

      head_dir = json.loads(data.decode('utf-8'))

    

      filesize_b = head_dir['filesize_bytes']

    

      filename = head_dir['filename']    

        #   接受真的文件内容

   

     recv_len = 0

   

     recv_mesg = b''

   

     old = time.time()

  

      f = open(filename, 'wb')   

     while recv_len < filesize_b:

   

             percent = recv_len / filesize_b

    

            process_bar(percent)        

            if filesize_b - recv_len > buffsize:

          

                  recv_mesg = tcp_client.recv(buffsize)

           

                 f.write(recv_mesg)

           

                 recv_len += len(recv_mesg)       

              else:

           

                 recv_mesg = tcp_client.recv(filesize_b - recv_len)

    

                 recv_len += len(recv_mesg)

           

                 f.write(recv_mesg)   

     print(recv_len, filesize_b)

  

      now = time.time()

  

      stamp = int(now - old)   

      print('总共用时%ds' % stamp)

   

      f.close()

 进度条

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# @File    : 进度条.py

# @Software: PyCharm

import sys

import time

def process_bar(precent, width=50):        use_num = int(precent*width)        space_num = int(width-use_num)        precent = precent*100  

  #   第一个和最后一个一样梯形显示, 中间两个正确,但是在python2中报错   # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent))    # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent), end='')    print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent),file=sys.stdout,flush=True, end='')

    # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent),file=sys.stdout,flush=True)

#for i in range(21):

#       precent = i/20

#       process_bar(precent)

#        time.sleep(0.2)

推荐课程:Python进阶视频教程

以上是 python怎么传送文件 的全部内容, 来源链接: utcz.com/z/528138.html

回到顶部