标签：stream __name__ add 通信 iss print str done sockets
刚开始学习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.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.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
标签：stream __name__ add 通信 iss print str done sockets
原文地址：https://www.cnblogs.com/ywxbbbbb/p/9980722.html
