java文件处理详解编程语言

package com.icos.utility.file; 
 
import java.io.*; 
import java.util.ArrayList; 
import java.util.List; 
import java.util.Stack; 
 
import org.apache.log4j.Logger; 
import com.icos.utility.date.DateUtils; 
import com.icos.utility.string.CharacterSetToolkit; 
import com.icos.utility.string.StringUtil; 
 
/** 
 * 文件相关操作 
 */ 
public class FileOper { 
    private static Logger logger = Logger.getLogger(FileOper.class); 
 
    /** 
     * 格式化路径,统一格式化为结尾带分隔符的路径 
     * 
     * @param path 要格式化的路径 
     * @return 
     */ 
    public static String formatePath(String path) { 
        path = path.replace("//", "/"); 
        if (!path.endsWith("/")) 
            path += "/"; 
        return path; 
    } 
 
    /** 
     * 删除修改时间在给定时间之前的文件 
     * 
     * @param dir      要搜索的文件夹 
     * @param regex    用于匹配文件名的正则表达式 
     * @param dateTime 时间点,格式为yyyy-MM-dd HH:mm:ss 
     */ 
    public static void delFileModifyBefore(String dir, String regex, String dateTime) { 
        List<String> subfiles = getFileModifyBefore(dir, regex, dateTime); 
        deleteFiles(subfiles); 
        List<String> dirs = getSubDir(dir, "[//w//d]+"); 
        for (String d : dirs) { 
            File f = new File(d); 
            File[] files = f.listFiles(); 
            //如果发现空目录则删除 
            if (files != null && files.length == 0) { 
                logger.info("Delete dir  " + d); 
                f.delete(); 
            } 
        } 
    } 
 
 
    public static void copyTo(String srcName, String targetName) throws IOException { 
        File file = new File(srcName); 
        if (file.exists()) { 
            BufferedInputStream inBuff = null; 
            BufferedOutputStream outBuff = null; 
            try { 
                // 新建文件输入流并对它进行缓冲 
                inBuff = new BufferedInputStream(new FileInputStream(srcName)); 
 
                // 新建文件输出流并对它进行缓冲 
                outBuff = new BufferedOutputStream(new FileOutputStream(targetName)); 
 
                // 缓冲数组 
                byte[] b = new byte[1024 * 5]; 
                int len; 
                while ((len = inBuff.read(b)) != -1) { 
                    outBuff.write(b, 0, len); 
                } 
                // 刷新此缓冲的输出流 
                outBuff.flush(); 
            } finally { 
                // 关闭流 
                if (inBuff != null) 
                    inBuff.close(); 
                if (outBuff != null) 
                    outBuff.close(); 
            } 
        } 
    } 
 
    public static void rename(String srcName, String targetName) { 
        File file = new File(srcName); 
        if (file.exists()) { 
            file.renameTo(new File(targetName)); 
        } 
    } 
 
    /** 
     * 对比两个文本文件是否相同 
     * 
     * @param source 原始文件 
     * @param target 目标文件 
     * @return 如果相同 返回 True,否则返回False 
     */ 
    public static boolean isSame(String source, String target) { 
        if (!isFileExist(source) || !isFileExist(target)) 
            return false; 
        boolean result = true; 
        try { 
            BufferedReader streamSource = new BufferedReader(new InputStreamReader(new FileInputStream(source), FileOper.getFileEncoding(source))); 
            BufferedReader targetSource = new BufferedReader(new InputStreamReader(new FileInputStream(target), FileOper.getFileEncoding(target))); 
            String sourceLne = ""; 
            String targetLne = ""; 
            while ((sourceLne = streamSource.readLine()) != null) { 
                targetLne = targetSource.readLine(); 
                if (targetLne == null) { 
                    result = false; 
                } else if (!targetLne.equals(sourceLne)) { 
                    result = false; 
                } 
                if (!result) 
                    break; 
            } 
            streamSource.close(); 
            targetSource.close(); 
        } catch (IOException e) { 
            logger.error(e.getMessage(), e); 
        } 
        return result; 
    } 
 
    public static List<String> getFileModifyBefore(String dir, String regex, String dateTime) { 
        List<String> files = getSubFiles(dir, regex, true); 
        List<String> results = new ArrayList<String>(); 
        Long time = DateUtils.getTimeinteger(dateTime); 
        for (String f : files) { 
            File file = new File(f); 
            if (file.lastModified() <= time) { 
                results.add(f); 
            } 
        } 
        return results; 
    } 
 
    public static void checkAndCreateForder(String fileOrForderName) { 
        File file = new File(fileOrForderName); 
        if (file.getParentFile() != null && !file.getParentFile().exists()) { 
            file.getParentFile().mkdirs(); 
        } else if (file.getName().indexOf(".") <= 0) { 
            file.mkdirs(); 
        } 
    } 
 
    /** 
     * 按行分割文件,主要用于对大数据的文件的入库等处理,注意本方法一般应用于文件大小不超过500M的情况为宜 
     * 
     * @param fileName 要分割的文件名 
     * @param rowCount 文件包括对行数 
     * @return 
     * @throws java.io.IOException 
     * @throws java.io.FileNotFoundException 
     * @author James Cheung Date:Dec 27, 2012 
     */ 
    public static List<String> splitFile(String fileName, int rowCount) throws FileNotFoundException, IOException { 
        List<String> result = new ArrayList<String>(); 
        String line; 
        InputStream is = new FileInputStream(fileName); 
        BufferedReader reader = new BufferedReader(new InputStreamReader(is)); 
        String outFilename = fileName + "_0"; 
        result.add(outFilename); 
        BufferedWriter out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(outFilename, true), "utf-8")); 
        line = reader.readLine(); 
        int count = 0; 
        int fileCount = 1; 
        while (line != null) { 
            out.write(line); 
            out.write("/"); 
            count++; 
            if (count == rowCount) { 
                out.flush(); 
                out.close(); 
                count = 0; 
                outFilename = fileName + "_" + fileCount; 
                fileCount++; 
                out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(outFilename, true), "utf-8")); 
                result.add(outFilename); 
            } 
            line = reader.readLine(); 
        } 
        out.close(); 
        reader.close(); 
        is.close(); 
        return result; 
    } 
 
 
    public static String formateFileName(String name) { 
        return name.replaceAll("[<|>|:|=|;|//s|,|-|/"]+", "_"); 
    } 
 
    /** 
     * @param filePathAndName String 文件路径及名称 如c:/fqf.txt 
     * @return boolean 
     */ 
    public static void delFile(String filePathAndName) { 
        String filePath = filePathAndName; 
        filePath = filePath.toString(); 
        File myDelFile = new File(filePath); 
        myDelFile.delete(); 
    } 
 
    /** 
     * 这个方法有问题,请谨慎使用,目前只支持带BOM的文件 
     * 
     * @param fileName 
     * @return 
     */ 
    public static String getFileEncoding(String fileName) { 
            return CharacterSetToolkit.UTF_8; 
    } 
 
    /** 
     * 获取给定目录下符合匹配结果的文件列表 
     * 
     * @param path 
     * @param extend 
     * @param includeSubDir 
     * @return 
     */ 
    public static List<String> getSubFiles(String path, String extend, boolean includeSubDir) { 
        List<String> files = new ArrayList<String>(); 
        File root = new File(path); 
        if (root.exists()) { 
            File[] filelist = root.listFiles(); 
            if (filelist != null) { 
                for (File f : filelist) { 
                    if (f.isDirectory() && includeSubDir) { 
                        files.addAll(getSubFiles(f.getAbsolutePath(), extend, includeSubDir)); 
                    } else if (f.getName().endsWith(extend) || StringUtil.isMatch(f.getName(), extend) || StringUtil.isEmpty(extend)) 
                        files.add(f.getAbsolutePath().replace("//", "/")); 
                } 
            } 
        } else { 
            logger.info("path not exists :" + path); 
        } 
        logger.debug("found " + files.size() + " file in " + path); 
        return files; 
    } 
 
    public static Stack<String> getSubDir(String path, String extend) { 
        Stack<String> files = new Stack<String>(); 
        File root = new File(path); 
        if (root.exists()) { 
            File[] filelist = root.listFiles(); 
            if (filelist != null) { 
                for (File f : filelist) { 
                    if (f.isDirectory()) { 
                        Stack<String> nextDirs = getSubDir(f.getAbsolutePath(), extend); 
                        while (!nextDirs.empty()) { 
                            files.push(nextDirs.pop()); 
                        } 
                        if (f.getName().endsWith(extend) || StringUtil.isMatch(f.getName(), extend) || StringUtil.isEmpty(extend)) 
                            files.push(f.getAbsolutePath()); 
                    } 
                } 
            } 
        } else { 
        	logger.info("path not exists :" + path); 
        } 
        return files; 
    } 
 
    public static List<String> getSubFiles(String path, String extend) { 
        return getSubFiles(path, extend, false); 
    } 
 
    public static String getFilePath(File file) { 
        if (file == null) return ""; 
        return file.getAbsolutePath().replace("//", "/"); 
    } 
 
    /** 
     * @param inFilename  输入文件 
     * @param outFilename 目标文件 
     * @param append      是否以追加方式写入 
     * @return 写入到新文件的字节数 
     * @throws java.io.IOException 
     */ 
    public static long copyFile(String inFilename, String outFilename, boolean append) throws IOException { 
        try { 
            FileOper.moveFile(inFilename, inFilename + ".tmp"); 
            inFilename = inFilename + ".tmp"; 
            InputStream is = new FileInputStream(inFilename); 
            int fileSize = 0; 
            File file = new File(outFilename); 
            if (!file.exists()) file.createNewFile(); 
            String line; 
            String encode = FileOper.getFileEncoding(inFilename); 
//            System.out.println(inFilename + " encoding is " + encode); 
            BufferedReader reader = new BufferedReader(new InputStreamReader(is, encode)); 
            // FileOutputStream构造函数中的第二个参数true表示以追加形式写文件 
            BufferedWriter out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(outFilename, append), encode)); 
            line = reader.readLine(); 
            while (line != null) { 
                out.write(line); 
                out.write("/"); 
                fileSize += line.length(); 
                line = reader.readLine(); 
            } 
            out.close(); 
            reader.close(); 
            is.close(); 
            return fileSize; 
        } catch (Exception ex) { 
            logger.error(ex.getMessage(), ex); 
            return 0; 
        } 
    } 
 
    public static void deleteFiles(List<String> files) { 
        for (String s : files) { 
            try { 
                logger.info("Delete file " + s); 
                delFile(s); 
            } catch (Exception ex) { 
                logger.error(ex.getMessage()); 
            } 
        } 
    } 
 
    public static void delFiles(String path, String filter) { 
        delFiles(path, filter, true); 
    } 
 
    public static void delFiles(String path, String filter, boolean subForder) { 
        List<String> files = getSubFiles(path, filter, subForder); 
        for (String file : files) { 
            delFile(file); 
        } 
    } 
 
    /** 
     * @param path String 文件夹路径 如 c:/fqf 
     */ 
    public static void delAllFile(String path) { 
        File file = new File(path); 
        if (!file.exists()) { 
            return; 
        } 
        if (!file.isDirectory()) { 
            return; 
        } 
        List<String> tempList = getSubFiles(path, ""); 
        File temp = null; 
        for (int i = 0; i < tempList.size(); i++) { 
            if (path.endsWith(File.separator)) { 
                temp = new File(tempList.get(i)); 
            } else { 
                temp = new File(tempList.get(i)); 
            } 
            if (temp.isFile()) { 
                temp.delete(); 
            } 
            if (temp.isDirectory()) { 
                delAllFile(tempList.get(i));// 先删除文件夹里面的文件 
                delFolder(tempList.get(i));// 再删除空文件夹 
            } 
        } 
    } 
 
    /** 
     * @param folderPath String 文件夹路径及名称 如c:/fqf 
     * @return boolean 
     */ 
    public static void delFolder(String folderPath) { 
        try { 
            delAllFile(folderPath); // 删除完里面所有内容 
            String filePath = folderPath; 
            filePath = filePath.toString(); 
            File myFilePath = new File(filePath); 
            myFilePath.delete(); // 删除空文件夹 
        } catch (Exception e) { 
            logger.error(e.getMessage(), e); 
        } 
    } 
 
    /** 
     * @param oldPath String 原文件路径 如:c:/fqf.txt 
     * @param newPath String 复制后路径 如:f:/fqf.txt 
     * @return boolean 
     */ 
    public static long copyFile(String oldPath, String newPath) { 
        try { 
            int byteread = 0; 
            int bytesum = 0; 
 
            File oldfile = new File(oldPath); 
            if (oldfile.exists()) { // 文件存在时 
                File newFile = new File(newPath); 
                if (newFile.isDirectory()) { 
                    if (!newPath.endsWith("//") && !newPath.endsWith("/")) { 
                        newPath += "/"; 
                    } 
                    newPath += oldfile.getName(); 
                } 
                InputStream inStream = new FileInputStream(oldPath); // 读入原文件 
                FileOutputStream fs = new FileOutputStream(newPath); 
                byte[] buffer = new byte[1444]; 
                while ((byteread = inStream.read(buffer)) != -1) { 
                    bytesum += byteread; // 字节数 文件大小 
                    fs.write(buffer, 0, byteread); 
                } 
                inStream.close(); 
                fs.close(); 
            } 
            return bytesum; 
        } catch (Exception e) { 
            logger.error(e.getMessage(), e); 
            return 0; 
        } 
    } 
 
    /** 
     * @param oldPath String 原文件路径 如:c:/fqf 
     * @param newPath String 复制后路径 如:f:/fqf/ff 
     * @return boolean 
     */ 
    public static void copyFolder(String oldPath, String newPath) { 
 
        try { 
            (new File(newPath)).mkdirs(); // 如果文件夹不存在 则建立新文件夹 
            File a = new File(oldPath); 
            String[] file = a.list(); 
            File temp = null; 
            for (int i = 0; i < file.length; i++) { 
                if (oldPath.endsWith(File.separator)) { 
                    temp = new File(oldPath + file[i]); 
                } else { 
                    temp = new File(oldPath + File.separator + file[i]); 
                } 
 
                if (temp.isFile()) { 
                    FileInputStream input = new FileInputStream(temp); 
                    FileOutputStream output = new FileOutputStream(newPath + "/" + (temp.getName()).toString()); 
                    byte[] b = new byte[1024 * 5]; 
                    int len; 
                    while ((len = input.read(b)) != -1) { 
                        output.write(b, 0, len); 
                    } 
                    output.flush(); 
                    output.close(); 
                    input.close(); 
                } 
                if (temp.isDirectory()) {// 如果是子文件夹 
                    copyFolder(oldPath + "/" + file[i], newPath + "/" + file[i]); 
                } 
            } 
        } catch (Exception e) { 
            logger.error(e.getMessage(), e); 
            e.printStackTrace(); 
        } 
    } 
 
    /** 
     * 移动 
     * @param oldPath String 如:c:/fqf.txt 
     * @param newPath String 如:d:/fqf.txt 
     * @return  
     */ 
    public static boolean moveFile(String oldPath, String newPath) { 
    	  File oldfile = new File(oldPath); 
    	if (!oldfile.exists()) { 
			logger.error("文件:" + oldPath + "不存在,不能移动!"); 
			return false; 
		} 
    	File newfile = new File(newPath); 
    	if(newfile.exists()){ 
    		logger.error("文件:" + newPath + "已存在,不能起重复名!"); 
			return false; 
    	} 
        copyFile(oldPath, newPath); 
        delFile(oldPath); 
		return true; 
    } 
 
 
    /** 
     * 移动文件到指定目录 
     * 
     * @param oldPath String 如:c:/fqf.txt 
     * @param newPath String 如:d:/fqf.txt 
     */ 
    public static void moveFolder(String oldPath, String newPath) { 
        copyFolder(oldPath, newPath); 
        delFolder(oldPath); 
    } 
 
    /** 
     * @return String 
     */ 
    public static String getPath() { 
        String sysPath = FileOper.class.getResource("/").getPath(); 
        // 对路径进行修改 
        sysPath = sysPath.substring(1, sysPath.length() - 16); 
        return sysPath; 
    } 
 
    public static void createForder(String path) { 
        File forder = new File(path); 
        if (!forder.exists()) { 
            forder.mkdirs(); 
        } 
    } 
 
    public static boolean isFileExist(String filePath) { 
        File file = new File(filePath); 
        return file.exists(); 
    } 
 
    public static long getLength(String filePath) { 
        File file = new File(filePath); 
        if (!file.exists()) return 0; 
        return file.length(); 
    } 
 
} 

  

原创文章,作者:Maggie-Hunter,如若转载,请注明出处:https://blog.ytso.com/tech/pnotes/17859.html

(0)
上一篇 2021年7月19日 20:34
下一篇 2021年7月19日 20:35

相关推荐

发表回复

登录后才能评论