最近做了一个简单的文件传输系统&＃xff0c;基于ftp协议&＃xff0c;使用python语言开发&＃xff0c;虽然python里面已经有ftplib模块&＃xff0c;可以很容易的实现ftp服务器。这次我使用的是socket实现client与ftp server之间的通讯和文件传输&＃xff0c;client另起一个flask服务器&＃xff0c;用于用户在浏览器端的交互。系统实现的功能有&＃xff1a;用户登录注册&＃xff0c;用户查看ftp服务器端文件和下载上传删除操作&＃xff0c;支持多进程、多用户。
一&＃xff0c;登录注册
该项目使用的是mongo数据库&＃xff0c;其实用户登录注册功能很好实现&＃xff0c;没有什么技术细节&＃xff0c;这里就略过了。数据库管理代码如下&＃xff1a;
import pymongo
from pymongo.collection import Collection
class DBManager(object):
def __init__(self):
client &＃61; pymongo.MongoClient("mongodb://localhost:27017/")
self.db &＃61; client["FTPDB"]
self.users &＃61; self.db[&＃39;user&＃39;]
#保存用户登录信息
def saveUserInfo(self,account,password):
users &＃61; self.users.find()
for item in users:
accountDB &＃61; item[&＃39;account&＃39;]
if accountDB &＃61;&＃61; account:
return "false"
data &＃61; []
userInfo &＃61; {}
userInfo[&＃39;account&＃39;] &＃61; account
userInfo[&＃39;password&＃39;] &＃61; password
data.append(userInfo)
collection &＃61; Collection(self.db,"user")
collection.insert(data)
return "true"
def confirmUserLoginInfo(self,account,password):
users &＃61; self.users.find()
&＃39;&＃39;&＃39;
result状态&＃xff1a; 1&＃xff1a;表示初始状态&＃xff0c;即不存在用户
2&＃xff1a;表示存在该用户、密码不正确
3&＃xff1a;验证成功
&＃39;&＃39;&＃39;
result &＃61; 1
for item in users:
accountDB &＃61; item[&＃39;account&＃39;]
passwordDB &＃61; item[&＃39;password&＃39;]
if accountDB &＃61;&＃61; account:
if passwordDB &＃61;&＃61; password:
result &＃61; 3
else:
result &＃61; 2
return result
前端注册js代码如下&＃xff1a;
function register() {
account &＃61; $("#account").val();
password &＃61; $("#password").val();
confirmPassword &＃61; $("#confirmPassword").val();
if(account &＃61;&＃61; null || password &＃61;&＃61; null || confirmPassword &＃61;&＃61; null){
alert("请先输入必要信息")
return;
}
if(password !&＃61; confirmPassword){
alert("密码不一致");
return;
}
var request &＃61; {
type:"register",
account:account,
password:password
}
sendData("http://localhost:8080/register",request)
}
//向服务器发送数据
function sendData(url,json) {
$.ajax({
url: url, //请求的url地址
dataType: "json", //返回格式为json
async: true, //请求是否异步&＃xff0c;默认为异步&＃xff0c;这也是ajax重要特性
data: json, //参数值
type: "post", //请求方式
success:function(data){
//alert(data)
if(data.toString() &＃61;&＃61; "false"){
alert("用户名已存在");
}else{
window.location.href &＃61; "http://localhost:8080/index";
}
},
error:function (error) {
console.log(error);
}
});
}
二&＃xff0c;文件管理(文件查看、删除、上传、下载)
客户端与服务器端约定命令格式&＃xff0c;服务器通过解析客户端命令来执行操作。
server.py
from socket import *
import os,sys
import signal
import time
# 全局变量
HOST &＃61; &＃39;0.0.0.0&＃39;
PORT &＃61; 8686
ADDR &＃61; (HOST,PORT)
FILE_PATH &＃61; &＃39;../serverFiles/&＃39;
# 处理僵尸进程
signal.signal(signal.SIGCHLD,signal.SIG_IGN)
# 服务端功能类
class Server(object):
def __init__(self):
self.connfd &＃61; ""
def do_list(self,account):
# 获取文件列表
file_list &＃61; os.listdir(FILE_PATH&＃43;account)
if not file_list:
self.connfd.send("服务器文件库为空".encode())
return
else:
self.connfd.send(b"OK")
time.sleep(0.1)
files &＃61; ""
for file in file_list:
if file[0] !&＃61; &＃39;.&＃39; and os.path.isfile(FILE_PATH &＃43; account &＃43;"/"&＃43; file):
files &＃43;&＃61; file &＃43; &＃39;#&＃39;
self.connfd.send(files.encode())
def delete(self,accout,fileName):
os.remove(FILE_PATH &＃43; accout &＃43; "/" &＃43; fileName)
self.connfd.send(b"OK")
time.sleep(0.1)
def do_get(self,account,filename):
try:
fd &＃61; open(FILE_PATH &＃43; account &＃43;"/"&＃43; filename,&＃39;rb&＃39;)
except IOError:
self.connfd.send("文件不存在".encode())
return
else:
#print("发送OK")
self.connfd.send(b&＃39;OK&＃39;)
time.sleep(0.1)
# 发送文件内容
while True:
data &＃61; fd.read(1024)
if not data:
time.sleep(0.1)
self.connfd.send(b&＃39;##&＃39;)
break
#print("正在发送数据")
self.connfd.send(data)
fd.close()
def do_put(self,account,filename):
if os.path.exists(FILE_PATH &＃43; account &＃43;"/"&＃43; filename):
self.connfd.send(&＃39;该文件已存在&＃39;.encode())
return
fd &＃61; open(FILE_PATH &＃43; account &＃43;"/"&＃43; filename,&＃39;wb&＃39;)
self.connfd.send(b&＃39;OK&＃39;)
# 接收文件内容
while True:
data &＃61; self.connfd.recv(1024)
if data &＃61;&＃61; b&＃39;**&＃39;:
break
fd.write(data)
fd.close()
def socket_tcp(self):
s &＃61; socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,True)
s.bind(ADDR)
s.listen(5)
print("Listen the port 8686...")
return s
def do_request(self,connfd):
self.connfd &＃61; connfd
while True:
data &＃61; connfd.recv(1024).decode()
datas &＃61; data.split(&＃39; &＃39;)
if not data or datas[1] &＃61;&＃61; &＃39;QUIT&＃64;#&＃39;:
connfd.close()
return
elif datas[1] &＃61;&＃61; "LIST&＃64;#":
#print("list")
self.do_list(datas[0])
elif datas[1] &＃61;&＃61; &＃39;GET&＃64;#&＃39;:
filename &＃61; datas[-1]
self.do_get(datas[0],filename)
elif datas[1] &＃61;&＃61; &＃39;PUT&＃64;#&＃39;:
filename &＃61; datas[-1]
self.do_put(datas[0],filename)
elif datas[1] &＃61;&＃61; &＃39;delete&＃64;#&＃39;:
filename &＃61; datas[-1]
self.delete(datas[0],filename)
def run(self):
# 创建套接字
s &＃61; self.socket_tcp()
while True:
try:
connfd,addr &＃61; s.accept()
except KeyboardInterrupt:
sys.exit("服务器退出")
except Exception as e:
print(e)
continue
print("Connect from",addr)
# 创建子进程
pid &＃61; os.fork()
if pid &＃61;&＃61; 0:
s.close()
self.do_request(connfd) #处理客户端具体请求
os._exit(0)
else:
connfd.close()
if __name__ &＃61;&＃61; "__main__":
server &＃61; Server()
server.run()
client.py
"""
client.py
"""
import socket
import os,sys
import time
# 服务器地址
ADDR &＃61; ("127.0.0.1",8686)
FILE_PATH &＃61; "./clientFiles/"
# 客户端功能类
class Client(object):
def __init__(self,account):
self.sockfd &＃61; ""
self.account &＃61; account
#获得服务器文件列表
def server_list(self):
ftpServerFiles &＃61; []
self.sockfd.send((self.account&＃43;&＃39; LIST&＃64;# &＃39;).encode())
# 等待回复
data &＃61; self.sockfd.recv(128).decode()
if data &＃61;&＃61; "OK":
files &＃61; self.sockfd.recv(4096).decode()
for file in files.split(&＃39;#&＃39;):
#print(file)
ftpServerFiles.append(file)
else:
# 无法完成操作
print(data)
ftpServerFiles &＃61; ftpServerFiles[:-1]
return ftpServerFiles
#获得用户文件夹列表
def client_list(self):
# 获取文件列表
userFiles &＃61; []
file_list &＃61; os.listdir(FILE_PATH&＃43;self.account&＃43;"/")
if not file_list:
return
else:
time.sleep(0.1)
files &＃61; ""
for file in file_list:
if file[0] !&＃61; &＃39;.&＃39; and os.path.isfile(FILE_PATH &＃43; self.account &＃43; "/" &＃43; file):
userFiles.append(file)
return userFiles
#退出
def do_quit(self):
self.sockfd.send((self.account&＃43;&＃39; QUIT&＃64;# &＃39;).encode())
self.sockfd.close()
sys.exit(&＃39;谢谢使用&＃39;)
#用户下载服务器文件
def do_get(self,filename):
self.sockfd.send((self.account&＃43;&＃39; GET&＃64;# &＃39;&＃43;filename).encode())
data &＃61; self.sockfd.recv(128).decode()
if data &＃61;&＃61; &＃39;OK&＃39;:
fd &＃61; open(FILE_PATH &＃43; self.account &＃43; "/" &＃43; filename,&＃39;wb&＃39;)
#复写
while True:
data &＃61; self.sockfd.recv(1024)
if data &＃61;&＃61; b&＃39;##&＃39;:
#print("##")
break
#print("正在写入数据")
fd.write(data)
fd.close()
else:
print(data)
#用户将文件上传到服务器文件夹
def do_put(self,filename):
try:
fd &＃61; open(FILE_PATH &＃43; self.account &＃43; "/" &＃43; filename,&＃39;rb&＃39;)
except IOError:
print("文件不存在")
return
# 获取文件名
filename &＃61; filename.split(&＃39;/&＃39;)[-1]
# else:
self.sockfd.send((self.account&＃43;&＃39; PUT&＃64;# &＃39;&＃43;filename).encode())
data &＃61; self.sockfd.recv(128).decode()
# 发送文件
if data &＃61;&＃61; &＃39;OK&＃39;:
while True:
data &＃61; fd.read(1024)
if not data:
time.sleep(0.1)
self.sockfd.send(b&＃39;**&＃39;)
break
self.sockfd.send(data)
fd.close()
return "true"
else:
print(data)
return "false"
#删除用户文件
def removeU(self,fileName):
os.remove(FILE_PATH &＃43; self.account &＃43; "/" &＃43; fileName)
return "true"
#删除用户文件
def removeF(self,fileName):
self.sockfd.send((self.account&＃43;&＃39; delete&＃64;# &＃39;&＃43;fileName).encode())
# 等待回复
data &＃61; self.sockfd.recv(128).decode()
if data &＃61;&＃61; "OK":
return "true"
def menu_display(self):
print("\n------命令选择-------")
print("*** clist ***")
print("*** slist ***")
print("*** get list ***")
print("*** put list ***")
print("*** quit ***")
print("----------------------")
def run(self,cmd):
# 创建套接字
sockfd &＃61; socket.socket()
try:
sockfd.connect(ADDR)
except Exception as e:
print(e)
return
result &＃61; ""
self.sockfd &＃61; sockfd
# choice(cmd,ftp)
if cmd &＃61;&＃61; "slist":
result &＃61; self.server_list()
return result
elif cmd &＃61;&＃61; "clist":
result &＃61; self.client_list()
return result
elif cmd &＃61;&＃61;&＃39;quit&＃39;:
self.do_quit()
elif cmd[:3] &＃61;&＃61; &＃39;get&＃39;:
filename &＃61; cmd.strip().split(&＃39; &＃39;)[-1]
self.do_get(filename)
elif cmd[:3] &＃61;&＃61; &＃39;put&＃39;:
filename &＃61; cmd.strip().split(&＃39; &＃39;)[-1]
result &＃61; self.do_put(filename)
return result
elif cmd[:7] &＃61;&＃61; &＃39;removeU&＃39;:
filename &＃61; cmd.strip().split(&＃39; &＃39;)[-1]
self.removeU(filename)
elif cmd[:7] &＃61;&＃61; &＃39;removeF&＃39;:
filename &＃61; cmd.strip().split(&＃39; &＃39;)[-1]
self.removeF(filename)
else:
print("请输入正确命令&＃xff01;")
if __name__ &＃61;&＃61; "__main__":
client &＃61; Client("ffy")
client.run()
运行界面&＃xff1a;
![]()
![]()
总结
到此这篇关于python实现ftp文件传输系统的文章就介绍到这了,更多相关python ftp文件传输内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家&＃xff01;
京公网安备 11010802041100号