Spring：文件上传RESTFUL Web服务

我正在使用Spring 4.0为RESTFUL Web服务创建POC。 如果我们只传递String或任何其他基本dataype，它工作正常。

@RequestMapping(value="/upload/file", method=RequestMapping.post) public String uploadFile(@RequestParam("fileName", required=false) String fileName){ logger.info("initialization of object"); //---------------------------------------- System.out.Println("name of File : " + fileName); //---------------------------------------- } 

这很好用。 但如果我想传递字节流或文件对象function，我怎么能写这个具有这些参数的function？ 如何编写提供传递字节流的客户端？

 @RequestMapping(value="/upload/file", method=RequestMapping.post) public String uploadFile(@RequestParam("file", required=false) byte [] fileName){ //--------------------- // } 

我尝试了这段代码，但得到了415错误。

 @RequestMapping(value = "/upload/file", method = RequestMethod.POST, consumes="multipart/form-data") public @ResponseBody String uploadFileContentFromBytes(@RequestBody MultipartFormDataInput input, Model model) { logger.info("Get Content. "); //------------ } 

客户端代码 – 使用apache HttpClient

 private static void executeClient() { HttpClient client = new DefaultHttpClient(); HttpPost postReqeust = new HttpPost(SERVER_URI + "/file"); try{ // Set Various Attributes MultipartEntity multipartEntity = new MultipartEntity(); multipartEntity.addPart("fileType" , new StringBody("DOCX")); FileBody fileBody = new FileBody(new File("D:\\demo.docx"), "application/octect-stream"); // prepare payload multipartEntity.addPart("attachment", fileBody); //Set to request body postReqeust.setEntity(multipartEntity); HttpResponse response = client.execute(postReqeust) ; //Verify response if any if (response != null) { System.out.println(response.getStatusLine().getStatusCode()); } } catch(Exception ex){ ex.printStackTrace(); } 

Answer 1

您可以像下面一样创建rest服务。

 @RequestMapping(value="/upload", method=RequestMethod.POST) public @ResponseBody String handleFileUpload( @RequestParam("file") MultipartFile file){ String name = "test11"; if (!file.isEmpty()) { try { byte[] bytes = file.getBytes(); BufferedOutputStream stream = new BufferedOutputStream(new FileOutputStream(new File(name + "-uploaded"))); stream.write(bytes); stream.close(); return "You successfully uploaded " + name + " into " + name + "-uploaded !"; } catch (Exception e) { return "You failed to upload " + name + " => " + e.getMessage(); } } else { return "You failed to upload " + name + " because the file was empty."; } } 

而对于客户端，请在下面进行。

 import java.io.File; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.HttpVersion; import org.apache.http.client.HttpClient; import org.apache.http.client.methods.HttpPost; import org.apache.http.entity.mime.MultipartEntity; import org.apache.http.entity.mime.content.ContentBody; import org.apache.http.entity.mime.content.FileBody; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.params.CoreProtocolPNames; import org.apache.http.util.EntityUtils; public class Test { public static void main(String[] args) throws Exception { HttpClient httpclient = new DefaultHttpClient(); httpclient.getParams().setParameter(CoreProtocolPNames.PROTOCOL_VERSION, HttpVersion.HTTP_1_1); HttpPost httppost = new HttpPost("http://localhost:8080/upload"); File file = new File("C:\\Users\\Kamal\\Desktop\\PDFServlet1.pdf"); MultipartEntity mpEntity = new MultipartEntity(); ContentBody cbFile = new FileBody(file, "multipart/form-data"); mpEntity.addPart("file", cbFile); httppost.setEntity(mpEntity); System.out.println("executing request " + httppost.getRequestLine()); HttpResponse response = httpclient.execute(httppost); HttpEntity resEntity = response.getEntity(); System.out.println(response.getStatusLine()); if (resEntity != null) { System.out.println(EntityUtils.toString(resEntity)); } if (resEntity != null) { resEntity.consumeContent(); } httpclient.getConnectionManager().shutdown(); } } 

Answer 2