python -伺服器與客戶端斷電續傳程式詳細介紹

来源:https://www.cnblogs.com/pythonywy/archive/2019/06/28/11104820.html
-Advertisement-
Play Games

6.28自我總結 客戶端與伺服器之間文件傳輸斷電續傳 `通過判斷文件大小,以及文件在讀取中的指針位置的調整來解決斷電續傳問題' 1.程式目錄 2.程式思路 第一步:我們什麼都不懂,但是有幾個模塊肯定會有一個是conf中的setting來存一些常量 第二步:我們也需要一個db文件來存內容 第三步:我們 ...


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剛剛好第二個月後的寫的程式


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 面向對象三大特性
    Java面向對象編程有三大特性，它們是封裝、繼承和多態。 封裝： 字面上來說就是將一個東西包裹起來，這樣會掩飾掉內部的細節。怎麼樣？這麼一說是不是有點想法。 將類封裝起來，只提供想提供的方法介面，而不需要提供具體實現細節，這樣一來使得程式更加健壯。 另一方面比方說項目做到一半換人了，老闆現在要求吧代 ...
  • 多線性方程組迭代演算法——Gauss-Seidel迭代演算法的Python實現
    多線性方程組的Gauss-Seidel迭代演算法的Python實現 ...
  • 針對源代碼和檢查元素不一致的網頁爬蟲——利用Selenium、PhantomJS、bs4爬取12306的列車途徑站信息
    針對多動態網頁的數據爬取，利用Selenium和bs4，csv庫存儲數據。 ...
  • 多線性方程組迭代演算法——Jacobi迭代演算法的Python實現
    多線性方程（張量）組迭代演算法的原理請看這裡：若想看原理部分請留言，不方便公開分享 Gauss-Seidel迭代演算法：多線性方程組迭代演算法——Gauss-Seidel迭代演算法的Python實現 1.1 Jacobi迭代演算法 1.2 張量A的生成函數和向量b的生成函數： 1.3 對稱張量S的生成函數： ...
  • 淺析分散式搜索引擎
    1. 基礎知識 1.1 認識Lucene 維基百科的定義： Lucene是一套用於 全文檢索 和 搜索 的 開放源碼程式庫 ，由Apache軟體基金會支持和提供。Lucene提供了一個簡單卻強大的應用程式介面，能夠做全文索引和搜索，在Java開發環境里Lucene是一個成熟的免費開放源代碼工具；就其 ...
  • 死磕 java同步系列之CyclicBarrier源碼解析——有圖有真相
    CyclicBarrier是什麼？ CyclicBarrier具有什麼特性？ CyclicBarrier與CountDownLatch的對比？ ...
  • python 之 面向對象基礎（定義類、創建對象，名稱空間）
    第七章面向對象 1、面向過程編程 核心是”過程“二字，過程指的是解決問題的步驟，即先乾什麼再乾什麼 基於該思想編寫程式就好比在編寫一條流水線，是一種機械式的思維方式 優點：複雜的問題流程化、進而簡單化 ​ 缺點：可擴展性差 2、面向對象 核心”對象“二字，對象指的是特征（變數）與技能（函數）的結合體 ...
  • Zookeeper 到底能幫我們解決哪些問題？
    Zookeeper 從設計模式角度來看，是一個基於觀察者模式設計的分散式服務管理框架，它負責存儲和管理大家都關心的數據，然後接受觀察者的註冊，一旦這些數據的狀態發生變化，Zookeeper 就將負責通知已經在 Zookeeper 上註冊的那些觀察者做出相應的反應，從而實現集群中類似 Master/S... ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類