python实现的ftp服务器

15468

#!/usr/bin/env python
# author:  Hua Liang [ Stupid ET ]
# email:   et@everet.org
# website: http://EverET.org
#
import socket, os, stat, threading, time, struct, getopt
import sys, re, signal, select, logging, logging.handlers
host = '127.0.0.1'
port = 21
limit_connection_number = 5     # max client number
timeout = 60 * 3                # timeout in second
default_home_dir = os.path.normpath(os.path.abspath(os.curdir)).replace('\\', '/')
logfile = '/var/log/ftp.py.log' if os.name == 'posix' else default_home_dir + 'ftp.py.log'
runas_user = 'www-data'
global_options = {'run_mode':'fork'}
# current working directory
account_info = {
'anonymous':{'pass':'', 'home_dir':default_home_dir, 'runas_user':runas_user},
}
def runas(username):
if os.name != 'posix': return
uid = get_uid(username)
os.setgid(uid)
os.setuid(uid)
class FTPConnection:
'''You can add handle func by startswith handle_ prefix.
When the connection receives CWD command, it'll use handle_CWD to handle it.
'''
def __init__(self, fd, remote_ip):
self.fd = fd
self.data_fd = 0
self.options = {'pasv': False, 'utf8': False}
self.data_host = ''
self.data_port = 0
self.localhost = fd.getsockname()[0]
self.home_dir = default_home_dir
self.curr_dir = '/'
self.running = True
self.handler = dict(
[(method[7:], getattr(self, method)) \
for method in dir(self) \
if method.startswith("handle_") and callable(getattr(self, method))])
def start(self):
try:
self.say_welcome()
while self.running:
success, command, arg = self.recv()
command = command.upper()
if self.options['utf8']:
arg = unicode(arg, 'utf8').encode(sys.getfilesystemencoding())
logger.info('[ ' + command + ' ] ' + arg)
if not success:
self.send_msg(500, "Failed")
continue
if not self.handler.has_key(command):
self.send_msg(500, "Command Not Found")
continue
try:
self.handler[command](arg)
except OSError, e:
logger.error(e)
logger.error("in start")
self.send_msg(500, 'Permission denied')
self.say_bye()
except Exception, e:
self.running = False
logger.error(e)
logger.error("in start")
finally:
self.fd.close()
logger.info("FTP connnection done.")
return True
def send_msg(self, code, msg):
if self.options['utf8']:
msg = unicode(msg, sys.getfilesystemencoding()).encode('utf8')
message = str(code) + ' ' + msg + '\r\n'
self.fd.send(message)
def recv(self):
'''returns 3 tuples, success, command, arg'''
try:
success, buf, command, arg = True, '', '', ''
while True:
data = self.fd.recv(4096)
if not data or data > 8 & 0xff), (port & 0xff)))
except Exception, e:
logger.error(e)
logger.error("in pasv")
self.send_msg(500, 'passive mode failed')
def handle_PORT(self, arg):
try:
if self.data_fd:
self.data_fd.close()
t = arg.split(',')
self.data_host = '.'.join(t[:4])
self.data_port = int(t[4]) * 256 + int(t[5])
self.data_fd = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except:
self.send_msg(500, "PORT failed")
self.send_msg(200, "OK")
def handle_DELE(self, arg):
remote, local = self.parse_path(arg)
if not os.path.exists(local):
self.send_msg(450, "File not exist")
return
os.remove(local)
self.send_msg(250, 'File deleted')
def handle_OPTS(self, arg):
if arg.upper() == "UTF8 ON":
self.options['utf8'] = True
self.send_msg(200, "OK")
elif arg.upper() == "UTF8 OFF":
self.options['utf8'] = False
self.send_msg(200, "OK")
else:
self.send_msg(500, "Invalid argument")

class FTPThread(threading.Thread):
'''FTPConnection Thread Wrapper'''
def __init__(self, fd, remote_ip):
threading.Thread.__init__(self)
self.ftp = FTPConnection(fd, remote_ip)
def run(self):
self.ftp.start()
logger.info("Thread done")
class FTPThreadServer:
'''FTP Server which is using thread'''
def serve_forever(self):
listen_fd = socket.socket()
listen_fd.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
listen_fd.bind((host, port))
listen_fd.listen(512)
while True:
logger.info('new server')
client_fd, client_addr = listen_fd.accept()
handler = FTPThread(client_fd, client_addr)
handler.start()

class FTPForkServer:
'''FTP Fork Server, use process per user'''
def child_main(self, client_fd, client_addr, write_end):
'''never return'''
for fd in self.read_fds:
os.close(fd)
self.read_fds = []
try:
handler = FTPConnection(client_fd, client_addr)
handler.start()
except Exception, e:
logger.error(e)
logger.error("in child_main")
os.write(write_end, str(write_end))
sys.exit()
def serve_forever(self):
listen_fd = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
listen_fd.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
listen_fd.bind((host, port))
listen_fd.listen(512)
self.read_fds = [listen_fd]
while True:
rlist, wlist, xlist = select.select(self.read_fds, [], [])
if listen_fd in rlist:
client_fd, client_addr = listen_fd.accept()
if len(self.read_fds) > limit_connection_number:
logger.error('reject client: ' + str(client_addr))
client_fd.close()
continue
try:
logger.info('new client: ' + str(client_addr))
read_end, write_end = os.pipe()
self.read_fds.append(read_end)
fork_result = os.fork()
if fork_result == 0: # child process
                        listen_fd.close()
self.read_fds.remove(listen_fd)
self.child_main(client_fd, client_addr, write_end) # never return
else:
os.close(write_end)
except Exception, e:
logger.error(e)
logger.error('Fork failed')
for read_fd in rlist:
if read_fd == listen_fd: continue
data = os.read(read_fd, 32)
self.read_fds.remove(read_fd)
os.close(read_fd)

def get_uid(username = 'www-data'):
'''get uid by username, I don't know whether there's a
function can get it, so I wrote this function.'''
pwd = open('/etc/passwd', 'r')
pat = re.compile(username + ':.*?:(.*?):.*?')
for line in pwd.readlines():
try:
uid = pat.search(line).group(1)
except: continue
return int(uid)
def get_logger(handler = logging.StreamHandler()):
logger = logging.getLogger()
formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s')
handler.setFormatter(formatter)
logger.addHandler(handler)
logger.setLevel(logging.NOTSET)
return logger
def daemonize(stdin='/dev/null', stdout='/dev/null', stderr='/dev/null'):
'''becomes a daemon'''
try:
pid = os.fork()
if pid > 0: sys.exit(0)
except OSError, e:
sys.stderr.write("fork #1 failed\n")
sys.exit(1)
os.umask(0)
os.setsid()
try:
pid = os.fork()
if pid > 0: sys.exit(0)
except OSError, e:
sys.stderr.write("fork #2 failed\n")
sys.exit(1)
for f in sys.stdout, sys.stderr: f.flush()
si = file(stdin, 'r')
so = file(stdout, 'a+')
se = file(stderr, 'a+', 0)
os.dup2(si.fileno(), sys.stdin.fileno())  # 0
os.dup2(so.fileno(), sys.stdout.fileno()) # 1
os.dup2(se.fileno(), sys.stderr.fileno()) # 2
def serve_forever():
global global_options
print global_options
if global_options['run_mode'] == 'fork':
signal.signal(signal.SIGCHLD, signal.SIG_IGN)
server = FTPForkServer()
else:
server = FTPThreadServer()
server.serve_forever()
def usage():
print '''usage: %s [-d] [-h] [-p port] [-o] [-t]
-d become a daemon
-h help
-p listen port
-o output log to stdout, by default, it outputs to a log file.
-t thread mode, fork model by default
Waring:
The Thread Mode is not complete.
Author:
Hua Liang [ Stupid ET ]
http://EverET.org
''' % os.path.basename(sys.argv[0])
def param_handler(opts):
global port, logger, global_options
be_daemon = False
logger = get_logger(logging.FileHandler(logfile))
for o, a in opts:
if o == '-h':
usage()
sys.exit(0)
elif o == '-d':
if not os.name == 'posix':
print 'Only support the os with posix specifications.'
sys.exit(-1)
be_daemon = True
elif o == '-o':
logger = get_logger()
elif o == '-p':
try: port = int(a)
except Exception, e:
usage()
sys.exit(0)
elif o == '-t':
global_options['run_mode'] = 'thread'
if os.name != 'posix' and global_options['run_mode'] == 'fork':
print "You can NOT run fork mode in a non posix os,\
please use -t options to run in thread mode"
sys.exit(-1)
if be_daemon: daemonize()
if __name__ == '__main__':
try:
opts, args = getopt.getopt(sys.argv[1:], 'hdp:ot')
except getopt.GetoptError:
usage()
sys.exit(2)
param_handler(opts)
socket.setdefaulttimeout(timeout)
'''You can write your account_info in ftp.py.config'''
try: execfile('ftp.py.config')
except Exception, e: logger.error(e)
serve_forever()