码迷,mamicode.com
首页 > 编程语言 > 详细

python-实现动态web服务器

时间:2017-09-17 20:53:29      阅读:275      评论:0      收藏:0      [点我收藏+]

标签:name   web   read   roc   method   for   __init__   lines   根目录   


#
encoding=utf-8 import socket from multiprocessing import Process import re import sys # 设置静态文件根目录 HTML_ROOT_DIR = ./html WSGI_PYTHON_DIR = ./wsgipython class HTTPServer(object): def __init__(self, application): 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_socket, args=(client_socket,)) handle_client_process.start() client_socket.close() def start_response(self, status, headers): """ status="200 ok" headers = [ (‘Content-Type‘, ‘text/plain‘) ] :param status: :param headers: :return: """ response_headers = "HTTP1.1 " + status + "\r\n" for header in headers: response_headers += "%s: %s\r\n" % header self.response_headers = response_headers def handle_socket(self, client_socket): """处理客户端请求""" # 获取客户端请求数据 request_data = client_socket.recv(1024) print("request data: ", request_data) request_lines = request_data.splitlines() for request_line in request_lines: print(request_line) # 解析请求报文 # ‘GET / HTTP/1.1‘ request_start_line = request_lines[0] print(& * 20) print(type(request_start_line)) # 提取用户请求的文件名 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) print(file_name)
     # 将路由的分发交给框架去做 ====================================================
# # "/ctime.py" # # "/sayhello.py" # if file_name.endswith(‘.py‘): # a = file_name[1:-3] # try: # m = __import__(file_name[1:-3]) # except Exception: # self.response_headers = "HTTP/1/1 404 Not Found\r\n" # response_body = ‘not found‘ # else: # env = { # "PATH_INFO": file_name, # ‘METHOD‘: method # } # # response_body = m.application(env, self.start_response) # # response = self.response_headers + ‘\r\n‘ + response_body # # else: # if ‘/‘ == file_name: # file_name = ‘/index.html‘ # # # 打开文件,读取内容 # try: # file = open(HTML_ROOT_DIR + file_name, "rb") # except IOError: # response_start_line = ‘HTTP/1.1 404 Not Found\r\n‘ # response_headers = ‘Server: Myserver\r\n‘ # response_body = ‘The file is not found!‘ # else: # file_data = file.read() # file.close() # # #  构造响应数据 # response_start_line = ‘HTTP/1.1 200 OK\r\n‘ # response_headers = ‘Server: Myserver\r\n‘ # response_body = file_data.decode(‘utf-8‘) # print(‘??‘ * 20) # print(type(response_body)) # # response = response_start_line + response_headers + ‘\r\n‘ + response_body # print(‘response data:‘, response) 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_v1.py Module:app") # python MyWebServer_v1.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(9000) http_server.start() if __name__ == __main__: main()

 

 

框架的实现

MyWebFrameWork_v2.py

# coding:utf-8

import time

# 设置静态文件根目录
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 frawework"

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)

 

运行上述代码需要pycharm中配置

服务器程序--Edit Configurations....

技术分享

 

python-实现动态web服务器

标签:name   web   read   roc   method   for   __init__   lines   根目录   

原文地址:http://www.cnblogs.com/wgDream/p/7536904.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!