Go语言Web服务：高效优雅地解析JSON POST请求体

package main

import (
    "encoding/json"
    "log"
    "net/http"
)

// 定义用于接收JSON数据的结构体
type test_struct struct {
    Test string
}

func test(rw http.ResponseWriter, req *http.Request) {
    req.ParseForm() // 错误：用于解析URL编码的表单数据，而非JSON请求体
    log.Println(req.Form)
    // LOG: map[{"test": "that"}:[]] - 整个JSON字符串被当作了一个表单键
    var t test_struct
    for key, _ := range req.Form {
        log.Println(key)
        // LOG: {"test": "that"}
        err := json.Unmarshal([]byte(key), &t) // 错误：从表单键中反序列化JSON
        if err != nil {
            log.Println(err.Error())
        }
    }
    log.Println(t.Test)
    // LOG: that
}

func main() {
    http.HandleFunc("/test", test)
    log.Fatal(http.ListenAndServe(":8082", nil))
}

package main

import (
    "encoding/json"
    "io"
    "log"
    "net/http"
)

// RequestPayload 定义了用于接收JSON数据的结构体
// 使用 `json:"fieldName"` 标签可以确保JSON字段名与Go结构体字段名的正确映射
type RequestPayload struct {
    Test string `json:"test"`
}

// handleJsonPost 是处理JSON POST请求的HTTP处理器函数
func handleJsonPost(rw http.ResponseWriter, req *http.Request) {
    // 1. 验证请求方法
    if req.Method != http.MethodPost {
        http.Error(rw, "Method Not Allowed", http.StatusMethodNotAllowed)
        return
    }

    // 2. 创建一个json.Decoder实例
    // 它将从请求体 req.Body 中读取数据。req.Body 是一个 io.ReadCloser。
    decoder := json.NewDecoder(req.Body)
    var payload RequestPayload // 定义一个结构体变量用于存储解码后的数据

    // 3. 使用 Decode 方法将请求体中的JSON数据解码到结构体中
    err := decoder.Decode(&payload)
    if err != nil {
        // 4. 错误处理
        // 如果请求体为空，Decode会返回io.EOF
        if err == io.EOF {
            http.Error(rw, "Request body is empty", http.StatusBadRequest)
            return
        }
        // 处理其他JSON解析错误，例如JSON格式不正确
        log.Printf("Error decoding JSON: %v", err)
        http.Error(rw, "Bad Request: Invalid JSON format", http.StatusBadRequest)
        return
    }

    // 5. 成功解码后，可以访问结构体中的数据
    log.Printf("Received payload: %+v", payload)
    log.Printf("Test field value: %s", payload.Test)

    // 6. 返回成功响应
    // 通常会设置 Content-Type 为 application/json
    rw.Header().Set("Content-Type", "application/json")
    // 使用 json.NewEncoder(rw).Encode() 将Go结构体编码为JSON并写入响应
    json.NewEncoder(rw).Encode(map[string]string{"message": "Data received successfully", "test_value": payload.Test})
}

func main() {
    // 注册HTTP处理器
    http.HandleFunc("/test", handleJsonPost)
    log.Println("Server starting on :8082")
    // 启动HTTP服务器
    log.Fatal(http.ListenAndServe(":8082", nil))
}

curl -X POST -H "Content-Type: application/json" -d '{"test": "hello from curl"}' http://localhost:8082/test