首页 > 编程语言 > 详细

Python:socket实现ftp程序

时间:2018-11-19 00:18:00      阅读:65      评论:0      收藏:0      [点我收藏+]

标签:handler   抛出异常   失败   all   accept   ESS   net   isp   spa   

刚开始学习socket编程,还不是特熟练,码了好长时间,中间遇到许多问题,记录一下用socketserver写ftp

server端:

 1 #!/usr/bin/env python
 2 
 3 import socketserver,os
 4 
 5 class FTP(socketserver.BaseRequestHandler):
 6     def handle(self):
 7         def clientsend(filename):
 8             f = open(/ftp/%s %filename,w)
 9         #    while 1:    
10             data = self.request.recv(4096).decode("utf-8")
11         #    if not data:break
12             f.write(data)
13             f.close()
14             print(File %s  receive done! % filename)
15         def clientdownload(filename):
16             f = open(/ftp/%s %filename,r)
17             data = f.read()
18             f.close()
19             self.request.sendall(data.encode("utf-8"))
20         print(listening connect from:,self.client_address)
21         listmsg = list:\n1.help\t\t\tdispaly the list\n2.send file\t\tsend + filename\n3.download file\t\tdownload + filename\n4.ls\t\t\tShow files and permissions\n5.exit\n
22         self.request.sendall("Welcome my ftp,input \033[34;1m‘help‘\033[0m dispaly meun".encode("utf-8"))
23         while 1:
24             try:
25                 re_msg = self.request.recv(1024).decode("utf-8")
26                 if not re_msg:break
27                 if re_msg == help or re_msg == ?:
28                     self.request.sendall(listmsg.encode("utf-8"))
29                 elif re_msg.split()[0] == send:
30                     filename = re_msg.split()[1]
31                     clientsend(filename)
32                 elif re_msg.split()[0] == ls:
33                     ls_list = os.popen(ls -l /ftp).read().encode("utf-8")
34                     self.request.sendall(ls_list)
35                 elif re_msg.split()[0] == download:
36                     filename = re_msg.split()[1]
37                     clientdownload(filename)
38                 else:
39                     self.request.sendall(Invalid value.encode("utf-8"))
40             finally:
41                 pass
42 if __name__ == __main__: #只有程序执行时才会触发下面的语句,程序被导入调用时,下面的语句不会触发
43     host = 192.168.101.128
44     port = 2222
45     server = socketserver.ThreadingTCPServer((host,port),FTP)
46     server.serve_forever()

client端:

 1 #!/usr/bin/env python
 2 import socket,sys
 3 
 4 host = 192.168.101.128
 5 port = 2222
 6 
 7 s = socket.socket()
 8 s.connect((host,port))
 9 info = s.recv(8096).decode("utf-8")
10 print(info)
11 while 1:
12     INPUT = str(input(input:))
13     if INPUT.split()[0] == send:
14         s.send(INPUT.encode("utf-8"))
15         filename = INPUT.split()[1]
16         f = open(filename,r)
17         file_data = f.read()
18         f.close()
19         s.sendall(file_data.encode("utf-8"))
20         print(file sent finished!)
21     elif INPUT.split()[0] == download:
22         s.send(INPUT.encode("utf-8"))
23         filename = INPUT.split()[1]
24         f = open(filename,w)
25         data = s.recv(8096).decode("utf-8")
26         f.write(data)
27         f.close()
28         print(%s has been download! %filename)
29     elif INPUT.split()[0] == exit:
30         sys.exit()
31     else:
32         s.send(INPUT.encode("utf-8"))
33         data = s.recv(8096).decode("utf-8")
34         print(data)
35 s.close()

socket 仅支持单线程,socketserver 支持多线程

socketserver:

定义请求处理类时,需要继承socketserver.BaseRequestHandler,并且需要创建新的handle()函数来处理请求

python中的socketserver模块已经为我们初始化好了,直接调用即可

self.request.recv(bufsize).decode("utf-8")  读取请求数据

self.request.sendall().encode("utf-8")    发送数据

self.client_address            客户端请求的地址

server = socketserver.ThreadingTCPServer((Host,Port),FTP)  多线程!!!

server = socketserver.TCPServer((Host,Port),FTP)        单线程

server.serve_forever()           持续监听,服务端一直运行,知道收到shutdown信号

socket:

socket.AF_UNIX      只能用于单一的Unix系统进程通信

socket.AF_INET      服务器之间网络通信

socket.AF_INET6       IPv6

 

socket.SOCK_STREAM    流式socket,for TCP

socket.SOCK_DGRAM   数据报式socket,for UDP

 

s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

s.bind((Host,Port))

s.listen()

s.connect((Host,Port))

conn,address = s.accept()  conn是新的套接字对象,可以用来接受和发送数据,address是客户端的地址

s.close()

s.recv(bufsize)       接受套接字的数据,数据以字符串的形式返回,bufsize是接收的最大数据量

s.sendall(string)       尝试发送所有数据,成功返回None,失败则抛出异常

s.getpeername()      返回连接套接字的远程地址,返回值通常为元组

s.gettimeout()        返回当前超时值,单位为秒,如果没有设置超时,则为None

Python:socket实现ftp程序

标签:handler   抛出异常   失败   all   accept   ESS   net   isp   spa   

原文:https://www.cnblogs.com/ywxbbbbb/p/9980722.html

(0)
(0)
   
举报
评论 一句话评论(0
0条  
登录后才能评论!
© 2014 bubuko.com 版权所有 鲁ICP备09046678号-4
打开技术之扣,分享程序人生!
             

鲁公网安备 37021202000002号