如何用Python实现http客户端和服务器
2024-10-21 05:38:45
功能:客户端可以向服务器发送get,post等请求,而服务器端可以接收这些请求,并返回给客户端消息。
客户端:
#coding=utf-8
import http.client
from urllib import request, parse
def send_get(url,path,data):#get请求函数
conn = http.client.HTTPConnection(url)
conn.request("GET", path)
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.read()
print(data1) #
conn.close()
def send_post(url,path,data,header):#post请求函数
conn = http.client.HTTPConnection(url)#建立连接
conn.request("POST", path,data,header)#用request请求,将信息封装成帧
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.read()
print(data1) #
conn.close()
def send_head(url,path,data,header):
conn = http.client.HTTPConnection(url)
conn.request("HEAD", path,data,header)
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.headers #
print(data1) #
conn.close()
def send_put(url,path,filedata,header):
conn = http.client.HTTPConnection(url)
conn.request("PUT", path,filedata,header)
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.read() #
print(data1)
conn.close()
def send_option(url,path,data,header):
conn = http.client.HTTPConnection(url)
conn.request("OPTION", path,data,header)
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.headers #
print(data1) #
conn.close()
def delete_option(url,path,filename,header):
conn = http.client.HTTPConnection(url)
conn.request("DELETE", path, filename, header)
r1 = conn.getresponse()
print(r1.status, r1.reason)
data1 = r1.read() #
print(data1)
conn.close()
if __name__ == '__main__':
url="localhost:8100"
data = {
'my post data': 'I am client , hello world',
}
datas = parse.urlencode(data).encode('utf-8')
headers = {"Content-type": "application/x-www-form-urlencoded","Accept": "text/plain"}
while True:
command = input("输入请求的命令:")
if command =='get':
print("----------发送get请求:-----------")
send_get(url,path="",data="None")
elif command=='post':
print("----------发送post请求-----------")
send_post(url, path="",data=datas,header=headers)
elif command =='put':
print("----------发送put请求-----------")
file = input("输入要发送的文件名:")
tfile=open(file,encoding="UTF-8",mode='r')
filedatas=tfile.read()
fileheaders = {"Content-type": "text/plain", "Accept": "text/plain",\
"content-length":str(len(filedatas))}
send_put(url, path="E:/pythonProject2/httpweb/", filedata=filedatas, header=fileheaders)
elif command=='head':
print("----------发送head请求:-----------")
send_head(url, path="", data=datas, header=headers)
elif command=='option':
print("----------发送option请求:-----------")
send_option(url,path="",data=datas,header=headers)
elif command=='delete':
print("----------发送delete请求-----------")
file = input("输入要删除的文件名:")
fileheaders = {"Content-type": "text/plain", "Accept": "text/plain"}
delete_option(url, path="E:/pythonProject2/httpweb/", filename = file, header=fileheaders)
elif command == 'exit':
break
服务器:
# -*- coding: utf-8 -*-
import socket
import re
import os
import threading
import urllib.parse
def service_client(new_socket):
# 为这个客户端返回数据
# 1.接收浏览器发过来的请求,即http请求
# GET / HTTP/1.1
request = new_socket.recv(1024).decode('utf-8')
request_header_lines = request.splitlines()
print(request_header_lines)
data = request_header_lines[-1]
# ret = re.match(r'[^/]+(/[^ ]*)', request_header_lines[0])
ret = list(request_header_lines[0].split(' '))[1]
method = list(request_header_lines[0].split(' '))[0]
path_name = "/"
if method == 'GET':
if ret:
path = ret
path_name = urllib.parse.unquote(path) # 浏览器请求的路径中带有中文,会被自动编码,需要先解码成中文,才能找到后台中对应的html文件
print("请求路径:{}".format(path_name))
if path_name == "/": # 用户请求/时,返回咖啡.html页面
path_name = "/咖啡.html"
# 2.返回http格式的数据给浏览器
file_name = 'E:/pythonProject2/httpweb/HTML/' + path_name
try:
f = open(file_name, 'rb')
except:
response = "HTTP/1.1 404 NOT FOUND\r\n"
response += "\r\n"
response += "------file not found------"
new_socket.send(response.encode("utf-8"))
else:
html_content = f.read()
f.close()
# 准备发给浏览器的数据 -- header
response = "HTTP/1.1 200 OK\r\n"
response += "\r\n"
new_socket.send(response.encode("utf-8"))
new_socket.send(html_content)
# 关闭套接字
if method == 'POST':
if ret:
path = ret
path_name = urllib.parse.unquote(path) # 浏览器请求的路径中带有中文,会被自动编码,需要先解码成中文,才能找到后台中对应的html文件
print("请求路径:{}".format(path_name))
if path_name == "/": # 用户请求/时,返回咖啡.html页面
path_name = "/咖啡.html"
# 2.返回http格式的数据给浏览器
file_name = 'E:/pythonProject2/httpweb/HTML/' + path_name
response = "HTTP/1.1 200 OK\r\n"
response += "\r\n"
new_socket.send(response.encode("utf-8"))
new_socket.send(file_name.encode("utf-8")+' data:'.encode("utf-8")+data.encode("utf-8"))
if method == 'PUT':
if ret:
path = ret
path_name = urllib.parse.unquote(path) # 浏览器请求的路径中带有中文,会被自动编码,需要先解码成中文,才能找到后台中对应的html文件
print("请求路径:{}".format(path_name))
if path_name == "/": # 用户请求/时,返回咖啡.html页面
path_name = "/咖啡.html"
# 2.返回http格式的数据给浏览器
file_name = list(request_header_lines[0].split(' '))[1] +'test.txt'
content = data.encode('utf-8')
response = "HTTP/1.1 200 OK\r\n"
response += "\r\n"
with open(file_name, 'ab') as f:
f.write(content)
new_socket.send(response.encode("utf-8"))
new_socket.send("finish".encode("utf-8"))
if method=='HEAD':
if ret:
path =ret
path_name = urllib.parse.unquote(path)
print("请求路径:{}".format(path_name))
if path_name =="/":
path_name = "/咖啡.html"
response = "HTTP/1.1 200 ok\r\n"
new_socket.send(response.encode("utf-8"))
new_socket.send(str(request_header_lines[1:]).encode("utf-8"))
if method=='OPTION':
if ret:
path = ret
path_name = urllib.parse.unquote(path)
print("请求路径:{}".format(path_name))
if path_name == "/":
path_name = "/咖啡.html"
response = "HTTP/1.1 200 ok\r\n"
new_socket.send(response.encode("utf-8"))
new_socket.send("OPTIONS GET,HEAD,POST,PUT,DELETE".encode("utf-8"))
if method =='DELETE':
if ret:
path = ret
path_name = urllib.parse.unquote(path) # 浏览器请求的路径中带有中文,会被自动编码,需要先解码成中文,才能找到后台中对应的html文件
print("请求路径:{}".format(path_name))
if path_name == "/": # 用户请求/时,返回咖啡.html页面
path_name = "/咖啡.html"
deletename = request_header_lines[-1]
# print(path_name+deletename)
os.remove(path_name+deletename)
# 2.返回http格式的数据给浏览器
content = data.encode('utf-8')
response = "HTTP/1.1 200 OK\r\n"
response += "\r\n"
# with open(file_name, 'ab') as f:
# f.write(content)
new_socket.send(response.encode("utf-8"))
new_socket.send("finish".encode("utf-8"))
# 关闭套接字
new_socket.close()
def main():
# 用来完成整体的控制
# 1.创建套接字
tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 2.绑定
tcp_server_socket.bind(("0.0.0.0", 8100))
# 3.变为监听套接字
tcp_server_socket.listen(128)
while True:
# 4.等待新客户端的链接
new_socket, client_addr = tcp_server_socket.accept()
# 5.为这个客户端服务
print("为",client_addr,"服务")
t = threading.Thread(target=service_client, args=(new_socket,))
t.start()
# 关闭监听套接字
tcp_server_socket.close()
if __name__ == '__main__':
main()
最新文章
- 【Win 10应用开发】分阶段进行数据绑定
- 自己动手打造WEB服务器 Windows + Apache + PHP + MySQL
- WPF listbox UI虚拟化
- Understanding and Managing SMTP Virtual Servers
- XAML系列学习
- 《C#入门典》
- linux多线程编程之互斥锁
- mysql的常用操作的封装
- (@WhiteTaken)设计模式学习——工厂方法模式
- JavaEE开发之SpringBoot工程的创建、运行与配置
- 解决Maven管理的项目下";Missing artifact xxx bundle";问题
- AMDP + XLSX Workbench 报表开发模式
- SQL运维
- Oracle学习笔记三
- ActiveMQ依赖JDK版本关系
- Windows上IOCP Socket事件模型管理
- IOS 设置视图半透明子控件不透明
- 详解Zookeeper原理与应用场景
- java web(七): mybatis的动态sql和mybatis generator自动生成pojo类和映射文件
- 使用jdom进行xml解析,网络抓包
热门文章
- .NET Conf 2022 &;ndash; 11 月 8 日至 10 日
- C# 获取打开的EXCEL中某列的行数
- 使用idea创建第一个Mybatis程序及可能遇到的问题
- November 练习(Tou Xue)打卡
- 2022春每日一题:Day 40
- Go语言核心36讲01
- 【Java 并发003】原理层面:Java并发三特性全解析
- 【Spark】Day05-内核解析:组件、流程、部署、运行模式、通讯架构、任务调度(Stage、task级)、两种Shuffle机制、内存管理、核心组件
- Karmada多云多集群生产实践专场圆满落幕
- nuxt.js中引入lib-flexible 和 postcss-px2rem 实现pc自适应