【Python高级编程037 ● 静态web服务器 ● 静态Web服务器-多任务版】

python


---------Python基础编程---------

Author : AI菌


【内容讲解】

一、需求

1、单任务版的Web服务器,不能支持多用户同时访问,只能一个一个的处理客户端的请求。

例如使用网络调试助手,建立连接后,不发送数据,主线程就会阻塞,其他用户就无法建立连接,

需要等网络调试助手的请求处理完毕,服务端才能继续处理后面的请求。

2、开发多任务版的web服务器同时处理多个客户端的请求。

二、实现步骤

1、使用多线程。当客户端和服务端建立连接成功,创建子线程,使用子线程专门处理客户端的请求,防止主线程阻塞。

2、把创建的子线程设置成为守护主线程,防止主线程无法退出。

【代码演示】

"""

一、需求

1、单任务版的Web服务器,不能支持多用户同时访问,只能一个一个的处理客户端的请求。

例如使用网络调试助手,建立连接后,不发送数据,主线程就会阻塞,其他用户就无法建立连接,

需要等网络调试助手的请求处理完毕,服务端才能继续处理后面的请求。

2、开发多任务版的web服务器同时处理多个客户端的请求。

二、实现步骤

1、使用多线程。当客户端和服务端建立连接成功,创建子线程,使用子线程专门处理客户端的请求,防止主线程阻塞。

2、把创建的子线程设置成为守护主线程,防止主线程无法退出。

"""

import socket

import threading

# 处理客户端的请求

def handle_client_request(new_socket):

# 接收客户端的数据

recv_client_data = new_socket.recv(4096)

# 判断接收的客户端数据是否为0

if len(recv_client_data) == 0:

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:

# 读取文件数据

# rb表示以二进制的方式读取文件数据,图片数据需要以二进制格式打开,使用rb

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:DiamondDownload1.0\r\n"

# 读取404页面数据

with open("static/error.html", "rb") as file:

file_data = file.read()

# 响应体

response_body = file_data

# 把数据封装成http响应报文格式的数据

response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body

# 发送给浏览器的响应报文数据

new_socket.send(response_data)

else:

# 代码执行到此,说明有请求的文件,返回200状态信息

# 响应行

response_line = "HTTP/1.1 200 OK\r\n"

# 响应头

response_header = "server:DiamondDownload1.0\r\n"

# 响应体

response_body = file_data

# 把数据封装成http响应报文格式的数据

response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body

# 发送给浏览器的响应报文数据

new_socket.send(response_data)

finally:

# 关闭服务端与客户端套接字

new_socket.close()

# 程序入口函数

def main():

# 创建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(("", 8000))

# 设置监听

tcp_server_socket.listen(128)

# 循环响应客户端请求

while True:

# 等待接受客户端的连接请求

new_socket, port = tcp_server_socket.accept()

# 代码执行到此,说明连接建立成功

# 当客户端和服务器建立连接程,创建子线程

sub_thread = threading.Thread(target=handle_client_request, args=(new_socket,))

# 设置守护线程

sub_thread.setDaemon(True)

# 启动子线程执行对应的任务

sub_thread.start()

if __name__ == '__main__':

main()

【运行结果】

 服务端程序控制台打印结果:

来自客户端的数据: GET / HTTP/1.1

Host: 192.168.1.64:8000

Connection: keep-alive

Cache-Control: max-age=0

Upgrade-Insecure-Requests: 1

User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/85.0.4183.102 Safari/537.36

Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9

Accept-Encoding: gzip, deflate

Accept-Language: zh-CN,zh;q=0.9

截取的请求资源的路径: /

来自客户端的数据: GET /favicon.ico HTTP/1.1

Host: 192.168.1.64:8000

Connection: keep-alive

Pragma: no-cache

Cache-Control: no-cache

User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/85.0.4183.102 Safari/537.36

Accept: image/avif,image/webp,image/apng,image/*,*/*;q=0.8

Referer: http://192.168.1.64:8000/

Accept-Encoding: gzip, deflate

Accept-Language: zh-CN,zh;q=0.9

浏览器访问:

【往期精彩】

▷【Python基础编程196 ● 读取文件的4种方式】
▷【Python基础编程197 ● 读取文件的4种方式】
▷【Python基础编程198 ● 读取文件的4种方式】
▷【Python基础编程199 ● Python怎么读/写很大的文件】
▷【Python基础编程200 ● 读取文件的4种方式】
▷【Python基础编程201 ● 读取文件的4种方式】
▷【Python基础编程202 ● 读取文件的4种方式】
▷【Python基础编程203 ● 读取文件的4种方式】

【加群交流】



以上是 【Python高级编程037 ● 静态web服务器 ● 静态Web服务器-多任务版】 的全部内容, 来源链接: utcz.com/z/386992.html

回到顶部