不写代码,使用twistd实现ftp服务器

使用方法以下: python

twistd ftp react

这时启动的ftp服务器的HOME目录为/usr/local/ftp,匿名用户名为anonymous,密码为随便的一个邮箱地址,端口号为2121。 django

能够经过以下命令查看此服务器的其余参数: 安全

twistd ftp –help 服务器

比较有用的就是–root,来指定登录的根目录。还有就是–port指定端口号。 app

不过要注意的是,这个服务器仅用于调试,不要应用于产品环境,由于它并无作安全性方面的工做。 this

#!/usr/bin/env python # -*- coding: utf-8 -*- """a very simple ftp server by twisted """ import sys, os sys.path.append('../../..') os.environ['DJANGO_SETTINGS_MODULE'] = 'settings' from twisted.protocols import ftp from twisted.cred import portal, checkers, credentials, error as credError from twisted.internet import reactor, defer from zope.interface import implements from twisted.python import filepath from django.contrib.auth import authenticate from django.contrib.auth.models import User class UserChecker:     implements(checkers.ICredentialsChecker)     credentialInterfaces = (credentials.IUsernamePassword,)          def __init__(self):         "passwords: a dict-like object mapping usernames to passwords"     def requestAvatarId(self, credentials):         user = authenticate(username=credentials.username, password=credentials.password)         if user is not None:             if user.is_active:                 return defer.succeed(credentials.username)             else:                 return defer.fail(credError.UnauthorizedLogin("access denied"))         else:             return defer.fail(credError.UnauthorizedLogin("No such user")) class MyFTPRealm:     implements(portal.IRealm)          def __init__(self, anonymousRoot):         self.anonymousRoot = filepath.FilePath(anonymousRoot)          def requestAvatar(self, avatarId, mind, *interfaces):         for iface in interfaces:             if iface is ftp.IFTPShell:                 if avatarId is checkers.ANONYMOUS:                     avatar = ftp.FTPAnonymousShell(self.anonymousRoot)                 else:                     try:                         user = User.objects.get(username=avatarId)                         ftpdir = user.ftp.all()[0].ftpdir                     except:                         raise "没有该用户"                     avatar = ftp.FTPShell(filepath.FilePath(ftpdir.encode("utf-8")))                 return ftp.IFTPShell, avatar, getattr(avatar, "logout", lambda:None)         raise NotImplementedError("only IFTPShell interface is supported by this realm") class MyFtpServer(ftp.FTP):     def __init__(self, *args, **kw):         super(ftp.FTP, self).__init__(*args, **kw)     def dataReceived(self, data):         self.transport.write(data) if __name__ == "__main__":     p = portal.Portal(MyFTPRealm(""))     p.registerChecker(UserChecker())     factory = ftp.FTPFactory(MyFtpServer())     factory.portal = p     reactor.listenTCP(2121, factory)     reactor.run()
相关文章
相关标签/搜索