接上篇
java多文件上传plupload控件实现多图片上传（一）
续写PluploadUtil 和 Plupload PO类，以及后台的action。
至此，可实现多文件上传功能。
上传文件Action类：
import gwm.xtkf.rights.domain.UserSession; import gwm.xtkf.tool.AliyunOSSUtil; import gwm.xtkf.tool.ResourceUtil; import gwm.xtkf.tool.ResultMessage; import gwm.zls.filemanage.util.Plupload; import gwm.zls.filemanage.util.PluploadUtil; import java.io.IOException; import java.util.Date; import java.util.List; import java.util.UUID; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.multipart.MultipartFile; import xs.jszx.housemanage.domain.HousePic; import xs.jszx.housemanage.service.HousePicService; @Controller @RequestMapping("/housePicController") public class HousePicController { @Autowired private HousePicService housePicService; //多文件上传 @RequestMapping("/saveHousePics" ) public String saveHousePics(HousePic housePic,Plupload plupload,HttpServletRequest request,HttpServletResponse response,HttpSession session) throws IllegalStateException, IOException { UserSession userSession = (UserSession)session.getAttribute("userSession"); plupload.setRequest(request); //文件存储路径 String fileName = plupload.getName(); String suffix = fileName.substring(fileName.lastIndexOf("."), fileName.length()); String realName = UUID.randomUUID().toString() + suffix; try { PluploadUtil.upload2AliyunOSS(plupload, realName); //判断文件是否上传成功（被分成块的文件是否全部上传完成） if (PluploadUtil.isUploadFinish(plupload)) { housePic.setRealName(realName); housePic.setUserId(userSession.getUserId()); housePic.setCreateTime(new Date()); //写入数据库 if (this.housePicService.saveHousePic(housePic)){ return "housemanage/pic_inc/pic_houseMain"; } } } catch (IllegalStateException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return "housemanage/pic_inc/pic_houseMain"; }
PluploadUtil类：
import gwm.xtkf.tool.AliyunOSSUtil; import gwm.xtkf.tool.ResourceUtil; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.Iterator; import java.util.List; import org.springframework.util.MultiValueMap; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; public class PluploadUtil { private static final int BUF_SIZE = 2 * 1024; /**上传失败响应的成功状态码*/ public static final String RESP_SUCCESS = "{\"jsonrpc\" : \"2.0\", \"result\" : \"success\", \"id\" : \"id\"}"; /**上传失败响应的失败状态码*/ public static final String RESP_ERROR = "{\"jsonrpc\" : \"2.0\", \"error\" : {\"code\": 101, \"message\": \"Failed to open input stream.\"}, \"id\" : \"id\"}"; /** * 用于Plupload插件的文件上传 到阿里OSS * @param plupload - 存放上传所需参数的bean * @param filename - 保存的文件名 * @throws IllegalStateException * @throws IOException */ public static void upload2AliyunOSS(Plupload plupload, String filename) throws IllegalStateException, IOException { int chunks = plupload.getChunks(); //获取总的碎片数 int chunk = plupload.getChunk(); //获取当前碎片(从0开始计数) MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) plupload.getRequest();MultiValueMap<String, MultipartFile> map = multipartRequest.getMultiFileMap(); if(map != null) { //事实上迭代器中只存在一个值,所以只需要返回一个值即可 Iterator<String> iter = map.keySet().iterator(); while(iter.hasNext()) { String str = (String) iter.next(); List<MultipartFile> fileList = map.get(str); for(MultipartFile multipartFile : fileList) { //因为只存在一个值,所以最后返回的既是第一个也是最后一个值 plupload.setMultipartFile(multipartFile); //存储到oss上文件路径和名称 String key = ResourceUtil.getOSSHousesPic() + filename; AliyunOSSUtil.ensureBucket(); //当chunks>1则说明当前传的文件为一块碎片，需要合并 if (chunks > 1) { String prefix = filename.substring(0, filename.lastIndexOf(".")-1); String suffix = filename.substring(filename.lastIndexOf("."), filename.length()); File tmpFile = File.createTempFile(prefix, suffix); //需要创建临时文件名，最后再更改名称 //如果chunk==0,则代表第一块碎片,不需要合并 saveUploadFile(multipartFile.getInputStream(), tmpFile, chunk == 0 ? false : true); //上传并合并完成，则将临时名称更改为指定名称 if (chunks - chunk == 1) { AliyunOSSUtil.uploadFile(key, tmpFile); } } else { AliyunOSSUtil.uploadMultipartFile(key, multipartFile); //否则直接将文件内容拷贝至新文件 //multipartFile.transferTo(targetFile); } } } } } /** * 用于Plupload插件的文件上传 上传到本地服务器 * @param plupload - 存放上传所需参数的bean * @param dir - 保存目标文件目录 * @throws IllegalStateException * @throws IOException */ public static void upload2Local(Plupload plupload, String filePath, String fileName) throws IllegalStateException, IOException { int chunks = plupload.getChunks(); //获取总的碎片数 int chunk = plupload.getChunk(); //获取当前碎片(从0开始计数) MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) plupload.getRequest();MultiValueMap<String, MultipartFile> map = multipartRequest.getMultiFileMap(); if(map != null) { File dir = new File(filePath); if (!dir.exists()) dir.mkdirs(); //如果目标文件夹不存在则创建新的文件夹 //事实上迭代器中只存在一个值,所以只需要返回一个值即可 Iterator<String> iter = map.keySet().iterator(); while(iter.hasNext()) { String str = (String) iter.next(); List<MultipartFile> fileList = map.get(str); for(MultipartFile multipartFile : fileList) { //因为只存在一个值,所以最后返回的既是第一个也是最后一个值 plupload.setMultipartFile(multipartFile); //创建新目标文件 File targetFile = new File(dir.getPath()+ "/" + fileName); //当chunks>1则说明当前传的文件为一块碎片，需要合并 if (chunks > 1) { //需要创建临时文件名，最后再更改名称 File tempFile = new File(dir.getPath()+ "/" + multipartFile.getName()); //如果chunk==0,则代表第一块碎片,不需要合并 saveUploadFile(multipartFile.getInputStream(), tempFile, chunk == 0 ? false : true); //上传并合并完成，则将临时名称更改为指定名称 if (chunks - chunk == 1) { tempFile.renameTo(targetFile); } } else { //否则直接将文件内容拷贝至新文件 multipartFile.transferTo(targetFile); } } } } } /** * 保存上传文件，兼合并功能 */ private static void saveUploadFile(InputStream input, File targetFile, boolean append) throws IOException { OutputStream out = null; try { if (targetFile.exists() && append) { out = new BufferedOutputStream(new FileOutputStream(targetFile, true), BUF_SIZE); } else { out = new BufferedOutputStream(new FileOutputStream(targetFile), BUF_SIZE); } byte[] buffer = new byte[BUF_SIZE]; int len = 0; //写入文件 while ((len = input.read(buffer)) > 0) { out.write(buffer, 0, len); } } catch (IOException e) { throw e; } finally { //关闭输入输出流 if (null != input) { try { input.close(); } catch (IOException e) { e.printStackTrace(); } } if (null != out) { try { out.close(); } catch (IOException e) { e.printStackTrace(); } } } } /** * 判断是否全部上传完成 * 碎片需合并后才返回真 */ public static boolean isUploadFinish(Plupload plupload) { return (plupload.getChunks() - plupload.getChunk() == 1); } }
Plupload PO类：
import javax.servlet.http.HttpServletRequest; import org.springframework.web.multipart.MultipartFile; /** * Plupload是一个上传插件。 * 这是一个bean类,主要存储Plupload插件上传时需要的参数。 * 属性名不可随意改动. * 这里主要使用MultipartFile文件上传方法 */ public class Plupload { /**文件临时名(打文件被分解时)或原名*/ private String name; /**总的块数*/ private int chunks = -1; /**当前块数（从0开始计数）*/ private int chunk = -1; /**HttpServletRequest对象，不能直接传入进来，需要手动传入*/ private HttpServletRequest request; /**保存文件上传信息，不能直接传入进来，需要手动传入*/ private MultipartFile multipartFile; public String getName() { return name; } public void setName(String name) { this.name = name; } public int getChunks() { return chunks; } public void setChunks(int chunks) { this.chunks = chunks; } public int getChunk() { return chunk; } public void setChunk(int chunk) { this.chunk = chunk; } public HttpServletRequest getRequest() { return request; } public void setRequest(HttpServletRequest request) { this.request = request; } public MultipartFile getMultipartFile() { return multipartFile; } public void setMultipartFile(MultipartFile multipartFile) { this.multipartFile = multipartFile; } }
