java多文件上传plupload控件实现多图片上传(二)_outputstream上传多图片-程序员宅基地

技术标签: 多图片上传  plupload控件  文件上传  

接上篇

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;  
    }  
      
}  


版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/nn2345/article/details/61198547

智能推荐

编译 Hadoop Eclipse Plugin-程序员宅基地

文章浏览阅读921次。1.首先从 git 下载源码 下载地址: https://github.com/winghc/hadoop2x-eclipse-plugin百度网盘下载: 链接:http://pan.baidu.com/s/1o6DMY4U 密码:y95i下载 ant-1.9.6 下载地址:http://mirrors.noc.im/apache//ant/binaries/apache-ant-1

Github删除仓库_这个仓库好像已经被从文件系统中删除,或者被移动到了其他地方。 你要删除这个标签-程序员宅基地

文章浏览阅读642次。既然写到了github这一块的知识点,那么,简单的说一下怎么删除一个仓库(项目)1:创建一个仓库2:填写仓库的名称3:创建完成4:如果要删除这个仓库的话,进入settings拉到最底下的Danger Zone5:输入仓库名称,Repository name,我的仓库名称是protest,删除即可原文作者:祈澈姑娘 技术博..._这个仓库好像已经被从文件系统中删除,或者被移动到了其他地方。 你要删除这个标签

引用 android string.xml文件中的整型和string型代替_android string.xml中引用其他值-程序员宅基地

文章浏览阅读4k次。在android的开发中,经常会遇见一句话,比如“我今年23岁了”;这个23需要在程序中生成,但是遇到一个问题,这完整的一句话是一个TextView中的,而不是三个textView拼接成的,而且是引用的string.xml文件中写好的;使用字符串拼接也可以实现,但是特别麻烦;今天遇到一个好方法,在string.xml中,不仅可以设置文字的格式换行等,还可以设置类似于变量的文本格式;_android string.xml中引用其他值

Hook 入门_hook入门-程序员宅基地

文章浏览阅读415次。Hook 简介为什么使用hook类组件和函数组件的区别没有破坏性改动Hook 使用规则useStateuseEffect自定义 HookuseRefuseContext为什么使用hookHook 是 React 16.8 的新增特性,是一些可以让你在函数组件里“钩入” React state 及生命周期等特性的函数。类组件和函数组件的区别详细参考 How Are Function Components Different from Classes?, 感兴趣的同学可以直接看原文。区别类组_hook入门

cruiscontroller的理解和学习_cruisbr-x-程序员宅基地

文章浏览阅读492次。CruiseControl:简称CC,持续集成工具,主要提供了基于版本管理工具(如CVS)感知变化或每天定时的持续集成,并提供持续集成报告、Email、Jabber等等方式通知相关负责人,其要求是需要进行日构建的项目已编写好全自动的项目编译脚本(可基于Maven或Ant)。在这里以一个项目来简要的说说cc的使用,通常项目对于日构建的类型的需求分为两种:1、每天的定时自动集成。2、感知版_cruisbr-x

《图形编程技术学习》(八)Windows配置freeglut、MAC配置freeglut以及配置glut_windows freeglut-程序员宅基地

文章浏览阅读834次。一.Windows配置freeglutWindows:1.下载Freeglut源码:http://freeglut.sourceforge.net/,2.VS2015中编译该源码工程,生成.lib和.dll文件(.h文件就在源码中)。(你也可以下载最新的,但相应操作可能会有所不同)3.将三类文件拷贝到相应目录下就完成了安装。具体 而言:如果是32位版本,则:1.\inc..._windows freeglut

随便推点

3.2.2 Python之pandas详解1-Series_from pandas import series什么意思-程序员宅基地

文章浏览阅读432次。Pandas是基于NumPy的一个常用库。之所以如此,是因为不论是读取还是处理数据,用它都非常简单。1,pandas基本数据结构Pandas有两种自己独有的基本数据结构。pandas虽然有两种数据结构,因为他是Python的一个库,所以Python的数据类型在这里依然适用,同样还可以使用类自己定义数据类型。Pandas里面又定义了两种数据类型:Series和DataFrame基本的导入方式:fro..._from pandas import series什么意思

【UE4 shader】扰动水流Shader_ue扰动-程序员宅基地

文章浏览阅读1.1w次,点赞11次,收藏81次。关键词:Fresnel(Lerp)、噪波(Panner Rotate TexCoord Time)、半透明、反射(屏幕空间反射SSR)、折射(Lerp IOR)、边缘波浪(世界位置偏移)、水波法线 、颜色变化-------------------------------------------------------------------------------Fresnel:用Lerp_ue扰动

利用tensorflow训练自己的图片数据集——数据准备_tensorflow训练自己的图库-程序员宅基地

文章浏览阅读2.3w次,点赞15次,收藏172次。昨天实现了一个简单的CNN网络。用了MNIST数据集,虽然看来对这个数据集用的很多,但是真正这个数据集是怎么在训练的时候被调用的,以及怎么把它换成自己的数据集都是一脸懵。直接附上链接:MNIST数据集解析作者给的代码是python2.x版本的,我用的python3.5,改了一些错误。import numpy as npimport structimport osimport m..._tensorflow训练自己的图库

day15_常用API-程序员宅基地

文章浏览阅读51次。day15_常用APIStringString是 java.lang.String , 使用不需要导包String是字符串类,是引用类型,底层是char数组,所以String的特性几乎和数组一致1 字符串一旦创建,该字符串对象不能更改2 为了提高字符串的访问效率,java虚拟机使用了一种缓存技术,可以对字符串操作更加简单方便,更加高效(字符串常量池)3 字符串会被保存在静态区中的常量池中,可以复用性增强当我们用到一个重复的字符串的时候,会去常量池中进行检索,如果有该字符串,则直接指向,如果

日常运维管理技巧十(linux下抓包 tcpdump)_tcpdump -nni-程序员宅基地

文章浏览阅读1.4k次。十、linux下抓包tcpdump命令是一款抓包工具,它可以打印所有经过网络接口的数据包的头信息,也可以使用-w选项将数据包保存到文件中,方便以后分析。1、tcpdump工具需要自行安装:# yum install -y tcpdump格式:tcpdump 选项可用选项,常见的我用红色标出:-a:尝试将网络和广播地址转换成名称;-c&lt;数据包数量&gt;:收到指定的..._tcpdump -nni

win7免费升级到win10专业版(正,亲测有用)_win7离线升级win10安装包-程序员宅基地

文章浏览阅读1.2k次,点赞2次,收藏10次。工具: MediaCreationTool20H2.exe_win7离线升级win10安装包

推荐文章

热门文章

相关标签