zoukankan      html  css  js  c++  java
  • 第二十三节 让web服务器支持WSGI协议

    import socket
    import multiprocessing
    import re
    import dynamic.mini_frame
    
    class WSGIServer():
    
        def __init__(self):
            self.web_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.web_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
            self.web_socket.bind(('192.168.0.106',7890))
            self.web_socket.listen(128)    
    
        def tcp_serve(self, resp_socket):
            recv_data = resp_socket.recv(1024).decode('utf-8')
            request_lines = recv_data.splitlines()
            file_name = ''
            ret = re.match(r"[^/]+(/[^ ]*)",request_lines[0])
            if ret:
                file_name=ret.group(1)
                print(file_name)
                if file_name == "/":
                    file_name = 'index.html'
    
            path = r'E:\360Downloads\Software\新建文件夹\新建文件夹\tmag_23_Infinity'+file_name
            if not file_name.endswith(".py"):
                # 判断是都是.py结尾,不是返回动态页面,是返回静态页面
                try:
                    f=open(path,'rb')
                except:
                    resp_data = 'HTTP/1.1 200 OK
    ' + "
    " + '.....file not find....'
                    resp_socket.send(resp_data.encode('utf-8'))
                else:
                    html_content = f.read()
                    f.close()
                    resp_data = 'HTTP/1.1 200 OK
    ' + "
    "
                    resp_socket.send(resp_data.encode('utf-8'))
                    resp_socket.send(html_content)
            else:
                # 动态页面处理
                env= dict()
                env['PATH INFO'] = file_name
                # 调用mini_frame框架里的application函数,返回header和body,在将两者在web服务器里组装,返回给浏览器
                body =dynamic.mini_frame.application(env, self.set_response_headers)
                header = 'HTTP/1.1 %s
    ' % self.status
                for temp in self.headers:
                    header += "%s:%s
    " % (temp[0], temp[1])
                header += "
    "
                resp_data = header +body
                resp_socket.send(resp_data.encode('utf-8'))
    
            resp_socket.close()
    
        def set_response_headers(self,status,headers):
            '''该方法用于接收mini_frame框架里返回的header数据'''
            self.status = status
            self.headers = [('Server','mini_web v8.8')]
            self.headers += headers
    
        def run_forver(self):
            while True:    
                resp_socket, resp_addr = self.web_socket.accept()
                p = multiprocessing.Process(target=self.tcp_serve, args=(resp_socket,))
                p.start()
                # 同乌班图一样也需要关闭套接字,跟文件描述符有关,不然页面一直刷新不出来
                resp_socket.close()
            # self.web_socket.close()
    
    def main():
        wsgi_server = WSGIServer()
        wsgi_server.run_forver()
    
    
    if __name__ == '__main__':
        main()
  • 相关阅读:
    redis 秒杀设计,常用命令
    wamp下配置多域名和访问路径的方法
    git commit 因执行yarn , npm,报错推送不了
    taro bug--小程序报错Error: 未找到入口 sitemap.json 文件,或者文件读取失败,请检查后重新编译。
    vscode引用相对路径,scss时路径报错问题解决
    space-between与space-around的区别
    Android可设置任意高度的TextView,如:设置0.5px设置0.1px等等
    Android可以打开微信支付,但是没法调起小程序支付
    dask
    Joblib-lightweight piplining tool
  • 原文地址:https://www.cnblogs.com/kogmaw/p/12602536.html
Copyright © 2011-2022 走看看