# -*- coding: UTF-8 -*-
import socket
import os
import struct
class FtpClient(object):
# 定义一个FtpClien类
def __init__(self, host, port):
self.host = host
self.port = port
def client_push(self):
# 声明协议类型,同时生成socket对象
ftp_client = socket.socket()
# 连接服务端
ftp_client.connect((self.host, self.port))
while True:
# 切换文件目录路径
print("输入文件目录路径")
pwd = input(">>:").strip()
# 列出文件名称
files_list = os.listdir('{}'.format(pwd))
for i in files_list:
print(i)
file_name = input('输入上传的文件名:').strip()
file_path = os.path.join(pwd, file_name)
if os.path.isfile(file_path):
file_info = struct.calcsize('128sl') # 定义打包规则
f_head = struct.pack('128sl', file_name.encode('utf-8'), os.stat(file_path).st_size)
ftp_client.send(f_head)
fo = open(file_path, 'rb')
while True:
file_data = fo.read(1024)
if not file_data:
break
ftp_client.send(file_data)
fo.close()
# 上传文件
ftp_client.send(file_data)
# client.close()
if __name__ == '__main__':
client = FtpClient('localhost', 8888)
client.client_push()