博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Python 搭建简单服务器
阅读量:6772 次
发布时间:2019-06-26

本文共 5656 字,大约阅读时间需要 18 分钟。

hot3.png

Python动态服务器网页(需要使用WSGI接口),基本实现步骤如下:  

    1.等待客户端的链接,服务器会收到一个http协议的请求数据报  
    2.利用正则表达式对这个请求数据报进行解析(请求方式、提取出文件的环境)
    3.提取出文件的环境之后,利用截断取片的方法将文件名转化为模块名称
    4.使用m = __import__(),就可以得到返回值为m的模块
    5.创建一个env字典:其中包含的是请求方式及文件环境等各种的键值对
    6.创建一个新的动态脚本,其中定义了application这个函数,必须包含env和start_response的参数(也是服务器里的调用方法)
    7.在这个动态脚本中定义状态码status和响应头headers(注意是字典形式,如Content-Type)
    8.然后再调用start_response(status,headers),但是要注意,这个函数在服务器被定义
    9.在动态脚本中编写动态执行程序
    10.m.appliction的返回值就是回应数据包的body,它的数据头在start_response被整合
    11.将数据头与数据body拼接起来,然后发送给客户端,就可显示动态网页 

MyWebServer# coding:utf-8import socketimport reimport sysfrom multiprocessing import Processfrom MyWebFramework import Application# 设置静态文件根目录HTML_ROOT_DIR = "./html"WSGI_PYTHON_DIR = "./wsgipython"class HTTPServer(object):    """"""    def __init__(self, application):        """构造函数, application指的是框架的app"""        self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)        self.server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)        self.app = application    def start(self):        self.server_socket.listen(128)        while True:            client_socket, client_address = self.server_socket.accept()            #print("[%s,%s]用户连接上了" % (client_address[0],client_address[1]))            print("[%s, %s]用户连接上了" % client_address)            handle_client_process = Process(target=self.handle_client, args=(client_socket,))            handle_client_process.start()            client_socket.close()    def start_response(self, status, headers):        """         status = "200 OK"    headers = [        ("Content-Type", "text/plain")    ]    star         """        response_headers = "HTTP/1.1 " + status + "\r\n"        for header in headers:            response_headers += "%s: %s\r\n" % header        self.response_headers = response_headers    def handle_client(self, client_socket):        """处理客户端请求"""        # 获取客户端请求数据        request_data = client_socket.recv(1024)        print("request data:", request_data)        request_lines = request_data.splitlines()        for line in request_lines:            print(line)        # 解析请求报文        # 'GET / HTTP/1.1'        request_start_line = request_lines[0]        # 提取用户请求的文件名        print("*" * 10)        print(request_start_line.decode("utf-8"))        file_name = re.match(r"\w+ +(/[^ ]*) ", request_start_line.decode("utf-8")).group(1)        method = re.match(r"(\w+) +/[^ ]* ", request_start_line.decode("utf-8")).group(1)        env = {            "PATH_INFO": file_name,            "METHOD": method        }        response_body = self.app(env, self.start_response)        response = self.response_headers + "\r\n" + response_body        # 向客户端返回响应数据        client_socket.send(bytes(response, "utf-8"))        # 关闭客户端连接        client_socket.close()    def bind(self, port):        self.server_socket.bind(("", port))def main():    sys.path.insert(1, WSGI_PYTHON_DIR)    if len(sys.argv) < 2:        sys.exit("python MyWebServer.py Module:app")    # python MyWebServer.py  MyWebFrameWork:app    module_name, app_name = sys.argv[1].split(":")    # module_name = "MyWebFrameWork"    # app_name = "app"    m = __import__(module_name)    app = getattr(m, app_name)    http_server = HTTPServer(app)    # http_server.set_port    http_server.bind(8000)    http_server.start()if __name__ == "__main__":    main()
MyWebFrameWork# coding:utf-8import time# from MyWebServer import HTTPServer# 设置静态文件根目录HTML_ROOT_DIR = "./html"class Application(object):    """框架的核心部分,也就是框架的主题程序,框架是通用的"""    def __init__(self, urls):        # 设置路由信息        self.urls = urls    def __call__(self, env, start_response):        path = env.get("PATH_INFO", "/")        # /static/index.html        if path.startswith("/static"):            # 要访问静态文件            file_name = path[7:]            # 打开文件,读取内容            try:                file = open(HTML_ROOT_DIR + file_name, "rb")            except IOError:                # 代表未找到路由信息,404错误                status = "404 Not Found"                headers = []                start_response(status, headers)                return "not found"            else:                file_data = file.read()                file.close()                status = "200 OK"                headers = []                start_response(status, headers)                return file_data.decode("utf-8")        for url, handler in self.urls:            #("/ctime", show_ctime)            if path == url:                return handler(env, start_response)        # 代表未找到路由信息,404错误        status = "404 Not Found"        headers = []        start_response(status, headers)        return "not found"def show_ctime(env, start_response):    status = "200 OK"    headers = [        ("Content-Type", "text/plain")    ]    start_response(status, headers)    return time.ctime()def say_hello(env, start_response):    status = "200 OK"    headers = [        ("Content-Type", "text/plain")    ]    start_response(status, headers)    return "hello itcast"def say_haha(env, start_response):    status = "200 OK"    headers = [        ("Content-Type", "text/plain")    ]    start_response(status, headers)    return "hello haha"urls = [            ("/", show_ctime),            ("/ctime", show_ctime),            ("/sayhello", say_hello),            ("/sayhaha", say_haha),        ]app = Application(urls)# if __name__ == "__main__":#     urls = [#             ("/", show_ctime),#             ("/ctime", show_ctime),#             ("/sayhello", say_hello),#             ("/sayhaha", say_haha),#         ]#     app = Application(urls)#     http_server = HTTPServer(app)#     http_server.bind(8000)#     http_server.start()

转载于:https://my.oschina.net/zhenfei/blog/1930207

你可能感兴趣的文章
Maven 中的jar包冲突
查看>>
关于大型网站技术演进的思考(三)--存储的瓶颈(3)
查看>>
lvs基于fwm定义集群服务
查看>>
事务的4种隔离级别
查看>>
使用goaccess解析nginx日志
查看>>
mvc问题小记
查看>>
awk 系列Part3:如何使用 awk 按模式筛选文本或字符串
查看>>
用cxfreeze打包Python3.3成exe文件
查看>>
关于c语言内存地址对齐的一点思考
查看>>
备份中心和VRRP
查看>>
Unity3D游戏开发之《愤怒的小鸟》弹弓实现的技能培训
查看>>
使用 IntraWeb (13) - 基本控件之 TIWLabel、TIWLink、TIWURL、TIWURLWindow
查看>>
浅析新手学seo的困惑及其应对方法
查看>>
MySQL数据库基础教程(下)
查看>>
在Windows 10中启用客户端Hyper-V
查看>>
Delphi 的接口(4) - 接口的属性
查看>>
怎么样编写Protobuf的.proto文件
查看>>
Python代码打包放到PyPI上
查看>>
tree
查看>>
Linux学习笔记——基本命令
查看>>