Python3.5 学习八

#动态导入   官方建议
import importlib
import_str="lib.aa"
lib=importlib.import_module(import_str)
obj=lib.A("dfasfdasfasfsdfsadfasf")
print(obj)

# #动态导入 另一种形式
# import_str = "lib.aa"
# mod= __import__("lib.aa")
# a=mod.aa.A("adasfaf")
# print(a)

断言：
assert type(obj.name) is str

复习Socket：
server=socket.socket(AF>INET,sock.SOCK_STREAM)
server.bind(localhost,9999)
server.listen()

conn,addr = server.accept()

while True:
　　print("new conn",addr)
　　data = conn.recv(102400)
　　print(data.upper())

编写一个ssh实例：详见20180807

socket的粘包:即如果socket连续执行两次以上send()可能会合并成一次缓冲发送，接收到的数据会将两个包的内容黏在一起
解决办法：在每两次发送之间，做一次数据接收处理。

Ftp server：
1　　　　读取文件名
2检测文件是否存在
3　　　　打开文件
4　　　　检测文件大小
5　　　  发送文件大小
6　　　　等客户端确认
7　　　　边读边发
8　　　　md5发送及确认

实例实现源码：
socket_ftp_server:

# Author:huhu
import socket,os,time,hashlib
server=socket.socket()
server.bind(("localhost",6970))
server.listen()
while True:
    print("开始监听...")
    conn,addr = server.accept()
    print("建立新连接",addr)
    data =conn.recv(1024)
    print("ask file name is %s"%data.decode())
    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("md5",m.hexdigest())
        f.close()
    print("send done")
    server_confirm=conn.recv(1024)#等待客户端确认接收完成
    conn.send(m.hexdigest().encode())
server.close()


socket_ftp_client:

# Author:huhu
import socket,hashlib
client=socket.socket()
client.connect(("localhost",6970))
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:",size)

            data = client.recv(size)
            m.update(data)
            received_size +=len(data)
            f.write(data)
            print("receiving %s %%"%round(received_size/file_total_size*100,2))
        else:
            print("receiving 100 % done")
            print(file_total_size, received_size)
            f.close()
            new_file_md5=m.hexdigest()
            #接收完成后向服务器端确认数据收完
            client.send(b"all data been received")
        print(new_file_md5)
        server_file_md5=client.recv(1024).decode()

        print("server file md5:",server_file_md5)

        print("client rev file md5:",new_file_md5)

SocketServer：最主要的作用：用来支持多并发
定义：用于将网络服务器的编程更容易更简化
类型：TCPServer、UDPServer、UnixStreamServer、UnixDatagramServer

　　创建一个SocketServer的过程：

　　1　　自己创建一个请求处理类，并且这个类要继承BaseRequestHandler，并且还要重写handle()方法

　　2　　你必须实例化TCPServer，并且传递server ip 和你上面创建的请求处理类给这个TCPServer

　　3　　server.serve_forever()来处理多个请求，永远执行

　　　　  server.handle_request()只能处理一个请求

　　SocketServer:

　　

# Author:huhu
import socketserver
class MyTCPHandler(socketserver.BaseRequestHandler):
    '''
    自定义Socketserver类的请求类
    '''
    def handle(self):
        print("{} connected:".format(self.client_address))
        while True:
            try:
                self.data=self.request.recv(1024).strip()
                print("{}:{} wrote:".format(self.client_address[0],self.client_address[1]))
                print(self.data)
                self.request.send(self.data.upper())
            except ConnectionResetError as e:
                print("err:",e)
                break
if __name__=="__main__":
    HOST,PORT="localhost",9999
    # server=socketserver.TCPServer((HOST,PORT),MyTCPHandler)
    server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler)
    server.serve_forever()

本节作业：开发一个多用户使用的FTP系统
作业要求：
1　　　　用户加密认证
2允许同事多用户登录
3　　　　每个用户有自己的家目录，且只能访问自己的家目录
4　　　　对用户进行磁盘配额，每个用户的可用空间不同
5　　　　允许用户在ftp server上随意切换目录
6　　　　允许用户查看当前目录下文件
7　　　　允许上传和下载文件，保证文件一致性
8　　　　文件传输过程中显示进度条
9　　　　附加功能　：支持文件的断点续传

初步老师带着做了一部分（180808下），剩下的自己研究去一点点的实现吧~~~