@laijj@调试文件上传

ipu-show-server/src/main/java/com/ai/ipu/show/bean/UploadDownloadBean.java

@@ -1,10 +1,6 @@
package com.ai.ipu.show.bean;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.*;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
@@ -25,102 +21,139 @@ import com.ai.ipu.basic.log.IpuLoggerFactory;
/**
 * @author huangbo
 * @date 2016-1-9 下午2:32:20 
 * @date 2016-1-9 下午2:32:20
 * @desc 上传下载使用范例
 */
public class UploadDownloadBean extends IpuAppBean {
	/**
	 * log在子类重新定义
	 */
	protected static final transient ILogger log = IpuLoggerFactory.getLogger(UploadDownloadBean.class);
    
	/**
	 * 文件上传
	 */
	public IData upload(IData param) throws Exception {
		/* 1.判断请求和参数是否合法 */
		String filePathStr = param.getString("FILE_PATH", ""); // 通过自定义参数决定文件存储规则
		String[] filePaths = filePathStr.split(",");
		if (filePaths.length == 0) {
			MobileUtility.error("请设置文件存储路径!");
		}
		/* 1.2.判断请求是否包含文件信息 */
		HttpServletRequest request = ServletManager.getRequest();
		if (!ServletFileUpload.isMultipartContent(request)) {
			MobileUtility.error("没有检测到文件,请重新提交!");
		}
    /**
     * log在子类重新定义
     */
    protected static final transient ILogger log = IpuLoggerFactory.getLogger(UploadDownloadBean.class);
		/* 2.处理上传文件的业务逻辑 */
		IData result = new DataMap();
		DiskFileItemFactory factory = new DiskFileItemFactory(); // 获得磁盘文件条目工厂
		// factory.setSizeThreshold(5*1024*1024); //设置缓存的大小。上传文件超过缓存时,将存储在临时目录中。
		// factory.setRepository(file); //设置临时存储
		ServletFileUpload upload = new ServletFileUpload(factory);
		OutputStream out = null;
		InputStream in = null;
		String filePath = null, savePath = ""; // 文件地址
		/* 多个上传文件 */
		List<FileItem> fileList = upload.parseRequest(request);
		// 多文件上传判断 还有些问题，未调通
		// if(fileList.size() != filePaths.length){
		// MobileUtility.error("提交的文件数量和保存的文件列表数量不一致，请检查参数!");
		// }
		for (int i = 0; i < fileList.size(); i++) {
			FileItem item = fileList.get(i);
			String name = item.getFieldName();// 获取表单的属性名
    /**
     * 文件上传
     */
    public IData upload(IData param) throws Exception {
        log.info("调用upload功能");
        IData result = new DataMap();//返回参数
        /* 1.判断请求和参数是否合法 */
        String filePathStr = param.getString("FILE_PATH", ""); // 通过自定义参数决定文件存储规则
        String[] filePaths = filePathStr.split(",");
        if (filePaths.length == 0) {
            MobileUtility.error("请设置文件存储路径!");
        }
        log.info("调用upload功能,filePathStr:" + filePathStr);
        /* 1.2.判断请求是否包含文件信息 */
        HttpServletRequest request = ServletManager.getRequest();
        if (!ServletFileUpload.isMultipartContent(request)) {
            MobileUtility.error("没有检测到文件,请重新提交!");
        }
        /* 2.处理上传文件的业务逻辑 */
        String filePath = null;  // 文件地址
        StringBuilder savePath = new StringBuilder();
        DiskFileItemFactory factory = new DiskFileItemFactory(); // 获得磁盘文件条目工厂
        ServletFileUpload upload = new ServletFileUpload(factory);
        /* 多个上传文件 */
        List<FileItem> fileList = upload.parseRequest(request);
        // 多文件上传判断 还有些问题，未调通
        // if(fileList.size() != filePaths.length){
        // MobileUtility.error("提交的文件数量和保存的文件列表数量不一致，请检查参数!");
        // }
        for (int i = 0; i < fileList.size(); i++) {
            FileItem item = fileList.get(i);
            // 获取表单的属性名
            String name = item.getFieldName();
            log.info("调用upload功能,fileList[" + i + "],name:" + name);
            /* 处理表单数据 */
            if (item.isFormField()) {
                request.setAttribute(name, item.getString());
            } else {
                String value = item.getName();
                // 保存文件名
                request.setAttribute(name, value);
                // 文件在server上保存地址
                filePath = ApplicationPath.getFilePath(request) + filePaths[i];
                log.debug("调用upload功能,filePath:" + filePath);
                File dir = new File(filePath).getParentFile();
                if (!dir.exists() && !dir.mkdirs()) {
                    MobileUtility.error("创建上传文件夹失败!");
                }
                savePath.append(filePath).append(",");
                log.debug("调用upload功能,拼接savePath:" + savePath);
                /* 保存文件 */
                File uploadFile = new File(filePath);
                saveFile(item, uploadFile);
                log.debug("调用upload功能,保存图片成功");
//				OutputStream out = null;
//				InputStream in = null;
//				try {
//					out = new FileOutputStream(uploadFile);
//					in = item.getInputStream();
//					int length = 0;
//					byte[] buf = new byte[1024];
//					while ((length = in.read(buf)) != -1) {
//						out.write(buf, 0, length);
//					}
//					log.debug("上传文件大小为：" + item.getSize());
//				} catch (Exception e) {
//					MobileUtility.error("上传文件失败!", e);
//				} finally {
//					if (in != null) {
//						in.close();
//					}
//					if (out != null) {
//						out.close();
//					}
//				}
            }
        }
        result.put("FILE_PATH", savePath.substring(0, savePath.length() - 1));
        result.put("MEESSAG", "上传文件成功:" + filePath);
        return result;
    }
			/* 处理表单数据 */
			if (item.isFormField()) {
				request.setAttribute(name, item.getString());
			} else {
				String value = item.getName();
				request.setAttribute(name, value); // 保存文件名
				// 文件在server上保存地址
				filePath = ApplicationPath.getFilePath(request) + filePaths[i];
				File dir = new File(filePath).getParentFile();
				if (!dir.exists() && !dir.mkdirs()) {
					MobileUtility.error("创建上传文件夹失败!");
				}
				savePath += filePath + ",";
				/* 保存文件 */
				File uploadFile = new File(filePath);
				try {
					out = new FileOutputStream(uploadFile);
					in = item.getInputStream();
					int length = 0;
					byte[] buf = new byte[1024];
					while ((length = in.read(buf)) != -1) {
						out.write(buf, 0, length);
					}
					log.debug("上传文件大小为：" + item.getSize());
				} catch (Exception e) {
					MobileUtility.error("上传文件失败!", e);
				} finally {
					if (in != null) {
						in.close();
					}
					if (out != null) {
						out.close();
					}
				}
			}
		}
		result.put("FILE_PATH", savePath.substring(0, savePath.length() - 1));
		result.put("MEESSAG", "上传文件成功:" + filePath);
		return result;
	}
	
	public InputStream download(IData param) throws Exception {
		String filePath = param.getString("FILE_PATH");
		HttpServletRequest request = ServletManager.getRequest();
		filePath = ApplicationPath.getFilePath(request) + filePath;
		
		File file = new File(filePath);
		if (!file.isFile()) {
			MobileUtility.error("没有指定的文件可供下载，请先上传文件！");
		}
    /**
     * 保存文件方法
     *
     * @param item
     * @param uploadFile
     * @throws IOException
     */
    private void saveFile(FileItem item, File uploadFile) throws IOException {
        OutputStream out = null;
        InputStream in = null;
        try {
            out = new FileOutputStream(uploadFile);
            in = item.getInputStream();
            int length = 0;
            byte[] buf = new byte[1024];
            while ((length = in.read(buf)) != -1) {
                out.write(buf, 0, length);
            }
            log.debug("上传文件大小为：" + item.getSize());
        } catch (Exception e) {
            MobileUtility.error("上传文件失败!", e);
        } finally {
            if (in != null) {
                in.close();
            }
            if (out != null) {
                out.close();
            }
        }
    }
		return new FileInputStream(file);
	}
    public InputStream download(IData param) throws Exception {
        String filePath = param.getString("FILE_PATH");
        HttpServletRequest request = ServletManager.getRequest();
        filePath = ApplicationPath.getFilePath(request) + filePath;
        File file = new File(filePath);
        if (!file.isFile()) {
            MobileUtility.error("没有指定的文件可供下载，请先上传文件！");
        }
        return new FileInputStream(file);
    }
}

ipu-show-server/src/main/java/com/ai/ipu/show/util/ApplicationPath.java

@@ -22,7 +22,6 @@ public final class ApplicationPath {
			
			if(serverType.equals("T")){
				appFilePath = request.getSession().getServletContext().getRealPath("/");
				
			}else{
				appFilePath = request.getSession().getServletContext().getResource("/").getPath();
			}