Python练习-基于socket的FTPServer

# 编辑者：闫龙
import socket,json,struct
class MySocket:
    with open("FtpServiceConfig","r",encoding="utf8") as f:
        Config = json.loads(f.read())
        AFType= eval("socket."+Config["AFType"])
        KIND=eval("socket."+Config["KIND"])
        IPaddress= Config["IPaddress"]
        Port=Config["Port"]
        MaxLinks=Config["MaxLinks"]
    def __init__(self):
        self.SockObj = socket.socket(self.AFType,self.KIND)
        self.SockObj.bind((self.IPaddress,self.Port))
        self.SockObj.listen(self.MaxLinks)
    def Starting(self):
        self.Clients,self.IpInfo=self.SockObj.accept()
    def GetHeadLen(self):
        return struct.unpack("i",self.Clients.recv(4))[0]
    def GetHead(self,Len:int):
        return json.loads(self.Clients.recv(Len).decode("utf8"))
    def GetDatas(self,Len:int):
        return self.Clients.recv(Len)
    def SendDatas(self,SendWhat):
        self.Clients.send(SendWhat.encode("utf8"))
    def ClientBye(self):
        self.Clients.close()
    def ByeBye(self):
        self.SockObj.close()

# 编辑者：闫龙
import socket,json,struct
class MyClient:
    with open("FtpClientConfig","r",encoding="utf8") as f:
        Config = json.loads(f.read())
        AFType = eval("socket."+Config["AFType"])
        KIND = eval("socket."+Config["KIND"])
        IPaddress = Config["IPaddress"]
        Port = Config["Port"]
    def __init__(self):
        self.SockObj = socket.socket(self.AFType,self.KIND)
    def ConnetService(self):
        self.SockObj.connect((self.IPaddress, self.Port))
    def GetInfo(self,Len:int):
        return self.SockObj.recv(Len)
    def SendInfo(self,SendWhat):
        self.SockObj.send(SendWhat)
    def SendHeadLen(self,HeadLen):
        HeadLen = json.dumps(HeadLen).encode("utf8")
        self.SockObj.send(struct.pack("i",len(HeadLen)))
    def SendHead(self,Head):
        self.SockObj.send(json.dumps(Head).encode("utf8"))

# 编辑者：闫龙
import FtpServerClass as fsc
import time
FtpService = fsc.MySocket()
FtpService.Starting()
while True:
    try:
        HeadLen = FtpService.GetHeadLen()
        Head = FtpService.GetHead(HeadLen)
        f = open(Head["FileName"],"wb")
        RecvSize = 0
        RecvData = b""
        i = 1
        while RecvSize < Head["DataSize"]:
            getdata = FtpService.GetDatas(1024)
            RecvData += getdata
            RecvSize = len(RecvData)
            f.write(getdata)
            print("%s/%s"%(RecvSize,Head["DataSize"]))
            time.sleep(0.0005)
     except Exception as e:
         print(e)
         break

# 编辑者：闫龙
import FtpClientClass as fcc
import os
FtpClient = fcc.MyClient()
FtpClient.ConnetService()
while True:
    choice = input(">>>:")
    if not choice : continue
    FileSize = os.path.getsize(choice)
    ClientHead = {"DataSize":FileSize,"FileName":os.path.basename(choice)}
    FtpClient.SendHeadLen(ClientHead)
    FtpClient.SendHead(ClientHead)
    SendSize = 0
    with open(choice,"rb") as f:
        for i in f:
            FtpClient.SendInfo(i)
            SendSize += len(i)
            print(SendSize)
        print("上传完成")

{"AFType":"AF_INET","KIND":"SOCK_STREAM","IPaddress":"127.0.0.1","Port":9527,"MaxLinks":5}

{"AFType":"AF_INET","KIND":"SOCK_STREAM","IPaddress":"127.0.0.1","Port":9527}

熬到现在头脑已经不清醒了,基本实现上传功能,未完待续

BUG太多,明天再说!

睡觉!