首页 > 代码库 > Python_FTP通讯软件
Python_FTP通讯软件
ftpServer.py
1 import socket 2 import threading 3 import os 4 import struct 5 6 #用户账号、密码、主目录 7 #也可以把这些信息存放到数据库中 8 users = {‘zhangsan‘:{‘pwd‘:‘zhangsan1234‘, ‘home‘:r‘c:\python 3.5‘}, 9 ‘lisi‘:{‘pwd‘:‘lisi567‘, ‘home‘:‘c:\\‘}} 10 11 def server(conn,addr, home): 12 print(‘新客户端：‘+str(addr)) 13 #进入当前用户主目录 14 os.chdir(home) 15 while True: 16 data = http://www.mamicode.com/conn.recv(100).decode().lower() 17 #显示客户端输入的每一条命令 18 print(data) 19 #客户端退出 20 if data in (‘quit‘, ‘q‘): 21 break 22 #查看当前文件夹的文件列表 23 elif data in (‘list‘, ‘ls‘, ‘dir‘): 24 files = str(os.listdir(os.getcwd())) 25 files = files.encode() 26 conn.send(struct.pack(‘I‘, len(files))) 27 conn.send(files) 28 #切换至上一级目录 29 elif ‘‘.join(data.split()) == ‘cd..‘: 30 cwd = os.getcwd() 31 newCwd = cwd[:cwd.rindex(‘\\‘)] 32 #考虑根目录的情况 33 if newCwd[-1] == ‘:‘: 34 newCwd += ‘\\‘ 35 #限定用户主目录 36 if newCwd.lower().startswith(home): 37 os.chdir(newCwd) 38 conn.send(b‘ok‘) 39 else: 40 conn.send(b‘error‘) 41 #查看当前目录 42 elif data in (‘cwd‘, ‘cd‘): 43 conn.send(str(os.getcwd()).encode()) 44 elif data.startswith(‘cd ‘): 45 #指定最大分隔次数，考虑目标文件夹带有空格的情况 46 #只允许使用相对路径进行跳转 47 data = http://www.mamicode.com/data.split(maxsplit=1) 48 if len(data) == 2 and os.path.isdir(data[1]) 49 and data[1]!=os.path.abspath(data[1]): 50 os.chdir(data[1]) 51 conn.send(b‘ok‘) 52 else: 53 conn.send(b‘error‘) 54 #下载文件 55 elif data.startswith(‘get ‘): 56 data = http://www.mamicode.com/data.split(maxsplit=1) 57 #检查文件是否存在 58 if len(data) == 2 and os.path.isfile(data[1]): 59 conn.send(b‘ok‘) 60 fp = open(data[1], ‘rb‘) 61 while True: 62 content = fp.read(4096) 63 #发送文件结束 64 if not content: 65 conn.send(b‘overxxxx‘) 66 break 67 #发送文件内容 68 conn.send(content) 69 if conn.recv(10) == b‘ok‘: 70 continue 71 fp.close() 72 else: 73 conn.send(b‘no‘) 74 #无效命令 75 else: 76 pass 77 78 conn.close() 79 print(str(addr)+‘关闭连接‘) 80 81 #创建Socket，监听本地端口，等待客户端连接 82 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 83 sock.bind((‘‘, 10600)) 84 sock.listen(5) 85 while True: 86 conn, addr = sock.accept() 87 #验证客户端输入的用户名和密码是否正确 88 userId, userPwd = conn.recv(1024).decode().split(‘,‘) 89 if userId in users and users[userId][‘pwd‘] == userPwd: 90 conn.send(b‘ok‘) 91 #为每个客户端连接创建并启动一个线程，参数为连接、客户端地址、客户主目录 92 home = users[userId][‘home‘] 93 t = threading.Thread(target=server, args=(conn,addr,home)) 94 t.daemon = True 95 t.start() 96 else: 97 conn.send(b‘error‘)
ftpClient.py
1 import socket 2 import threading 3 import os 4 import struct 5 6 #用户账号、密码、主目录 7 #也可以把这些信息存放到数据库中 8 users = {‘zhangsan‘:{‘pwd‘:‘zhangsan1234‘, ‘home‘:r‘c:\python 3.5‘}, 9 ‘lisi‘:{‘pwd‘:‘lisi567‘, ‘home‘:‘c:\\‘}} 10 11 def server(conn,addr, home): 12 print(‘新客户端：‘+str(addr)) 13 #进入当前用户主目录 14 os.chdir(home) 15 while True: 16 data = http://www.mamicode.com/conn.recv(100).decode().lower() 17 #显示客户端输入的每一条命令 18 print(data) 19 #客户端退出 20 if data in (‘quit‘, ‘q‘): 21 break 22 #查看当前文件夹的文件列表 23 elif data in (‘list‘, ‘ls‘, ‘dir‘): 24 files = str(os.listdir(os.getcwd())) 25 files = files.encode() 26 conn.send(struct.pack(‘I‘, len(files))) 27 conn.send(files) 28 #切换至上一级目录 29 elif ‘‘.join(data.split()) == ‘cd..‘: 30 cwd = os.getcwd() 31 newCwd = cwd[:cwd.rindex(‘\\‘)] 32 #考虑根目录的情况 33 if newCwd[-1] == ‘:‘: 34 newCwd += ‘\\‘ 35 #限定用户主目录 36 if newCwd.lower().startswith(home): 37 os.chdir(newCwd) 38 conn.send(b‘ok‘) 39 else: 40 conn.send(b‘error‘) 41 #查看当前目录 42 elif data in (‘cwd‘, ‘cd‘): 43 conn.send(str(os.getcwd()).encode()) 44 elif data.startswith(‘cd ‘): 45 #指定最大分隔次数，考虑目标文件夹带有空格的情况 46 #只允许使用相对路径进行跳转 47 data = http://www.mamicode.com/data.split(maxsplit=1) 48 if len(data) == 2 and os.path.isdir(data[1]) 49 and data[1]!=os.path.abspath(data[1]): 50 os.chdir(data[1]) 51 conn.send(b‘ok‘) 52 else: 53 conn.send(b‘error‘) 54 #下载文件 55 elif data.startswith(‘get ‘): 56 data = http://www.mamicode.com/data.split(maxsplit=1) 57 #检查文件是否存在 58 if len(data) == 2 and os.path.isfile(data[1]): 59 conn.send(b‘ok‘) 60 fp = open(data[1], ‘rb‘) 61 while True: 62 content = fp.read(4096) 63 #发送文件结束 64 if not content: 65 conn.send(b‘overxxxx‘) 66 break 67 #发送文件内容 68 conn.send(content) 69 if conn.recv(10) == b‘ok‘: 70 continue 71 fp.close() 72 else: 73 conn.send(b‘no‘) 74 #无效命令 75 else: 76 pass 77 78 conn.close() 79 print(str(addr)+‘关闭连接‘) 80 81 #创建Socket，监听本地端口，等待客户端连接 82 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 83 sock.bind((‘‘, 10600)) 84 sock.listen(5) 85 while True: 86 conn, addr = sock.accept() 87 #验证客户端输入的用户名和密码是否正确 88 userId, userPwd = conn.recv(1024).decode().split(‘,‘) 89 if userId in users and users[userId][‘pwd‘] == userPwd: 90 conn.send(b‘ok‘) 91 #为每个客户端连接创建并启动一个线程，参数为连接、客户端地址、客户主目录 92 home = users[userId][‘home‘] 93 t = threading.Thread(target=server, args=(conn,addr,home)) 94 t.daemon = True 95 t.start() 96 else: 97 conn.send(b‘error‘)
Python_FTP通讯软件
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。