一：文件流通用操作工具类

package com.zkyq.file.common.utils;

import com.zkyq.common.utils.DateUtils;
import com.zkyq.file.common.service.EleRealDataService;
import com.zkyq.file.common.service.impl.EleRealDataServiceImpl;
import com.zkyq.file.common.template.FileTemplate;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.nio.charset.StandardCharsets;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * @创建人 KT
 * @创建时间 2023/6/12
 * @描述 文件的操作工具类
 */
public class FileUtils {

    private static Logger logger = LoggerFactory.getLogger(JavaBeanUtils.class);

    /** 读取文件，并按照文件写入时间进行排序 */
    public static List<FileTemplate> readFileInfo(String rootDir) {

        List<FileTemplate> voList = new ArrayList<>();
        BufferedReader br = null;
        try {

            File[] files = new File(rootDir).listFiles((dir, fileName) -> fileName.endsWith(".txt"));

            if (files == null || files.length == 0) { return voList;}
            for (File file : files) {

                br = new BufferedReader(new InputStreamReader(new FileInputStream(file),
                        StandardCharsets.UTF_8));
                String contentLine;

                while ((contentLine = br.readLine()) != null) {
                    voList.add(new FileTemplate(file, file.lastModified(), contentLine));
                }
                br.close();
            }
            return voList;
        } catch (UnsupportedEncodingException e) {
            logger.error("获取文件流转码异常", e);
        } catch (FileNotFoundException e) {
            logger.error("获取文件流异常", e);
        } catch (IOException e) {
            logger.error("读取文件异常", e);
        }finally {
            try {
                if (br != null){br.close();}
            } catch (IOException e) {
                logger.error("关闭流异常", e);
            }
        }
        return voList;
    }

    /** 转移文件 */
    public static void backupsFile(String backupPath, FileTemplate fileVo){
        String day = DateUtils.getDay(0);
        File file = new File(backupPath + "\\" + day);
        if (!file.exists()){ file.mkdirs(); }
        File oldFile = fileVo.getFile();
        String name = oldFile.getName();
        File newFile = new File(backupPath + "\\" + day + "\\" + name);
        oldFile.renameTo(newFile);
    }

    /** 批量转移文件 */
    public static void backupsFiles(String backupPath, List<FileTemplate> fileVos){
        String day = DateUtils.getDay(0);
        String path = backupPath + "/" + day;
        File file = new File(path);
        if (!file.exists()){ file.mkdirs();}
        for (FileTemplate fileVo : fileVos) {
            if (fileVo.getFile().exists()){
                File oldFile = fileVo.getFile();
                String name = oldFile.getName();
                String newPath = path + "/" + name;
                File newFile = new File(newPath);
                oldFile.renameTo(newFile);
            }
        }
    }

    /** 删除文件夹及其下面所有的文件 */
    public static void deleteFile(String backupPath, Integer daysBefore){
        Integer day = Integer.valueOf(DateUtils.getDay(daysBefore));
        File file = new File(backupPath);
        if (file.isDirectory()){
            File[] files = file.listFiles();
            if (files != null && files.length != 0){
                for (File menuFile : files) {
                    if (menuFile.isDirectory() && Integer.valueOf(menuFile.getName()) < day){ for (File document : menuFile.listFiles()) { document.delete(); } }
                    menuFile.delete();
                }
            }
        }
    }

    public static void main(String[] args) throws ParseException {
        EleRealDataService realDataService = new EleRealDataServiceImpl();
        realDataService.insertRealInfo();
    }
}

二、工具类讲解

     工具类读取文件作用：
         此工具类不仅可以循环获取需要读取的文件，还可以获取读取一个文件里面的多条数据。即同时可以读取多个文件的多条内容。
     重点方法（读取多条数据方法）readLine（）讲解：
         readLine()方法是属于BufferReader：字符读取流缓冲区的方法；它表示每次读取一行数据。
         参数：此方法不接受任何参数（行尾应以’\ n’或’\ r’或EOF来理解）。
         返回值：此方法返回此方法读取的String，并排除任何可用的终止符号。如果缓冲的流已经结束并且没有要读取的行，则此方法返回NULL。
         异常：如果发生I /O错误，则此方法将引发IOException。
     readLine()方法的原理及与rede()对比：
         readLine()方法无论读取一行数据还是读取多个字符，最终调用的方法还是读取字符流(Reader)中的read()方法，一次读取一个字符。

read()方法读取输入流

         read()方法读取的是单个字符，也可以说只要有输入流就会一直读取，返回的值是：作为一个整数（其范围从 0 到 65535 (0x00-0xffff)）读入的字符，如果已到达流末尾，则返回 -1

         因此使用该方法时应该尽量避免输入流数据重复的发送，这样会导致read()读取到很长的重复数据，导致读取超时，但是对于仅有单次发送的输入流，则可以使用read()方法，具体使用如下：

InputStream in = client.getInputStream(); //获取到客户端的输入流
byte[] a = new byte[1024]; //定义字节数组
int len = in.read(a); //由于信息的传输是以二进制的形式，所以要以二进制的形式进行数据的读取
String data = new String(a, 0,len);
System.out.println("输入流消息：" + data);

Readline()方法读取输入流

         readLine方法读取一个是文本行。通过下列字符之一即可认为某行已终止：换行 (‘\n’)、回车 (‘\r’) 或回车后直接跟着换行。 返回的值是：包含该行内容的字符串，不包含任何行终止符，如果已到达流末尾，则返回 null
也就是说只要readLine方法读取到的输入流中含有回车换行符，则读取结束，这样的话对于连续重复发送的输入流信息，我们可以在每条信息的末尾增加一个回车换行符，这样readLine方法读取到该符号时就会自动结束，具体使用如下：

BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "9527"));
String msg = br.readLine();
if(msg != null) {
    System.out.println("收到输入流信息：" + msg + "\n");
}

Readlines()方法读取输入流(Python)
         相对于readline()方法来说readlines()相对会快一些，因为readlines()是一次读取文本中的所有行，并且返回值是一个列表。

三、拓展报错解决

//报错信息
java.net.SocketTimeoutException: Read timed out

         即读取时间超时，但是从服务器发送过来的数据并不很长，所以按照正常情况下读取超时的情况一般是不会出现的，经过仔细研究发现是因为read()方法读取的是单个字符，会以流末尾作为结束，也就是说只要连接方一直在重复的发送数据，那么read()就会一直在读取一个很长的输入流，这样的话当然就会很容易造成读取超时的问题了，所以使用readLine（）即解决此问题