寫入管讀數到golang

Question

這裏http響應是模式：

客戶端發送POST請求到服務器A

服務器A進程的這一和發送GET到服務器B

服務器B發送通過一個響應到客戶端

---

不過，我覺得最好的辦法是讓這將讀取的GET的響應，並寫入到POST的響應管道，但我有很多類型的問題。

func main() { 
    r := mux.NewRouter() 
    r.HandleFunc("/test/{hash}", testHandler) 

    log.Fatal(http.ListenAndServe(":9095", r)) 
} 

func handleErr(err error) { 
    if err != nil { 
     log.Fatalf("%s\n", err) 
    } 
} 


func testHandler(w http.ResponseWriter, r *http.Request){ 

    fmt.Println("FIRST REQUEST RECEIVED") 
    vars := mux.Vars(r) 
    hash := vars["hash"] 
    read, write := io.Pipe() 

    // writing without a reader will deadlock so write in a goroutine 
    go func() { 
     write, _ = http.Get("http://localhost:9090/test/" + hash) 
     defer write.Close() 
    }() 

    w.Write(read) 
} 

當我運行此我得到以下錯誤：

./ReverseProxy.go:61：不能在參數中使用讀取（鍵入* io.PipeReader）類型[]字節w.Write

有沒有辦法，以正確地插入到http響應io.PipeReader格式？ 還是我以完全錯誤的方式做這件事？

Answer 1

你實際上沒有寫信給它，你正在替換管道的寫入。

func testHandler(w http.ResponseWriter, r *http.Request) { 

    fmt.Println("FIRST REQUEST RECEIVED") 

    vars := mux.Vars(r) 
    hash := vars["hash"] 

    read, write := io.Pipe() 

    // writing without a reader will deadlock so write in a goroutine 
    go func() { 
     defer write.Close() 
     resp, err := http.Get("http://localhost:9090/test/" + hash) 
     if err != nil { 
      return 
     } 
     defer resp.Body.Close() 
     io.Copy(write, resp.Body) 

    }() 

    io.Copy(w, read) 

} 

雖然，我與@JimB同意，對於這種情況下，甚至沒有必要管，這樣的事情應該是更有效：

func testHandler(w http.ResponseWriter, r *http.Request) { 
    vars := mux.Vars(r) 
    hash := vars["hash"] 

    resp, err := http.Get("http://localhost:9090/test/" + hash) 
    if err != nil { 
     // handle error 
     return 
    } 
    defer resp.Body.Close() 

    io.Copy(w, resp.Body) 
} 

沿線的

東西