Java POI重复读取excel:stream closed,回退流PushbackInputStream解决

简介:

Java POI读取Excel有两种文件格式,2003和2007以上的,需要通过不同的api进行读取,于是写了下面的工具类。

public class ExcelReadUtil {
private static Logger log = LoggerFactory.getLogger(ExcelReadKit.class);
 /**
     * 
     * @param fis
     *            输入的文件流
     * @param sheetIndex
     *            第x个sheet
     * @return
     */
    public void readExcel(InputStream fis, int sheetIndex) {
    
        try {
            Sheet sheet = null;
            Workbook wb = null;
            try {
 // 利用poi读取excel文件流,2003版本
                POIFSFileSystem fs = new POIFSFileSystem(fis);
                wb = new HSSFWorkbook(fs); // 读取excel工作簿
                sheet = wb.getSheetAt(sheetIndex); // 读取excel的sheet,0表示读取第一个
            } catch (Exception e) {
 // 利用poi读取excel文件流,2007及以上版本
                wb = new XSSFWorkbook(fis); // 读取excel工作簿
                sheet = wb.getSheetAt(sheetIndex); // 读取excel的sheet,0表示读取第一个
            }

//读取操作省略。。。

            wb.cloneSheet(sheetIndex);
            fis.close();
        } catch (Exception e) {
            log.error("读取Excel文件流时出错:", e);
        } finally {
            if (fis != null) {
                try {
                    fis.close();
                } catch (Exception e) {
                }
            }
        }
    }
}

先读取2003(.xls)版本的,如果异常就读取2007(.xlsx)版本的,看起来没什么问题,但是实际使用中,当读取xlsx文件的时候会stream closed报错,这是为什么呢?原来当读取了一次文件流的异常之后,运行到wb = new XSSFWorkbook(fis); // 读取excel工作簿的时候,输入流已经被关闭了。
怎么解决这个InputStream 被关闭的问题呢?使用前用PushbackInputStream包装,读取前先POIFSFileSystem.hasPOIFSHeaderPOIFSFileSystem.hasPOIFSHeader方法读取流的头判断文件格式

修改如下:

public class ExcelReadUtil {
private static Logger log = LoggerFactory.getLogger(ExcelReadKit.class);
 /**
     * 
     * @param fis
     *            输入的文件流
     * @param sheetIndex
     *            第x个sheet
     * @return
     */
    public void readExcel(InputStream fis, int sheetIndex) {
    
        try {
             Sheet sheet = null;
            Workbook wb = null;
            // 不加报错:java.io.IOException: mark/reset not supported
            //PushbackInputStream参考:https://my.oschina.net/fhd/blog/345011
            if (!fis.markSupported()) {
                fis = new PushbackInputStream(fis, 8);
            }
            /**
             * 只能通过这种方式判断版本,使用如果通过
             * try catch捕获异常方式先读取了一次,流会被关闭,后面就读取不到了
             */
            //2003版
            if (POIFSFileSystem.hasPOIFSHeader(fis)) {
                // 读取excel工作簿
                wb = new HSSFWorkbook(fis);
            }
            //2007版
            else if (POIXMLDocument.hasOOXMLHeader(fis)) {
                //OPCPackage.open(fis)取得一个文件的读写权限
                wb = new XSSFWorkbook(OPCPackage.open(fis));
            }

//读取操作省略。。。

            wb.cloneSheet(sheetIndex);
            fis.close();
        } catch (Exception e) {
            log.error("读取Excel文件流时出错:", e);
        } finally {
            if (fis != null) {
                try {
                    fis.close();
                } catch (Exception e) {
                }
            }
        }
    }
}

使用工具类,此时读取两种格式的文件都没有问题了

public class ExcelReaderTest {

    @Test
    public void readData() throws IOException, ParseException {

        File file = new File("D:\\test.xlsx");
        ExcelReadUtil excelReader = new ExcelReadUtil();
        //只读取第一个sheet页
        excelReader.readExcel(new FileInputStream(file), 0);
//...
    }
}

具体PushbackInputStream介绍参考:https://my.oschina.net/fhd/blog/345011

目录
相关文章
|
7天前
|
安全 Java 大数据
|
10天前
|
SQL 存储 Java
java流式计算Stream
java流式计算Stream
11 0
|
20天前
|
Java API
掌握Java 8 Stream API的艺术:详解流式编程(三)
掌握Java 8 Stream API的艺术:详解流式编程
16 2
|
7天前
|
Java Unix Windows
|
1天前
|
分布式计算 Java API
Java 8新特性之Lambda表达式与Stream API
【5月更文挑战第1天】本文将介绍Java 8中的两个重要特性:Lambda表达式和Stream API。Lambda表达式是一种新的函数式编程语法,可以简化代码并提高可读性。Stream API是一种用于处理集合的新工具,可以方便地进行数据操作和转换。通过结合Lambda表达式和Stream API,我们可以更加简洁高效地编写Java代码。
|
2天前
|
Java
Java8 Stream Collectors groupingBy使用
Java8 Stream Collectors groupingBy使用
|
5天前
|
JavaScript Serverless API
Serverless 应用引擎操作报错合集之在Serverless 应用引擎中,FC3.0读取response body的时候出现错误提示"Caused by: java.io.IOException: closed"如何解决
Serverless 应用引擎(SAE)是阿里云提供的Serverless PaaS平台,支持Spring Cloud、Dubbo、HSF等主流微服务框架,简化应用的部署、运维和弹性伸缩。在使用SAE过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
19 3
|
5天前
|
Java API 开发者
【专栏】Java 8新特性之Stream API详解
【4月更文挑战第27天】Java 8的Stream API是处理集合数据的新方式,强调简洁和声明式编程。它基于延迟执行和惰性求值,提供创建、中间操作(如filter、map)和终端操作(如forEach、collect)。示例展示了如何通过Stream排序、过滤、映射和聚合数据。
|
7天前
|
Java 编译器 API
Java基础教程(17)-Java8中的lambda表达式和Stream、Optional
【4月更文挑战第17天】Lambda表达式是Java 8引入的函数式编程特性,允许函数作为参数或返回值。它有简洁的语法:`(parameters) -> expression 或 (parameters) ->{ statements; }`。FunctionalInterface注解用于标记单方法接口,可以用Lambda替换。
|
7天前
【POI】常用excel操作方法
【POI】常用excel操作方法
12 1