Golang net/http标准库常用方法(三)

大家好，针对Go语言 net/http 标准库，将梳理的相关知识点分享给大家~~
围绕 net/http 标准库相关知识点还有许多章节，请大家多多关注。
文章中代码案例只有关键片段，完整代码请查看github仓库：https://github.com/hltfaith/go-example/tree/main/net-http

本章节案例，请大家以 go1.16+ 版本以上进行参考。

net/http标准库系列文章

  • Golang net/http标准库常用请求方法(一)
  • Golang net/http标准库常用方法(二)
  • Golang net/http标准库常用方法(三)

本节内容

  • ProxyFromEnvironment() 函数
  • ProxyURL() 函数
  • Serve() 函数
  • ServeContent() 函数
  • DetectContentType() 函数
  • MaxBytesReader() 函数

ProxyFromEnvironment()

ProxyFromEnvironment()函数，用于读取所在环境的环境变量返回代理地址。比如环境变量HTTP_PROXY、HTTPS_PROXY和NO_PROXY，如果在 NO_PROXY 排除的地址则不进行代理。
代理地址格式可以是完整的URL，也可以是host[:port]。支持 HTTP、HTTPS、SOCKS5代理。
如果环境中未定义代理，或者NO_PROXY定义的给定请求不应使用代理，则返回nil URL和nil错误。如果 req.URL.Host 地址为 localhost 加或没加端口，都会返回 nil 错误。
函数原型

func ProxyFromEnvironment(req *Request) (*url.URL, error)

函数使用
proxyfromenvironment.go

func main() {os.Setenv("HTTP_PROXY", "http://127.0.0.1:12345")req, err := http.NewRequest("GET", "http://example.com", nil)if err != nil {panic(err)}url, err := http.ProxyFromEnvironment(req)if err != nil {panic(err)}fmt.Println(url)
}

案例中 http.ProxyFromEnvironment(req) 仅会把读取环境变量 HTTP_PROXY 的代理地址，在我们使用 http.NewRequest() 请求时，不会使用代理请求。
下面通过 ProxyURL() 函数案例，发起代理请求。

ProxyURL()

ProxyURL() 作用是返回一个代理函数主要用于在 Transport{} 类型中，其参数是代理地址。
函数原型

func ProxyURL(fixedURL *url.URL) func(*Request) (*url.URL, error)

举例：使用代理发送 HTTP 请求。
proxyurl.go

func main() {url, err := url.Parse("http://188.68.176.2:8080")if err != nil {panic(err)}client := http.Client{Transport: &http.Transport{Proxy:           http.ProxyURL(url),TLSClientConfig: &tls.Config{InsecureSkipVerify: true},},}res, err := client.Get("http://baidu.com")if err != nil {panic(err)}b, _ := httputil.DumpRequest(res.Request, false)fmt.Println(string(b))
}

上述例子中， 将代理函数ProxyURL(url)通过Transport{}类型封装好后，向目标服务发送GET请求。
Client{}、Transport{}类型后续文章将详细讲解。

注：代理地址，可以参考 https://www.kuaidaili.com/free/fps/ 用于测试使用。

上面案例，也可以将 http.ProxyURL() 函数改成 ProxyFromEnvironment() 用环境变量的方式。
proxyurl2.go

func main() {url, err := url.Parse("http://google.com")if err != nil {panic(err)}os.Setenv("HTTP_PROXY", "http://127.0.0.1:7890")client := http.Client{Transport: &http.Transport{Proxy:           http.ProxyFromEnvironment,TLSClientConfig: &tls.Config{InsecureSkipVerify: true}, // 跳过https},}req := http.Request{Method: "GET",URL:    url,Header: map[string][]string{"Proxy-Connection": {"keep-alive"},},}res, err := client.Do(&req)if err != nil {panic(err)}defer res.Body.Close()
}

这里是通过我本地环境的代理VPN所监听的端口 http://127.0.0.1:7890

下面我通过抓包，大家可以看到执行代理请求的时候源端口 50130是我们请求端，访问的谷歌网站目的端已经变成了 http://127.0.0.1:7890 地址也是我们的代理端，后面的响应也是由代理端给我们请求回应数据包。

Serve()

Serve() 函数，接收监听 HTTP 连接请求，为每个连接创建一个新goroutine。goroutine读取请求，然后调用处理程序来回复它们。
官方建议 handler 为 nil类型， 则默认使用 DefaultServerMux 全局锁机制。 （可以参考上篇文章中有所介绍）
只有当 Listener 返回tls的时候，才支持HTTP/2协议。
Serve() 函数返回非 nil 的报错。
函数原型

func Serve(l net.Listener, handler Handler) error

Serve()函数实际上是调用的 Server{} 类型中封装的一个方法。

func Serve(l net.Listener, handler Handler) error {srv := &Server{Handler: handler}return srv.Serve(l)
}

例如，上篇文章中介绍的 ListenAndServe()、ListenAndServeTLS() 方法它们最终执行都是 Server{}类型中的 Serve() 方法。

函数使用
serve.go

func main() {ln, err := net.Listen("tcp", ":8080")if err != nil {panic(err)}http.HandleFunc("/", func(w http.ResponseWriter, req *http.Request) {io.WriteString(w, "帽儿山的枪手!\n")})log.Panicln(http.Serve(ln, nil))
}

ServeContent()

ServeContent() 函数，使用ReadSeeker所读取的内容回复给用户请求。

ServeContent比io.Copy更好的是，他能够合适的处理一批请求，设置MIME类型，并且能够处理文件是否修改的请求。

如果响应的内容类型头没有设置,该函数首先会尝试从文件的文件扩展名推断文件类型。 如果推断不出来，则会读取文件的第一个块并传送给DetectContentType来检测类型。

文件名称也可以不使用。 如果文字名称为空，则服务器不会传送给响应。 如果修改时间不为0，ServeContent会把它放在服务器响应的Last-Modified头里面。 如果客户端请求中包含了If-Modified-Since头，ServeContent会使用modtime来判断是否把内容传给客户端。
content的Seek方法必须能够工作。 ServeContent通过定位到文件结尾来确定文件大小。 *os.File中实现了io.ReadSeeker接口。

函数原型

func ServeContent(w ResponseWriter, req *Request, name string, modtime time.Time, content io.ReadSeeker)
  • 参数 w 服务器响应
  • 参数 req 客户端请求
  • 参数 name 文件名称
  • 参数 modtime 文件的修改时间
  • 参数 content 文件的内容，必须实现 io.ReadSeeker 这个接口中的方法

下面案例使用 ServeContent() 函数实现文件下载功能。
servecontent.go

func main() {http.HandleFunc("/download", func(w http.ResponseWriter, r *http.Request) {file := "servecontent.go"fileBytes, err := ioutil.ReadFile(file)if err != nil {panic(err)}mime := http.DetectContentType(fileBytes)fileSize := len(string(fileBytes))w.Header().Set("Content-Type", mime)w.Header().Set("Content-Disposition", "attachment; filename="+file)w.Header().Set("Content-Length", strconv.Itoa(fileSize))http.ServeContent(w, r, file, time.Now(), bytes.NewReader(fileBytes))})log.Fatal(http.ListenAndServe(":8080", nil))
}

首先通过 DetectContentType()函数获取了文件的 MIME 类型，然后将文件转换为 Byte 类型传入 ServeContent() 函数中实现下载功能。
结合上篇文章中介绍的 ServeFile()函数它实现起来更简洁仅需要一行代码实现文件下载，但前提需要知道文件上下文路径。
ServeContent() 函数更适用于当你只能拿到 byte[] 数据时，可以优先使用它。

DetectContentType()

DetectContentType() 该函数实现了一个算法，用来检测指定的数据是否符合该标准http://mimesniff.spec.whatwg.org 。

最多需要数据的前512个字节，DetectContentType()会返回一个有效的MIME类型。 如果它不能够识别数据，将会返回"application/octet-stream"。
函数原型

func DetectContentType(data []byte) string

函数使用

func main() {// image/pngfmt.Println(http.DetectContentType([]byte("\x89PNG\x0D\x0A\x1A\x0A")))// image/jpegfmt.Println(http.DetectContentType([]byte("\xFF\xD8\xFF")))
}

注：一些类型的识别，可以参考go源码测试用例。

MaxBytesReader()

MaxBytesReader() 函数，用来保护服务器端，以避免客户端偶然或者恶意发送的长数据请求导致的服务端资源的浪费。

MaxBytesReader()跟io.LimitReader函数很像。但是它被设计来设置接收的请求体的最大大小。 跟io.LimitReader不同MaxBytesReader()的返回值是一个ReadCloser，当读取超过限制时会返回non-nil错误。 并且当它调用关闭方法的时候会把潜在的读取者（函数/进程）也关闭掉。

函数原型

func MaxBytesReader(w ResponseWriter, r io.ReadCloser, n int64) io.ReadCloser
  • 参数 w服务器响应
  • 参数 r可以指向 req.Body
  • 参数 n限制大小

案例，限制客户端上传数据为10个字节。
maxbytesreader.go

func main() {http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {r.Body = http.MaxBytesReader(w, r.Body, 10)_, err := io.Copy(ioutil.Discard, r.Body)if err != nil {panic(err)}io.WriteString(w, "200\n")})log.Fatal(http.ListenAndServe(":8080", nil))
}

下面我们通过 curl 命令模拟客户端请求， 其中body内容已经超出了10个字节

root@hc:~# curl --location --request POST 'http://127.0.0.1:8080' \
--header 'Content-Type: application/json' \
--data-raw '{"t": "1234567890"
}'

请求完成后，看到服务端已经提示 请求Body过大。

技术文章持续更新，请大家多多关注呀~~

搜索微信公众号，关注我【 帽儿山的枪手 】

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/840821.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

科技前沿：IDEA插件Translation v3.6 带来革命性更新，翻译和发音更智能！

科技前沿：IDEA插件Translation v3.6 带来革命性更新，翻译和发音更智能！

博主猫头虎的技术世界 🌟 欢迎来到猫头虎的博客 — 探索技术的无限可能！ 专栏链接： 🔗 精选专栏： 《面试题大全》 — 面试准备的宝典！《IDEA开发秘籍》 — 提升你的IDEA技能！《100天精通鸿蒙》 …
阅读更多...
利用天气API接口自己DIY一个预报小管家

利用天气API接口自己DIY一个预报小管家

天气预报查询API 是一种实用的日常工具，它通过编程方式为开发者提供实时的天气数据。开发者可以通过简单的代码调用，与天气预报服务提供商进行交互，获取特定地区的天气信息，如温度、湿度、风速、风向、降水量等，以及未…
阅读更多...
OWASP top10--SQL注入（一）

OWASP top10--SQL注入（一）

SQL注入式攻击技术，一般针对基于Web平台的应用程序.造成SQL注入攻击漏洞的原因，是由于程序员在编写Web程序时，没有对浏览器端提交的参数进行严格的过滤和判断。用户可以修改构造参数，提交SQL查询语句，并传递至服务器端…
阅读更多...
XILINX FPGA DDR 学习笔记(一)

XILINX FPGA DDR 学习笔记(一)

DDR 内存的本质是数据的存储器，首先回到数据的存储上，数据在最底层的表现是地址。为了给每个数据进行存放并且在需要的时候读取这个数据，需要对数据在哪这个抽象的概念进行表述，我们科技树发展过程中把数据在哪用地址表示。一个数…
阅读更多...
K8S认证|CKA题库+答案| 11. 创建PVC

K8S认证|CKA题库+答案| 11. 创建PVC

11、创建PVC 您必须在以下Cluster/Node上完成此考题： Cluster Master node Worker node ok8s master …
阅读更多...
失落的方舟台服预下载教程 一键下载＋账号注册教程

失落的方舟台服预下载教程 一键下载＋账号注册教程

失落的方舟台服预下载教程 一键下载＋账号注册教程 是一款今年备受瞩目的游戏，将于5月30日正式上线，这款游戏搭建在虚幻引擎的基础上，为玩家们带来了极佳的视觉体验。这款游戏秉承着MMO类型游戏一贯的玩法，但是制作组在…
阅读更多...
海康威视硬盘录像机NVR连接公网视频监控平台，注册失败，抓包发现有403 forbidden的问题解决

海康威视硬盘录像机NVR连接公网视频监控平台，注册失败，抓包发现有403 forbidden的问题解决

目录 一、问题描述 二、问题定位 1、查看DVR的配置 2、查看需要使用的端口是否开放 3、查看日志 4、抓包 （1）找出错误 （2）查看数据包内容 三、问题分析 1、国标28181中的域的概念 2、域应该如何定义 （1&am…
阅读更多...
ChatGPT可以开车吗？分享大型语言模型在自动驾驶方面的应用案例

ChatGPT可以开车吗？分享大型语言模型在自动驾驶方面的应用案例

自动驾驶边缘案例需要复杂的、类似人类的推理，远远超出传统的算法和人工智能模型。而大型语言模型正在致力实现这一目标。 人工智能技术如今正在快速发展和应用，人工智能模型也是如此。拥有100亿个参数的通用模型的性能正在碾压拥有5000万个参数的任务特…
阅读更多...
缓存IO与直接IO

缓存IO与直接IO

IO类型 缓存 I/O 缓存 I/O 又被称作标准 I/O，大多数文件系统的默认 I/O 操作都是缓存 I/O。在 Linux 的缓存 I/O 机制中，数据先从磁盘复制到内核空间的缓冲区，然后从内核空间缓冲区复制到应用程序的地址空间（用户空间&#xff0…
阅读更多...
提示优化 | PhaseEvo：面向大型语言模型的统一上下文提示优化

提示优化 | PhaseEvo：面向大型语言模型的统一上下文提示优化

【摘要】为大型语言模型 (LLM) 制作理想的提示是一项具有挑战性的任务，需要大量资源和专家的人力投入。现有的工作将提示教学和情境学习示例的优化视为不同的问题，导致提示性能不佳。本研究通过建立统一的上下文提示优化框架来解决这一限制，旨…
阅读更多...
Langchain-Chatchat的markdownHeaderTextSplitter使用

Langchain-Chatchat的markdownHeaderTextSplitter使用

文章目录 背景排查步骤官方issue排查测试正常对话测试官方默认知识库Debug排查vscode配置launch.json命令行自动启动condadebug知识库搜索测试更换ChineseRecursiveTextSplitter分词器 结论 关于markdownHeaderTextSplitter的探索标准的markdown测试集Langchain区分head1和head…
阅读更多...
Linux驱动（2）---Linux内核的组成

Linux驱动（2）---Linux内核的组成

1.Linux内核源码目录 arch包含和硬件体系相关结构相关源码，每个平台占用一个目录 block：块设备驱动程序I/O调度 crypto：常用加密和三列算法，还有一些压缩和CRC校验算法。 documentation:内核个部分的通用解释和注释.。 drive…
阅读更多...
01_尚硅谷JavaWeb最新版笔记

01_尚硅谷JavaWeb最新版笔记

尚硅谷JAVAWEB概述 课程概述 计划学习时间：1周以内
阅读更多...
【2024软考】史上最全！软考刷题+解析大合集（9万字全手工打，货真价实）

【2024软考】史上最全！软考刷题+解析大合集（9万字全手工打，货真价实）

计算机基础知识 1.中断向量表用来保存各个中断源的中断服务程序的入口地址。当外设发出中断请求信号（INTR）以后，由中断控制器（INTC）确定其中断号，并根据中断号查找中断向量表来取得其中断服务程序的入口地…
阅读更多...
第86天：代码审计-PHP项目TP框架安全写法1day利用0day分析

第86天：代码审计-PHP项目TP框架安全写法1day利用0day分析

案例一： 利用框架漏洞-TP3框架-SQL注入&Demo&YxtCMF 首先先查询thinkphp的版本 去寻找版本漏洞: Thinkphp3.2.3及以下版本漏洞整理_thinkphp3.2.3漏洞-CSDN博客 去查这个exp注入 这里的利用条件是必须有find方法，并且where后面的参数是数组 …
阅读更多...
java基础-JVM日志、参数、内存结构、垃圾回收器

java基础-JVM日志、参数、内存结构、垃圾回收器

一、基础基础 1.1 数据类型 Java的数据类型分为原始数据类型和引用数据类型。 原始数据类型又分为数字型和布尔型。 数字型又有byte、short、int、long、char、float、double。注意，在这里char被定义为整数型，并且在规范中明确定义：byte、…
阅读更多...
电赛一等奖！基于TMS320F2812的简易数字频率计

电赛一等奖！基于TMS320F2812的简易数字频率计

电赛一等奖！简易数字频率计设计（原理图、PCB、源码、分析报告） 这份文件是关于合肥工业大学电气与自动化工程学院的一个项目报告，题目为“基于TMS320F2812的简易数字频率计”。项目由方敏、侯其立、李苗、张巧云四位本科生完成&am…
阅读更多...
Redis 哨兵机制的工作原理——Java全栈知识（22）

Redis 哨兵机制的工作原理——Java全栈知识（22）

Redis 哨兵机制的工作原理 在之前的文章我们讲到了 Redis 的三种集群架构：跳转文章：Redis集群模式 接下来我们详细讲哨兵机制的作用以及实现原理 以下是 Redis 哨兵的结构图 1、Redis 哨兵的作用 哨兵的作用如下： 1、监控，2、…
阅读更多...
【ArcGIS微课1000例】0111：谷歌地球Google Earth下载安装与使用教程

【ArcGIS微课1000例】0111：谷歌地球Google Earth下载安装与使用教程

一、谷歌地球安装 双击安装包，默认点击完成即可。 二、谷歌地球使用 打开快捷方式，开始使用谷歌地球。欢迎界面： 软件主界面： 三、谷歌地球下载 软件安装包位于《ArcGIS微课实验1000例(附数据)专栏配套完数据包中的0111.rar中…
阅读更多...
企业如何防止数据泄密？大型企业必备的文件加密软件

企业如何防止数据泄密？大型企业必备的文件加密软件

随着信息化建设的大步推进，越来越多的企业资料以电子文件的形式保存，企业内部和企业之间的信息交流也主要依靠电子文件。近年来的泄密事件层出不穷，比如东软泄密案、HTC窃密案、力拓案等，给企业带来灾难性的经济损失及信誉重创。如…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023