这里写自定义目录标题

• 一：文件流通用操作工具类
• • 二、工具类讲解
  • 三、拓展报错解决

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

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（）即解决此问题

本文链接：https://my.lmcjl.com/post/8780.html