Board logo

标题: 万物互联之~网络编程深入篇(3) [打印本页]

作者: look_w    时间: 2019-1-17 21:21     标题: 万物互联之~网络编程深入篇(3)

2.2.路由版动态服务器和上面基本一样,多了个路由表(self.router_urls)而已
import reimport socketclass HttpServer(object):    def __init__(self):        # 路由表        self.router_urls = {"/test": "/test.py", "/user": "/test2.py"}    def run(self):        with socket.socket() as server:            # 端口复用            server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)            server.bind(("", 8080))            server.listen()            while True:                self.client_socket, self.client_address = server.accept()                print(f"[{self.client_address}已上线]")                self.handler()    def response(self, status, body=None):        with self.client_socket as socket:            header = f"HTTP/1.1 {status}\r\n\r\n"            socket.send(header.encode("utf-8"))            if body:                socket.send(body)    def __static_handler(self, name):        try:            with open(f"./www{name}", "rb") as fs:                return fs.read()        except Exception as ex:            print(ex)            return None    def __dynamic_handler(self, name):        try:            m = __import__(name)            return m.application().encode("utf-8")        except Exception as ex:            print(ex)            return None    def handler(self):        data = self.client_socket.recv(2048)        if data:            header, _ = data.decode("utf-8").split("\r\n", 1)            # GET /xxx HTTP/1.1            ret = re.match("^\w+? (/[^ ]*) .+$", header)            if ret:                url = ret.group(1)                print(url)  # print url log                body = None                # 路由有记录:动态页面                if url in self.router_urls.keys():                    url = self.router_urls[url]                    # 切片提取模块名                    body = self.__dynamic_handler(url[1:-3])                else:  # 静态服务器                    if url == "/":                        url = "/index.html"                    body = self.__static_handler(url)                # 没有这个页面或者出错                if body:                    self.response("200 ok", body)                else:                    self.response("404 Not Found")            else:                # 404                self.response("404 Not Found")        else:            print(f"{self.client_address}已下线")            self.client_socket.close()if __name__ == "__main__":    import sys    # 临时添加模块所在路径    sys.path.insert(1, "./www/bin")    HttpServer().run()
输出:




欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/) Powered by Discuz! 7.0.0