1 回答
TA贡献1858条经验 获得超8个赞
在您的示例中,您试图读取 r.Body 就好像它是从请求的 PDF 部分中剥离出来的一样,但事实并非如此。您需要分别处理 PDF 和 JSON 这两个部分。使用http.(*Request).MultipartReader()。
r.MultipartReader() 将返回mime/multipart.Reader对象,因此您可以使用r.NextPart()函数迭代各个部分并分别处理每个部分。
所以你的处理函数应该是这样的:
func (s *Server) PostFileHandler(w http.ResponseWriter, r *http.Request) {
mr, err := r.MultipartReader()
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
doc := Doc{}
for {
part, err := mr.NextPart()
// This is OK, no more parts
if err == io.EOF {
break
}
// Some error
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
// PDF 'file' part
if part.FormName() == "file" {
doc.Url = part.FileName()
fmt.Println("URL:", part.FileName())
outfile, err := os.Create("./docs/" + part.FileName())
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
defer outfile.Close()
_, err = io.Copy(outfile, part)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
}
// JSON 'doc' part
if part.FormName() == "doc" {
jsonDecoder := json.NewDecoder(part)
err = jsonDecoder.Decode(&doc)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
fmt.Println(doc.Title, doc.Url, doc.Cat, doc.Date)
}
}
doc.Id = len(docs) + 1
err = s.db.Insert(&doc)
checkErr(err, "Insert failed")
s.Ren.JSON(w, http.StatusOK, &doc)
}
- 1 回答
- 0 关注
- 353 浏览
添加回答
举报