今天在工作中遇到了一个需求，需要用Java处理post请求中的csv文件，由于之前没处理过，遇到了很多问题，特此记录。
由于具体的业务会有区别，本文主要介绍了处理逻辑的代码，如需要请结合具体业务与注释做出修改即可。

pom坐标

<!--GetByteEncode,用来判断二进制字节流的编码-->
        <dependency>
            <groupId>com.googlecode.juniversalchardet</groupId>
            <artifactId>juniversalchardet</artifactId>
            <version>1.0.3</version>
        </dependency>

Controller

用springboot中的MultipartFile去接收文件，然后转为字节数组调用我们写好的工具类处理，处理结果为List形式，key为我们配置的列名，value为数据，每列数据存入一个map中，可以根据需要自行修改。

@RestController
@RequestMapping("/admin")
public class TestCntroller {
    
    @RequestMapping("/test/upload")
    public void upload(HttpServletRequest request , MultipartFile upfile) throws Exception{
    
        if(request.getMethod().equals("POST")){
    
            byte[] bate = upfile.getBytes();
            List<Map<String,Object>> list = ReadCsvUtil.getResource(bate);
}

csv工具类具体代码

import java.io.*;
import java.util.*;

public class ReadCsvUtil {
    
    private static final String FIX="\uFEFF";
    /**
     * 获取csv文件内容
     * @return 对象list
     */
    public static List<Map<String,Object>> getResource(byte[] bate) throws IOException {
    
        List<Map<String,Object>> allString = new ArrayList();
        Map<String,Object> callLogInfo;
        List<String> list = new ArrayList();
        // 获取文件内容
        list = getSource(bate);
        // 获取文件表头
        List<String> title = Arrays.asList(list.get(0).split(","));
        //此处可用一循环去获取文件表头
        String customerName = title.get(0).trim();

        // 头部会带有"\uFEFF"值
        if(customerName.startsWith(FIX)){
    
            customerName = customerName.replace(FIX, "");
        }
        callLogInfo = new HashMap();
        //此处可用一循环遍历所有列
        callLogInfo.put("列名",customerName);
		//将当前列处理完后加入list中
        allString.add(callLogInfo);
		//去掉表头行
        list.remove(0);
        // 循环内容
        for(int i = 0; i<list.size();i++){
    
            List<String> content = Arrays.asList(list.get(i).split(","));
            if(content!=null){
    
                callLogInfo = new HashMap();
                //此处可根据需要遍历所有列添加
                callLogInfo.put("列名",content.get(0));

                allString.add(callLogInfo);
            }
        }
        return allString;
    }

    /**
     * 读文件数据
     */
    public static List<String> getSource(byte[] bate) throws IOException {
    
        BufferedReader br = null;
        ByteArrayInputStream fis=null;
        InputStreamReader isr = null;
        try {
    
            fis = new ByteArrayInputStream(bate);
            //指定以当前文件编码读取
            isr = new InputStreamReader(fis,GetByteEncode.getEncoding(bate));
            br = new BufferedReader(isr);
        } catch (Exception e) {
    
            e.printStackTrace();
        }
        String line;
        String everyLine ;
        List<String> allString = new ArrayList<>();
        try {
    
            //读取到的内容给line变量
            while ((line = br.readLine()) != null){
    
                everyLine = line;
                allString.add(everyLine);
            }
        } catch (IOException e) {
    
            e.printStackTrace();
        }finally {
    
            if(fis != null){
    
                fis.close();
            }
            if(isr != null){
    
                isr.close();
            }
        }
        return allString;
    }
}

判断二进制字节流编码

由于会遇到很多不同的编码格式的文件，因此需要判断文件编码格式。注意最上方的的pom一定要导入，否则无法使用。

import org.mozilla.universalchardet.UniversalDetector;
/**
 * 获取byte编码
 * @Author LuChuan
 * @Date 2021/7/8 11:28
 */
public class GetByteEncode {
    

    /**
     * 获取文件编码类型
     *
     * @param bytes 文件bytes数组
     * @return      编码类型
     */
    public static String getEncoding(byte[] bytes) {
    
        String defaultEncoding = "UTF-8";
        UniversalDetector detector = new UniversalDetector(null);
        detector.handleData(bytes, 0, bytes.length);
        detector.dataEnd();
        String encoding = detector.getDetectedCharset();
        detector.reset();
        if (encoding == null) {
    
            encoding = defaultEncoding;
        }
        return encoding;
    }
}

前端测试代码

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form action="http://localhost:8080/admin/test/upload" method="post" enctype="multipart/form-data">
    上传:<input type="file" name="upfile"/>
    <input type="submit" value="提交"/>
</form>
</body>
</html>