mini_frame(web框架)

文件目录：

 dynamic中：框架

static:css,jss静态文件

teplates：模板

web_server.conf: 配置文件

web_server.py： 主程序

run.sh:运行脚本

web_server.py:

import socket
import multiprocessing
import re
import dynamic.mini_frame
import sys

class WSGIServer(object):
    def __init__(self,port,app,static_path):
        # 1.创建socket对象
        self.tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # 2.设置重复使用地址
        self.tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        # 3.绑定端口
        self.tcp_server_socket.bind(("", port))
        # 4.设置监听状态
        self.tcp_server_socket.listen(128)
        # web服务器模板中的application方法
        self.application = app
        # config文件
        self.static_path = static_path


    
    def clinet_server(self,new_client_socket):
        # 1.接受消息
        request = new_client_socket.recv(1024).decode("utf-8")
        lines = request.splitlines()
        # print("")
        # print(">" * 20)
        # print(lines)
        # 2.匹配请求网页
        request_name = re.match(r"[^/]+(/[^ ]*)",lines[0])
        if request_name:
            file_name = request_name.group(1)
            if file_name == "/":
                file_name = "/index.html"

        # 返回数据给浏览器
        if not file_name.endswith(".py"):
            # 3.打开文件
            try:
                f = open(self.static_path + file_name,"rb")
            except Exception as ret:
                pass
            else:
                html_content = f.read()
                f.close()
                # 4.创建header和body
                response_body = html_content
                response_header = "HTTP/1.1 200 ok
"
                response_header += "Content-Length:%d
" % len(response_body)
                response_header += "
"
                response = response_header.encode("utf-8") + response_body
                # 5.发送
                new_client_socket.send(response)


        else:
            # 如果是.py结尾,则认为是动态页面请求/
            env = dict();
            env['PATH_INFO'] = file_name
            print(env['PATH_INFO'])
            # application(字典， 方法名) 固定用法
            body = self.application(env, self.start_respones_header)
            # 拼装header头
            header = "HTTP/1.1 %s
" % self.status
            for temp in self.headers:
                header += "%s:%s
" % (temp[0], temp[1])
            header += "
"
            # 拼装返回数据
            response = header + body
            # 发送数据
            new_client_socket.send(response.encode("utf-8"))

        # 6.关闭socket
        new_client_socket.close()

    def start_respones_header(self, status, headers):
        """接受并保存application传过来的值"""
        self.status = status
        self.headers = [("server","mini_web v1.0")]
        self.headers += headers
    
    
    def run_forever(self):
        """运行"""
        while True:
            # 5.接收客户地址，创建新socket
            new_socket,client_addr = self.tcp_server_socket.accept()
            # 6.为新客户端服务
            p = multiprocessing.Process(target=self.clinet_server,args=(new_socket,))
            p.start()
            # 7.关闭新客户端
            new_socket.close()
        # 7.关闭socket
        self.tcp_server_socket.close()

def main():
    # 给程序传参数， 导入sys库
    ret = sys.argv
    if len(ret) == 3:
        # 接收端口信息
        port = int(ret[1])
        # 接收web服务器信息
        frame_app_name = ret[2]
    else:
        print("请重新输入参数")
    # web服务器包和名
    frame_app = re.match(r"([^:]+):([^:]+)",frame_app_name)
    frame_name = frame_app.group(1)
    app_name = frame_app.group(2)

    # 导入包的路径
    sys.path.append("./dynamic")
    # 导入模板
    frame = __import__(frame_name)
    # 此时app指向了 dynamic/mini_frame模板中的application这个函数
    app = getattr(frame,app_name)

    with open("web_server.conf","r") as f:
        # eval() 把{"xx":"xx"} 这种字符串转化为字典
        config_path = eval(f.read())

    wsgi_server = WSGIServer(port,app,config_path['static_path'])
    wsgi_server.run_forever()


if __name__ == '__main__':
    main()

mini_frame.py:

def center():
    with open("./templates/center.html","r") as f:
        return f.read()

def index():
    with open("./templates/index.html", "r") as f:
        return f.read()

def application(env, start_respones):
    start_respones('200 ok',[("Content-Type","text/html;charset=utf-8")])
    file_name = env['PATH_INFO']
    # print(file_name)
    if file_name == "/index.py":
        return index()
    elif file_name == "/center.py":
        return center()
    else:
        return "python 中国"

web_server.conf:

{
    "static_path":"./static",
    "dynamic_path":"./dynamic"
}

　　

run.sh:

python3 web_server.py 7788 mini_frame:application