zoukankan      html  css  js  c++  java
  • 文件读取FileUtil工具类 亲测可用

    package com.bestpay.o2o.reconciliation.biz.utils;
    
    import com.bestpay.ext.logback.util.TraceLogIdUtil;
    import org.apache.commons.lang.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.slf4j.MDC;
    import org.slf4j.helpers.BestpayMarker;
    
    import java.io.*;
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     *
     * 读写  工具类
     * 超过百兆的文件  最好不要用此类 哈哈
     * @author    wangchunyang
     */
    public class FileUtils {
        public static final Logger logger = LoggerFactory.getLogger(FileUtils.class);
    
        /**
         * 指定目录下创建空文件
         *
         * @param filePath
         * @param fileName
         * @return
         */
        public static Boolean createNewFile(String filePath, String fileName) {
            // 如果dir不以文件分隔符结尾,自动添加文件分隔符  防止跨平台出现路径问题
            if (!filePath.endsWith(File.separator)) {
                filePath = filePath + File.separator;
            }
            //文件夹不存在则新建
            File fileDir = new File(filePath);
            if (!fileDir.exists()) {
                fileDir.setWritable(true);
                fileDir.mkdirs();
            }
    
            //新建文件
            File myFile = new File(filePath, fileName);
            try {
                myFile.createNewFile();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return true;
        }
    
    
        /**
         * 读文件
         * @param filePath /Users/baonier/Downloads/
         * @param fileName 2018.txt
         * @return
         */
        public static List<String[]> readerFile(String filePath, String fileName){
            MDC.put(BestpayMarker.TRACE_LOG_ID, TraceLogIdUtil.createTraceLogId());
            logger.info("call[FileUtils][readerFile]PARAMETER:[" + filePath+fileName + "]");
            long currentTime = System.currentTimeMillis();
            // 如果dir不以文件分隔符结尾,自动添加文件分隔符  防止跨平台出现路径问题
            if (!filePath.endsWith(File.separator)){
                filePath = filePath + File.separator;
            }
            // Text文件
            File file = new File(filePath+fileName);
            // 构造一个BufferedReader类来读取文件
            BufferedReader br = null;
            String s = null;
            String[] readers = null;
            List<String[]> readersList = new ArrayList<>();
            try {
                logger.info("开始读取文件路径:"+filePath+"中的:"+fileName);
                long readerTime = System.currentTimeMillis();
                br = new BufferedReader(new FileReader(file));
                // 使用readLine方法,一次读一行
                while ((s = br.readLine()) != null) {
                    //拆分
                    readers = s.split("\|");
                    //添加到集合中
                    readersList.add(readers);
                }
                logger.info("读取文件路径:"+filePath+"中的:"+fileName+"一共耗时:"+(System.currentTimeMillis()-readerTime));
            } catch (IOException e) {
                logger.error("读取文件路径:"+filePath+"中的:"+fileName+"发生异常,异常信息是:", e);
                return null;
            }finally {
                try {
                    if (br != null){
                        br.close();
                    }
                } catch (IOException e) {
                    logger.error("关闭读取文件流发生异常,异常信息是:", e);
                    return null;
                    }
            }
            logger.info("call[FileUtils][readerFile]PARAMETER:[" + filePath+fileName ,System.currentTimeMillis()-currentTime+"]");
            return readersList;
        }
    
        /**
         * 写文件
         * @param readersList  数据
         * @param filePath  路径  本地路径
         * @param fileName  文件名   远程文件名称.txt
         * @param controlWriterNum  从第几行开始写 例如: 从第2行开始 参数写  2
         * @Param wmFlag  标识  主要用于物美商户
         * @Param iphone  标识  手机号
         * @return
         */
        public static Boolean writerFile(List<String[]> readersList,String filePath,String fileName,
                                         int controlWriterNum,String isWmMerchant,
                                         String iphone){
            MDC.put(BestpayMarker.TRACE_LOG_ID, TraceLogIdUtil.createTraceLogId());
            logger.info("call[FileUtils][writerFile]PARAMETER:[" + filePath+fileName + "]");
            long currentTime = System.currentTimeMillis();
            FileWriter fw = null;
            File file = new File(filePath+fileName);
            int writerNum = 0;
            // 如果dir不以文件分隔符结尾,自动添加文件分隔符  防止跨平台出现路径问题
            if (!filePath.endsWith(File.separator)){
                filePath = filePath + File.separator;
            }
            try {
                //如果文件存在 那么删除它
                if (file.exists()){
                    file.getAbsolutePath();
                    boolean isDelete = deleteFile(filePath+fileName);
                    if (isDelete){
                        logger.info("文件已存在,原文件已删除");
                    }
                    file.createNewFile();
                }
                fw = new FileWriter(filePath+fileName);
                logger.info("开始写入文件路径:"+filePath+"中的:"+fileName);
                long writerTime = System.currentTimeMillis();
                for (String[] readers:readersList) {
                    writerNum++;
                    if (writerNum < controlWriterNum){
                        continue;
                    }
                    //物美对账专用
                    if ("WuMartMerchant".equals(isWmMerchant)){
                        //处理物美对账文件
                        handlerWuMartFile(readers,fw,iphone);
                    }else {
                        //普通的写文件
                        for (String reader:readers) {
                            fw.write(reader);
                        }
                    }
                }
                logger.info("写入文件路径:"+filePath+"中的:"+fileName+"一共耗时:"+(System.currentTimeMillis()-writerTime));
            } catch (IOException e) {
                logger.error("写入文件路径:"+filePath+"中的:"+fileName+"发生异常,异常信息是:", e);
                //出现异常删除已经写的文件
                if (!file.exists()) {
                    logger.error("删除文件失败:" + fileName + "不存在!");
                    return false;
                } else {
                    //如果是文件
                    if (file.isFile()){
                        deleteFile(filePath+fileName);
                    }
                    //如果是文件夹
                    else{
                        deleteDirectory(fileName);
                    }
                }
                return false;
            }finally {
                try {
                    if (fw != null){
                        fw.close();
                    }
                } catch (IOException e) {
                    logger.error("关闭写入文件流发生异常,异常信息是:", e);
                    return false;
                }
            }
            logger.info("call[FileUtils][writerFile]PARAMETER:[" + filePath+fileName ,System.currentTimeMillis()-currentTime+"]");
            return true;
        }
    
        /**
         * 处理物美对账文件
         * @param readers  读取到的数据
         * @param fw
         * @param iphone  手机号
          */
        public static void handlerWuMartFile(String[] readers,FileWriter fw,String iphone){
            for (int i = 0; i < readers.length; i++){
                //替换指定的字段  2  6  7
                if (i==2){
                    //手机号
                    readers[2]=iphone;
                }
                if (i==6){
                    //交易类型
                    if (readers[6].equals("0001")){
                        readers[6]="00";
                    }
                    if (readers[6].equals("0002")){
                        readers[6]="01";
                    }
                }
                if (i==7){
                    //手续费
                    int amt = Integer.parseInt(readers[7]);
                    amt = Math.abs(amt);
                    readers[7]=String.valueOf(amt);
                }
                try {
                    fw.write(readers[i]);
                    fw.write(",");
                    //此处暂时写死, 写完一行补位两个0, 待扩展
                    fw.write("0,0");
                    //系统的换行符
                    fw.write(System.getProperty("line.separator"));
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    
    
        /**
         * 删除单个文件
         *
         * @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.error("删除单个文件" + fileName + "成功!");
                    return true;
                } else {
                    logger.error("删除单个文件" + fileName + "失败!");
                    return false;
                }
            } else {
                logger.error("删除单个文件失败:" + fileName + "不存在!");
                return false;
            }
        }
    
        /**
         * 删除目录及目录下的文件
         *
         * @param dir
         *            要删除的目录的文件路径
         * @return 目录删除成功返回true,否则返回false
         */
        public static boolean deleteDirectory(String dir) {
            // 如果dir不以文件分隔符结尾,自动添加文件分隔符  防止跨平台出现路径问题
            if (!dir.endsWith(File.separator)){
                dir = dir + File.separator;
            }
            File dirFile = new File(dir);
            // 如果dir对应的文件不存在,或者不是一个目录,则退出
            if ((!dirFile.exists()) || (!dirFile.isDirectory())) {
                logger.error("删除目录失败:" + dir + "不存在!");
                return false;
            }
            boolean flag = true;
            // 删除文件夹中的所有文件包括子目录
            File[] files = dirFile.listFiles();
            for (int i = 0; i < files.length; i++) {
                // 删除子文件
                if (files[i].isFile()) {
                    /*
                        getAbsolutePath() 方法返回文件的绝对路径,如果构造的时候是全路径就直接返回全路径,
                        如果构造时是相对路径,就返回当前目录的路径 + 构造 File 对象时的路径
                     */
                    flag = deleteFile(files[i].getAbsolutePath());
                    if (!flag){
                        break;
                    }
                }
                // 删除子目录
                else if (files[i].isDirectory()) {
                    flag = deleteDirectory(files[i]
                            .getAbsolutePath());
                    if (!flag){
                        break;
                    }
                }
            }
            if (!flag) {
                logger.error("删除目录失败!");
                return false;
            }
            // 删除当前目录
            if (dirFile.delete()) {
                logger.error("删除目录" + dir + "成功!");
                return true;
            } else {
                return false;
            }
        }
    }

    使用者需要稍作修改 !!!

  • 相关阅读:
    learn go memoization
    learn go return fuction
    Java5 并发学习
    Java中的protected访问修饰符
    LinkedBlockingQueue
    BlockingQueue的使用
    Java并发编程:Callable、Future和FutureTask
    Java线程池的工作原理与实现
    SQL Server中Delete语句表名不能用别名
    请问JDBC中IN语句怎么构建
  • 原文地址:https://www.cnblogs.com/yang1314/p/9504022.html
Copyright © 2011-2022 走看看