我正在嘗試執(zhí)行以下操作。|Upload file in HTML post file form| | ?|Server A forwards the multipart request| | ? |Server B receives and stores the file from the forwarded multipart request| | ?|Server A receives response from Server B when Server B is done|在服務(wù)器 A 上處理多部分請(qǐng)求很簡(jiǎn)單，但是當(dāng)我嘗試在服務(wù)器 B 上處理轉(zhuǎn)發(fā)的請(qǐng)求時(shí)，它失敗。multipart: NextPart: EOF我正在嘗試創(chuàng)建單獨(dú)的前端/后端服務(wù)。前端只處理與UI相關(guān)的處理，而后端實(shí)際上會(huì)對(duì)文件進(jìn)行一些處理，因此需要多部分請(qǐng)求轉(zhuǎn)發(fā)。服務(wù)器 A 上的轉(zhuǎn)發(fā)代碼如下所示。解決方案已從這里開始。https://stackoverflow.com/a/34725635/6569715func forwardRequest(address string, path string, r *http.Request) (interface{}, error) { body, err := ioutil.ReadAll(r.Body) if err != nil { return nil, err } r.Body = ioutil.NopCloser(bytes.NewReader(body)) proxyReq, err := http.NewRequest(r.Method, fmt.Sprintf("%s%s", address, path), bytes.NewReader(body)) if err != nil { return nil, err } for header, values := range r.Header { for _, value := range values { proxyReq.Header.Add(header, value) } } client := &http.Client{} resp, err := client.Do(proxyReq) if err != nil { return nil, err } defer resp.Body.Close() return resp, nil}以及服務(wù)器 B 上用于處理轉(zhuǎn)發(fā)請(qǐng)求的代碼：func testMultiPart(w http.ResponseWriter, r *http.Request) { if err := r.ParseMultipartForm(10 << 20); err != nil { err = errors.Wrap(errors.WithStack(err), "Backend: Failed to parse form") w.WriteHeader(http.StatusInternalServerError) fmt.Fprint(w, fmt.Sprintf("{\"error\":\"%s\"}", err.Error()) return }}任何幫助是值得贊賞的。
1 回答
叮當(dāng)貓咪
TA貢獻(xiàn)1776條經(jīng)驗(yàn) 獲得超12個(gè)贊
我設(shè)法讓它工作。我相信這只是我自己的錯(cuò)誤，沒有正確填寫URI。無論如何，我將發(fā)布我的解決方案中的片段以供將來參考。
客戶端 html 文件格式部分：
<form action="/test-main/file-test" enctype="multipart/form-data" method="post">
<label for="file-upload">Upload your file :</label>
<input type="file" id="file-upload" name="file-upload" accept="image/*">
</form>
服務(wù)器 A 代碼：
import (
"net/http"
"errors"
"fmt"
"log"
"io/ioutil"
"bytes"
"github.com/gorilla/mux"
)
func fileUpload(w http.ResponseWriter, r *http.Request) {
body, err := ioutil.ReadAll(r.Body)
if err != nil {
return log.Fatal(err)
}
r.Body = ioutil.NopCloser(bytes.NewReader(body))
// If Server A and B are separate docker images, you may need to use their docker subnet IP, like below.
proxyReq, err := http.NewRequest(r.Method, fmt.Sprintf("http://172.18.0.2:8082%s", r.RequestURI), bytes.NewReader(body))
if err != nil {
return log.Fatal(err)
}
for header, values := range r.Header {
for _, value := range values {
proxyReq.Header.Add(header, value)
}
}
client := &http.Client{}
resp, err := client.Do(proxyReq)
if err != nil {
return log.Fatal(err)
}
defer resp.Body.Close()
respBody, err := ioutil.ReadAll(resp.Body)
if err != nil {
return log.Fatal(err)
}
// Process Server B response
// ...
}
func createRouter() *mux.Router {
r := mux.NewRouter()
testPath := r.PathPrefix("/test-main").Subrouter()
testPath.HandleFunc("/file-test", fileUpload)
return r
}
func main() {
// Create Server and Route Handlers
srv := &http.Server{
Handler: createRouter(),
Addr: ":8081",
ReadTimeout: 30 * time.Second,
WriteTimeout: 30 * time.Second,
}
// Start Server
go func() {
log.Println("Starting Server")
if err := srv.ListenAndServe(); err != nil {
log.Fatal(err)
}
}()
}
和服務(wù)器 B 代碼：
import (
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
"github.com/gorilla/mux"
)
func uploadFile(w http.ResponseWriter, r *http.Request) {
if err := r.ParseMultipartForm(10 << 20); err != nil {
log.Fatal(err)
}
file, handler, err := r.FormFile("file-upload")
if err == http.ErrMissingFile {
return nil
}
if err != nil {
log.Fatal(err)
}
fmt.Printf("Uploaded File: %+v\n", handler.Filename)
fmt.Printf("File Size: %+v\n", handler.Size)
fmt.Printf("MIME Header: %+v\n", handler.Header)
defer file.Close()
// Create file
dst, err := os.Create(fmt.Sprintf("/some-destination-folder/%s", handler.Filename))
if err != nil {
log.Fatal(err)
}
// Copy the uploaded file to the created file on the file system.
if _, err := io.Copy(dst, file); err != nil {
if err2 := dst.Close(); err2 != nil {
log.Fatal(err)
}
log.Fatal(err)
}
dst.Close()
return nil
}
func (c *Controller) createRouter() *mux.Router {
r := mux.NewRouter()
testPath := r.PathPrefix("/test-main").Subrouter()
testPath.HandleFunc("/file-test", uploadFile)
return r
}
func main() {
// Create Server and Route Handlers
srv := &http.Server{
Handler: createRouter(),
Addr: ":8082",
ReadTimeout: 30 * time.Second,
WriteTimeout: 30 * time.Second,
}
// Start Server
go func() {
log.Println("Starting Server")
if err := srv.ListenAndServe(); err != nil {
log.Fatal(err)
}
}()
}
祝未來的讀者好運(yùn)。
- 1 回答
- 0 關(guān)注
- 170 瀏覽
添加回答
舉報(bào)
0/150
提交
取消