我在写动态资源请求框架时,遇到无法解决的问题,求助

d382813

我在写动态资源请求框架时,在实现路由列表功能时,浏览器不能解析我的web服务器返回的数据.
代码错误提示是:UnicodeDecodeError: 'gbk' codec can't decode byte 0xaa in position 214: illegal multibyte sequence
1.虽然提示的是Unicode解码错误,但是我把编码全部换成gbk,仍然没解决bug,
2. illegal multibyte sequence 不合法的多字节序列问题提示,我始终没找出代码中有什么序列是不合法的,这应该是产生问题的原因.
简易的web框架代码如下:

1. import time
   
2. 
   
3. def index():
   
4.     # 响应状态
   
5.     status = "200 OK"
   
6.     # 响应头
   
7.     response_header = [("Server", "PWS2.0")]
   
8. 
   
9.     # 1. 打开模板文件，读取数据
   
10.     with open("template/index.html", "r") as file:
    
11.         file_data = file.read()
    
12. 
    
13.     # 处理后的数据, 从数据库查询
    
14.     data = time.ctime()
    
15.     # 2. 替换模板文件中的模板遍历
    
16.     result = file_data.replace("{%content%}", data)
    
17. 
    
18.     return status, response_header, result
    
19. 
    
20. def center():
    
21.     # 响应状态
    
22.     status = "200 OK"
    
23.     # 响应头
    
24.     response_header = [("Server", "PWS2.0")]
    
25. 
    
26.     # 打开模板文件，读取数据
    
27.     with open("template/center.html", "r") as file:
    
28.         file_data = file.read()
    
29. 
    
30.     # 处理后的数据, 从数据库查询
    
31.     data = time.ctime()
    
32.     # 替换模板文件中的模板遍历
    
33.     result = file_data.replace("{%content%}", data)
    
34. 
    
35.     return status, response_header, result
    
36. 
    
37. 
    
38. route_list = [
    
39.     ("/index.html", index),
    
40.     ("/center.html", center)
    
41. ]
    
42. 
    
43. 
    
44. def not_found():
    
45.     # 响应行,响应头,响应体信息
    
46.     status = "404 NOT FOUND"
    
47.     response_header = [("Server", "PWS/1.1")]
    
48.     data = "not found"
    
49. 
    
50.     return status, response_header, data
    
51. 
    
52. 
    
53. def handle_request(env):
    
54.     # 获取动态请求资源路径
    
55.     request_path = env["request_path"]
    
56.     print("接收到的动态资源请求:", request_path)
    
57.     for path, func in route_list:
    
58.         if request_path == path:
    
59.             result = func()
    
60.             return result
    
61.     else:
    
62.         # 没有找到动态资源
    
63.         result = not_found()
    
64.         return result

复制代码

web服务器的代码如下:

1. import socket
   
2. import threading
   
3. import sys
   
4. import frame_work
   
5. 
   
6. 
   
7. # 定义web服务器类
   
8. class HttpWebServer(object):
   
9.     def __init__(self, port):
   
10.         # 创建tcp服务端套接字
    
11.         tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
12.         # 设置端口号复用, 程序退出端口立即释放
    
13.         tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    
14.         # 绑定端口号
    
15.         tcp_server_socket.bind(("", port))
    
16.         # 设置监听
    
17.         tcp_server_socket.listen(128)
    
18.         self.tcp_server_socket = tcp_server_socket
    
19. 
    
20.     # 处理客户的请求
    
21.     @staticmethod
    
22.     def handle_client_quest(new_socket):
    
23.         # 代码执行到此，说明连接建立成功
    
24.         recv_client_data = new_socket.recv(4096)
    
25.         if len(recv_client_data) == 0:
    
26.             print("关闭浏览器了")
    
27.             # 关闭服务与客户端的套接字
    
28.             new_socket.close()
    
29.             return
    
30. 
    
31.         # 对二进制数据进行解码
    
32.         recv_client_content = recv_client_data.decode("utf-8")
    
33.         print(recv_client_content)
    
34.         # 根据指定字符串进行分割， 最大分割次数指定2
    
35.         request_list = recv_client_content.split(" ", maxsplit=2)
    
36. 
    
37.         # 获取请求资源路径
    
38.         request_path = request_list[1]
    
39.         print(request_path)
    
40. 
    
41.         # 判断请求的是否是根目录，如果条件成立，指定首页数据返回
    
42.         if request_path == "/":
    
43.             request_path = "/index.html"
    
44. 
    
45.         # 判断是否是动态资源请求
    
46.         if request_path.endswith(".html"):
    
47.             """这里是动态资源请求，把请求信息交给框架处理"""
    
48.             # 字典存储用户的请求信息
    
49.             env = {
    
50.                 "request_path": request_path
    
51.             }
    
52. 
    
53.             # 获取处理结果
    
54.             status, headers, response_body = frame_work.handle_request(env)
    
55. 
    
56.             # 使用框架处理的数据拼接响应报文
    
57.             # 响应行
    
58.             response_line = "HTTP/1.1 %s\r\n" % status
    
59.             # 响应头
    
60.             response_header = ""
    
61.             # 遍历头部信息
    
62.             for header in headers:
    
63.                 # 拼接多个响应头
    
64.                 response_header += "%s: %s\r\n" % header
    
65.             response_data = (response_line +
    
66.                              response_header +
    
67.                              "\r\n" +
    
68.                              response_body).encode("utf-8")
    
69.             # 发送数据
    
70.             new_socket.send(response_data)
    
71.             # 关闭socket
    
72.             new_socket.close()
    
73. 
    
74.         else:
    
75.             """这里是静态资源请求"""
    
76.             try:
    
77.                 # 动态打开指定文件
    
78.                 with open("static" + request_path, "rb") as file:
    
79.                     # 读取文件数据
    
80.                     file_data = file.read()
    
81.             except Exception as e:
    
82.                 # 请求资源不存在，返回404数据
    
83.                 # 响应行
    
84.                 response_line = "HTTP/1.1 404 Not Found\r\n"
    
85.                 # 响应头
    
86.                 response_header = "Server: PWS1.0\r\n"
    
87.                 with open("static/error.html", "rb") as file:
    
88.                     file_data = file.read()
    
89.                 # 响应体
    
90.                 response_body = file_data
    
91. 
    
92.                 # 拼接响应报文
    
93.                 response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body
    
94.                 # 发送数据
    
95.                 new_socket.send(response_data)
    
96.             else:
    
97.                 # 响应行
    
98.                 response_line = "HTTP/1.1 200 OK\r\n"
    
99.                 # 响应头
    
100.                 response_header = "Server: PWS1.0\r\n"
     
101. 
     
102.                 # 响应体
     
103.                 response_body = file_data
     
104. 
     
105.                 # 拼接响应报文
     
106.                 response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body
     
107.                 # 发送数据
     
108.                 new_socket.send(response_data)
     
109.             finally:
     
110.                 # 关闭服务与客户端的套接字
     
111.                 new_socket.close()
     
112. 
     
113.     def start(self):
     
114.         while True:
     
115.             # 等待接受客户端的连接请求
     
116.             new_socket, ip_port = self.tcp_server_socket.accept()
     
117.             sub_thread = threading.Thread(target=self.handle_client_quest, args=(new_socket,))
     
118.             # 设置守护线程
     
119.             sub_thread.setDaemon(True)
     
120.             sub_thread.start()
     
121. 
     
122. 
     
123. # 程序入口函数
     
124. def main():
     
125. 
     
126.     # 获取命令行参数判断长度
     
127.     # if len(sys.argv) != 2:
     
128.     #     print("执行命令如下: python3 xxx.py 9000")
     
129.     #     return
     
130.     #
     
131.     # # 判断端口号是否是数字
     
132.     # if not sys.argv[1].isdigit():
     
133.     #     print("执行命令如下: python3 xxx.py 9000")
     
134.     #     return
     
135.     #
     
136.     # # 需要转成int类型
     
137.     # port = int(sys.argv[1])
     
138. 
     
139.     # 创建web服务器
     
140.     web_server = HttpWebServer(8000)
     
141.     # 启动web服务器
     
142.     web_server.start()
     
143. 
     
144. 
     
145. if __name__ == '__main__':
     
146.     main()
     

复制代码

d382813

真心求教大佬们,自学真的太难了.

d382813

求各位大佬帮帮小弟吧,谢谢了!

tryhi

不懂，帮顶