python实现FTP文件传输（服务器端和客户端）

用python实现FTP文件传输，包括服务器端和客户端，要求

（1）客户端访问服务器端要有一个验证功能

（2）可以有多个客户端访问服务器端

（3）可以对重名文件重新上传或下载

FTP（File Transfer Protocol，文件传输协议） 是 TCP/IP 协议组中的协议之一。FTP协议包括两个组成部分，其一为FTP服务器，其二为FTP客户端。其中FTP服务器用来存储文件，用户可以使用FTP客户端通过FTP协议访问位于FTP服务器上的资源。在开发网站的时候，通常利用FTP协议把网页或程序传到Web服务器上。它工作在TCP 模型的第四层， 即应用层， 使用 TCP 传输而不是 UDP， 客户在和服务器建立连接前要经过一个“三次握手”的过程， 保证客户与服务器之间的连接是可靠的， 而且是面向连接， 为数据传输提供可靠保证。

服务器端

 首先要实现对访问客户端的验证，在本地建立一个数据库文件，将客户端的用户名和密码写入到文件中。这样每次访问时都将用户名和密码和数据库中存在的进行匹配，实现验证功能。这里对密码进行了MD5加密，保证了密码不会轻易泄露。

{"username": "ahpu", "password": "96e79218965eb72c92a549dd5a330112", "limitsize": 10240000, "homepath": "D:\FTP\home\ahpu"}

登录验证功能具体实现

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : hgh

import hashlib
import os
import json
from conf import settings

class User_auth(object):
    def auth(self, account_info):
        """
        #此功能是进行用户的登录信息验证，如果登录成功，那么返回用户对应的http状态码及账户信息,否则只返回http状态码
        :param account_info: 用户的账户信息：用户名，密码
        :return:
        """
        name = account_info.split(":")[0]
        pwd = account_info.split(":")[1]
        pwd = self.hash(pwd.encode())   # 将用户名的密码转换成hash值
        user_db_file = settings.DATABASE + r"\%s.db" % name  # 也可以写成 "\%s.db"  or "/%s.db"
        if os.path.isfile(user_db_file):    # 输入的用户名存在
            with open(user_db_file) as fr:
                user_db_info = json.loads(fr.read())     # or josn.load(fr)
                if pwd == user_db_info['password']:
                    return "200", user_db_info      # 确定，客户请求成功
                else:
                    return "403.11", None     # 密码错误
        else:
            return "400", None     # 用户名不存在，用户认证失败


    def hash(self, pwd):
        """
         用户的密码加密
        :param self:
        :param pwd: 用户密码
        :return:
        """
        m = hashlib.md5()
        m.update(pwd)
        return m.hexdigest()

然后是重传功能实现

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : hgh

import hashlib
import sys


class Breakpoint(object):
    # 本模块确认用户上传或下载的文件是否存在，如果存在是否需要断点续传
    def transfer(self, filename, has_send_size, total_size, conn):
        """
        进行续传
        :param filename:
        :param has_send_size: 已经发送的文件大小
        :param total_size: 需要传输文件总大小
        :param conn: 客户端和服务端进行数据交换的接口
        :return:
        """
        with open(filename, 'rb') as fr:
            fr.seek(has_send_size)     # 定位到续传的位置
            print("has_send", has_send_size, "total", total_size)
            m = hashlib.md5()
            if has_send_size == total_size:
                self.progress_bar(has_send_size, total_size)
            for line in fr:
                conn.send(line)
                m.update(line)
                has_send_size += len(line)
                # self.progress_bar(has_send_size,total_size)
        return m.hexdigest()

    def progress_bar(self, has_send_size, total_size):
        bar_width = 50     # 进度条长度
        process = has_send_size / total_size
        send_bar = int(process * bar_width + 0.5)     # 发送的数据占到的进度条长度，四舍五入取整
        sys.stdout.write("#" * send_bar + "=" * (bar_width - send_bar) + "
")  # 注意点：只能这么写才能达到要求
        sys.stdout.write("
%.2f%%: %s%s" % (process * 100, "#" * send_bar, "=" * (bar_width - send_bar)))  # 注意点：在pycharm中要加

                                                                       # 用sublime只要
否则换行
        sys.stdout.flush()

服务器端代码

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : hgh

import sys
import os
from core import socket_server

path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(path)



if __name__ == "__main__":
    HOST, PORT = "192.168.40.1", 9901
    server = socket_server.socketserver.ThreadingTCPServer((HOST, PORT), socket_server.MyTCPServer)
    server.serve_forever()

客户端

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : hgh

from core import socket_client
import os
import sys

path = os.path.dirname(os.path.abspath(__file__))
sys.path.append(path)



if __name__ == "__main__":
    host, port = "192.168.40.1", 9901
    myClient = socket_client.MySocketClient(host, port)
    myClient.start()

由于篇幅有限，具体服务器端及客户端代码都放在了github上，地址https://github.com/heguohang/FTP-python