Python之路-python(面向对象进阶（模块的动态导入、断言、Socket Server）)

1 class C(object):
2     def __init__(self):
3         self.name = "zhangsan"

1 #动态导入
2 import  importlib
3 test = importlib.import_module("lib.test")
4 print(test.C().name)

try:
    assert True == 0
except AssertionError as e:
    print("断言不成立")
else:
    print("断言成立")
>>>断言不成立

1 try:
2     assert True == 1
3 except AssertionError as e:
4     print("断言不成立")
5 else:
6     print("断言成立")
7 >>>断言成立

服务器端

import  socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            try:
                self.data = self.request.recv(1024).strip()
                print("{} wrote:".format(self.client_address[0]))
                print(self.data)
                self.request.send(self.data.upper())
            except ConnectionResetError as e:
                print("error",e)
                break
if __name__ == ‘__main__‘:
    HOST,PORT = "localhost",9999
    server = socketserver.ThreadingTCPServer((HOST,PORT),MyTCPHandler)
    server.serve_forever()

#客户端
import socket
client = socket.socket() #声明socket类型，同时生成socket连接对象
#client.connect((‘192.168.16.200‘,9999))
client.connect((‘localhost‘,9999))
while True:
    msg = input(">>:").strip()
    if len(msg) == 0:continue
    client.send(msg.encode("utf-8"))
    data = client.recv(10240)
    print("recv:",data.decode())
client.close()

#ftp服务端
import os,hashlib
import  socket
server = socket.socket()
server.bind((‘localhost‘,9999))
server.listen()
while True:
    conn,addr = server.accept()
    print("new conn:",addr)
    while True:
        print("等待新指令")
        data = conn.recv(1024)
        if not data:
            print("客户端已经断开")
            break
        cmd,filename = data.decode().split()
        print(filename)
        if os.path.isfile(filename):
           f = open(filename,"rb")
           m = hashlib.md5()
           file_size = os.stat(filename).st_size
           conn.send(str(file_size).encode())
           conn.recv(1024)
           for line in f:
               m.update(line)
               conn.send(line)
           print("file md5",m.hexdigest())
           f.close()
           conn.send(m.hexdigest().encode())
           print("send done")
server.close()

#ftp客户端
import  socket,hashlib
client = socket.socket()
client.connect(("localhost",9999))
while True:
    cmd = input(">>：").strip()
    if len(cmd) == 0:continue
    if cmd.startswith("get"):
        client.send(cmd.encode())
        server_response = client.recv(1024)
        print("server response:",server_response)
        client.send(b"ready to recv file")
        file_total_size = int(server_response.decode())
        received_size = 0
        filename = cmd.split()[1]
        f = open(filename+".new","wb")
        m = hashlib.md5()
        while received_size < file_total_size:
            if file_total_size - received_size > 1024:#要收不止一次
                size = 1024
            else:##最后一次了，剩多少收多少
                size = file_total_size - received_size
                print("last receive:",size)
            data  = client.recv(size)
            received_size += len(data)
            m.update(data)
            f.write(data)
        else:
            new_file_md5 = m.hexdigest()
            print("file recv done",received_size,file_total_size)
            f.close()
        server_file_md5 = client.recv(1024)
        print("server file md5",server_file_md5)
        print("client file md5",new_file_md5)
client.close()