http上传文件客户端和服务端代码

package com.itrus.controller; import okhttp3.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.multipart.commons.CommonsMultipartFile; import javax.servlet.http.HttpServletRequest; import java.io.*; import java.text.SimpleDateFormat; import java.util.Date; /** * @Author jiangwenhui * @Description * @Date Created in 2017/12/25 0025 */ @RestController @RequestMapping("/file") public class FileController { private static final Logger logger = LoggerFactory.getLogger(FileController.class); //请求路径 private static final String url = "http://localhost:8080/file-service-demo/file/upload"; //文件分隔符 private static final String separator = File.separator; //media type private static final MediaType MEDIA_TYPE = MediaType.parse("media/type"); //okhttp-client private final OkHttpClient client = new OkHttpClient(); //编码 public static final MediaType JSON = MediaType.parse("application/json;charset=utf-8"); /** * 本地单文件上传 */ public void uploadFileLocalSingle() { //获取文件 File file = new File("E:" + separator +"testFileUpload"+ separator + "eclipse-jee-luna-SR1-win32-x86_64.zip"); //设置请求body RequestBody body = new MultipartBody.Builder() .addFormDataPart("file", file.getName(), RequestBody.create(MediaType.parse("media/type"), file)) .setType(MultipartBody.FORM) .build(); final SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式 final String startTime = df.format(new Date()); System.out.println("当前时间" + startTime);// new Date()为获取当前系统时间 //返回相应 Response response = null; try { //创建请求 Request request = new Request.Builder() .url(url) .post(body) .build(); //发起请求 Call call = client.newCall(request); call.enqueue(new Callback() { public void onFailure(Call call, IOException e) { e.printStackTrace(); } public void onResponse(Call call, Response response){ if (!response.isSuccessful()) { System.out.println("Unexpected code " + response.code()); } else { ResponseBody responseBody = response.body(); if(null != responseBody){ System.out.println("上传成功"); final String endTime = df.format(new Date()); System.out.println("结束时间 " + endTime); }else { System.out.println("responseBody is null"); } } } }); } catch (Exception e) { e.printStackTrace(); } finally { if(null != response){ response.close(); } } } /** * 本地多文件上传 */ public void uploadFileMult(){ //获取文件 File file1 = new File("E:" + separator + "testFileUpload" + "171221线上快裁业务流程V1.5(1).pdf"); File file2 = new File("E:" + separator + "testFileUpload" + "test1.txt"); File file3 = new File("E:" + separator + "testFileUpload" + "test2.txt"); RequestBody filebody1 = RequestBody.create(MEDIA_TYPE,file1); RequestBody filebody2 = RequestBody.create(MEDIA_TYPE,file2); RequestBody filebody3 = RequestBody.create(MEDIA_TYPE,file3); MultipartBody mBody = new MultipartBody.Builder() .setType(MultipartBody.FORM) .addFormDataPart("file" , file1.getName() , filebody1) .addFormDataPart("file" , file2.getName() , filebody2) .addFormDataPart("file" , file3.getName(), filebody3) .build(); //返回相应 Response response = null; try { //创建请求 Request request = new Request.Builder() .url(url) .post(mBody) .build(); //发起请求 Call call = client.newCall(request); call.enqueue(new Callback() { public void onFailure(Call call, IOException e) { } public void onResponse(Call call, Response response){ if (!response.isSuccessful()) { System.out.println("Unexpected code " + response.code()); } else { ResponseBody responseBody = response.body(); if(null != responseBody){ System.out.println(responseBody.toString()); }else { System.out.println("responseBody is null"); } } } }); } catch (Exception e) { e.printStackTrace(); } finally { if(null != response){ response.close(); } } } public static void main(String[] args) { FileController fileController = new FileController(); //fileController.uploadFileMult(); //多文件 fileController.uploadFileLocalSingle(); //单文件 } @RequestMapping("/upload") public String upload(@RequestParam("allFile") CommonsMultipartFile[] files, HttpServletRequest request){ for(int i = 0;i<files.length;i++){ System.out.println("fileName---------->" + files[i].getOriginalFilename()); CommonsMultipartFile commonsMultipartFiles = files[i]; try { InputStream inputStream = commonsMultipartFiles.getInputStream(); } catch (IOException e) { e.printStackTrace(); } if(!files[i].isEmpty()){ int pre = (int) System.currentTimeMillis(); try { //拿到输出流，同时重命名上传的文件 FileOutputStream os = new FileOutputStream("E:/" + System.currentTimeMillis() + files[i].getOriginalFilename()); //拿到上传文件的输入流 FileInputStream in = (FileInputStream) files[i].getInputStream(); //以写字节的方式写文件 int b = 0; while((b=in.read()) != -1){ os.write(b); } os.flush(); os.close(); in.close(); int finaltime = (int) System.currentTimeMillis(); System.out.println(finaltime - pre); } catch (Exception e) { e.printStackTrace(); System.out.println("上传出错"); } } } return "/success"; } }