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

Python可以通过ftplib模块和socket模块实现FTP文件传输的方法。FTPlib模块可以通过FTP协议实现文件上传、下载等操作，socket模块可以实现FTP协议的底层通信。下面分别介绍客户端和服务器端的实现方法。

客户端

客户端的实现步骤如下：

1. 创建FTP对象；
2. 连接FTP服务器；
3. 进行登录认证；
4. 进行文件上传或下载；
5. 关闭FTP连接。

示例1：文件上传

import ftplib

# 连接FTP服务器
ftp = ftplib.FTP("10.0.0.100")
ftp.login("username", "password")

# 打开文件并上传
with open("test.txt", "rb") as f:
    ftp.storbinary("STOR /test.txt", f, 1024)

# 关闭FTP连接
ftp.quit()

该示例实现了将本地的test.txt文件上传到FTP服务器。首先创建FTP对象并连接FTP服务器，在进行登录认证之后，使用ftp.storbinary()方法将文件上传至服务器。最后关闭FTP连接。

示例2：文件下载

import ftplib

# 连接FTP服务器
ftp = ftplib.FTP("10.0.0.100")
ftp.login("username", "password")

# 下载文件
with open("test.txt", "wb") as f:
    ftp.retrbinary("RETR /test.txt", f.write, 1024)

# 关闭FTP连接
ftp.quit()

该示例实现了将FTP服务器上的test.txt文件下载至本地。与上传类似，先创建FTP对象并连接FTP服务器，进行登录认证，之后使用ftp.retrbinary()方法将文件下载至本地。最后关闭FTP连接。

服务器端

服务器端的实现步骤如下：

1. 创建FTP对象；
2. 绑定FTP服务器IP地址和端口号；
3. 进行登录认证；
4. 设置FTP根目录；
5. 监听FTP连接，并对文件上传或下载进行处理；
6. 关闭FTP连接。

示例1：文件上传

import socketserver
import threading
import os

class FTPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        # 进行登录认证
        self.request.sendall(b"220 Welcome to FTP Server\r\n")
        req = self.request.recv(1024).decode()
        if req.startswith("USER"):
            self.request.sendall(b"331 Password required for anonymous\r\n")
        elif req.startswith("PASS"):
            self.request.sendall(b"230 User logged in, proceed\r\n")
        else:
            self.request.sendall(b"530 Not logged in.\r\n")

        # 接收上传文件
        req = self.request.recv(1024).decode()
        if req.startswith("STOR"):
            filename = req.split(" ")[1]
            with open(filename, "wb") as f:
                while True:
                    data = self.request.recv(1024)
                    if not data:
                        break
                    f.write(data)
            self.request.sendall(b"226 Transfer complete.\r\n")
        else:
            self.request.sendall(b"530 Not logged in.\r\n")

class FTPServer(threading.Thread):
    def __init__(self, host, port):
        super().__init__()
        self.server = socketserver.TCPServer((host, port), FTPHandler)

    def run(self):
        self.server.serve_forever()

    def shutdown(self):
        self.server.shutdown()

# 启动FTP服务
server = FTPServer("10.0.0.100", 21)
server.start()

# 使用exit命令停止服务
while True:
    cmd = input()
    if cmd == "exit":
        server.shutdown()
        break

该示例实现了基于socketserver模块的FTP服务器端功能，并使用了线程实现并发处理。在handle()方法中，首先进行登录认证，之后通过req.startswith()方法判断客户端的操作类型，如果是上传文件则使用循环接收客户端发送的数据并写入本地文件中。最后，使用self.request.sendall()方法向客户端发送响应信息。

示例2：文件下载

import socketserver
import threading
import os

class FTPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        # 进行登录认证
        self.request.sendall(b"220 Welcome to FTP Server\r\n")
        req = self.request.recv(1024).decode()
        if req.startswith("USER"):
            self.request.sendall(b"331 Password required for anonymous\r\n")
        elif req.startswith("PASS"):
            self.request.sendall(b"230 User logged in, proceed\r\n")
        else:
            self.request.sendall(b"530 Not logged in.\r\n")

        # 发送下载文件
        req = self.request.recv(1024).decode()
        if req.startswith("RETR"):
            filename = req.split(" ")[1]
            with open(filename, "rb") as f:
                while True:
                    data = f.read(1024)
                    if not data:
                        break
                    self.request.sendall(data)
            self.request.sendall(b"226 Transfer complete.\r\n")
        else:
            self.request.sendall(b"530 Not logged in.\r\n")

class FTPServer(threading.Thread):
    def __init__(self, host, port):
        super().__init__()
        self.server = socketserver.TCPServer((host, port), FTPHandler)

    def run(self):
        self.server.serve_forever()

    def shutdown(self):
        self.server.shutdown()

# 启动FTP服务
server = FTPServer("10.0.0.100", 21)
server.start()

# 使用exit命令停止服务
while True:
    cmd = input()
    if cmd == "exit":
        server.shutdown()
        break

该示例实现了基于socketserver模块的FTP服务器端功能，并使用了线程实现并发处理。在handle()方法中，首先进行登录认证，之后通过req.startswith()方法判断客户端的操作类型，如果是下载文件则使用循环读取本地文件中的数据并发送给客户端。最后，使用self.request.sendall()方法向客户端发送响应信息。