Python实现搭建-简单服务器教程

董征华

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

1. import socket
2. import re
3. import sys
5. from multiprocessing import Process
6. from MyWebFramework import Application
8. # 设置静态文件根目录
9. HTML_ROOT_DIR = "./html"
10. WSGI_PYTHON_DIR = "./wsgipython"
12. class HTTPServer(object):
13.     """"""
14.     def __init__(self, application):
15.         """构造函数， application指的是框架的app"""
16.         self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
17.         self.server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
18.         self.app = application
20.     def start(self):
21.         self.server_socket.listen(128)
22.         while True:
23.             client_socket, client_address = self.server_socket.accept()
24.             #print("[%s,%s]用户连接上了" % (client_address[0],client_address[1]))
25.             print("[%s, %s]用户连接上了" % client_address)
26.             handle_client_process = Process(target=self.handle_client, args=(client_socket,))
27.             handle_client_process.start()
28.             client_socket.close()
30.     def start_response(self, status, headers):
31.         """
32.          status = "200 OK"
33.     headers = [
34.         ("Content-Type", "text/plain")
35.     ]
36.     star
37.         """
38.         response_headers = "HTTP/1.1 " + status + "\r\n"
39.         for header in headers:
40.             response_headers += "%s: %s\r\n" % header
42.         self.response_headers = response_headers
44.     def handle_client(self, client_socket):
45.         """处理客户端请求"""
46.         # 获取客户端请求数据
47.         request_data = client_socket.recv(1024)
48.         print("request data:", request_data)
49.         request_lines = request_data.splitlines()
50.         for line in request_lines:
51.             print(line)
53.         # 解析请求报文
54.         # 'GET / HTTP/1.1'
55.         request_start_line = request_lines[0]
56.         # 提取用户请求的文件名
57.         print("*" * 10)
58.         print(request_start_line.decode("utf-8"))
59.         file_name = re.match(r"\w+ +(/[^ ]*) ", request_start_line.decode("utf-8")).group(1)
60.         method = re.match(r"(\w+) +/[^ ]* ", request_start_line.decode("utf-8")).group(1)
62.         env = {
63.             "PATH_INFO": file_name,
64.             "METHOD": method
65.         }
66.         response_body = self.app(env, self.start_response)
67.         response = self.response_headers + "\r\n" + response_body
69.         # 向客户端返回响应数据
70.         client_socket.send(bytes(response, "utf-8"))
71.         # 关闭客户端连接
72.         client_socket.close()
74.     def bind(self, port):
75.         self.server_socket.bind(("", port))
77. def main():
78.     sys.path.insert(1, WSGI_PYTHON_DIR)
79.     if len(sys.argv) < 2:
80.         sys.exit("python MyWebServer.py Module:app")
81.     # python MyWebServer.py  MyWebFrameWork:app
82.     module_name, app_name = sys.argv[1].split(":")
83.     # module_name = "MyWebFrameWork"
84.     # app_name = "app"
85.     m = __import__(module_name)
86.     app = getattr(m, app_name)
87.     http_server = HTTPServer(app)
88.     # http_server.set_port
89.     http_server.bind(8000)
90.     http_server.start()
92. if __name__ == "__main__":
93.     main()

复制代码

MyWebFrameWork

1. import time
2. # from MyWebServer import HTTPServer
4. # 设置静态文件根目录
5. HTML_ROOT_DIR = "./html"
7. class Application(object):
8.     """框架的核心部分，也就是框架的主题程序，框架是通用的"""
9.     def __init__(self, urls):
10.         # 设置路由信息
11.         self.urls = urls
13.     def __call__(self, env, start_response):
14.         path = env.get("PATH_INFO", "/")
15.         # /static/index.html
16.         if path.startswith("/static"):
17.             # 要访问静态文件
18.             file_name = path[7:]
19.             # 打开文件，读取内容
20.             try:
21.                 file = open(HTML_ROOT_DIR + file_name, "rb")
22.             except IOError:
23.                 # 代表未找到路由信息，404错误
24.                 status = "404 Not Found"
25.                 headers = []
26.                 start_response(status, headers)
27.                 return "not found"
28.             else:
29.                 file_data = file.read()
30.                 file.close()
32.                 status = "200 OK"
33.                 headers = []
34.                 start_response(status, headers)
35.                 return file_data.decode("utf-8")
37.         for url, handler in self.urls:
38.             #("/ctime", show_ctime)
39.             if path == url:
40.                 return handler(env, start_response)
42.         # 代表未找到路由信息，404错误
43.         status = "404 Not Found"
44.         headers = []
45.         start_response(status, headers)
46.         return "not found"
48. def show_ctime(env, start_response):
49.     status = "200 OK"
50.     headers = [
51.         ("Content-Type", "text/plain")
52.     ]
53.     start_response(status, headers)
54.     return time.ctime()
56. def say_hello(env, start_response):
57.     status = "200 OK"
58.     headers = [
59.         ("Content-Type", "text/plain")
60.     ]
61.     start_response(status, headers)
62.     return "hello itcast"
64. def say_haha(env, start_response):
65.     status = "200 OK"
66.     headers = [
67.         ("Content-Type", "text/plain")
68.     ]
69.     start_response(status, headers)
70.     return "hello haha"
72. urls = [
73.             ("/", show_ctime),
74.             ("/ctime", show_ctime),
75.             ("/sayhello", say_hello),
76.             ("/sayhaha", say_haha),
77.         ]
78. app = Application(urls)
79. # if __name__ == "__main__":
80. #     urls = [
81. #             ("/", show_ctime),
82. #             ("/ctime", show_ctime),
83. #             ("/sayhello", say_hello),
84. #             ("/sayhaha", say_haha),
85. #         ]
86. #     app = Application(urls)
87. #     http_server = HTTPServer(app)
88. #     http_server.bind(8000)
89. #     http_server.start()

复制代码

来源:https://www.cnblogs.com/djdjdj123/p/17329903.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！