Go语言：高效处理HTTP请求中的JSON数组并反序列化为结构体切片

[
  {"name": "Rob"},
  {"name": "John"}
]

package main

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

// User 结构体用于映射JSON中的单个用户对象
type User struct {
    // `json:"name"` 是结构体标签（struct tag），
    // 它告诉encoding/json包，当进行JSON序列化或反序列化时，
    // Go结构体中的Name字段应与JSON中的"name"字段进行映射。
    Name string `json:"name"`
}

func readRequestBody(r *http.Request) ([]byte, error) {
    body, err := io.ReadAll(r.Body)
    if err != nil {
        return nil, fmt.Errorf("读取请求体失败: %w", err)
    }
    // 务必关闭请求体，以释放资源
    defer r.Body.Close()
    return body, nil
}

// parseUsers 函数接受一个包含JSON数组的字节切片，并尝试将其反序列化为User结构体切片
func parseUsers(jsonBuffer []byte) ([]User, error) {
    // 声明一个空的User结构体切片，用于存储反序列化后的数据
    var users []User

    // 使用json.Unmarshal进行反序列化。
    // 第一个参数是JSON数据的字节切片，
    // 第二个参数是指向目标Go数据结构的指针。
    // 注意这里是 &users，因为Unmarshal需要修改users切片的内容。
    err := json.Unmarshal(jsonBuffer, &users)
    if err != nil {
        return nil, fmt.Errorf("JSON反序列化失败: %w", err)
    }

    // 如果反序列化成功，users切片现在就包含了JSON数组中的所有用户数据
    return users, nil
}

package main

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

// User 结构体用于映射JSON中的单个用户对象
type User struct {
    Name string `json:"name"`
}

// handleUsersRequest 是一个HTTP处理程序，用于处理包含用户JSON数组的请求
func handleUsersRequest(w http.ResponseWriter, r *http.Request) {
    // 1. 检查请求方法
    if r.Method != http.MethodPost {
        http.Error(w, "只接受POST请求", http.StatusMethodNotAllowed)
        return
    }

    // 2. 从请求体读取JSON数据
    body, err := io.ReadAll(r.Body)
    if err != nil {
        http.Error(w, fmt.Sprintf("读取请求体失败: %v", err), http.StatusInternalServerError)
        return
    }
    defer r.Body.Close() // 确保关闭请求体

    // 3. 反序列化JSON数据到User结构体切片
    var users []User
    err = json.Unmarshal(body, &users)
    if err != nil {
        http.Error(w, fmt.Sprintf("JSON反序列化失败: %v", err), http.StatusBadRequest)
        return
    }

    // 4. 处理反序列化后的数据（例如，打印或存储）
    fmt.Println("成功接收并反序列化用户数据:")
    for i, user := range users {
        fmt.Printf("用户 %d: Name=%s\n", i+1, user.Name)
    }

    // 5. 返回成功响应
    w.WriteHeader(http.StatusOK)
    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(map[string]string{"message": "用户数据处理成功"})
}

func main() {
    http.HandleFunc("/users", handleUsersRequest)

    fmt.Println("服务器正在监听 :8080 端口...")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

curl -X POST -H "Content-Type: application/json" -d '[{"name": "Alice"}, {"name": "Bob"}]' http://localhost:8080/users

成功接收并反序列化用户数据:
用户 1: Name=Alice
用户 2: Name=Bob

{"message":"用户数据处理成功"}