Java实现读取TXT和CSV文件内容
作者：just-do-it-zzj
这篇文章主要为大家详细介绍了如何利用Java语言实现读取TXT和CSV文件内容的功能，文中的示例代码讲解详细，感兴趣的小伙伴可以了解一下
最近在编写一个通用可配置的实时ETL工具，即把通过Flink把Kafka的JSON 格式的数据解析后写入关系型数据库，业务要求新来一个JSON格式的业务数据后，通过在配置文件中读取JSON和关系型数据库中表的列映射关系，运行作业即可入库；每一个JSON格式的API对应一个CSV的配置文件，因此需要读取CSV的文件获取配置，本文记录读取CSV和过程，顺便记录了读取TXT的过程。
1.引入java
使用com.csvreader.CsvReader时需要在pom.xml中引用对应的jar包
<!--csv文件操作-->
<dependency>
<groupId>net.sourceforge.javacsv</groupId>
<artifactId>javacsv</artifactId>
<version>2.0</version>
</dependency>
2.实现代码
package util;
import com.csvreader.CsvReader;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
import java.util.ArrayList;
public class ReadFileTool {
//读取文件
public static String readTextFile(String jsonFile) {
StringBuilder stringBuilder = new StringBuilder();
try {
//01.FileInputStream（字节流） 实现了InputStream接口，用来读取文件中的字节流，参数是文件或者文件路径+文件名称
FileInputStream fileInputStream = new FileInputStream(jsonFile);
//02.将 fileInputStream（字节流） 流作为参数，转为InputStreamReader（字符流）
InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "UTF-8");
//03.将 字符流（参数）转为字符串流，带缓冲的流读取，默认缓冲区8k
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
String tempString;
while ((tempString = bufferedReader.readLine()) != null)
// 将字符串 添加到 stringBuilder中
stringBuilder.append(tempString);
bufferedReader.close();
} catch (Exception e) {
e.printStackTrace();
return stringBuilder.toString();
//通过BufferedReader读取CSV
public static ArrayList readCsvFileFromJava(String csvFile,String encoding) {
ArrayList<String[]> csvArrList=new ArrayList<String[]>();
StringBuilder stringBuilder = new StringBuilder();
try {
//01.FileInputStream（字节流） 实现了InputStream接口，用来读取文件中的字节流，参数是文件或者文件路径+文件名称
FileInputStream fileInputStream = new FileInputStream(csvFile);
//02.将 fileInputStream（字节流） 流作为参数，转为InputStreamReader（字符流）
InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, encoding);
//03.将 字符流（参数）转为字符串流，带缓冲的流读取，默认缓冲区8k
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
String line;
while ((line = bufferedReader.readLine()) != null)
// System.out.println(line);
String item[] = line.split(",",-1);//CSV格式文件为逗号分隔符文件，这里根据逗号切分,-1表示获取所有空值
csvArrList.add(item);
bufferedReader.close();
} catch (Exception e) {
e.printStackTrace();
return csvArrList;
//通过com.csvreader.CsvReader 读取CSV
public static ArrayList readCsvFileFromCsvReader(String csvFile,String encoding) {
ArrayList<String[]> csvArrList=new ArrayList<String[]>();
try {
CsvReader reader = new CsvReader(csvFile, ',', Charset.forName(encoding));
reader.readHeaders();
String[] headArray = reader.getHeaders();//获取标题
for(String a:headArray){
System.out.print(a);
System.out.println();
System.out.println("---------");
while (reader.readRecord()) {
// System.out.println(Arrays.asList(reader.getValues()));
// 按行读取，并把每一行的数据添加到list集合
csvArrList.add(reader.getValues());
reader.close();
} catch (Exception e) {
e.printStackTrace();
return csvArrList;
public static void main(String[] args) {
String userDir = System.getProperty("user.dir");
String fileDir = userDir + File.separator + "sourceFile" + File.separator;
String cfgFileName = "dwd_op_event.csv";
String csvFullFileName = fileDir + cfgFileName;
ArrayList<String []> csvArrList =readCsvFileFromCsvReader(csvFullFileName,"GBK");
到此这篇关于Java实现读取TXT和CSV文件内容的文章就介绍到这了,更多相关Java读取TXT CSV内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
您可能感兴趣的文章:
IDEA插件之mybatisx插件使用教程(超详细!)2023-06-06
详解Java中的有参构造方法与无参构造方法2023-06-06
Java中Bean转Map问题归纳总结2023-06-06
SpringSecurity安全框架在SpringBoot框架中的使用详解2023-06-06
一文详解如何在控制台显示MyBatis的SQL语句2023-06-06
Java实现更新顺序表中的指定元素的示例2023-06-06
详解Java中的有参构造方法与无参构造方法2023-06-06
Spring中bean标签的用法详解2023-06-06
美国设下计谋,用娘炮文化重塑日本,已影响至中国2021-11-19
时空伴随者是什么意思?时空伴随者介绍2021-11-09
工信部称网盘企业免费用户最低速率应满足基本下载需求，天翼云盘回应：坚决支持，始终2021-11-05
2022年放假安排出炉：五一连休5天 2022年所有节日一览表2021-10-26
电脑版 - 返回首页
2006-2023 脚本之家 JB51.Net , All Rights Reserved.
苏ICP备14036222号
