温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Python面向对象如何实现静态Web服务器处理客户端请求

发布时间:2022-06-18 09:29:35 来源:亿速云 阅读:130 作者:iii 栏目:开发技术

这篇文章主要讲解了“Python面向对象如何实现静态Web服务器处理客户端请求”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Python面向对象如何实现静态Web服务器处理客户端请求”吧!

    概述

    把Web服务器抽象成一个类,方法初始化,在初始化中建立套接字对线。提供一个开启Web服务器的方法,让Web服务器处理客户端的请求。

    实现步骤

    1.定义web服务器类

    初始化类
    class HttpWebServer(object):
        def __init__(self):
            # 创建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(("", 9000))
            # 设置监听
            tcp_server_socket.listen(128)
            # 保存创建成功的服务器套接字
            self.tcp_server_socket = tcp_server_socket
    处理客户端请求
    @staticmethod
        def handle_client_request(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"
            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()
    启动web服务器进行工作
    def start(self):
            while True:
                # 等待接受客户端的连接请求
                new_socket, ip_port = self.tcp_server_socket.accept()
                # 当客户端和服务器建立连接程,创建子线程
                sub_thread = threading.Thread(target=self.handle_client_request, args=(new_socket,))
                # 设置守护主线程
                sub_thread.setDaemon(True)
                # 启动子线程执行对应的任务
                sub_thread.start()

    代码实现

    import socket
    import threading
    # 定义web服务器类
    class HttpWebServer(object):
        def __init__(self):
            # 创建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(("", 9000))
            # 设置监听
            tcp_server_socket.listen(128)
            # 保存创建成功的服务器套接字
            self.tcp_server_socket = tcp_server_socket
        # 处理客户端的请求
        @staticmethod
        def handle_client_request(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"
            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()
        # 启动web服务器进行工作
        def start(self):
            while True:
                # 等待接受客户端的连接请求
                new_socket, ip_port = self.tcp_server_socket.accept()
                # 当客户端和服务器建立连接程,创建子线程
                sub_thread = threading.Thread(target=self.handle_client_request, args=(new_socket,))
                # 设置守护主线程
                sub_thread.setDaemon(True)
                # 启动子线程执行对应的任务
                sub_thread.start()
    # 程序入口函数
    def main():
        # 创建web服务器对象
        web_server = HttpWebServer()
        # 启动web服务器进行工作
        web_server.start()
    if __name__ == '__main__':
        main()

    感谢各位的阅读,以上就是“Python面向对象如何实现静态Web服务器处理客户端请求”的内容了,经过本文的学习后,相信大家对Python面向对象如何实现静态Web服务器处理客户端请求这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI