Go语言：高效解码Base64编码的HTTP请求体到二进制数据流

import (
    "encoding/base64"
    "io/ioutil"
    "net/http"
)

func handleBase64Upload(w http.ResponseWriter, r *http.Request) {
    // 错误示范：试图将r.Body直接转换为字符串
    // r.Body 是一个 io.ReadCloser，不能直接转换为字符串
    // data, err := ioutil.ReadAll(r.Body)
    // if err != nil { /* ... */ }
    // base64String := string(data) // 此时 base64String 包含了原始的 Base64 字符串
    // decodedBytes, err := base64.StdEncoding.DecodeString(base64String)
    // if err != nil { /* ... */ }
    // ...
}

func NewDecoder(enc *Encoding, r io.Reader) io.Reader

package main

import (
    "bytes"
    "encoding/base64"
    "fmt"
    "io"
    "log"
    "net/http"
    "os"
)

// handleBase64Upload 处理Base64编码的请求体
func handleBase64Upload(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodPost {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    // 1. 创建一个Base64解码器，它直接从 r.Body 读取数据
    // dec 是一个 io.Reader，从它读取的数据将是 r.Body 解码后的二进制数据
    dec := base64.NewDecoder(base64.StdEncoding, r.Body)

    // 2. 将解码后的二进制数据处理到目标位置
    // 目标可以是：
    //    a) bytes.Buffer (如果数据量不大，需要存储在内存中)
    //    b) 文件 (如果需要保存到磁盘)
    //    c) 另一个 http.ResponseWriter (如果需要直接转发)

    // 示例 a: 将解码后的数据复制到 bytes.Buffer (适用于小文件或内存处理)
    buf := &bytes.Buffer{}
    n, err := io.Copy(buf, dec)
    if err != nil {
        http.Error(w, fmt.Sprintf("Failed to copy decoded data to buffer: %v", err), http.StatusInternalServerError)
        return
    }
    fmt.Printf("Successfully decoded %d bytes into buffer.\n", n)
    // 此时，buf.Bytes() 包含了完整的原始二进制数据
    // 例如，如果上传的是图片，可以将其保存为文件：
    // err = os.WriteFile("decoded_image_from_buffer.png", buf.Bytes(), 0644)
    // if err != nil {
    //     log.Printf("Error writing file from buffer: %v", err)
    // }

    // 示例 b: 直接将解码后的数据写入文件 (推荐用于大文件)
    // file, err := os.Create("decoded_output.bin")
    // if err != nil {
    //  http.Error(w, fmt.Sprintf("Failed to create file: %v", err), http.StatusInternalServerError)
    //  return
    // }
    // defer file.Close() // 确保文件在函数结束时关闭
    //
    // n, err = io.Copy(file, dec) // 注意：如果上面已经从dec读取过，这里将无数据可读
    // if err != nil {
    //  http.Error(w, fmt.Sprintf("Failed to copy decoded data to file: %v", err), http.StatusInternalServerError)
    //  return
    // }
    // fmt.Printf("Successfully decoded %d bytes to file: decoded_output.bin\n", n)


    // 3. 返回成功响应
    w.WriteHeader(http.StatusOK)
    w.Write([]byte(fmt.Sprintf("Base64 data decoded and processed. Total bytes: %d", n)))
}

func main() {
    http.HandleFunc("/upload-base64", handleBase64Upload)

    port := ":8080"
    fmt.Printf("Server listening on port %s\n", port)
    log.Fatal(http.ListenAndServe(port, nil))
}

curl -X POST -H "Content-Type: text/plain" --data "SGVsbG8sIEdvIQ==" http://localhost:8080/upload-base64