python实现类似ftp传输文件的网络程序示例

“Program for ftp server”

from SocketServer import *
from time import *
import os
import loginauth

class MyFtp(StreamRequestHandler):
    def handle(self):
        try:
            while True:
                sleep(0.5)
                self.request.sendall(‘auth’)
                name = self.request.recv(BUFSIZ)
                sleep(0.5)
                self.request.sendall(‘pauth’)
                password = self.request.recv(BUFSIZ)
                print name,password
                auth_result = loginauth.user_create(name,password)
                print auth_result
                if auth_result == 0:
                    self.request.sendall(‘ok2login’)
                    break
                elif auth_result == 1:
                    self.request.sendall(‘fail2login’)
                    continue

            while True:
                recv来源gaodai#ma#com搞@@代~&码网_data = self.request.recv(BUFSIZ).split()
                if recv_data[0] == ‘rls’:
                    result = os.popen(‘ls -l ./’).read()
                    self.request.sendall(result)
                    continue
                if recv_data[0] == ‘?’ or recv_data[0] == ‘help’:
                    send_help = ”’\033[32;1m
                                ?\help:     Get help.
                                Get:        Downlaod file from remote server.
                                Send:       Send local file to remote server.
                                ls:         List local file.
                                rls:        List remote server file.
                                quit\exit:  Quit the application.
                                \033[0m”’
                    self.request.sendall(send_help)
                    continue
                if recv_data[0] == ‘send’:
                    filename = recv_data[1]
                    self.request.sendall(‘ok2send’)
                    recv_data = self.request.recv(BUFSIZ)
                    file2w = open(filename,’wb’)
                    file2w.write(recv_data)
                    file2w.flush()
                    file2w.close()
                    self.request.sendall(‘\033[33;1mFile transfer successed!!!\033[0m’)
                    continue

                if recv_data[0] == ‘get’:
                    filename = recv_data[1]
                    if os.path.isfile(filename):
                        self.request.sendall(‘ok2get’)
                        if self.request.recv(BUFSIZ) == ‘ok2send’:
                            self.request.sendall(‘sending’)
                            sleep(0.5)
                            file_data = open(filename,’rb’)
                            file_tmp = file_data.read()
                            self.request.sendall(file_tmp)
                            sleep(1)
                            self.request.sendall(‘\033[33;1mDownloading complete!\033[0m’)
                            file_data.close()

                    else:
                        self.request.sendall(‘fail2get’)
                        if self.request.recv(BUFSIZ) == ‘ack’:
                            self.request.sendall(‘\033[31;1m%s not found\033[0m’% filename)
        except :
            pass

if __name__ == ‘__main__’:
    HOST,PORT = ”,9889
    ADDR = (HOST,PORT)
    BUFSIZ = 8192

    try:
        server = ThreadingTCPServer(ADDR,MyFtp)
        server.serve_forever()
    except KeyboardInterrupt:
        server.shutdown()