(更新时间)2021年3月28日 python基础知识(搭建自己的框架)

一：框架程序

1. 框架职责介绍

接收web服务器的动态资源请求，给web服务器提供处理动态资源请求的服务。

2. 动态资源判断

根据请求资源路径的后缀名进行判断

如果请求资源路径的后缀名是.html则是动态资源请求, 让web框架程序进行处理。

否则是静态资源请求，让web服务器程序进行处理。

web服务器程序(web.py)代码:

import socket import threading import sys import framework # 定义web服务器类 class HttpWebServer(object): def __init__(self, port): # 创建tcp服务端套接字 tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 设置端口号复用, 程序退出端口立即释放 tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) # 绑定端口号 tcp_server_socket.bind(("", port)) # 设置监听 tcp_server_socket.listen(128) self.tcp_server_socket = tcp_server_socket # 处理客户的请求 @staticmethod def handle_client_quest(new_socket): # 代码执行到此，说明连接建立成功 recv_client_data = new_socket.recv(4096) if len(recv_client_data) == 0: print("关闭浏览器了") # 关闭服务与客户端的套接字 new_socket.close() return # 对二进制数据进行解码 recv_client_content = recv_client_data.decode("utf-8") print(recv_client_content) # 根据指定字符串进行分割， 最大分割次数指定2 request_list = recv_client_content.split(" ", maxsplit=2) # 获取请求资源路径 request_path = request_list[1] print(request_path) # 判断请求的是否是根目录，如果条件成立，指定首页数据返回 if request_path == "/": request_path = "/index.html" # 判断是否是动态资源请求 if request_path.endswith(".html"): """这里是动态资源请求，把请求信息交给框架处理""" # 字典存储用户的请求信息 env = { "request_path": request_path } # 获取处理结果 status, headers, response_body = framework.handle_request(env) # 使用框架处理的数据拼接响应报文 # 响应行 response_line = "HTTP/1.1 %s\r\n" % status # 响应头 response_header = "" # 遍历头部信息 for header in headers: # 拼接多个响应头 response_header += "%s: %s\r\n" % header response_data = (response_line + response_header + "\r\n" + response_body).encode("utf-8") # 发送数据 new_socket.send(response_data) # 关闭socket new_socket.close() else: """这里是静态资源请求""" try: # 动态打开指定文件 with open("static" + request_path, "rb") as file: # 读取文件数据 file_data = file.read() except Exception as e: # 请求资源不存在，返回404数据 # 响应行 response_line = "HTTP/1.1 404 Not Found\r\n" # 响应头 response_header = "Server: PWS1.0\r\n" with open("static/error.html", "rb") as file: file_data = file.read() # 响应体 response_body = file_data # 拼接响应报文 response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body # 发送数据 new_socket.send(response_data) else: # 响应行 response_line = "HTTP/1.1 200 OK\r\n" # 响应头 response_header = "Server: PWS1.0\r\n" # 响应体 response_body = file_data # 拼接响应报文 response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body # 发送数据 new_socket.send(response_data) finally: # 关闭服务与客户端的套接字 new_socket.close() def start(self): while True: # 等待接受客户端的连接请求 new_socket, ip_port = self.tcp_server_socket.accept() sub_thread = threading.Thread(target=self.handle_client_quest, args=(new_socket,)) # 设置守护线程 sub_thread.setDaemon(True) sub_thread.start() # 程序入口函数 def main(): # 获取命令行参数判断长度 if len(sys.argv) != 2: print("执行命令如下: python3 xxx.py 9000") return # 判断端口号是否是数字 if not sys.argv[1].isdigit(): print("执行命令如下: python3 xxx.py 9000") return # 需要转成int类型 port = int(sys.argv[1]) # 创建web服务器 web_server = HttpWebServer(port) # 启动web服务器 web_server.start() if __name__ == '__main__': main()

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

3. 处理客户端的动态资源请求

创建web框架程序

接收web服务器的动态资源请求

处理web服务器的动态资源请求并把处理结果返回给web服务器

web服务器把处理结果组装成响应报文发送给浏览器

web框架程序(framework.py)代码:

"""miniweb框架，负责处理动态资源请求""" import time # 获取首页数据 def index(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 处理后的数据 data = time.ctime() return status, response_header, data # 没有找到动态资源 def not_found(): # 响应状态 status = "404 Not Found"; # 响应头 response_header = [("Server", "PWS2.0")] # 处理后的数据 data = "not found" return status, response_header, data # 处理动态资源请求 def handle_request(env): # 获取动态请求资源路径 request_path = env["request_path"] print("接收到的动态资源请求:", request_path) if request_path == "/index.html": # 获取首页数据 result = index() return result else: # 没有找到动态资源 result = not_found() return result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

4. 小结

动态资源的判断通过请求资源路径的后缀是.html来完成，否则是静态资源

处理客户端的动态资源请求 接收web服务器的动态资源请求 处理动态资源请求并把处理结果返回给web服务器

web服务器把处理结果组装成响应报文发送给浏览器

二：模板替换输出

1. 读取页面信息模板文件

framework.py示例代码:

# 获取首页数据 def index(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 打开模板文件，读取数据 with open("template/index.html", "r") as file: file_data = file.read()

1

2

3

4

5

6

7

8

9

10

2. 使用模拟数据替换模板变量

framework.py示例代码:

# 获取首页数据 def index(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 1. 打开模板文件，读取数据 with open("template/index.html", "r") as file: file_data = file.read() # 处理后的数据, 从数据库查询 data = time.ctime() # 2. 替换模板文件中的模板遍历 result = file_data.replace("{%content%}", data) return status, response_header, result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

3. 小结

模板替换功能

打开template目录下的index.html模板文件，读取模板文件数据

把模板文件中的模板变量进行替换

三：路由列表功能

1. 路由的介绍

接着上面程序的判断场景，假如咱们再处理一个个人中心的动态资源请求非常简单，再添加一个函数和更加一个分支判断就可以实现了。

framework.py 示例代码:

# 获取个人中心数据 def center(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 打开模板文件，读取数据 with open("template/center.html", "r") as file: file_data = file.read() # 处理后的数据, 从数据库查询 data = time.ctime() # 替换模板文件中的模板遍历 result = file_data.replace("{%content%}", data) return status, response_header, result # 处理动态资源请求 def handle_request(env): # 获取动态请求资源路径 request_path = env["request_path"] print("接收到的动态资源请求:", request_path) if request_path == "/index.html": # 获取首页数据 result = index() return result elif request_path == "/center.html": # 获取个人中心数据 result = center() return result else: # 没有找到动态资源 result = not_found() return result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

那如果咱们的框架处理的页面请求路径再多一些，比如:5个路径判断，大家可能感觉条件分支完全可以胜任，如果是40个甚至更多呢? 如果这是还是用普通的条件分支简直无法忍受。

解决办法: 可以使用路由

什么是路由？

路由就是请求的URL到处理函数的映射，也就是说提前把请求的URL和处理函数关联好。

路由列表

这么多的路由如何管理呢， 可以使用一个路由列表进行管理，通过路由列表保存每一个路由。

2. 在路由列表添加路由

framework.py 示例代码:

# 定义路由列表 route_list = [ ("/index.html", index), ("/center.html", center) ]

1

2

3

4

5

3. 根据用户请求遍历路由列表处理用户请求

framework.py 示例代码:

# 处理动态资源请求 def handle_request(env): # 获取动态请求资源路径 request_path = env["request_path"] print("接收到的动态资源请求:", request_path) # 遍历路由列表，选择执行的函数 for path, func in route_list: if request_path == path: result = func() return result else: # 没有找到动态资源 result = not_found() return result # if request_path == "/index.html": # # 获取首页数据 # result = index() # return result # elif request_path == "/center.html": # # 获取个人中心数据 # result = center() # return result # else: # # 没有找到动态资源 # result = not_found() # return result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

小结

路由是请求的URL到处理函数的映射

路由列表是用来保存每一个设置好的路由

用户的动态资源请求通过遍历路由列表找到对应的处理函数来完成。

四：装饰器方式的添加路由

1. 使用带有参数的装饰器添加路由

前面我们已经实现了路由列表，但是每次添加路由都需要手动添加来完成，接下来我们想要完成路由的自动添加，可以通过装饰器来实现，在使用装饰器对处理函数进行装饰的时候我们需要知道装饰的函数和那个请求路径进行关联，也就是说装饰器需要接收一个url参数，这样我们定义的装饰器是一个带有参数的装饰器。

示例代码:

"""miniweb框架，负责处理动态资源请求""" import time # 定义路由列表 route_list = [] # 定义带有参数的装饰器 def route(path): # 装饰器 def decorator(func): # 当执行装饰器装饰指定函数的时候，把路径和函数添加到路由列表 route_list.append((path, func)) def inner(): # 执行指定函数 return func() return inner # 返回装饰器 return decorator # 获取首页数据 @route("/index.html") def index(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 打开模板文件，读取数据 with open("template/index.html", "r") as file: file_data = file.read() # 处理后的数据, 从数据库查询 data = time.ctime() # 替换模板文件中的模板遍历 result = file_data.replace("{%content%}", data) return status, response_header, result # 获取个人中心数据 @route("/center.html") def center(): # 响应状态 status = "200 OK"; # 响应头 response_header = [("Server", "PWS2.0")] # 打开模板文件，读取数据 with open("template/center.html", "r") as file: file_data = file.read() # 处理后的数据, 从数据库查询 data = time.ctime() # 替换模板文件中的模板遍历 result = file_data.replace("{%content%}", data) return status, response_header, result # 没有找到动态资源 def not_found(): # 响应状态 status = "404 Not Found"; # 响应头 response_header = [("Server", "PWS2.0")] # 处理后的数据 data = "not found" return status, response_header, data # 处理动态资源请求 def handle_request(env): # 获取动态请求资源路径 request_path = env["request_path"] print("接收到的动态资源请求:", request_path) # 遍历路由列表，选择执行的函数 for path, func in route_list: if request_path == path: result = func() return result else: # 没有找到动态资源 result = not_found() return result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

2. 小结

使用带有参数的装饰器对处理函数进行装饰，并完成路由的添加功能。

五：日志的使用

1. logging日志的介绍

在现实生活中，记录日志非常重要，比如:银行转账时会有转账记录；飞机飞行过程中，会有个黑盒子（飞行数据记录器）记录着飞机的飞行过程，那在咱们python程序中想要记录程序在运行时所产生的日志信息，怎么做呢?

可以使用 logging 这个包来完成

记录程序日志信息的目的是:

可以很方便的了解程序的运行情况

可以分析用户的操作行为、喜好等信息

方便开发人员检查bug

2. logging日志级别介绍

日志等级可以分为5个，从低到高分别是:

DEBUG

INFO

WARNING

ERROR

CRITICAL

日志等级说明:

DEBUG：程序调试bug时使用

INFO：程序正常运行时使用

WARNING：程序未按预期运行时使用，但并不是错误，如:用户登录密码错误

ERROR：程序出错误时使用，如:IO操作失败

CRITICAL：特别严重的问题，导致程序不能再继续运行时使用，如:磁盘空间为空，一般很少使用

默认的是WARNING等级，当在WARNING或WARNING之上等级的才记录日志信息。

日志等级从低到高的顺序是: DEBUG < INFO < WARNING < ERROR < CRITICAL

3. logging日志的使用

在 logging 包中记录日志的方式有两种:

输出到控制台

保存到日志文件

日志信息输出到控制台的示例代码:

import logging logging.debug('这是一个debug级别的日志信息') logging.info('这是一个info级别的日志信息') logging.warning('这是一个warning级别的日志信息') logging.error('这是一个error级别的日志信息') logging.critical('这是一个critical级别的日志信息')

1

2

3

4

5

6

7

运行结果:

WARNING:root:这是一个warning级别的日志信息 ERROR:root:这是一个error级别的日志信息 CRITICAL:root:这是一个critical级别的日志信息

1

2

3

说明:

日志信息只显示了大于等于WARNING级别的日志，这说明默认的日志级别设置为WARNING

logging日志等级和输出格式的设置:

import logging # 设置日志等级和输出日志格式 logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s') logging.debug('这是一个debug级别的日志信息') logging.info('这是一个info级别的日志信息') logging.warning('这是一个warning级别的日志信息') logging.error('这是一个error级别的日志信息') logging.critical('这是一个critical级别的日志信息')

1

2

3

4

5

6

7

8

9

10

11

运行结果:

2019-02-13 20:41:33,080 - hello.py[line:6] - DEBUG: 这是一个debug级别的日志信息 2019-02-13 20:41:33,080 - hello.py[line:7] - INFO: 这是一个info级别的日志信息 2019-02-13 20:41:33,080 - hello.py[line:8] - WARNING: 这是一个warning级别的日志信息 2019-02-13 20:41:33,080 - hello.py[line:9] - ERROR: 这是一个error级别的日志信息 2019-02-13 20:41:33,080 - hello.py[line:10] - CRITICAL: 这是一个critical级别的日志信息

1

2

3

4

5

代码说明:

level 表示设置的日志等级

format 表示日志的输出格式, 参数说明:

%(levelname)s: 打印日志级别名称 %(filename)s: 打印当前执行程序名 %(lineno)d: 打印日志的当前行号 %(asctime)s: 打印日志的时间 %(message)s: 打印日志信息

1

2

3

4

5

日志信息保存到日志文件的示例代码:

import logging logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s', filename="log.txt", filemode="w") logging.debug('这是一个debug级别的日志信息') logging.info('这是一个info级别的日志信息') logging.warning('这是一个warning级别的日志信息') logging.error('这是一个error级别的日志信息') logging.critical('这是一个critical级别的日志信息')

1

2

3

4

5

6

7

8

9

10

11

12

运行结果:

4. logging日志在mini-web项目中应用

web.py 程序使用logging日志示例:

程序入口模块设置logging日志的设置

import socket import threading import sys import framework import logging # logging日志的配置 logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s', filename="log.txt", filemode="w")

1

2

3

4

5

6

7

8

9

10

11

INFO级别的日志输出，示例代码:

# 判断是否是动态资源请求 if request_path.endswith(".html"): """这里是动态资源请求，把请求信息交给框架处理""" logging.info("动态资源请求:" + request_path) ... else: """这里是静态资源请求""" logging.info("静态资源请求:" + request_path) ...

1

2

3

4

5

6

7

8

9

WARNING级别的日志输出，示例代码:

# 获取命令行参数判断长度 if len(sys.argv) != 2: print("执行命令如下: python3 xxx.py 9000") logging.warning("用户在命令行启动程序参数个数不正确!") return # 判断端口号是否是数字 if not sys.argv[1].isdigit(): print("执行命令如下: python3 xxx.py 9000") logging.warning("用户在命令行启动程序参数不是数字字符串!") return

1

2

3

4

5

6

7

8

9

10

11

framework.py 程序使用logging日志示例:

ERROR级别的日志输出，示例代码:

# 处理动态资源请求 def handle_request(env): # 获取动态请求资源路径 request_path = env["request_path"] print("接收到的动态资源请求:", request_path) # 遍历路由列表，选择执行的函数 for path, func in route_list: if request_path == path: result = func() return result else: logging.error("没有设置相应的路由:" + request_path) # 没有找到动态资源 result = not_found() return result

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

说明:

logging日志配置信息在程序入口模块设置一次，整个程序都可以生效。

logging.basicConfig 表示 logging 日志配置操作

5. 小结

记录python程序中日志信息使用 logging 包来完成

logging日志等级有5个:

DEBUG INFO WARNING ERROR CRITICAL

1

2

3

4

5

打印(记录)日志的函数有5个:

logging.debug函数, 表示: 打印(记录)DEBUG级别的日志信息 logging.info函数, 表示: 打印(记录)INFO级别的日志信息 logging.warning函数, 表示: 打印(记录)WARNING级别的日志信息 logging.error函数, 表示: 打印(记录)ERROR级别的日志信息 logging.critical函数, 表示: 打印(记录)CRITICAL级别的日志信息

1

2

3

4

5

Python web前端

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。