基于TCP的Web服务器
模拟浏览器请求web服务器的网页过程，使用TCP实现HTTP协议(请求报文格式和响应报文格式)
"""
1、导入模块
2、创建套接字
3、建立连接
4、拼接请求协议
5、发送请求协议
6、接收服务器响应内容
7、保存内容
8、关闭连接
"""
import socket
tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_client_socket.connect(("www.baidu.com", 80))
request_line = "GET / HTTP/1.1\r\n"
request_header = "Host:www.baidu.com\r\n"
request_blank = "\r\n"
request_data = request_line + request_header + request_blank
tcp_client_socket.send(request_data.encode())
recv_date = tcp_client_socket.recv(4096).decode()
print(recv_date[recv_date.find("\r\n\r\n")+4:recv_date.find("\r\n\r\n")+104])
recv_list = []
for i in recv_date.split("\r\n"):
recv_list.append(i)
print(recv_list[-1][:100])
tcp_client_socket.close()
<!DOCTYPE html><html><head><meta http-equiv="Content-Type" content="text/html; charset=UTF-8"><!DOCTYPE html><html><head><meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
简单的Web服务器
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
def request_handler(new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
else:
response_line = "HTTP/1.1 200 OK\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
response_body = "HelloWorld!"
response_data = response_line + response_header + response_blank + response_body
new_client_socket.send(response_data.encode())
new_client_socket.close()
def main():
"""主函数段"""
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(("", 8080))
tcp_server_socket.listen(128)
while True:
new_client_socket, ip_port = tcp_server_socket.accept()
request_handler(new_client_socket, ip_port)
tcp_server_socket.close()
if __name__ == '__main__':
main()
简单的Web服务器-返回固定页面
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
def request_handler(new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
else:
response_line = "HTTP/1.1 200 OK\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
with open("D:/dist/index.html", "rb") as file:
response_body = file.read()
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body
new_client_socket.send(response_data)
new_client_socket.close()
def main():
"""主函数段"""
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(("", 8080))
tcp_server_socket.listen(128)
while True:
new_client_socket, ip_port = tcp_server_socket.accept()
request_handler(new_client_socket, ip_port)
tcp_server_socket.close()
if __name__ == '__main__':
main()
简单的Web服务器-返回指定页面
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
def request_handler(new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
else:
request_line_path = request_data.split("\r\n")[0].split(" ")[1]
print(request_line_path)
if request_line_path == "/":
request_line_path = "/index.html"
try:
response_line = "HTTP/1.1 200 OK\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
with open(f"D:/dist{request_line_path}", "rb") as file:
response_body = file.read()
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body
new_client_socket.send(response_data)
new_client_socket.close()
except Exception as e:
print("访问路径不存在！请重试！")
response_line = "HTTP/1.1 404 Not Found\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
response_body = f"Error! 页面{request_line_path}不存在！"
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body.encode("GBK")
new_client_socket.send(response_data)
new_client_socket.close()
else:
print("访问成功！")
def main():
"""主函数段"""
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(("", 8080))
tcp_server_socket.listen(128)
while True:
new_client_socket, ip_port = tcp_server_socket.accept()
request_handler(new_client_socket, ip_port)
tcp_server_socket.close()
if __name__ == '__main__':
main()
/
访问成功！
/favicon.ico
访问成功！
/index2.html
访问成功！
/ddd.html
访问路径不存在！请重试！
简单的Web服务器-面向对象封装
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
class WebServer(object):
def __init__(self):
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(("", 8080))
tcp_server_socket.listen(128)
self.tcp_server_socket = tcp_server_socket
def start(self):
while True:
new_client_socket, ip_port = self.tcp_server_socket.accept()
self.request_handler(new_client_socket, ip_port)
def request_handler(self, new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
else:
request_line_path = request_data.split("\r\n")[0].split(" ")[1]
print(request_line_path)
if request_line_path == "/":
request_line_path = "/index.html"
try:
response_line = "HTTP/1.1 200 OK\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
with open(f"D:/dist{request_line_path}", "rb") as file:
response_body = file.read()
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body
new_client_socket.send(response_data)
new_client_socket.close()
except Exception as e:
print("访问路径不存在！请重试！")
response_line = "HTTP/1.1 404 Not Found\r\n"
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
response_body = f"Error! 页面{request_line_path}不存在！"
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body.encode("GBK")
new_client_socket.send(response_data)
new_client_socket.close()
else:
print("访问成功！")
def main():
"""主函数段"""
ws = WebServer()
ws.start()
if __name__ == '__main__':
main()
/index2.html
访问成功！
/favicon.ico
访问成功！
/index.html
访问成功！
/
访问成功！
/ddd.html
访问路径不存在！请重试！
简单的Web服务器-基础框架构建
def create_http_response(status, response_body):
response_line = "HTTP/1.1 %s\r\n" % status
response_header = "Server:Python20WS/2.1\r\n"
response_blank = "\r\n"
response_data = response_line.encode() + response_header.encode() + response_blank.encode() + response_body
return response_data
from py.WebServer import WebServer_utils
def application(current_dir, request_data):
request_line_path = request_data.split("\r\n")[0].split(" ")[1]
print(request_line_path)
if request_line_path == "/":
request_line_path = "/index.html"
try:
with open(f"{current_dir}{request_line_path}", "rb") as file:
response_body = file.read()
status = "200 OK"
response_data = WebServer_utils.create_http_response(status, response_body)
except Exception as e:
print("访问路径不存在！请重试！")
response_body = f"Error! 页面{request_line_path}不存在！"
response_body = response_body.encode("GBK")
status = "404 Not Found"
response_data = WebServer_utils.create_http_response(status, response_body)
return response_data
import socket
from py.WebServer import WebServer_app
class WebServer(object):
def __init__(self):
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(("", 8080))
tcp_server_socket.listen(128)
self.tcp_server_socket = tcp_server_socket
def start(self):
while True:
new_client_socket, ip_port = self.tcp_server_socket.accept()
self.request_handler(new_client_socket, ip_port)
def request_handler(self, new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
request_data = WebServer_app.application("D:/dist", request_data)
new_client_socket.send(request_data)
new_client_socket.close()
def main():
"""主函数段"""
ws = WebServer()
ws.start()
if __name__ == '__main__':
main()
简单的Web服务器-加上命令行参数
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
from py.WebServer import WebServer_app
import sys
class WebServer(object):
def __init__(self, port):
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
def start(self):
print("Web服务器已经启动，等待客户端连接！")
while True:
new_client_socket, ip_port = self.tcp_server_socket.accept()
self.request_handler(new_client_socket, ip_port)
def request_handler(self, new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
response_data = WebServer_app.application("D:/dist", request_data)
new_client_socket.send(response_data)
new_client_socket.close()
def main():
"""主函数段"""
"""
命令行指定参数启动
1、导入sys模块
2、获取系统传递到程序的参数
3、判断参数格式是否正确
4、判断端口号是否是一个数字
5、获取端口号
6、在启动的web服务器的时候，使用指定的端口
"""
params_list = sys.argv
print(params_list)
if len(params_list) == 1:
port = 8080
else:
if len(params_list) != 2:
print(f"指定的参数格式错误！正确格式：python3 xxx.py 端口号")
return
if not params_list[1].isdigit():
print("启动失败，端口号必须是一个纯数字")
return
port = int(params_list[1])
ws = WebServer(port)
ws.start()
if __name__ == '__main__':
main()
简单的Web服务器-网游服务器
"""
1、导入模块
2、创建套接字
3、设置地址重用
4、绑定端口
5、设置监听，让套接字由主动变为被动接收
6、接受客户端连接 定义函数 request_handler()
7、接收客户端浏览器发送的请求协议
8、判断协议是否为空
9、拼接响应的报文
10、发送响应报文
11、关闭操作
"""
import socket
import WebServer_app
import sys
"""
1、在类的初始化方法中配置当前当前的项目
{"2048":"./2048", "植物大战僵尸v1":"./zwdzjs-v1", ...}
2、给类增加一个初始化项目配置的方法 init_projects()
2.1 显示所有可以发布的游戏 菜单
2.2 接收用户的选择
2.3 根据用户的选择发布指定的项目 （保存用户选择的游戏对应的本地目录）
3、更改Web服务器打开的文件目录
"""
class WebServer(object):
def __init__(self, port):
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
self.current_dir = ""
self.projects_dict = dict()
self.projects_dict['植物大战僵尸-普通版'] = "zwdzjs-v1"
self.projects_dict['植物大战僵尸-外挂版'] = "zwdzjs-v2"
self.projects_dict['保卫萝卜'] = "tafang"
self.projects_dict['2048'] = "2048"
self.projects_dict['读心术'] = "dxs"
self.init_projects()
def init_projects(self):
keys_list = list(self.projects_dict.keys())
for index, game_name in enumerate(keys_list):
print(f"{index}.{game_name}")
sel_no = int(input("请选择要发布的游戏序号：\n"))
key = keys_list[sel_no]
self.current_dir = self.projects_dict[key]
def start(self):
print("Web服务器已经启动，等待客户端连接！")
while True:
new_client_socket, ip_port = self.tcp_server_socket.accept()
self.request_handler(new_client_socket, ip_port)
def request_handler(self, new_client_socket, ip_port):
request_data = new_client_socket.recv(1024).decode()
if not request_data:
print(f"客户端{str(ip_port)}已经下线！")
new_client_socket.close()
return
response_data = WebServer_app.application_game(f"D:/python-study-master/day05/{self.current_dir}", request_data)
new_client_socket.send(response_data)
new_client_socket.close()
def main():
"""主函数段"""
"""
命令行指定参数启动
1、导入sys模块
2、获取系统传递到程序的参数
3、判断参数格式是否正确
4、判断端口号是否是一个数字
5、获取端口号
6、在启动的web服务器的时候，使用指定的端口
"""
params_list = sys.argv
print(params_list)
if len(params_list) == 1:
port = 8080
else:
if len(params_list) != 2:
print(f"指定的参数格式错误！正确格式：python3 xxx.py 端口号")
return
if not params_list[1].isdigit():
print("启动失败，端口号必须是一个纯数字")
return
port = int(params_list[1])
ws = WebServer(port)
ws.start()
if __name__ == '__main__':
main()
