python-实现动态web服务器

# 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 + "
"
        for header in headers:
            response_headers += "%s: %s
" % 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
"
        #         response_body = 'not found'
        #     else:
        #         env = {
        #             "PATH_INFO": file_name,
        #             'METHOD': method
        #         }
        #
        #         response_body = m.application(env, self.start_response)
        #
        #     response = self.response_headers + '
' + 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
'
        #         response_headers = 'Server: Myserver
'
        #         response_body = 'The file is not found!'
        #     else:
        #         file_data = file.read()
        #         file.close()
        #
        #         # 　构造响应数据
        #         response_start_line = 'HTTP/1.1 200 OK
'
        #         response_headers = 'Server: Myserver
'
        #         response_body = file_data.decode('utf-8')
        #         print('??' * 20)
        #         print(type(response_body))
        #
        #     response = response_start_line + response_headers + '
' + 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 + '
' + 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....