Go语言与PHP在HTTP POST请求中处理表单数据及签名的最佳实践

<?php
// ... (之前的代码，省略)

$parameters= array();
$parameters['nonce']    = usecTime();
$data = http_build_query($parameters); // 将数组编码为查询字符串

// ... (签名生成，省略)

// 初始化PHP curl代理
$ch = curl_init();
// ... (其他 curl_setopt 设置)
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $data); // 使用预编码的字符串作为POST请求体
// ... (执行请求)
?>

func NewRequest(method, url string, body io.Reader) (*Request, error)

package main

import (
    "bytes"
    "crypto/hmac"
    "crypto/sha512"
    "encoding/base64"
    "encoding/hex"
    "encoding/json"
    "fmt"
    "io/ioutil"
    "net/http"
    "net/url"
    "strconv"
    "strings"
    "time"

    // 假设在Google App Engine环境，使用urlfetch
    "google.golang.org/appengine"
    "google.golang.org/appengine/urlfetch"
)

// GenerateSignatureFromValues 根据密钥、端点和编码后的表单数据生成签名
func GenerateSignatureFromValues(secretKey string, endpoint string, encodedValues string) string {
    toEncode := []byte(endpoint)
    toEncode = append(toEncode, 0x00) // 拼接空字节
    toEncode = append(toEncode, []byte(encodedValues)...) // 拼接编码后的表单数据

    key := []byte(secretKey)
    hmacHash := hmac.New(sha512.New, key)
    hmacHash.Write(toEncode)
    answer := hmacHash.Sum(nil)

    // 注意：原始PHP示例中对hex编码后的字符串进行了ToLower，这里保持一致
    return base64.StdEncoding.EncodeToString(([]byte(strings.ToLower(hex.EncodeToString(answer)))))
}

// Call 执行API请求
func Call(c appengine.Context) (map[string]interface{}, error) {
    serverURL := "https://api.vaultofsatoshi.com"
    apiKey := "ENTER_YOUR_API_KEY_HERE"
    apiSecret := "ENTER_YOUR_API_SECRET_HERE"
    endpoint := "/info/order_detail" // 假设的端点

    // 1. 构建url.Values
    values := url.Values{}
    values.Set("nonce", strconv.FormatInt(time.Now().UnixNano()/1000, 10))

    // 2. 仅调用一次Encode()，确保签名和请求体数据一致
    encodedFormData := values.Encode()

    // 3. 生成签名，使用encodedFormData
    signature := GenerateSignatureFromValues(apiSecret, endpoint, encodedFormData)

    // 4. 将编码后的表单数据作为请求体
    reqBody := bytes.NewBufferString(encodedFormData)

    // 5. 创建HTTP请求，将reqBody作为body参数
    req, err := http.NewRequest("POST", serverURL+endpoint, reqBody)
    if err != nil {
        c.Errorf("Error creating request: %s", err)
        return nil, fmt.Errorf("error creating request: %w", err)
    }

    // 6. 设置HTTP头部
    req.Header.Set("Api-Key", apiKey)
    req.Header.Set("Api-Sign", signature)
    req.Header.Set("Content-Type", "application/x-www-form-urlencoded") // 显式设置Content-Type

    // 使用urlfetch.Transport发送请求 (适用于App Engine)
    tr := urlfetch.Transport{Context: c}
    resp, err := tr.RoundTrip(req)
    if err != nil {
        c.Errorf("API post error: %s", err)
        return nil, fmt.Errorf("API post error: %w", err)
    }
    defer resp.Body.Close()

    // 7. 读取响应
    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        c.Errorf("Error reading response body: %s", err)
        return nil, fmt.Errorf("error reading response body: %w", err)
    }

    if resp.StatusCode != http.StatusOK {
        c.Errorf("API response status: %d, body: %s", resp.StatusCode, string(body))
        return nil, fmt.Errorf("API returned non-OK status: %d, body: %s", resp.StatusCode, string(body))
    }

    result := make(map[string]interface{})
    if err := json.Unmarshal(body, &result); err != nil {
        c.Errorf("Error unmarshaling JSON response: %s", err)
        return nil, fmt.Errorf("error unmarshaling JSON response: %w", err)
    }

    return result, nil
}

// 示例用法（在App Engine环境中）
// func handler(w http.ResponseWriter, r *http.Request) {
//  c := appengine.NewContext(r)
//  result, err := Call(c)
//  if err != nil {
//      http.Error(w, err.Error(), http.StatusInternalServerError)
//      return
//  }
//  json.NewEncoder(w).Encode(result)
// }