python實(shí)現(xiàn)類似ftp傳輸文件的網(wǎng)絡(luò)程序示例
此代碼在linux上編寫,適用于linux,windows下需要更改幾個(gè)命令。
1、客戶端輸入IP,端口,可服務(wù)器端進(jìn)行連接,被要求輸入用戶名和密碼進(jìn)行驗(yàn)證。
2、使用獨(dú)立的模塊來驗(yàn)證登錄用戶(技術(shù)有限,不支持客戶端創(chuàng)建用戶),用戶名:ftpuser 密碼:userlogin
2、客戶端登錄驗(yàn)證成功后,可使用?或者h(yuǎn)elp查看可使用的命令。
ftpserver.py
#!/usr/bin/env python
#-*- coding:utf-8
"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_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()
loginauth.py
#!/usr/bin/env python
#-*- coding:utf-8
#Filename:userlogin.py
"Program for userlogin"
import sys,time
import cPickle as pickle
#If it's your first running this program,use USERDB = {}
#If it is not your first running this program,use USERDB = pickle.load(open('userdb','rb'))
USERDB = pickle.load(open('userdb','rb'))
#USERDB = {}
class userdb(object):
def __init__(self,username,password,time):
self.username = username
self.passwd = password
self.time = time
def save_user(self):
USERDB[self.username] = [self.passwd,self.time]
pickle.dump(USERDB,open('userdb','wb'),True)
def update_db(self):
pass
def user_create(NAME,PASSWD = ''):
if NAME in USERDB:
if PASSWD == USERDB[NAME][0]:
p = userdb(NAME,PASSWD,time.time())
p.save_user()
return 0
else:
return 1
else:
#p = userdb(NAME,PASSWD,time.time())
#p.save_user()
return 1
if __name__ == '__main__':
user_create(name,password)
ftpclient.py
#!/usr/bin/env python
#-*- coding:utf-8
"Program for ftp client."
from socket import *
from time import sleep
import os
def auth():
while 1:
try:
recv_msg = s.recv(BUFSIZ)
if recv_msg == 'auth':
USER = str(raw_input('Please input your username: ')).strip()
s.sendall(USER)
if s.recv(BUFSIZ) == 'pauth':
PASS = str(raw_input('Please input your password: ')).strip()
s.sendall(PASS)
recv_msg1 = s.recv(BUFSIZ)
if recv_msg1 == 'ok2login':
print '\033[33;1mlogin success!!!\033[0m'
break
elif recv_msg1 == 'fail2login':
print '\033[33;1mlogin failure!!!\033[0m'
continue
else:
continue
except:
return 'error'
def switch():
while True:
INPUT = str(raw_input('ftp> ')).strip()
if len(INPUT) == 0:continue
elif INPUT == 'quit' or INPUT == 'exit':
s.close()
break
elif INPUT == '?' or INPUT == 'help':
s.send(INPUT)
recv_data = s.recv(BUFSIZ)
print recv_data
continue
elif INPUT == 'get' or INPUT == 'send':
print '\033[31;1mYou must specified filename!!\033[0m'
continue
elif INPUT == 'ls':
cmd = os.popen('ls -l ./').read()
print cmd
continue
elif INPUT == 'rls':
s.send(INPUT)
recv_data = s.recv(BUFSIZ)
print recv_data
continue
elif INPUT.split()[0] == 'send':
filename = INPUT.split()[1]
if os.path.isfile(filename):
print 'Sending %s......'% filename
s.sendall(INPUT)
re_data = s.recv(BUFSIZ)
if re_data == 'ok2send':
file_data = open(filename,'rb')
file_tmp = file_data.read()
file_data.close()
s.sendall(file_tmp)
sleep(0.5)
recv_data = s.recv(BUFSIZ)
print recv_data
continue
else:continue
else:
print '\033[31;1m%s not found!\033[0m'% filename
elif INPUT.split()[0] == 'get':
filename = INPUT.split()[1]
s.sendall(INPUT)
msg1 = s.recv(BUFSIZ)
if msg1 == 'ok2get':
s.sendall('ok2send')
msg2 = s.recv(BUFSIZ)
if msg2 == 'sending':
file_data = s.recv(BUFSIZ)
file2w = open(filename,'wb')
file2w.write(file_data)
file2w.flush()
file2w.close()
msg3 = s.recv(BUFSIZ)
print msg3
continue
elif msg1 == 'fail2get':
s.send('ack')
msg4 = s.recv(BUFSIZ)
print msg4
continue
else:
continue
if __name__ == '__main__':
#Default 127.0.0.1
HOST = str(raw_input('Server IP: ')).strip()
#Defautl 9889
PORT = int(raw_input('Server PORT: '))
ADDR = (HOST,PORT)
BUFSIZ = 8192
s = socket(AF_INET,SOCK_STREAM)
try:
s.connect(ADDR)
except :
pass
if auth() == 'error':
print 'Connection refused.'
else:
switch()
相關(guān)文章
python 移動(dòng)圖片到另外一個(gè)文件夾的實(shí)例
今天小編就為大家分享一篇python 移動(dòng)圖片到另外一個(gè)文件夾的實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2019-01-01python des,aes,rsa加解密的實(shí)現(xiàn)
這篇文章主要介紹了python des,aes,rsa加解密的實(shí)現(xiàn),幫助大家更好的理解和使用python,感興趣的朋友可以了解下2021-01-01Python自動(dòng)化測試之異常處理機(jī)制實(shí)例詳解
為了保持自動(dòng)化測試用例的健壯性,異常的捕獲及處理,日志的記錄對(duì)掌握自動(dòng)化測試執(zhí)行情況尤為重要,下面這篇文章主要給大家介紹了關(guān)于Python自動(dòng)化測試之異常處理機(jī)制的相關(guān)資料,需要的朋友可以參考下2022-06-06keras load model時(shí)出現(xiàn)Missing Layer錯(cuò)誤的解決方式
這篇文章主要介紹了keras load model時(shí)出現(xiàn)Missing Layer錯(cuò)誤的解決方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-06-06python向json中追加數(shù)據(jù)的兩種方法總結(jié)
JSON用來存儲(chǔ)和交換文本信息,比xml更小/更快/更易解析,下面這篇文章主要給大家介紹了關(guān)于python向json中追加數(shù)據(jù)的兩種方法,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-05-05python list數(shù)據(jù)等間隔抽取并新建list存儲(chǔ)的例子
今天小編就為大家分享一篇python list數(shù)據(jù)等間隔抽取并新建list存儲(chǔ)的例子,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2019-11-11Python?ArcPy實(shí)現(xiàn)批量拼接長時(shí)間序列柵格圖像
這篇文章主要介紹了如何基于Python中ArcPy模塊,對(duì)大量不同時(shí)相的柵格遙感影像按照其成像時(shí)間依次執(zhí)行批量拼接的方法,感興趣的可以了解一下2023-03-03python實(shí)現(xiàn)人臉識(shí)別經(jīng)典算法(一) 特征臉法
這篇文章主要為大家詳細(xì)介紹了python實(shí)現(xiàn)人臉識(shí)別經(jīng)典算法,特征臉法,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-03-03