d382813 发表于 2020-12-27 22:09:55

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

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

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

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


route_list = [
    ("/index.html", index),
    ("/center.html", center)
]


def not_found():
    # 响应行,响应头,响应体信息
    status = "404 NOT FOUND"
    response_header = [("Server", "PWS/1.1")]
    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

web服务器的代码如下:
import socket
import threading
import sys
import frame_work


# 定义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
      print(request_path)

      # 判断请求的是否是根目录,如果条件成立,指定首页数据返回
      if request_path == "/":
            request_path = "/index.html"

      # 判断是否是动态资源请求
      if request_path.endswith(".html"):
            """这里是动态资源请求,把请求信息交给框架处理"""
            # 字典存储用户的请求信息
            env = {
                "request_path": request_path
            }

            # 获取处理结果
            status, headers, response_body = frame_work.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.isdigit():
    #   print("执行命令如下: python3 xxx.py 9000")
    #   return
    #
    # # 需要转成int类型
    # port = int(sys.argv)

    # 创建web服务器
    web_server = HttpWebServer(8000)
    # 启动web服务器
    web_server.start()


if __name__ == '__main__':
    main()


d382813 发表于 2020-12-27 22:10:58

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

d382813 发表于 2020-12-27 22:24:31

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

tryhi 发表于 2020-12-28 09:52:39

不懂,帮顶
页: [1]
查看完整版本: 我在写动态资源请求框架时,遇到无法解决的问题,求助