golang的net/http库提供了创建http服务器和客户端的核心功能,支持路由定义、请求处理、客户端请求发送及响应解析,并具备性能优化与安全机制。1. 创建http服务器需注册路由与处理函数,并通过http.server配置超时等参数启动监听;2. http客户端可通过http.get、http.post或自定义http.client发起请求并处理响应;3. 请求处理中可通过*http.request获取方法、url、header、body等信息,通过http.responsewriter设置状态码与响应内容;4. 性能优化包括连接池、keep-alive、合理超时配置及优雅关闭;5. 安全性方面涵盖https/tls加密、输入验证、错误信息控制、cors配置及限流策略。

Golang的net/http库是构建网络应用的核心,它提供了一套简洁而强大的API,让你能够轻松地创建HTTP服务器来响应请求,或者作为HTTP客户端去访问外部资源。它把复杂的网络通信细节抽象化,让开发者可以专注于业务逻辑本身,无论是简单的API服务,还是复杂的微服务架构,net/http都能提供坚实的基础。

创建HTTP服务器的核心在于定义路由和处理函数,然后启动监听。而作为客户端,则需要构建请求并发送,然后解析服务器的响应。

创建HTTP服务器:
立即学习“go语言免费学习笔记(深入)”;
一个最基础的HTTP服务器通常包含一个处理函数和监听端口的逻辑。

package main
import (
"fmt"
"log"
"net/http"
"time" // 引入time包,用于演示超时配置
)
// homeHandler 是处理根路径请求的函数
func homeHandler(w http.ResponseWriter, r *http.Request) {
fmt.Fprintf(w, "你好,世界!这是Go HTTP服务器的响应。")
log.Printf("收到来自 %s 的请求: %s", r.RemoteAddr, r.URL.Path)
}
// aboutHandler 处理 /about 路径的请求
func aboutHandler(w http.ResponseWriter, r *http.Request) {
fmt.Fprintf(w, "这是一个关于页面,展示了Go的简洁魅力。")
log.Printf("收到来自 %s 的请求: %s", r.RemoteAddr, r.URL.Path)
}
func main() {
// 注册路由和对应的处理函数
http.HandleFunc("/", homeHandler)
http.HandleFunc("/about", aboutHandler)
// 我个人觉得,Go的net/http库在服务器配置方面做得非常人性化,
// 尤其是http.Server结构体,能让你对服务器的行为有更细致的掌控。
// 这里演示如何创建一个自定义配置的服务器。
server := &http.Server{
Addr: ":8080", // 监听端口
Handler: http.DefaultServeMux, // 默认的请求多路复用器
ReadTimeout: 5 * time.Second, // 读取请求头的超时时间
WriteTimeout: 10 * time.Second, // 写入响应的超时时间
IdleTimeout: 120 * time.Second, // 连接空闲超时时间
// MaxHeaderBytes: 1 << 20, // 可选:最大请求头大小,1MB
}
log.Println("HTTP服务器正在端口 8080 上启动...")
// 启动服务器监听,如果出错会阻塞并返回错误
if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
log.Fatalf("服务器启动失败: %v", err)
}
log.Println("服务器已关闭。")
}创建HTTP客户端:
客户端的创建相对直接,通常使用http.Get或http.Post等便捷函数,或者通过http.Client进行更细粒度的控制。
package main
import (
"fmt"
"io/ioutil"
"log"
"net/http"
"strings"
"time"
)
func main() {
// 1. 使用 http.Get 发送GET请求
log.Println("发送GET请求到 example.com...")
resp, err := http.Get("http://example.com")
if err != nil {
log.Printf("GET请求失败: %v", err)
} else {
defer resp.Body.Close() // 确保关闭响应体
body, _ := ioutil.ReadAll(resp.Body)
log.Printf("GET请求响应状态码: %d", resp.StatusCode)
// log.Printf("GET请求响应体: %s", body) // 响应体可能很大,这里不打印
_ = body // 避免unused variable警告
}
// 2. 使用 http.Post 发送POST请求 (application/x-www-form-urlencoded)
log.Println("发送POST请求到 httpbin.org/post (表单)...")
resp, err = http.Post("https://httpbin.org/post", "application/x-www-form-urlencoded",
strings.NewReader("name=Go&language=Golang"))
if err != nil {
log.Printf("POST请求失败: %v", err)
} else {
defer resp.Body.Close()
body, _ := ioutil.ReadAll(resp.Body)
log.Printf("POST请求响应状态码: %d", resp.StatusCode)
log.Printf("POST请求响应体: %s", string(body))
}
// 3. 使用 http.Client 进行更精细的控制,例如设置超时
log.Println("使用http.Client发送GET请求,并设置超时...")
client := &http.Client{
Timeout: 5 * time.Second, // 设置整个请求的超时时间
}
req, err := http.NewRequest("GET", "https://httpbin.org/delay/6", nil) // 这个请求会延迟6秒
if err != nil {
log.Printf("创建请求失败: %v", err)
return
}
resp, err = client.Do(req) // 发送请求
if err != nil {
// 这里会因为超时而失败
log.Printf("使用http.Client发送请求失败 (可能超时): %v", err)
} else {
defer resp.Body.Close()
body, _ := ioutil.ReadAll(resp.Body)
log.Printf("使用http.Client响应状态码: %d", resp.StatusCode)
log.Printf("使用http.Client响应体: %s", string(body))
}
}在Go的HTTP服务器里,每个传入的HTTP请求都会被抽象成一个*http.Request对象,而响应则通过http.ResponseWriter接口来构建。这两者是处理函数(http.HandlerFunc或实现http.Handler接口的类型)的两个核心参数。在我看来,http.Request的设计非常精妙,它几乎包含了你可能需要的所有请求信息,从URL、方法、Header到Body,一应俱全。
http.Request提供了丰富的字段和方法来访问请求的各个部分:
r.Method: 获取请求方法,如"GET", "POST", "PUT"等。r.URL: 这是一个*url.URL类型,包含了请求的路径、查询参数、Host等信息。比如 r.URL.Path 是请求的路径部分,r.URL.RawQuery 是原始的查询字符串。如果你需要解析查询参数,r.URL.Query() 会返回一个url.Values类型,可以通过r.URL.Query().Get("paramName")来获取特定参数。r.Header: 一个http.Header类型,本质上是map[string][]string,用于访问请求头。例如,r.Header.Get("User-Agent") 可以获取用户代理信息。r.Body: 这是一个io.ReadCloser接口,用于读取请求体。对于POST或PUT请求,你通常需要从这里读取数据,比如JSON或表单数据。记住,读取完后一定要关闭r.Body,即使没有读取完,也应该关闭,以释放底层资源。r.Form 和 r.PostForm: 如果请求的Content-Type是application/x-www-form-urlencoded或multipart/form-data,你可以调用r.ParseForm()或r.ParseMultipartForm(maxMemory)来解析表单数据,然后通过这两个字段访问。http.ResponseWriter则负责构建并发送HTTP响应。它是一个接口,提供了几个关键方法:
w.Header().Set("Content-Type", "application/json"): 通过Header()方法获取响应头,然后设置各种Header。w.WriteHeader(http.StatusOK): 设置HTTP状态码。注意,这个方法只能调用一次,并且通常在写入响应体之前调用。如果先写入了响应体,Go会自动发送一个200 OK状态码。fmt.Fprintf(w, "...") 或 w.Write([]byte("...")): 将数据写入响应体。Write方法接受字节切片,而Fprintf则更方便地格式化字符串。在实际项目中,处理函数内部的错误处理至关重要。如果处理过程中发生错误,比如数据库查询失败或参数校验不通过,你应该通过w.WriteHeader()设置相应的错误状态码(如http.StatusInternalServerError或http.StatusBadRequest),并可能在响应体中返回错误信息,而不是简单地让程序崩溃。另外,context.Context在请求处理中也扮演着越来越重要的角色,它允许你在请求的生命周期中传递请求范围的数据、取消信号和截止时间,这对于处理超时和优雅关闭服务器非常有帮助。
作为HTTP客户端,net/http库提供了多种方式来发起请求。最简单直接的莫过于http.Get()和http.Post(),它们适合那些不需要太多定制的场景。但说实话,在我的经验里,大部分生产环境下的客户端请求都需要更精细的控制,比如设置超时、自定义Header、处理重定向等,这时http.Client就成了不二之选。
http.Get(url string): 发送一个GET请求到指定的URL。它返回*http.Response和error。这是最简单的GET请求方式,但它内部使用了默认的http.DefaultClient,这意味着你无法控制超时等行为。
http.Post(url, contentType string, body io.Reader): 发送一个POST请求。contentType参数指定请求体的MIME类型(如application/json,application/x-www-form-urlencoded),body参数是一个io.Reader,用于提供请求体数据。
http.PostForm(url string, data url.Values): 专门用于发送application/x-www-form-urlencoded类型的POST请求,data是一个url.Values类型,非常方便。
http.Client: 这是最强大和灵活的客户端构建方式。你可以创建一个http.Client实例,并对其进行配置:
client.Timeout: 设置整个请求(包括连接、发送请求、接收响应)的超时时间。这是我个人觉得最常用的一个配置项,避免了请求长时间阻塞。client.Transport: 这是一个http.RoundTripper接口,允许你自定义底层HTTP传输行为,比如设置连接池、TLS配置、代理等。http.DefaultTransport是默认的实现,通常已经足够好。client.CheckRedirect: 一个函数,用于控制重定向行为。默认情况下,客户端会自动跟随重定向。使用http.Client发起请求的标准流程是:
对象**:req, err := http.NewRequest(method, url, body)。method可以是"GET", "POST", "PUT"等,body同样是一个io.Reader`。req.Header.Set("Authorization", "Bearer token")。client.Do(req)发送请求:这个方法返回*http.Response和error。处理响应:
无论通过哪种方式发起请求,你都会得到一个*http.Response对象。处理响应的关键步骤通常包括:
client.Do()或http.Get()等函数返回的error,这可能是网络问题、DNS解析失败或超时等。defer resp.Body.Close()是必须的,即使你没有读取响应体,也要确保关闭它,以释放底层网络连接资源。resp.StatusCode会返回HTTP状态码(如200, 404, 500等)。通常需要检查resp.StatusCode == http.StatusOK来判断请求是否成功。body, err := ioutil.ReadAll(resp.Body)。读取到的body是[]byte类型,你可以根据resp.Header.Get("Content-Type")来决定如何解析它,比如解析JSON (json.Unmarshal) 或XML。在我日常工作中,我发现很多人会忽略resp.Body.Close(),这在并发量大的情况下很容易导致文件描述符耗尽或者连接泄露,所以务必注意。
构建一个健壮的HTTP服务器,除了实现业务逻辑,性能和安全性是两个不可忽视的维度。Go的net/http库在这方面提供了很多开箱即用的能力,但也需要开发者有意识地去配置和使用。
性能优化:
net/http默认支持HTTP/1.1的Keep-Alive机制,这意味着客户端和服务器之间的TCP连接在一次请求-响应周期后不会立即关闭,而是保持一段时间,以便处理后续请求。这大大减少了连接建立和关闭的开销。对于客户端,http.DefaultClient内部也维护着连接池,这在并发请求量大时尤其重要。我有时会遇到一些老旧系统不支持Keep-Alive,导致连接频繁建立,这种情况下性能会大打折扣。http.Server的ReadTimeout, WriteTimeout, IdleTimeout。这些超时设置对于防止慢速客户端攻击、确保资源及时释放至关重要。ReadTimeout: 限制读取客户端请求头的总时间。WriteTimeout: 限制写入响应的总时间。IdleTimeout: 限制Keep-Alive连接在关闭前可以空闲的最长时间。
合理配置这些超时能有效提升服务器的韧性。http.Server.Shutdown(ctx context.Context)方法提供了优雅关闭的能力。结合os.Interrupt信号和context.WithTimeout,可以在接收到关闭信号后,等待现有请求处理完毕,并在一个限定时间内完成关闭,这对于保持服务连续性至关重要。// 优雅关闭的简化示例
// func main() {
// server := &http.Server{Addr: ":8080", Handler: http.DefaultServeMux}
// go func() {
// if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
// log.Fatalf("listen: %s\n", err)
// }
// }()
// quit := make(chan os.Signal, 1)
// signal.Notify(quit, os.Interrupt, syscall.SIGTERM) // 监听中断和终止信号
// <-quit // 阻塞直到收到信号
// log.Println("Shutting down server...")
// ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) // 5秒内完成关闭
// defer cancel()
// if err := server.Shutdown(ctx); err != nil {
// log.Fatalf("Server forced to shutdown: %v", err)
// }
// log.Println("Server exiting")
// }安全性考量:
net/http通过http.ListenAndServeTLS(addr, certFile, keyFile, handler)提供了原生支持。你需要提供TLS证书和私钥文件。这是加密客户端和服务器之间通信最基本也是最重要的手段。go-playground/validator)可以帮助你。Access-Control-Allow-Origin等响应头,或者使用第三方库如github.com/rs/cors。net/http没有内置的限流功能,但可以通过中间件的方式实现,例如使用令牌桶算法(如golang.org/x/time/rate包)。在我看来,安全性不是一个可以事后添加的功能,它应该贯穿于整个开发生命周期。特别是HTTPS,在今天简直是标配,没有HTTPS的网站和服务,几乎寸步难行。
以上就是Golang的net/http库如何使用 详解HTTP服务器与客户端的创建方法的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号