02:SocketServer服务

import socketserver
class MyTcpServer(socketserver.BaseRequestHandler):def handle(self):while True:self.request.recv(1024)self.request.send(&＃39;I am server&＃39;.encode(&＃39;utf-8&＃39;))
server &＃61; socketserver.ThreadingTCPServer((&＃39;127.0.0.1&＃39;,8888),MyTcpServer)
server.serve_forever()

import socketserver
#每个客户端过来都会实例化一个MyTCPHandler实例&＃xff0c;并调用handle方法来处理与客户端的通信
class MyTCPHandler(socketserver.BaseRequestHandler):
#1 第一步&＃xff1a;创建一个request handler class&＃xff08;请求处理类&＃xff09;&＃xff0c;继承自BaseRequestHandler classdef handle(self): #2 第二步&＃xff1a;并重写它的handle()方法&＃xff0c;该方法将处理客户端的请求while True:try:self.data &＃61; self.request.recv(1024).strip() #conn.recv(1024) &＃61; self.request.recv()print("{} wrote:".format(self.client_address[0]))print(self.data)self.request.send(self.data.upper()) #conn.send()&＃61;self.request.sendall()except ConnectionResetError as e:print("error",e)break
if __name__ &＃61;&＃61; "__main__":HOST, PORT &＃61; "localhost", 9999server &＃61; socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) #socketserver.TCPServer(单)server.serve_forever() #4 第四步&＃xff1a;调用server class对象的serve_forever()方法来开始处理请求
#3 第三步&＃xff1a;实例化一个server class对象&＃xff0c;并将服务的地址和之前创建的request handler class传递给它
#注&＃xff1a; 实例化一个server class对象工作原理
#a. (HOST, PORT)&＃xff1a;将监听地址当做一个参数传递给socketserver.TCPServer&＃xff08;&＃xff09;
#b. 每连接一个客户端就用MyTCPHandler实例化一个对象&＃xff0c;将实例对象传送给socketserver.TCPServer
#c. 然后服务器端使用MyTCPHandler类中的handle方法与客户端通信

import socket
client &＃61; socket.socket() #声明socket类型&＃xff0c;同时生成socket连接对象
client.connect((&＃39;localhost&＃39;,9999)) #指定要连接的服务器地址和端口号
while True:msg &＃61; input(">>:").strip() #输入要发送给服务器的消息if len(msg) &＃61;&＃61; 0:continue #如果客户端输入空格&＃xff0c;让客户端继续输入client.send(msg.encode("utf-8")) #将输入的消息发送到服务器端data &＃61; client.recv(1024) #接收服务器端发送过来的数据&＃xff0c;每次1024字节print(&＃39;client_recv:&＃39;,data) #将从服务器端接收的数据在客户端打印出来
client.close()

import socketserver,os,json #服务器端代码
class MyTCPHandler(socketserver.BaseRequestHandler):def put(self,*args):&＃39;&＃39;&＃39;接收客户端文件&＃39;&＃39;&＃39;cmd_dic &＃61; args[0]filename &＃61; cmd_dic["filename"]filesize &＃61; cmd_dic["size"]if os.path.isfile(filename):f &＃61; open(filename &＃43; &＃39;.new&＃39;,&＃39;wb&＃39;)else:f &＃61; open(filename,&＃39;wb&＃39;)print("file not exist",filename)self.request.send(b"200 ok")receive_size &＃61; 0while receive_size < filesize:data &＃61; self.request.recv(1024)f.write(data)receive_size &＃43;&＃61; len(data)else:print("file [%s] hsa uploaded ..."%filename)def handle(self):while True:try:self.data &＃61; self.request.recv(1024).strip()print("{} wrote:".format(self.client_address[0]))print(self.data)cmd_dic &＃61; json.loads(self.data.decode())action &＃61; cmd_dic["action"]if hasattr(self,action):func &＃61; getattr(self,action)func(cmd_dic)except ConnectionResetError as e:print("error",e)break
if __name__ &＃61;&＃61; "__main__":HOST, PORT &＃61; "0.0.0.0", 9999server &＃61; socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler)server.serve_forever()

import socket,os,json
class FtpClient(object):def __init__(self):self.client &＃61; socket.socket()def help(self):msg &＃61; &＃39;&＃39;&＃39;ls; pwd; cd .. ;get filename ; put filename&＃39;&＃39;&＃39;print(msg)def connect(self,ip,port):self.client.connect((ip,port))def interactive(self):#self.authenticate()while True:cmd &＃61; input(">>:").strip()if len(cmd) &＃61;&＃61; 0:continuecmd_str &＃61; cmd.split()[0]if hasattr(self,&＃39;cmd_%s&＃39;%cmd_str):func &＃61; getattr(self,&＃39;cmd_%s&＃39;%cmd_str)func(cmd)else:self.help()def cmd_put(self,*args):cmd_split &＃61; args[0].split()if len(cmd_split) > 1:filename &＃61; cmd_split[1]if os.path.isfile(filename):filesize &＃61; os.stat(filename).st_sizemsg_dic &＃61; {"action": "put","filename":filename,&＃39;size&＃39;:filesize,&＃39;overridden&＃39;:True}self.client.send( json.dumps(msg_dic).encode(&＃39;utf-8&＃39;) )server_response &＃61; self.client.recv(1024) #防止连包&＃xff0c; 等服务器确认f &＃61; open(filename,&＃39;rb&＃39;)for line in f:self.client.send(line)else:print("file upload success.....")f.close()else:print(filename,"is not exist")def cmd_get(self):pass
ftp &＃61; FtpClient()
ftp.connect("1.1.1.3",9999)
ftp.interactive()

1、将server端代码复制到Linux下&＃xff0c;路径&＃xff1a;/bbb/server.py
2. 将client端代码直接放到PyCharm中运行
3. 在PyCharm中执行put tt.py将本目录下的tt.py文件上传到linux的/bbb文件夹中>>:put tt.pyfile upload success.....
4. 执行命令完成后就可以看到有这个文件&＃xff1a;/bbb/tt.py

import sys,time
def view_bar(num, total):rate &＃61; num / totalrate_num &＃61; int(rate * 100)r &＃61; &＃39;\r[%s%s]%d%%&＃39; % ("&＃61;"*num, " "*(100-num), rate_num, )sys.stdout.write(r)sys.stdout.flush()for i in range(0, 101):time.sleep(0.1)view_bar(i, 100)# 1&＃xff09;这里使用的是sys.stdout.write(r)&＃xff0c;输出结果是进度条增加&＃xff0c;但是不会换行
# 2&＃xff09;2.x中的print无法指定end符号为其他值&＃xff0c;默认会输出一个"\n"&＃xff0c;也就是用一次必定换到下一行
# 3&＃xff09;到了3.x中print成为了一个真正意义上的函数&＃xff0c;后来就可以任意指定end符号的值&＃xff0c;你可以输出一次后末尾添加上任意你想要的值&＃xff0c;而不是强制换行。
# 4&＃xff09;stdout没有end这个符号这一说&＃xff0c;输出不会换行&＃xff0c;因此如果你想同一样输出多次&＃xff0c;在需要输出的字符串对象里面加上"\r",就可以回到行首了。