Go语言中将HTTP请求体中的JSON数组反序列化为结构体切片

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

package main

import "encoding/json"

// User 结构体用于匹配JSON中的用户对象
type User struct {
    // `json:"name"` 是结构体标签（struct tag），
    // 它告诉 `encoding/json` 包在反序列化时，
    // 将JSON中的 "name" 字段映射到 Go 结构体的 Name 字段。
    Name string `json:"name"`
}

import (
    "io" // 推荐使用 io.ReadAll
    "net/http"
)

func readRequestBody(r *http.Request) ([]byte, error) {
    // io.ReadAll 从 r.Body 中读取所有数据直到 EOF
    // 注意：r.Body 是一个 io.Reader，读取后会被消耗，不能重复读取。
    body, err := io.ReadAll(r.Body)
    if err != nil {
        return nil, err // 返回读取错误
    }
    return body, nil
}

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

    // json.Unmarshal 将 jsonBuffer 中的数据反序列化到 users 变量中。
    // 注意：第二个参数必须是指向目标变量的指针（&users）。
    err := json.Unmarshal(jsonBuffer, &users)
    if err != nil {
        return nil, 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"`
}

// handleUsersPost 是一个 HTTP 处理函数，用于接收并解析用户数组
func handleUsersPost(w http.ResponseWriter, r *http.Request) {
    // 1. 检查请求方法
    if r.Method != http.MethodPost {
        http.Error(w, "Only POST method is allowed", http.StatusMethodNotAllowed)
        return
    }

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

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

    // 4. 处理解析后的用户数据（此处仅打印）
    fmt.Printf("Received %d users:\n", len(users))
    for i, user := range users {
        fmt.Printf("  User %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": "Users processed successfully"})
}

func main() {
    // 注册 HTTP 处理函数
    http.HandleFunc("/users", handleUsersPost)

    // 启动 HTTP 服务器
    port := ":8080"
    fmt.Printf("Server listening on port %s\n", port)
    log.Fatal(http.ListenAndServe(port, nil))
}