1.ftp client
1 #!/usr/bin/env python
2 #_*_coding:utf-8_*_
3
4
5 import socket
6 import subprocess
7
8 user_data = {
9 'user':None,
10 }
11
12 user_status = False #用户验证，只是当用户可以链接的时候需要去验证一下用户密码
13 def login():
14 count = 0
15 global user_status
16 while True:
17 user_name = input("请输入您的用户名>>>:")
18 with open('D:\\kkk\\day5work\\db.txt', 'r',encoding="utf-8") as files:
19 for i in files.readlines(): #整行读取
20 if user_name in i: #空格为分隔符生成字典
21 while True:
22 passwd = input("请输入您的密码>>>:")
23 if str(passwd) == str(i.split(' ')[-1].strip('\n')):#上面空格分隔符后面的密码
24 user_data['user'] = user_name
25 #print(user_data['user']) 调试用的可以删除
26 user_status = True
27 break
28 else:
29 count += 1
30 if count >= 3:
31 print('input passwd error')
32 exit("您输入过多次错误密码，将被锁定:") #锁定的方法还没有实现上去
33 if user_status == True:
34 break
35 login()
36 if user_status == True:
37 print("1111")
38
39
40 client = socket.socket()
41 client.connect(('10.10.10.140',8002)) #客户端需要链接的Ip 和 端口
42 while True:
43 msg = input('>>>:').strip() #用户输入想要执行的命令
44 if len(msg) == 0: continue #判断无输入继续
45 print('to server', msg)
46 client.send('put')
47 if 'put' in msg:
48 res_obj = subprocess.Popen('cat filename', shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) #本地查看文件长度
49 res = res_obj.stdout.read() # 执行命令的结果
50 client.send(str(len(res)).encode()) # 命令执行结果的长度字符串一下
51 client.send(res) # 发送给客户端需要循环单次长度
52
53 if 'get' in msg:
54 client.send(msg.encode()) #将用户输入的命令编码，只接收二进制文件
55 date = client.recv(1024) #接收的文件字符数
56 print("res:",date.decode())
57 total_size = int(date.decode()) #将接收的字符串解码并整型
58 recevied_size = 0 #标识
59 res = b''
60 while recevied_size < total_size: #接收大小与总数相比
61 d = client.recv(1024)
62 res += d
63 old = open("filename.txt", "r+", encoding="utf-8")
64 old.write(d)
65 recevied_size += len(d) #每次循环加上之前获取的大小
66 # print("rece done----")
67 # print(res.decode())
68
69 if 'put' in msg:
70 client.send(msg.encode()) # 将用户输入的命令编码，只接收二进制文件
71 date = client.recv(1024) # 接收的文件字符数
72 print("res:", date.decode())
73 total_size = int(date.decode()) # 将接收的字符串解码并整型
74 recevied_size = 0 # 标识
75 res = b''
76 while recevied_size < total_size: # 接收大小与总数相比
77 d = client.recv(1024)
78 res += d
79 old = open("filename.txt", "r+", encoding="utf-8")
80 old.write(d)
81 recevied_size += len(d) # 每次循环加上之前获取的大小
82 #(家目录应该是字符串的拼接吧)
2.ftp server
#!/usr/bin/env python
#_*_coding:utf-8_*_
import socket
import subprocess
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #创建实例
server.bind(("0.0.0.0",8002)) #监听所有IP，端口
server.listen(5) #排列监听主机数，不是并发
print("--------listen-----------")
while True:
conn,client_addr = server.accept() #接受客户端的链接
while True:
date = conn.recv(1024) # 接收客户端发过来的字符串的长度
if 'put' in date:
total_size = int(date.decode()) # 将接收的字符串解码并整型
recevied_size = 0 # 标识
res = b''
while recevied_size < total_size: # 接收大小与总数相比
d = conn.recv(1024)
old = open("filename.txt", "r+", encoding="utf-8")
old.write(d)
res += d
recevied_size += len(d) # 每次循环加上之前获取的大小
print("rece done----")
if 'get' in date:
res_obj = subprocess.Popen('cat filename',shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE) #在本机实行的命令
res = res_obj.stdout.read() #执行命令的结果
conn.send(str(len(res)).encode()) #命令执行结果的长度字符串一下
conn.send(res) #发送给客户端需要循环单次长度