python -服务器与客户端断电续传程序详细介绍

唐伯虎

　　6.28自我总结
　　客户端与服务器之间文件传输断电续传
　　`通过判断文件大小,以及文件在读取中的指针位置的调整来解决断电续传问题'
1.程序目录

E:/断电续传
|___bil
|  |___common.py     #公共方法
|___conf
|  |___logger_setting.py  #存日志的格式
|  |___setting.py     #一些常量
|___db
|  |___client    #程序端存文件的文件夹
|  |___logger    #存日志的文件夹
|  |___sever     #服务端存文件的文件夹
|___requirements.txt #方便别人导入库
|___test.py      #程序写的时候有些东西需要单独拿出来试试
|___客户端.py
|___服务端.py

2.程序思路

• 　　第一步:我们什么都不懂,但是有几个模块肯定会有一个是conf中的setting来存一些常量
  
• 　　第二步:我们也需要一个db文件来存内容
  
• 　　第三步:我们要也有个bil存一些可能会出现的公共方法,可以精简代码
  
• 　　第四部:生成requirements.txt文件,方便其他人用模板时候可以一键安装需要的模板
  　　​         requirements的自动生成方式cmd中输入pip freeze > requirements.txt
  　　​         然后清空下内容,如果有用到第三方库什么的可以写进去方便别人安装
  
• 　　第五步:根据功能然后进行添加,有些常量丢setting里面,公共方法丢common里面去
  

3.程序内容

1.conf
1.setting.py

import os
项目文件夹路径
PATH = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))文件存放夹路径
DB_PATH = os.path.join(PATH,'db')客户端存放路径
CLIENT_PATH = os.path.join(PATH,'db','client')服务端存放路径
SEVER_PATH = os.path.join(PATH,'db','sever')日志存放路径
LOGGER_PATH = os.path.join(PATH,'db','logger')
服务端PROT
IP = '127.0.0.1'服务端端口
PROT = 8000

2.logger_setting.py

import os
import logging.config函数上面部分要根据你程序进行修改定义三种日志输出格式 开始
standard_format = '[%(asctime)s][%(threadName)s:%(thread)d][task_id:%(name)s][%(filename)s:%(lineno)d]' \
          '[%(levelname)s][%(message)s]'  # 其中name为getLogger()指定的名字；lineno为调用日志输出函数的语句所在的代码行

　　simple_format = '[%(levelname)s][%(asctime)s][%(filename)s:%(lineno)d]%(message)s'
id_simple_format = '[%(levelname)s][%(asctime)s] %(message)s'
定义日志输出格式 结束

log配置字典

　　LOGGING_DIC = {
　　'version': 1,
　　'disable_existing_loggers': False,
　　'formatters': {

'standard': {
      'format': standard_format
    },
    'simple': {
      'format': simple_format
    },
  },
  'filters': {},  # filter可以不定义
  'handlers': {
    # 打印到终端的日志
    'console': {
      'level': 'DEBUG',
      'class': 'logging.StreamHandler',  # 打印到屏幕
      'formatter': 'simple'
    },
    # 打印到文件的日志,收集info及以上的日志
    'default': {
      'level': 'INFO',
      'class': 'logging.handlers.RotatingFileHandler',  # 保存到文件
      'formatter': 'standard',
      'filename': 1,  # 日志文件
      'maxBytes': 1024 * 1024 * 5,  # 日志大小 5M  (*****)
      'backupCount': 5,
      'encoding': 'utf-8',  # 日志文件的编码，再也不用担心中文log乱码了
    },
  },
  'loggers': {
    # logging.getLogger(__name__)拿到的logger配置。如果''设置为固定值logger1，则下次导入必须设置成logging.getLogger('logger1')
    '': {
      # 这里把上面定义的两个handler都加上，即log数据既写入文件又打印到屏幕
      'handlers': ['default', 'console'],
      'level': 'DEBUG',
      'propagate': False,  # 向上（更高level的logger）传递
    },
  },

}2.bil
　　common.py

from conf.setting import 
import struct
from conf.logger_setting import 
import logging.config
import datetime
获取文件路径下的子文件的目录列表
def get_flie_lis(path):
'''获取文件路径下的子文件的目录列表'''
if os.path.exists(path):return os.listdir(path)
return False
获取客文件的大小
def get_flie_size(filename,filefrom):
'''获取客文件的大小'''
path = os.path.join(DB_PATH,filefrom,filename)
if os.path.exists(path): return os.path.getsize(path)
return 0
内容大小进行压缩,int格式内容进行压缩成4个字符
def zip_data(data:int):
'''内容大小进行压缩,int格式内容进行压缩成4个字符'''
return struct.pack('i',data)
解压缩
def uncompress(zipflie):
'''解压缩压缩文件'''
return struct.unpack('i',zipflie)[0]
根据文件路径读取文件大小以及文件的内容变成个生成器
def get_file_size_data(path):
'''根据文件路径读取文件大小以及文件的内容变成个生成器'''
#生成文件大小
file_name = path.split('\\')[-1]
file_size = get_flie_size(file_name,'client')
size = os.path.getsize(path)
with open(path,'rb') as fr:
    fr.seek(file_size,0)
    while True:
      data = fr.read(10240)
      if data == bytes():return True
      yield size,data

日志

　　def load_my_logging_cfg(name):
　　'''生成随着时间生成文件夹日志'''
　　#生成日志保存路径
　　time = str(datetime.datetime.now())
　　time = time.split(' ')[0]
　　path = os.path.join(LOGGER_PATH,time)
　　if not os.path.exists(path):os.mkdir(path)
　　file_path = os.path.join(path, f'{name}.log')
　　#修改定义格式中的地址
　　logger_fromat = LOGGING_DIC
　　logger_fromat['handlers']['default']['filename'] =file_path
　　logging.config.dictConfig(logger_fromat)  # 导入上面定义的logging配置
　　logger = logging.getLogger(name)  # 生成一个log实例
　　logger.info(f'{name} works!')  # 记录该文件的运行状态可以自己修改
3.db
　　可以先新建好这三个文件夹,也可以用os.path.exists(path)判断路径来生成
4.服务端.py

from socket import *
from conf.setting import IP,PROT,SEVER_PATH
from bil.common import 
from conf.setting import 
load_my_logging_cfg('sever')生成服务器
sever = socket()
sever.bind((IP,PROT))
sever.listen(5)
print('start....')消息的传输
while True:
#建立连接
conn,addr = sever.accept()
while True:
    try:
      #进行文件的传输
      #接受1
      request = conn.recv(1024)
      #获得客户端目录下的所有文件名称,并且转换成list
      flie_list = get_flie_lis(SEVER_PATH)

#列表内容进行压缩
      flie_list_str_len = zip_data(len(str(flie_list)))

#发送列表字符串格式大小
      conn.send(flie_list_str_len)
      # 发送列表的字符串
      conn.send(str(flie_list).encode('utf8'))

#接收文件名
      file_name = conn.recv(1024).decode('utf8')

#拼接文件路径
      file_path = os.path.join(SEVER_PATH,file_name)

#判断文件是不是客户端已经下载完成了
      file_name = file_path.split('\\')[-1]
      #为了防止客户端因为没有文件而报错,且没有文件把他大小设置成0
      try:
        file_size = get_flie_size(file_name, 'client')
      except Exception:
        file_size = 0
      sever_file_size = get_flie_size(file_name, 'sever')

print(file_size,sever_file_size,file_size == sever_file_size)
      # 生成文件内容与文件大小的生成器
      if file_size != sever_file_size:
        count = 0
        for size,file_data in get_file_size_data(file_path):
          #就第一次发送文件大小
          if count == 0:

conn.send(zip_data(size))
            print(str(zip_data(size)).encode('utf8'))
          print(file_data)
          conn.send(file_data)
          count += 1
      else:
        print(1)
        #文件已经传输好了客户端有这个文件了
        conn.send(zip_data(0))
    except:
      break
  conn.close()

5.客户端.py

from socket import *
from bil.common import 
from conf.setting import 
load_my_logging_cfg('client')生成客户端
client = socket()
与服务端建立连接
client.connect(('127.0.0.1',8000))
消息的传输
while True:
#自动发送请求获取
client.send(b'1')
#接受文件目录大小
list_st_size = client.recv(4)
#根据文件目录大小获取列表的字符串内容
data = client.recv(uncompress(list_st_size))
#将文件目录进行打印
file_list = eval(data.decode('utf8'))
print('请选择你要打印文件')
for file_index,file_name in enumerate(file_list):
    print(f'文件编号{file_index}文件名{file_name}')
    
  while True:
    chiose = input('请选择你要下载文件的编号:')
    try:
      chiose_file_name = file_list[int(chiose)]
      break
    except Exception:
      print('序号不存在')
      continue
  
  #发送选择的文件名
  chiose_file_name = file_list[int(chiose)]
  print(chiose_file_name)
  client.send(str(chiose_file_name).encode('utf8'))

　　#接收文件大小
　　file_size = uncompress(client.recv(4))
　　print(file_size)
　　if file_size != 0:

#初始下载文件大小
    client_file_size = get_flie_size(chiose_file_name,'clien')

#下载文件
    path  = os.path.join(CLIENT_PATH,chiose_file_name)
    print(client_file_size)
    print(file_size)
    while client_file_size <file_size:

data = client.recv(10240)
      client_file_size += 10240
      with open(path,'ab') as fa:
         fa.write(data)

#打印进度条
      if client_file_size < file_size:
        schedule = int((client_file_size/file_size)*100)
        #为了好看加了颜色进去
        print("\r",f'[\033[1;31;40m%-{schedule}s%-3s\033[0m%-{100-schedule}s' % ('', f'{schedule}%', ''),end=']')

print("\r",f'[\033[1;31;40m%-100s%-3s\033[0m%-0s' % ('', '100%', ''),end='')
    print('')
  else:
    print('')
    print('文件已经下载好了')
  chiose_end = input('输入Q退出下载,输入其他继续下载')
  if chiose_end =='Q' :break

有不足的地方请指出来,谢谢,这是我在写程序中的总结,这是我学习python刚刚好第二个月后的写的程序