zoukankan      html  css  js  c++  java
  • 【总结】java 后台文件上传整理

    public Map<String,String> clientUploadAttachment(Long belongId, String fileSource,
                MultipartFile file, User currentUser) {
            Map<String,String> map = new HashMap<String, String>();
            if(file==null){
    //            map.put("uploadError", "uploadError");
                return null;//上传失败返回null
            }
            try{
                InputStream is = file.getInputStream();
                String storePath =upLoadPath+DateUtils.getYear()+"/"+DateUtils.getMonth()+"/"+DateUtils.getDay()+"/"+belongId+"/";
                String tempFileName = file.getOriginalFilename();
                
                //缓存文件类型转换  源文件
                CommonsMultipartFile cf= (CommonsMultipartFile)file; 
                DiskFileItem fi = (DiskFileItem)cf.getFileItem(); 
                File tempOrginFile = fi.getStoreLocation();
                
                String mimeType = file.getContentType();
                int fileType = 5;// 文件类型 1:图片  2:文档 3:视频 4:音频 5.其他
                if (mimeType.startsWith("image/")) {
                    fileType = 1;
                }else if(mimeType.startsWith("video")||mimeType.startsWith("mp4")){
                    fileType = 3;
                    storePath += "video/";
                }else if(mimeType.startsWith("mp3")){
                    fileType = 4;
                    storePath += "audio/";
                }else{
                    storePath += "other/";
                }
                String uuid = IdGen.uuid();
                if(is != null&&StringUtils.isNotBlank(tempFileName)){
                    Attachment attachment = new Attachment();
                    attachment.setBelongId(belongId);
                    attachment.setFileType(fileType);
                    attachment.setFileName(tempFileName);
                    attachment.setCreatorId(currentUser.getId());
                    attachment.setCreatorName(currentUser.getLoginName());
                    attachment.setFileSize(FileUtils.getFileSize(file));
                    attachment.setFileSource(fileSource==null?5:Integer.parseInt(fileSource));
                    
                    //生成文件名
                    String extendName = tempFileName.substring(tempFileName.indexOf("."));
                    String fileName =uuid + extendName;
                    String waterName = uuid + extendName;
                    if(fileType == 1){//图片 缩略图 路径
                        waterName = uuid + "_small" + extendName;
                    }else if(fileType == 3){//视频截图 路径
                        waterName = uuid + "_view" + extendName;
                    }
                    //设置临时文件目录
                    String waterTempPath = SpringContextHolder.getRootRealPath()+"/static/temp/"+waterName;
                    
                    //開始上傳
                    FTPUtils ftpUtils = FTPUtils.getInstance();
                    attachment.setFilePath(storePath+fileName);
                    attachment.setWaterPath(storePath+waterName);
                    synchronized(this){
                        boolean upTemp = ftpUtils.storeFile(storePath,fileName,is);
                        if(upTemp){
                            if(fileType == 1){//图片 缩略图 处理并上传
                                 ImageUtil.createCompressImg(tempOrginFile,waterTempPath, 200);
                                 File waterFile = new File(waterTempPath);
                                 if(waterFile.exists()&&waterFile.isFile()){
                                     ftpUtils.storeFile(storePath,waterName,new FileInputStream(waterFile)); 
                                     FileUtils.deleteFile(waterTempPath);
                                 }
                            }else if(fileType == 3){//视频截图 处理并上传
                                 //TODO://视频截图 处理并上传
                            }
                            attachmentDao.saveObj(attachment);
                        }
                    }
                    map.put("attachmentId", String.valueOf(attachment.getId()));
                    map.put("attachmentUrl", storePath+fileName);
                    map.put("waterUrl", storePath+waterName);
                    return map;
                }else{
                    return null;//上传失败返回null
                }
            }catch(IOException e){
                e.printStackTrace();
                return null;//上传失败返回null
            }
        }
    package com.bankhui.center.common.utils;
    
    import java.awt.Container;
    import java.awt.Graphics;
    import java.awt.Image;
    import java.awt.MediaTracker;
    import java.awt.Toolkit;
    import java.awt.image.BufferedImage;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.MalformedURLException;
    import java.net.URL;
    
    import com.sun.image.codec.jpeg.JPEGCodec;
    import com.sun.image.codec.jpeg.JPEGEncodeParam;
    import com.sun.image.codec.jpeg.JPEGImageEncoder;
    
    import javax.imageio.ImageIO;
    
    import org.apache.commons.lang.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    /**
     * 图片处理Util
     */
    public class ImageUtil {
        private static Logger logger = LoggerFactory.getLogger(ImageUtil.class);
        /** 
         * @param args 
         */  
        public static void main(String[] args) {  
           /* String imageUrl="C:\Users\Public\Pictures\Sample Pictures\1.jpg"; 
            BufferedImage image = getBufferedImageByLocal(imageUrl); //使用ImageUtil获取到图片的高宽
            float scale = ((float)image.getWidth() )/ 200; //计算出宽压缩到600px时,压缩的多少倍
            int imageHeight = (int) (image.getHeight() / scale); //同样将高也压缩这个多倍(以免图片失真)
            Tosmallerpic(new File(imageUrl), new File("D:\000.jpg"), 200, imageHeight, 0.75f); //使用Tosmallerpic将图片按照比例压缩 
           */
        }  
        
        /**
         * 生成缩略图
         * @param oldSrc
         * @param newSrc
         * @param width
         */
        public static void createCompressImg(File oldFile,String newSrc,Integer width){
            BufferedImage image = getBufferedImageByLocal(oldFile);
            float scale = ((float)image.getWidth() )/ width; 
            int imageHeight = (int) (image.getHeight() / scale); 
            Tosmallerpic(oldFile, new File(newSrc), width, imageHeight, 0.75f);
        }
    
        /** 
         * 通过图片链接获取
         * @param imgUrl 图片地址 
         * @return  
         */  
        public static BufferedImage getBufferedImage(String imgUrl) {  
            URL url = null;  
            InputStream is = null;  
            BufferedImage img = null;  
            try {  
                url = new URL(imgUrl);  
                is = url.openStream();  
                img = ImageIO.read(is);  
            } catch (MalformedURLException e) {  
                e.printStackTrace();  
            } catch (IOException e) {  
                e.printStackTrace();  
            } finally {  
                  
                try {  
                    is.close();  
                } catch (IOException e) {  
                    e.printStackTrace();  
                }  
            }  
            return img;  
        }  
        
        /**
         * 文件
         * @param imgUrl
         * @return
         * @author liu787427876@126.com
         * @date 2014-7-20
         */
        public static BufferedImage getBufferedImageByLocal(File file) {  
            InputStream is = null;  
            BufferedImage img = null; 
            try {
                   is = new FileInputStream(file);
                   img = ImageIO.read(is);  
                  } catch (FileNotFoundException e) {
                   e.printStackTrace();
                  } catch (IOException e) {
                   e.printStackTrace();
                  } finally {  
                       try {  
                           is.close();  
                       } catch (IOException e) {  
                           e.printStackTrace();  
                       }  
                  } 
            return img;  
        }  
        
        public static BufferedImage getBufferedImageByLocal(String imgUrl) { 
             if(StringUtils.isBlank(imgUrl)){
              throw new NullPointerException("图片路径不能为空!");
             }
             File file = new File(imgUrl);
             return getBufferedImageByLocal(file);
        }
        
        /** 
         * 
         * @param f 图片输出路径 
         * @param filelist 图片路径 
         * @param ext 缩略图扩展名 
         * @param n 图片名 
         * @param w 目标宽 
         * @param h 目标高 
         * @param per 百分比 
         */ 
        public static void  Tosmallerpic(File oldFile,File newFile,int width,int height,float quality){
                if(!newFile.getParentFile().exists()){
                     newFile.getParentFile().mkdirs();
                 }
                 Image src=null; 
                 BufferedImage tag=null;
                 FileOutputStream newimage=null;
                try { 
                     try{
                         src = javax.imageio.ImageIO.read(oldFile); //构造Image对象 
                     }catch(Exception e){ 
                         e.printStackTrace();
                         logger.info(oldFile.getName()+"图片的ICC信息可能已经被破坏开始转换:");
                         try { 
                              ThumbnailConvert convert=new ThumbnailConvert();
                              //convert.setCMYK_COMMAND(oldFile.getPath()); 
                              String CMYK_COMMAND = "mogrify -colorspace RGB -quality 100 file1";//转换cmyk格式
                              convert.exeCommand(CMYK_COMMAND.replace("file1",oldFile.getPath()));
                              src = Toolkit.getDefaultToolkit().getImage(oldFile.getPath());
                              MediaTracker mediaTracker = new MediaTracker(new Container());
                              mediaTracker.addImage(src, 0); 
                              mediaTracker.waitForID(0); 
                              src.getWidth(null); 
                              src.getHeight(null); 
                            }catch (Exception e1){ 
                                e1.printStackTrace(); 
                            } 
                     } 
                     
                   //,String ext 保留字段 缩略图拼接字段
                   //String img_midname=newFile; 
                   int old_w=src.getWidth(null)==-1?src.getWidth(null); //得到源图宽
                   int old_h=src.getHeight(null)==-1?height:src.getHeight(null); 
                   int new_w=0; 
                   int new_h=0; //得到源图长
                   double w2=(old_w*1.00)/(width*1.00); 
                   double h2=(old_h*1.00)/(height*1.00);
                    //图片调整为方形结束 
                   if(old_w>width) 
                   new_w=(int)Math.round(old_w/w2); 
                   else 
                       new_w=old_w; 
                   if(old_h>height) 
                   new_h=(int)Math.round(old_h/h2);//计算新图长宽 
                   else 
                       new_h=old_h; 
                   tag = new BufferedImage(new_w,new_h,BufferedImage.TYPE_INT_RGB);      
                   //tag.getGraphics().drawImage(src,0,0,new_w,new_h,null); //绘制缩小后的图
                   tag.getGraphics().drawImage(src.getScaledInstance(new_w, new_h,Image.SCALE_SMOOTH), 0,0,null);
                   newimage=new FileOutputStream(newFile); //输出到文件流 
                   JPEGImageEncoder encoder = JPEGCodec.createJPEGEncoder(newimage);
                   JPEGEncodeParam jep=JPEGCodec.getDefaultJPEGEncodeParam(tag); 
                    /* 压缩质量 */ 
                   jep.setQuality(quality, true); 
                   encoder.encode(tag, jep); 
                   //encoder.encode(tag); //近JPEG编码 
                   newimage.close(); 
                } catch (IOException ex) { 
                     ex.printStackTrace();
                     logger.info(oldFile.getName()+"图片压缩问题;"+ex);
                    //Logger.getLogger(File:mpress.class.getName()).log(Level.SEVERE, null, ex);
                }finally{
                    if(newimage!=null){
                        try {
                            newimage.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                    if(tag!=null){
                        tag.flush();
                    }
                }
        } 
    
        /**
         * 缩放图像 
         * @param srcImageFile 源图像文件地址 
         * @param result       缩放后的图像地址 
         * @param destWidth    缩放宽度
         * @param destHeight   缩放高度; 
         */  
        public static boolean scaleImg(File srcImageFile, String result, int destWidth, int destHeight) {  
            boolean exeRs = false;
            try{  
                BufferedImage src = ImageIO.read(srcImageFile);
                Image image = src.getScaledInstance(destWidth, destHeight, Image.SCALE_DEFAULT);  
                BufferedImage tag = new BufferedImage(destWidth, destHeight, BufferedImage.TYPE_INT_RGB);  
                Graphics g = tag.getGraphics();  
                g.drawImage(image, 0, 0, null); // 绘制缩小后的图  
                g.dispose();  
                ImageIO.write(tag, "JPEG", new File(result));// 输出到文件流  
                exeRs = true;
            } catch (IOException e) {  
                e.printStackTrace();  
            } 
            return exeRs;
        }
    }
    package com.bankhui.core.base.util;
    
    import java.awt.AlphaComposite;
    import java.awt.Color;
    import java.awt.Font;
    import java.awt.Graphics2D;
    import java.awt.Image;
    import java.awt.RenderingHints;
    import java.awt.image.BufferedImage;
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.InputStream;
    import java.io.OutputStream;
    
    import javax.imageio.ImageIO;
    import javax.swing.ImageIcon;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * 图片处理类
     * @author wangjx
     */
    public class ImageUtils {
        private final static Logger logger = LoggerFactory.getLogger(ImageUtils.class);
        // 水印透明度 
        private static float alpha = 0.5f;
        // 水印横向位置
        private static int positionWidth = 150;
        // 水印纵向位置
        private static int positionHeight = 300;
        // 水印文字字体
        private static Font font = new Font("宋体", Font.BOLD, 30);
        // 水印文字颜色
        private static Color color = Color.red;
    
        /**  
         * 给图片添加图片水印
         * @param iconPath 水印图片路径  
         * @param file 源文件  
         * @param targerPath 目标图片路径  
         * @param degree 水印图片旋转角度  
         */  
        public static void markImageByIcon(String iconPath, File file,   
                String targerPath, Integer degree) {   
            OutputStream os = null;   
            try { 
                logger.info("水印图片路径:{}", iconPath);
                logger.info("源文件:{}", file.getAbsolutePath());
                logger.info("目标图片路径:{}", targerPath);
                Image srcImg = ImageIO.read(file);  
      
                BufferedImage buffImg = new BufferedImage(srcImg.getWidth(null),   
                        srcImg.getHeight(null), BufferedImage.TYPE_INT_RGB);   
      
                // 得到画笔对象   
                Graphics2D g = buffImg.createGraphics();   
      
                // 设置对线段的锯齿状边缘处理   
                g.setRenderingHint(RenderingHints.KEY_INTERPOLATION,   
                        RenderingHints.VALUE_INTERPOLATION_BILINEAR);   
      
                g.drawImage(srcImg.getScaledInstance(srcImg.getWidth(null), srcImg   
                        .getHeight(null), Image.SCALE_SMOOTH), 0, 0, null);   
      
                if (null != degree) {   
                    // 设置水印旋转   
                    g.rotate(Math.toRadians(degree),   
                            (double) buffImg.getWidth() / 2, (double) buffImg   
                                    .getHeight() / 2);   
                }   
      
                // 水印图象的路径 水印一般为gif或者png的,这样可设置透明度   
                ImageIcon imgIcon = new ImageIcon(iconPath);   
      
                // 得到Image对象。   
                Image img = imgIcon.getImage();   
      
                float alpha = 0.5f; // 透明度   
                g.setComposite(AlphaComposite.getInstance(AlphaComposite.SRC_ATOP,   
                        alpha));   
      
                // 表示水印图片的位置   相对于中心店的宽高以及水印图片宽高(img,x,y,width,height,obnull)
                g.drawImage(img, buffImg.getWidth() / 6,buffImg.getHeight() / 3, buffImg.getWidth() / 2,buffImg.getHeight() / 4, null);   
      
                g.setComposite(AlphaComposite.getInstance(AlphaComposite.SRC_OVER));   
      
                g.dispose();   
      
                os = new FileOutputStream(targerPath);   
      
                // 生成图片   
                ImageIO.write(buffImg, "JPG", os);   
      
                logger.info("图片完成添加水印");   
            } catch (Exception e) {   
                e.printStackTrace(); 
                logger.error("图片完成添加水印error:{}", e.getMessage());
            } finally {   
                try {   
                    if (null != os)   
                        os.close();   
                } catch (Exception e) {   
                    e.printStackTrace();   
                }   
            }   
        }   
        
        /**
         * 给图片添加水印文字
         * @param logoText 水印文字
         * @param srcImgPath 原图片路径
         * @param targerPath 目标图片路径
         * @param degree 旋转角度
         */
        public static void markImageByText(String logoText, String srcImgPath,
                String targerPath, Integer degree) {
             
            InputStream is = null;
            OutputStream os = null;
            try {
                // 1、源图片
                Image srcImg = ImageIO.read(new File(srcImgPath));
                BufferedImage buffImg = new BufferedImage(srcImg.getWidth(null),srcImg.getHeight(null), BufferedImage.TYPE_INT_RGB);
     
                // 2、得到画笔对象
                Graphics2D g = buffImg.createGraphics();
                // 3、设置对线段的锯齿状边缘处理
                g.setRenderingHint(RenderingHints.KEY_INTERPOLATION,RenderingHints.VALUE_INTERPOLATION_BILINEAR);
                g.drawImage(srcImg.getScaledInstance(srcImg.getWidth(null), srcImg.getHeight(null), Image.SCALE_SMOOTH), 0, 0, null);
                // 4、设置水印旋转
                if (null != degree) {
                    g.rotate(Math.toRadians(degree),(double) buffImg.getWidth() / 2, (double) buffImg.getHeight() / 2);
                }
                // 5、设置水印文字颜色
                g.setColor(color);
                // 6、设置水印文字Font
                g.setFont(font);
                // 7、设置水印文字透明度
                g.setComposite(AlphaComposite.getInstance(AlphaComposite.SRC_ATOP,alpha));
                // 8、第一参数->设置的内容,后面两个参数->文字在图片上的坐标位置(x,y)
                g.drawString(logoText, positionWidth, positionHeight);
                // 9、释放资源
                g.dispose();
                // 10、生成图片
                os = new FileOutputStream(targerPath);
                ImageIO.write(buffImg, "JPG", os);
     
                logger.info("图片完成添加水印文字");
                 
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    if (null != is)
                        is.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                try {
                    if (null != os)
                        os.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        
        /**
         * 判断文件是不是图片
         * @param file
         * @return
         * @author guogf
         */
        public static boolean isImage(File file)  
            {  
                boolean flag = false;   
                try  
                {  
                    Image is = ImageIO.read(file);  
                    if(null != is)  
                    {  
                        flag = true;
                    }
                } catch (Exception e)  
                {  
                    e.printStackTrace();  
                }  
                return flag;  
            }
        
        public static void main(String[] args) {
            markImageByText("测试", "d:/5442.jpg", "d:/zzz.jpg", 45);
    //        markImageByIcon("d:/logo.png", "d:/5442.jpg", "d:/zzz.jpg", 45);
            
        }
        
    }
    /**
         * 用户附件上传
         */
        @Override
    //    @Transactional
        public Result uploadAttachment(Attachment attachment,
                MultipartFile[] files) {
        Result result = new Result();
        for (MultipartFile file: files) {
            try {
                if(file!=null){
                    InputStream is = file.getInputStream();
                    String tempFileName = file.getOriginalFilename();
                    String fileType = file.getContentType();
                    boolean isImage = fileType.contains("image/");
                    if(is != null&&StringUtils.isNotBlank(tempFileName)){
                        //生成文件名
                        String uuid = IdGen.uuid();
                        String fileName = uuid+tempFileName.substring(tempFileName.indexOf("."));
                        String waterName= uuid + "_water"+tempFileName.substring(tempFileName.indexOf("."));
                        //生成文件路徑
                        String storePath = upLoadPath+attachment.getBelongId()+"/";
                        
                        //缓存文件类型转换
                        CommonsMultipartFile cf= (CommonsMultipartFile)file; 
                        DiskFileItem fi = (DiskFileItem)cf.getFileItem(); 
                        File tempFile = fi.getStoreLocation();
    
                        boolean ftpWaterRs=true;
                        FTPUtils ftpUtils = FTPUtils.getInstance();
                        //图片加水印 getResourceRootRealPath
                        if(isImage){
                            attachment.setFileType(1);
    
                            String waterTempPath = SpringContextHolder.getRootRealPath()+"/"+waterName;
    
                            String logoPath=SpringContextHolder.getRootRealPath()+"/Contents/bankhimages/shuiyin.png";  
    
                               ImageUtils.markImageByIcon(logoPath, tempFile, waterTempPath, 45);
                            File waterFile = new File(waterTempPath);
                            //上传水印图片
                            ftpWaterRs = ftpUtils.storeFile(storePath,waterName,new FileInputStream(waterFile));
                            if(!ftpWaterRs){
                                is.close();
                                result.setCode(GlobalConstant.FAIL);
                                result.setMsg("图片添加水印失败,请重试······");
                                return result;
                            }
                            FileUtils.deleteFile(waterTempPath);
                            
                            attachment.setWaterPath(storePath+waterName);
                        }else{
                            attachment.setFileType(2);
                            attachment.setWaterPath(storePath+fileName);
                        }
                        
                        //上传源文件
                        boolean ftpFileRs = ftpUtils.storeFile(storePath, fileName, is);
                        if(ftpFileRs&&ftpWaterRs){
                            //更新旧文件记录
    /*                        Map map= new HashMap<String, String >();
                            map.put("type", attachment.getType());
                            map.put("userId", attachment.getUserId());
                            map.put("status", 0);//标记为历史记录
                            homeUserInfoManager.updateAttachmentRecord(map);*/
                            //添加新的文件记录
                            attachment.setFilePath(storePath+fileName);
                            //attachment.setIsWater(0);
                            attachment.setStatus(1);
                            int rs=homeUserInfoManager.addAttachmentRecord(attachment);
                            if(rs>0){
                                result.setCode(GlobalConstant.SUCCESS);
                                result.setMsg("附件上传成功。");
                            }else{
                                result.setCode(GlobalConstant.FAIL);
                                result.setMsg("附件记录保存失败了···请重试······");
                            }
                        }else{
                            result.setCode(GlobalConstant.FAIL);
                            result.setMsg("上传附件失败了···请重试······");
                        }
                        is.close();
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return result;
    }
    /**
     * Copyright &copy; 2012-2016 <a href="https://github.com/thinkgem/jeesite">JeeSite</a> All rights reserved.
     */
    package com.bankhui.center.common.utils;
    
    import java.io.BufferedOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.RandomAccessFile;
    import java.text.DecimalFormat;
    import java.util.Enumeration;
    import java.util.List;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import org.apache.tools.zip.ZipEntry;
    import org.apache.tools.zip.ZipFile;
    import org.apache.tools.zip.ZipOutputStream;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.web.multipart.MultipartFile;
    
    import com.google.common.collect.Lists;
    
    /**
     * 文件操作工具类
     * 实现文件的创建、删除、复制、压缩、解压以及目录的创建、删除、复制、压缩解压等功能
     * @author ThinkGem
     * @version 2015-3-16
     */
    public class FileUtils extends org.apache.commons.io.FileUtils {
        
        private static Logger logger = LoggerFactory.getLogger(FileUtils.class);
    
        /**
         * 复制单个文件,如果目标文件存在,则不覆盖
         * @param srcFileName 待复制的文件名
         * @param descFileName 目标文件名
         * @return 如果复制成功,则返回true,否则返回false
         */
        public static boolean copyFile(String srcFileName, String descFileName) {
            return FileUtils.copyFileCover(srcFileName, descFileName, false);
        }
    
        /**
         * 复制单个文件
         * @param srcFileName 待复制的文件名
         * @param descFileName 目标文件名
         * @param coverlay 如果目标文件已存在,是否覆盖
         * @return 如果复制成功,则返回true,否则返回false
         */
        public static boolean copyFileCover(String srcFileName,
                String descFileName, boolean coverlay) {
            File srcFile = new File(srcFileName);
            // 判断源文件是否存在
            if (!srcFile.exists()) {
                logger.debug("复制文件失败,源文件 " + srcFileName + " 不存在!");
                return false;
            }
            // 判断源文件是否是合法的文件
            else if (!srcFile.isFile()) {
                logger.debug("复制文件失败," + srcFileName + " 不是一个文件!");
                return false;
            }
            File descFile = new File(descFileName);
            // 判断目标文件是否存在
            if (descFile.exists()) {
                // 如果目标文件存在,并且允许覆盖
                if (coverlay) {
                    logger.debug("目标文件已存在,准备删除!");
                    if (!FileUtils.delFile(descFileName)) {
                        logger.debug("删除目标文件 " + descFileName + " 失败!");
                        return false;
                    }
                } else {
                    logger.debug("复制文件失败,目标文件 " + descFileName + " 已存在!");
                    return false;
                }
            } else {
                if (!descFile.getParentFile().exists()) {
                    // 如果目标文件所在的目录不存在,则创建目录
                    logger.debug("目标文件所在的目录不存在,创建目录!");
                    // 创建目标文件所在的目录
                    if (!descFile.getParentFile().mkdirs()) {
                        logger.debug("创建目标文件所在的目录失败!");
                        return false;
                    }
                }
            }
    
            // 准备复制文件
            // 读取的位数
            int readByte = 0;
            InputStream ins = null;
            OutputStream outs = null;
            try {
                // 打开源文件
                ins = new FileInputStream(srcFile);
                // 打开目标文件的输出流
                outs = new FileOutputStream(descFile);
                byte[] buf = new byte[1024];
                // 一次读取1024个字节,当readByte为-1时表示文件已经读取完毕
                while ((readByte = ins.read(buf)) != -1) {
                    // 将读取的字节流写入到输出流
                    outs.write(buf, 0, readByte);
                }
                logger.debug("复制单个文件 " + srcFileName + " 到" + descFileName
                        + "成功!");
                return true;
            } catch (Exception e) {
                logger.debug("复制文件失败:" + e.getMessage());
                return false;
            } finally {
                // 关闭输入输出流,首先关闭输出流,然后再关闭输入流
                if (outs != null) {
                    try {
                        outs.close();
                    } catch (IOException oute) {
                        oute.printStackTrace();
                    }
                }
                if (ins != null) {
                    try {
                        ins.close();
                    } catch (IOException ine) {
                        ine.printStackTrace();
                    }
                }
            }
        }
    
        /**
         * 复制整个目录的内容,如果目标目录存在,则不覆盖
         * @param srcDirName 源目录名
         * @param descDirName 目标目录名
         * @return 如果复制成功返回true,否则返回false
         */
        public static boolean copyDirectory(String srcDirName, String descDirName) {
            return FileUtils.copyDirectoryCover(srcDirName, descDirName,
                    false);
        }
    
        /**
         * 复制整个目录的内容 
         * @param srcDirName 源目录名
         * @param descDirName 目标目录名
         * @param coverlay 如果目标目录存在,是否覆盖
         * @return 如果复制成功返回true,否则返回false
         */
        public static boolean copyDirectoryCover(String srcDirName,
                String descDirName, boolean coverlay) {
            File srcDir = new File(srcDirName);
            // 判断源目录是否存在
            if (!srcDir.exists()) {
                logger.debug("复制目录失败,源目录 " + srcDirName + " 不存在!");
                return false;
            }
            // 判断源目录是否是目录
            else if (!srcDir.isDirectory()) {
                logger.debug("复制目录失败," + srcDirName + " 不是一个目录!");
                return false;
            }
            // 如果目标文件夹名不以文件分隔符结尾,自动添加文件分隔符
            String descDirNames = descDirName;
            if (!descDirNames.endsWith(File.separator)) {
                descDirNames = descDirNames + File.separator;
            }
            File descDir = new File(descDirNames);
            // 如果目标文件夹存在
            if (descDir.exists()) {
                if (coverlay) {
                    // 允许覆盖目标目录
                    logger.debug("目标目录已存在,准备删除!");
                    if (!FileUtils.delFile(descDirNames)) {
                        logger.debug("删除目录 " + descDirNames + " 失败!");
                        return false;
                    }
                } else {
                    logger.debug("目标目录复制失败,目标目录 " + descDirNames + " 已存在!");
                    return false;
                }
            } else {
                // 创建目标目录
                logger.debug("目标目录不存在,准备创建!");
                if (!descDir.mkdirs()) {
                    logger.debug("创建目标目录失败!");
                    return false;
                }
    
            }
    
            boolean flag = true;
            // 列出源目录下的所有文件名和子目录名
            File[] files = srcDir.listFiles();
            for (int i = 0; i < files.length; i++) {
                // 如果是一个单个文件,则直接复制
                if (files[i].isFile()) {
                    flag = FileUtils.copyFile(files[i].getAbsolutePath(),
                            descDirNames + files[i].getName());
                    // 如果拷贝文件失败,则退出循环
                    if (!flag) {
                        break;
                    }
                }
                // 如果是子目录,则继续复制目录
                if (files[i].isDirectory()) {
                    flag = FileUtils.copyDirectory(files[i]
                            .getAbsolutePath(), descDirNames + files[i].getName());
                    // 如果拷贝目录失败,则退出循环
                    if (!flag) {
                        break;
                    }
                }
            }
    
            if (!flag) {
                logger.debug("复制目录 " + srcDirName + " 到 " + descDirName + " 失败!");
                return false;
            }
            logger.debug("复制目录 " + srcDirName + " 到 " + descDirName + " 成功!");
            return true;
    
        }
    
        /**
         * 
         * 删除文件,可以删除单个文件或文件夹
         * 
         * @param fileName 被删除的文件名
         * @return 如果删除成功,则返回true,否是返回false
         */
        public static boolean delFile(String fileName) {
             File file = new File(fileName);
            if (!file.exists()) {
                logger.debug(fileName + " 文件不存在!");
                return true;
            } else {
                if (file.isFile()) {
                    return FileUtils.deleteFile(fileName);
                } else {
                    return FileUtils.deleteDirectory(fileName);
                }
            }
        }
    
        /**
         * 
         * 删除单个文件
         * 
         * @param fileName 被删除的文件名
         * @return 如果删除成功,则返回true,否则返回false
         */
        public static boolean deleteFile(String fileName) {
            File file = new File(fileName);
            if (file.exists() && file.isFile()) {
                if (file.delete()) {
                    logger.debug("删除文件 " + fileName + " 成功!");
                    return true;
                } else {
                    logger.debug("删除文件 " + fileName + " 失败!");
                    return false;
                }
            } else {
                logger.debug(fileName + " 文件不存在!");
                return true;
            }
        }
    
        /**
         * 
         * 删除目录及目录下的文件
         * 
         * @param dirName 被删除的目录所在的文件路径
         * @return 如果目录删除成功,则返回true,否则返回false
         */
        public static boolean deleteDirectory(String dirName) {
            String dirNames = dirName;
            if (!dirNames.endsWith(File.separator)) {
                dirNames = dirNames + File.separator;
            }
            File dirFile = new File(dirNames);
            if (!dirFile.exists() || !dirFile.isDirectory()) {
                logger.debug(dirNames + " 目录不存在!");
                return true;
            }
            boolean flag = true;
            // 列出全部文件及子目录
            File[] files = dirFile.listFiles();
            for (int i = 0; i < files.length; i++) {
                // 删除子文件
                if (files[i].isFile()) {
                    flag = FileUtils.deleteFile(files[i].getAbsolutePath());
                    // 如果删除文件失败,则退出循环
                    if (!flag) {
                        break;
                    }
                }
                // 删除子目录
                else if (files[i].isDirectory()) {
                    flag = FileUtils.deleteDirectory(files[i]
                            .getAbsolutePath());
                    // 如果删除子目录失败,则退出循环
                    if (!flag) {
                        break;
                    }
                }
            }
    
            if (!flag) {
                logger.debug("删除目录失败!");
                return false;
            }
            // 删除当前目录
            if (dirFile.delete()) {
                logger.debug("删除目录 " + dirName + " 成功!");
                return true;
            } else {
                logger.debug("删除目录 " + dirName + " 失败!");
                return false;
            }
    
        }
    
        /**
         * 创建单个文件
         * @param descFileName 文件名,包含路径
         * @return 如果创建成功,则返回true,否则返回false
         */
        public static boolean createFile(String descFileName) {
            File file = new File(descFileName);
            if (file.exists()) {
                logger.debug("文件 " + descFileName + " 已存在!");
                return false;
            }
            if (descFileName.endsWith(File.separator)) {
                logger.debug(descFileName + " 为目录,不能创建目录!");
                return false;
            }
            if (!file.getParentFile().exists()) {
                // 如果文件所在的目录不存在,则创建目录
                if (!file.getParentFile().mkdirs()) {
                    logger.debug("创建文件所在的目录失败!");
                    return false;
                }
            }
    
            // 创建文件
            try {
                if (file.createNewFile()) {
                    logger.debug(descFileName + " 文件创建成功!");
                    return true;
                } else {
                    logger.debug(descFileName + " 文件创建失败!");
                    return false;
                }
            } catch (Exception e) {
                e.printStackTrace();
                logger.debug(descFileName + " 文件创建失败!");
                return false;
            }
    
        }
    
        /**
         * 创建目录
         * @param descDirName 目录名,包含路径
         * @return 如果创建成功,则返回true,否则返回false
         */
        public static boolean createDirectory(String descDirName) {
            String descDirNames = descDirName;
            if (!descDirNames.endsWith(File.separator)) {
                descDirNames = descDirNames + File.separator;
            }
            File descDir = new File(descDirNames);
            if (descDir.exists()) {
                logger.debug("目录 " + descDirNames + " 已存在!");
                return false;
            }
            // 创建目录
            if (descDir.mkdirs()) {
                logger.debug("目录 " + descDirNames + " 创建成功!");
                return true;
            } else {
                logger.debug("目录 " + descDirNames + " 创建失败!");
                return false;
            }
    
        }
    
        /**
         * 写入文件
         * @param file 要写入的文件
         */
        public static void writeToFile(String fileName, String content, boolean append) {
            try {
                FileUtils.write(new File(fileName), content, "utf-8", append);
                logger.debug("文件 " + fileName + " 写入成功!");
            } catch (IOException e) {
                logger.debug("文件 " + fileName + " 写入失败! " + e.getMessage());
            }
        }
    
        /**
         * 写入文件
         * @param file 要写入的文件
         */
        public static void writeToFile(String fileName, String content, String encoding, boolean append) {
            try {
                FileUtils.write(new File(fileName), content, encoding, append);
                logger.debug("文件 " + fileName + " 写入成功!");
            } catch (IOException e) {
                logger.debug("文件 " + fileName + " 写入失败! " + e.getMessage());
            }
        }
        
        /**
         * 压缩文件或目录
         * @param srcDirName 压缩的根目录
         * @param fileName 根目录下的待压缩的文件名或文件夹名,其中*或""表示跟目录下的全部文件
         * @param descFileName 目标zip文件
         */
        public static void zipFiles(String srcDirName, String fileName,
                String descFileName) {
            // 判断目录是否存在
            if (srcDirName == null) {
                logger.debug("文件压缩失败,目录 " + srcDirName + " 不存在!");
                return;
            }
            File fileDir = new File(srcDirName);
            if (!fileDir.exists() || !fileDir.isDirectory()) {
                logger.debug("文件压缩失败,目录 " + srcDirName + " 不存在!");
                return;
            }
            String dirPath = fileDir.getAbsolutePath();
            File descFile = new File(descFileName);
            try {
                ZipOutputStream zouts = new ZipOutputStream(new FileOutputStream(
                        descFile));
                if ("*".equals(fileName) || "".equals(fileName)) {
                    FileUtils.zipDirectoryToZipFile(dirPath, fileDir, zouts);
                } else {
                    File file = new File(fileDir, fileName);
                    if (file.isFile()) {
                        FileUtils.zipFilesToZipFile(dirPath, file, zouts);
                    } else {
                        FileUtils
                                .zipDirectoryToZipFile(dirPath, file, zouts);
                    }
                }
                zouts.close();
                logger.debug(descFileName + " 文件压缩成功!");
            } catch (Exception e) {
                logger.debug("文件压缩失败:" + e.getMessage());
                e.printStackTrace();
            }
    
        }
    
        /**
         * 解压缩ZIP文件,将ZIP文件里的内容解压到descFileName目录下
         * @param zipFileName 需要解压的ZIP文件
         * @param descFileName 目标文件
         */
        public static boolean unZipFiles(String zipFileName, String descFileName) {
            String descFileNames = descFileName;
            if (!descFileNames.endsWith(File.separator)) {
                descFileNames = descFileNames + File.separator;
            }        
            try {
                // 根据ZIP文件创建ZipFile对象
                ZipFile zipFile = new ZipFile(zipFileName);
                ZipEntry entry = null;
                String entryName = null;
                String descFileDir = null;
                byte[] buf = new byte[4096];
                int readByte = 0;
                // 获取ZIP文件里所有的entry
                @SuppressWarnings("rawtypes")
                Enumeration enums = zipFile.getEntries();
                // 遍历所有entry
                while (enums.hasMoreElements()) {
                    entry = (ZipEntry) enums.nextElement();
                    // 获得entry的名字
                    entryName = entry.getName();
                    descFileDir = descFileNames + entryName;
                    if (entry.isDirectory()) {
                        // 如果entry是一个目录,则创建目录
                        new File(descFileDir).mkdirs();
                        continue;
                    } else {
                        // 如果entry是一个文件,则创建父目录
                        new File(descFileDir).getParentFile().mkdirs();
                    }
                    File file = new File(descFileDir);
                    // 打开文件输出流
                    OutputStream os = new FileOutputStream(file);
                    // 从ZipFile对象中打开entry的输入流
                    InputStream is = zipFile.getInputStream(entry);
                    while ((readByte = is.read(buf)) != -1) {
                        os.write(buf, 0, readByte);
                    }
                    os.close();
                    is.close();
                }
                zipFile.close();
                logger.debug("文件解压成功!");
                return true;
            } catch (Exception e) {
                logger.debug("文件解压失败:" + e.getMessage());
                return false;
            }
        }
    
        /**
         * 将目录压缩到ZIP输出流
         * @param dirPath 目录路径
         * @param fileDir 文件信息
         * @param zouts 输出流
         */
        public static void zipDirectoryToZipFile(String dirPath, File fileDir, ZipOutputStream zouts) {
            if (fileDir.isDirectory()) {
                File[] files = fileDir.listFiles();
                // 空的文件夹
                if (files.length == 0) {
                    // 目录信息
                    ZipEntry entry = new ZipEntry(getEntryName(dirPath, fileDir));
                    try {
                        zouts.putNextEntry(entry);
                        zouts.closeEntry();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    return;
                }
    
                for (int i = 0; i < files.length; i++) {
                    if (files[i].isFile()) {
                        // 如果是文件,则调用文件压缩方法
                        FileUtils
                                .zipFilesToZipFile(dirPath, files[i], zouts);
                    } else {
                        // 如果是目录,则递归调用
                        FileUtils.zipDirectoryToZipFile(dirPath, files[i],
                                zouts);
                    }
                }
            }
        }
    
        /**
         * 将文件压缩到ZIP输出流
         * @param dirPath 目录路径
         * @param file 文件
         * @param zouts 输出流
         */
        public static void zipFilesToZipFile(String dirPath, File file, ZipOutputStream zouts) {
            FileInputStream fin = null;
            ZipEntry entry = null;
            // 创建复制缓冲区
            byte[] buf = new byte[4096];
            int readByte = 0;
            if (file.isFile()) {
                try {
                    // 创建一个文件输入流
                    fin = new FileInputStream(file);
                    // 创建一个ZipEntry
                    entry = new ZipEntry(getEntryName(dirPath, file));
                    // 存储信息到压缩文件
                    zouts.putNextEntry(entry);
                    // 复制字节到压缩文件
                    while ((readByte = fin.read(buf)) != -1) {
                        zouts.write(buf, 0, readByte);
                    }
                    zouts.closeEntry();
                    fin.close();
                    System.out
                            .println("添加文件 " + file.getAbsolutePath() + " 到zip文件中!");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    
        /**
         * 获取待压缩文件在ZIP文件中entry的名字,即相对于跟目录的相对路径名
         * @param dirPat 目录名
         * @param file entry文件名
         * @return
         */
        private static String getEntryName(String dirPath, File file) {
            String dirPaths = dirPath;
            if (!dirPaths.endsWith(File.separator)) {
                dirPaths = dirPaths + File.separator;
            }
            String filePath = file.getAbsolutePath();
            // 对于目录,必须在entry名字后面加上"/",表示它将以目录项存储
            if (file.isDirectory()) {
                filePath += "/";
            }
            int index = filePath.indexOf(dirPaths);
    
            return filePath.substring(index + dirPaths.length());
        }
    
        /**
         * 根据“文件名的后缀”获取文件内容类型(而非根据File.getContentType()读取的文件类型)
         * @param returnFileName 带验证的文件名
         * @return 返回文件类型
         */
        public static String getContentType(String returnFileName) {
            String contentType = "application/octet-stream";
            if (returnFileName.lastIndexOf(".") < 0)
                return contentType;
            returnFileName = returnFileName.toLowerCase();
            returnFileName = returnFileName.substring(returnFileName.lastIndexOf(".") + 1);
            if (returnFileName.equals("html") || returnFileName.equals("htm") || returnFileName.equals("shtml")) {
                contentType = "text/html";
            } else if (returnFileName.equals("apk")) {
                contentType = "application/vnd.android.package-archive";
            } else if (returnFileName.equals("sis")) {
                contentType = "application/vnd.symbian.install";
            } else if (returnFileName.equals("sisx")) {
                contentType = "application/vnd.symbian.install";
            } else if (returnFileName.equals("exe")) {
                contentType = "application/x-msdownload";
            } else if (returnFileName.equals("msi")) {
                contentType = "application/x-msdownload";
            } else if (returnFileName.equals("css")) {
                contentType = "text/css";
            } else if (returnFileName.equals("xml")) {
                contentType = "text/xml";
            } else if (returnFileName.equals("gif")) {
                contentType = "image/gif";
            } else if (returnFileName.equals("jpeg") || returnFileName.equals("jpg")) {
                contentType = "image/jpeg";
            } else if (returnFileName.equals("js")) {
                contentType = "application/x-javascript";
            } else if (returnFileName.equals("atom")) {
                contentType = "application/atom+xml";
            } else if (returnFileName.equals("rss")) {
                contentType = "application/rss+xml";
            } else if (returnFileName.equals("mml")) {
                contentType = "text/mathml";
            } else if (returnFileName.equals("txt")) {
                contentType = "text/plain";
            } else if (returnFileName.equals("jad")) {
                contentType = "text/vnd.sun.j2me.app-descriptor";
            } else if (returnFileName.equals("wml")) {
                contentType = "text/vnd.wap.wml";
            } else if (returnFileName.equals("htc")) {
                contentType = "text/x-component";
            } else if (returnFileName.equals("png")) {
                contentType = "image/png";
            } else if (returnFileName.equals("tif") || returnFileName.equals("tiff")) {
                contentType = "image/tiff";
            } else if (returnFileName.equals("wbmp")) {
                contentType = "image/vnd.wap.wbmp";
            } else if (returnFileName.equals("ico")) {
                contentType = "image/x-icon";
            } else if (returnFileName.equals("jng")) {
                contentType = "image/x-jng";
            } else if (returnFileName.equals("bmp")) {
                contentType = "image/x-ms-bmp";
            } else if (returnFileName.equals("svg")) {
                contentType = "image/svg+xml";
            } else if (returnFileName.equals("jar") || returnFileName.equals("var") 
                    || returnFileName.equals("ear")) {
                contentType = "application/java-archive";
            } else if (returnFileName.equals("doc")) {
                contentType = "application/msword";
            } else if (returnFileName.equals("pdf")) {
                contentType = "application/pdf";
            } else if (returnFileName.equals("rtf")) {
                contentType = "application/rtf";
            } else if (returnFileName.equals("xls")) {
                contentType = "application/vnd.ms-excel";
            } else if (returnFileName.equals("ppt")) {
                contentType = "application/vnd.ms-powerpoint";
            } else if (returnFileName.equals("7z")) {
                contentType = "application/x-7z-compressed";
            } else if (returnFileName.equals("rar")) {
                contentType = "application/x-rar-compressed";
            } else if (returnFileName.equals("swf")) {
                contentType = "application/x-shockwave-flash";
            } else if (returnFileName.equals("rpm")) {
                contentType = "application/x-redhat-package-manager";
            } else if (returnFileName.equals("der") || returnFileName.equals("pem")
                    || returnFileName.equals("crt")) {
                contentType = "application/x-x509-ca-cert";
            } else if (returnFileName.equals("xhtml")) {
                contentType = "application/xhtml+xml";
            } else if (returnFileName.equals("zip")) {
                contentType = "application/zip";
            } else if (returnFileName.equals("mid") || returnFileName.equals("midi") 
                    || returnFileName.equals("kar")) {
                contentType = "audio/midi";
            } else if (returnFileName.equals("mp3")) {
                contentType = "audio/mpeg";
            } else if (returnFileName.equals("ogg")) {
                contentType = "audio/ogg";
            } else if (returnFileName.equals("m4a")) {
                contentType = "audio/x-m4a";
            } else if (returnFileName.equals("ra")) {
                contentType = "audio/x-realaudio";
            } else if (returnFileName.equals("3gpp")
                    || returnFileName.equals("3gp")) {
                contentType = "video/3gpp";
            } else if (returnFileName.equals("mp4")) {
                contentType = "video/mp4";
            } else if (returnFileName.equals("mpeg")
                    || returnFileName.equals("mpg")) {
                contentType = "video/mpeg";
            } else if (returnFileName.equals("mov")) {
                contentType = "video/quicktime";
            } else if (returnFileName.equals("flv")) {
                contentType = "video/x-flv";
            } else if (returnFileName.equals("m4v")) {
                contentType = "video/x-m4v";
            } else if (returnFileName.equals("mng")) {
                contentType = "video/x-mng";
            } else if (returnFileName.equals("asx") || returnFileName.equals("asf")) {
                contentType = "video/x-ms-asf";
            } else if (returnFileName.equals("wmv")) {
                contentType = "video/x-ms-wmv";
            } else if (returnFileName.equals("avi")) {
                contentType = "video/x-msvideo";
            }
            return contentType;
        }
        
        /**
         * 向浏览器发送文件下载,支持断点续传
         * @param file 要下载的文件
         * @param request 请求对象
         * @param response 响应对象
         * @return 返回错误信息,无错误信息返回null
         */
        public static String downFile(File file, HttpServletRequest request, HttpServletResponse response){
             return downFile(file, request, response, null);
        }
        
        /**
         * 向浏览器发送文件下载,支持断点续传
         * @param file 要下载的文件
         * @param request 请求对象
         * @param response 响应对象
         * @param fileName 指定下载的文件名
         * @return 返回错误信息,无错误信息返回null
         */
        public static String downFile(File file, HttpServletRequest request, HttpServletResponse response, String fileName){
            String error  = null;
            if (file != null && file.exists()) {
                if (file.isFile()) {
                    if (file.length() <= 0) {
                        error = "该文件是一个空文件。";
                    }
                    if (!file.canRead()) {
                        error = "该文件没有读取权限。";
                    }
                } else {
                    error = "该文件是一个文件夹。";
                }
            } else {
                error = "文件已丢失或不存在!";
            }
            if (error != null){
                logger.debug("---------------" + file + " " + error);
                return error;
            }
    
            long fileLength = file.length(); // 记录文件大小
            long pastLength = 0;     // 记录已下载文件大小
            int rangeSwitch = 0;     // 0:从头开始的全文下载;1:从某字节开始的下载(bytes=27000-);2:从某字节开始到某字节结束的下载(bytes=27000-39000)
            long toLength = 0;         // 记录客户端需要下载的字节段的最后一个字节偏移量(比如bytes=27000-39000,则这个值是为39000)
            long contentLength = 0; // 客户端请求的字节总量
            String rangeBytes = ""; // 记录客户端传来的形如“bytes=27000-”或者“bytes=27000-39000”的内容
            RandomAccessFile raf = null; // 负责读取数据
            OutputStream os = null;     // 写出数据
            OutputStream out = null;     // 缓冲
            byte b[] = new byte[1024];     // 暂存容器
    
            if (request.getHeader("Range") != null) { // 客户端请求的下载的文件块的开始字节
                response.setStatus(javax.servlet.http.HttpServletResponse.SC_PARTIAL_CONTENT);
                logger.debug("request.getHeader("Range") = " + request.getHeader("Range"));
                rangeBytes = request.getHeader("Range").replaceAll("bytes=", "");
                if (rangeBytes.indexOf('-') == rangeBytes.length() - 1) {// bytes=969998336-
                    rangeSwitch = 1;
                    rangeBytes = rangeBytes.substring(0, rangeBytes.indexOf('-'));
                    pastLength = Long.parseLong(rangeBytes.trim());
                    contentLength = fileLength - pastLength; // 客户端请求的是 969998336  之后的字节
                } else { // bytes=1275856879-1275877358
                    rangeSwitch = 2;
                    String temp0 = rangeBytes.substring(0, rangeBytes.indexOf('-'));
                    String temp2 = rangeBytes.substring(rangeBytes.indexOf('-') + 1, rangeBytes.length());
                    pastLength = Long.parseLong(temp0.trim()); // bytes=1275856879-1275877358,从第 1275856879 个字节开始下载
                    toLength = Long.parseLong(temp2); // bytes=1275856879-1275877358,到第 1275877358 个字节结束
                    contentLength = toLength - pastLength; // 客户端请求的是 1275856879-1275877358 之间的字节
                }
            } else { // 从开始进行下载
                contentLength = fileLength; // 客户端要求全文下载
            }
    
            // 如果设设置了Content-Length,则客户端会自动进行多线程下载。如果不希望支持多线程,则不要设置这个参数。 响应的格式是:
            // Content-Length: [文件的总大小] - [客户端请求的下载的文件块的开始字节]
            // ServletActionContext.getResponse().setHeader("Content- Length", new Long(file.length() - p).toString());
            response.reset(); // 告诉客户端允许断点续传多线程连接下载,响应的格式是:Accept-Ranges: bytes
            if (pastLength != 0) {
                response.setHeader("Accept-Ranges", "bytes");// 如果是第一次下,还没有断点续传,状态是默认的 200,无需显式设置;响应的格式是:HTTP/1.1 200 OK
                // 不是从最开始下载, 响应的格式是: Content-Range: bytes [文件块的开始字节]-[文件的总大小 - 1]/[文件的总大小]
                logger.debug("---------------不是从开始进行下载!服务器即将开始断点续传...");
                switch (rangeSwitch) {
                    case 1: { // 针对 bytes=27000- 的请求
                        String contentRange = new StringBuffer("bytes ").append(new Long(pastLength).toString()).append("-")
                                .append(new Long(fileLength - 1).toString()).append("/").append(new Long(fileLength).toString()).toString();
                        response.setHeader("Content-Range", contentRange);
                        break;
                    }
                    case 2: { // 针对 bytes=27000-39000 的请求
                        String contentRange = rangeBytes + "/" + new Long(fileLength).toString();
                        response.setHeader("Content-Range", contentRange);
                        break;
                    }
                    default: {
                        break;
                    }
                }
            } else {
                // 是从开始下载
                logger.debug("---------------是从开始进行下载!");
            }
    
            try {
                response.addHeader("Content-Disposition", "attachment; filename="" + 
                        Encodes.urlEncode(StringUtils.isBlank(fileName) ? file.getName() : fileName) + """);
                response.setContentType(getContentType(file.getName())); // set the MIME type.
                response.addHeader("Content-Length", String.valueOf(contentLength));
                os = response.getOutputStream();
                out = new BufferedOutputStream(os);
                raf = new RandomAccessFile(file, "r");
                try {
                    switch (rangeSwitch) {
                        case 0: { // 普通下载,或者从头开始的下载 同1
                        }
                        case 1: { // 针对 bytes=27000- 的请求
                            raf.seek(pastLength); // 形如 bytes=969998336- 的客户端请求,跳过 969998336 个字节
                            int n = 0;
                            while ((n = raf.read(b, 0, 1024)) != -1) {
                                out.write(b, 0, n);
                            }
                            break;
                        }
                        case 2: { // 针对 bytes=27000-39000 的请求
                            raf.seek(pastLength); // 形如 bytes=1275856879-1275877358 的客户端请求,找到第 1275856879 个字节
                            int n = 0;
                            long readLength = 0; // 记录已读字节数
                            while (readLength <= contentLength - 1024) {// 大部分字节在这里读取
                                n = raf.read(b, 0, 1024);
                                readLength += 1024;
                                out.write(b, 0, n);
                            }
                            if (readLength <= contentLength) { // 余下的不足 1024 个字节在这里读取
                                n = raf.read(b, 0, (int) (contentLength - readLength));
                                out.write(b, 0, n);
                            }
                            break;
                        }
                        default: {
                            break;
                        }
                    }
                    out.flush();
                    logger.debug("---------------下载完成!");
                } catch (IOException ie) {
                    /**
                     * 在写数据的时候, 对于 ClientAbortException 之类的异常,
                     * 是因为客户端取消了下载,而服务器端继续向浏览器写入数据时, 抛出这个异常,这个是正常的。
                     * 尤其是对于迅雷这种吸血的客户端软件, 明明已经有一个线程在读取 bytes=1275856879-1275877358,
                     * 如果短时间内没有读取完毕,迅雷会再启第二个、第三个。。。线程来读取相同的字节段, 直到有一个线程读取完毕,迅雷会 KILL
                     * 掉其他正在下载同一字节段的线程, 强行中止字节读出,造成服务器抛 ClientAbortException。
                     * 所以,我们忽略这种异常
                     */
                    logger.debug("提醒:向客户端传输时出现IO异常,但此异常是允许的,有可能客户端取消了下载,导致此异常,不用关心!");
                }
            } catch (Exception e) {
                logger.error(e.getMessage(), e);
            } finally {
                if (out != null) {
                    try {
                        out.close();
                    } catch (IOException e) {
                        logger.error(e.getMessage(), e);
                    }
                }
                if (raf != null) {
                    try {
                        raf.close();
                    } catch (IOException e) {
                        logger.error(e.getMessage(), e);
                    }
                }
            }
            return null;
        }
    
        /**
         * 修正路径,将 \ 或 / 等替换为 File.separator
         * @param path 待修正的路径
         * @return 修正后的路径
         */
        public static String path(String path){
            String p = StringUtils.replace(path, "\", "/");
            p = StringUtils.join(StringUtils.split(p, "/"), "/");
            if (!StringUtils.startsWithAny(p, "/") && StringUtils.startsWithAny(path, "\", "/")){
                p += "/";
            }
            if (!StringUtils.endsWithAny(p, "/") && StringUtils.endsWithAny(path, "\", "/")){
                p = p + "/";
            }
            if (path != null && path.startsWith("/")){
                p = "/" + p; // linux下路径
            }
            return p;
        }
        
        /**
         * 获目录下的文件列表
         * @param dir 搜索目录
         * @param searchDirs 是否是搜索目录
         * @return 文件列表
         */
        public static List<String> findChildrenList(File dir, boolean searchDirs) {
            List<String> files = Lists.newArrayList();
            for (String subFiles : dir.list()) {
                File file = new File(dir + "/" + subFiles);
                if (((searchDirs) && (file.isDirectory())) || ((!searchDirs) && (!file.isDirectory()))) {
                    files.add(file.getName());
                }
            }
            return files;
        }
    
        /**
         * 获取文件扩展名(返回小写)
         * @param fileName 文件名
         * @return 例如:test.jpg  返回:  jpg
         */
        public static String getFileExtension(String fileName) {
            if ((fileName == null) || (fileName.lastIndexOf(".") == -1) || (fileName.lastIndexOf(".") == fileName.length() - 1)) {
                return null;
            }
            return StringUtils.lowerCase(fileName.substring(fileName.lastIndexOf(".") + 1));
        }
    
        /**
         * 获取文件名,不包含扩展名
         * @param fileName 文件名
         * @return 例如:d:files	est.jpg  返回:d:files	est
         */
        public static String getFileNameWithoutExtension(String fileName) {
            if ((fileName == null) || (fileName.lastIndexOf(".") == -1)) {
                return null;
            }
            return fileName.substring(0, fileName.lastIndexOf("."));
        }
        
        /**
         * 获取文件大小
         * @param file
         * @return
         * @author guogf
         */
        public static String getFileSize(MultipartFile file) {
            DecimalFormat df = new DecimalFormat("0.00");
            String fileSizeString = "";
            if (file.getSize() < 1024) {
                fileSizeString = df.format((double) file.getSize()) + "B";
            } else if (file.getSize() < 1048576) {
                fileSizeString = df.format((double) file.getSize() / 1024) + "K";
            } else if (file.getSize() < 1073741824) {
                fileSizeString = df.format((double) file.getSize() / 1048576) + "M";
            } else {
                fileSizeString = df.format((double) file.getSize() / 1073741824) + "G";
            }
            return fileSizeString;
        }
    }
  • 相关阅读:
    poj----1330Nearest Common Ancestors(简单LCA)
    Tarjan--LCA算法的个人理解即模板
    hdu----(4545)魔法串(LCS)
    hdu---(1325)Is It A Tree?(并查集)
    hdu----(1599)最大子矩阵(几何/dp)
    hdu---(1054)Strategic Game(最小覆盖边)
    整理的一些模版LCS(连续和非连续)
    hdu---(4310)Hero(贪心算法)
    hdu----(4308)Saving Princess claire_(搜索)
    hdu------(4302)Holedox Eating(树状数组+二分)
  • 原文地址:https://www.cnblogs.com/sybboy/p/6929686.html
Copyright © 2011-2022 走看看