用python实现ftp服务器，要求如下：1、项目目标 （1）通过socket API接口，掌握FTP协议，并设计和实现FTP协议定义的FTP服务器的核心功能。 （2）使用ftp客户端，和自己编写实现的FTP服务器进行通讯，展示FTP服务器各核心功能是正常工作的。 2、项目要求： （1）功能上包含FTP服务器的核心功能。 （2）设计成多线程循环处理的模式。

实现FTP服务器的核心功能可以参考以下步骤：

1. 创建服务器socket并绑定到指定的IP地址和端口号。
2. 监听客户端的连接请求，并创建新的线程处理每个客户端的请求。
3. 处理客户端的登录请求，验证用户名和密码，并返回登录结果。
4. 处理客户端的文件上传和下载请求，包括打开文件、读取文件、写入文件、关闭文件等操作。
5. 处理客户端的文件列表请求，返回当前目录下的所有文件和子目录。
6. 处理客户端的目录切换请求，切换当前工作目录到指定的目录。
7. 处理客户端的文件删除请求，删除指定的文件或目录。

以下是一个简单的FTP服务器示例代码：

import socket
import threading
import os

class FTPServer:
    def __init__(self, ip, port):
        self.ip = ip
        self.port = port
        self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.server_socket.bind((self.ip, self.port))
        self.server_socket.listen(5)
        print("FTP server started at {}:{}".format(self.ip, self.port))

    def handle_client(self, conn, addr):
        print("New client connected: {}".format(addr))
        conn.send("220 FTP server ready\r\n".encode())
        username = ""
        while True:
            data = conn.recv(1024).decode().strip()
            if not data:
                break
            if data.startswith("USER "):
                username = data.split()[1]
                conn.send("331 Password required for {}\r\n".format(username).encode())
            elif data.startswith("PASS "):
                password = data.split()[1]
                if self.authenticate(username, password):
                    conn.send("230 User {} logged in\r\n".format(username).encode())
                    break
                else:
                    conn.send("530 Login incorrect\r\n".encode())
            else:
                conn.send("530 Please login with USER and PASS\r\n".encode())
        while True:
            data = conn.recv(1024).decode().strip()
            if not data:
                break
            if data.startswith("PWD"):
                conn.send("257 \"{}\" is the current directory\r\n".format(os.getcwd()).encode())
            elif data.startswith("CWD "):
                path = data.split()[1]
                if os.path.isdir(path):
                    os.chdir(path)
                    conn.send("250 Directory changed to {}\r\n".format(os.getcwd()).encode())
                else:
                    conn.send("550 Directory not found\r\n".encode())
            elif data.startswith("LIST"):
                files = os.listdir(os.getcwd())
                conn.send("150 Here comes the directory listing\r\n".encode())
                for f in files:
                    conn.send("{}\r\n".format(f).encode())
                conn.send("226 Directory send OK\r\n".encode())
            elif data.startswith("STOR "):
                filename = data.split()[1]
                with open(filename, "wb") as f:
                    conn.send("150 Ok to send data\r\n".encode())
                    while True:
                        data = conn.recv(1024)
                        if not data:
                            break
                        f.write(data)
                    conn.send("226 Transfer complete\r\n".encode())
            elif data.startswith("RETR "):
                filename = data.split()[1]
                if os.path.isfile(filename):
                    conn.send("150 Opening data connection\r\n".encode())
                    with open(filename, "rb") as f:
                        while True:
                            data = f.read(1024)
                            if not data:
                                break
                            conn.send(data)
                    conn.send("226 Transfer complete\r\n".encode())
                else:
                    conn.send("550 File not found\r\n".encode())
            elif data.startswith("DELE "):
                filename = data.split()[1]
                if os.path.isfile(filename):
                    os.remove(filename)
                    conn.send("250 File deleted\r\n".encode())
                else:
                    conn.send("550 File not found\r\n".encode())
            elif data.startswith("QUIT"):
                conn.send("221 Goodbye\r\n".encode())
                break
            else:
                conn.send("500 Command not understood\r\n".encode())
        conn.close()

    def authenticate(self, username, password):
        # TODO: Implement authentication logic here
        return True

    def start(self):
        while True:
            conn, addr = self.server_socket.accept()
            thread = threading.Thread(target=self.handle_client, args=(conn, addr))
            thread.start()

if __name__ == "__main__":
    ftp_server = FTPServer("localhost", 21)
    ftp_server.start()

注意：这只是一个简单的示例代码，实际应用中需要考虑更多的安全性和性能方面的问题。