EasyExcel多次写入数据&多个EasyExcel文件导出到zip压缩文件

笔者最近需要导出一百多万条数据到Excel,已经超出单张工作表的最大容量(2^20=1048576),需要导出到多个工作表或多个Excel文件。

海量数据导出面临的问题有以下几个:

  1. 如果一次性查出所有数据,很可能内存溢出,所以需要分页导出,分页导出就必须解决大分页查询的性能问题。
    该问题网上有很多解决办法,本文不涉及。

  2. 如果使用POI进行数据导出,内存、CPU占用都很高,而且速度很慢,所以采用EasyExcel进行数据导出。在上一篇使用EasyExcel读写Excel文件中,数据是一次性写入的,本文介绍EasyExcel多次写入数据的方法。

  3. 将多个EasyExcel的数据写入到zip文件中。通过将EasyExcel写入到ByteArrayOutputStream,再将ByteArrayOutputStream转成byte数组,写入到zip中。


1.在pom.xml中添加POI相关依赖

        <!-- easyexcel -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>easyexcel-core</artifactId>
            <version>3.3.2</version>
        </dependency>

2.实体类

package com.example.study.entity;


import com.alibaba.excel.annotation.ExcelProperty;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Getter;
import lombok.Setter;

import java.util.Date;

@Getter
@Setter
public class StudentEntity {
    @ExcelProperty(value = "id", order = 1)
    private Integer id;

    @ExcelProperty(value = "生日", order = 4)
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date birthday;

    @ExcelProperty(value = "名字", order = 2)
    private String name;

    @ExcelProperty(value = "性别", order = 3)
    private String sex;

    private String desc;

    private String extra;
}

3.写入数据

package com.example.study.common;

import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.ExcelWriter;
import com.alibaba.excel.write.metadata.WriteSheet;
import com.example.study.entity.StudentEntity;

import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

public class EasyExcelWriteToZipDemo {
    public static void main(String[] args) {
        String writeExcel = "F:\\tmp\\batch_export.zip";
        write(writeExcel);
    }

    private static void write(String writeExcel) {
        // 设置不需要导出的字段
        Set<String> excludeColumnFieldNames = new HashSet<>();
        excludeColumnFieldNames.add("desc");
        excludeColumnFieldNames.add("extra");
        WriteSheet sheet = EasyExcel.writerSheet("花名册")
                .excludeColumnFieldNames(excludeColumnFieldNames)
                .needHead(Boolean.TRUE)
                .build();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ExcelWriter workbook = EasyExcel.write(baos, StudentEntity.class).build();
        int sheetMaxSize = 1001;
        int currentExcelSize = 0;
        int count = 0;
        int total = 3111;
        int fileIndex = 1;
        try (FileOutputStream fos = new FileOutputStream(writeExcel);
             ZipOutputStream zos = new ZipOutputStream(fos)) {
            while (count < total) {
                List<StudentEntity> page = getPage(count + 1, total);
                if (currentExcelSize + page.size() > sheetMaxSize) {
                    // 超过单个文件最大数据条数后,写入到zip文件,并将当前页面数据写入新的excel文件
                    workbook.close();
                    zos.putNextEntry(new ZipEntry(String.format("数据导出文件_%s.xlsx", fileIndex++)));
                    zos.write(baos.toByteArray());
                    baos = new ByteArrayOutputStream();
                    workbook = EasyExcel.write(baos, StudentEntity.class).build();
                    currentExcelSize = page.size();
                } else {
                    currentExcelSize += page.size();
                }
                workbook.write(page, sheet);
                count += page.size();
            }
            if (currentExcelSize > 0) {
                workbook.close();
                zos.putNextEntry(new ZipEntry(String.format("数据导出文件_%s.xlsx", fileIndex++)));
                zos.write(baos.toByteArray());
            }
            zos.flush();
            fos.flush();
        } catch (IOException exception) {
            exception.printStackTrace();
        }
    }

    private static List<StudentEntity> getPage(int lastMaxId, int total) {
        List<StudentEntity> page = new ArrayList<>();
        for (int index = lastMaxId; index < Math.min(lastMaxId + 100, total + 1); index++) {
            StudentEntity student = new StudentEntity();
            student.setId(index);
            student.setName("名字_" + index);
            student.setSex(index % 2 == 0 ? "女" : "男");
            student.setBirthday(new Date());
            student.setDesc("test desc");
            student.setExtra("test extra");
            page.add(student);
        }
        return page;
    }
}
在使用 EasyExcel 和 `ZipEntry` 实现多文件流压缩并将压缩结果上传至服务器时,可以通过以下步骤完成整个流程: ### 数据准备与导出Excel 文件流 首先,通过 EasyExcel多个数据导出多个 Excel 文件流。可以利用 `ByteArrayOutputStream` 作为每个 Excel 文件的临时存储容器,以便后续将其添加到 ZIP 压缩包中。 ```java public static ByteArrayOutputStream exportExcelToStream(ExcelData excelData) { ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); EasyExcel.write(outputStream) .head(excelData.getHead()) .sheet(excelData.getSheetName()) .doWrite(excelData.getData()); return outputStream; } ``` ### 构建 ZIP 流并添加多个 Excel 文件流 接下来,将上述生成的多个 Excel 文件流依次写入到一个 ZIP 流中。可以使用 `ZipOutputStream` 和 `ZipEntry` 来实现该功能。 ```java public static byte[] createZipWithExcelFiles(List&lt;ExcelData&gt; dataList) throws IOException { ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream(); try (ZipOutputStream zipOut = new ZipOutputStream(zipOutputStream)) { for (ExcelData data : dataList) { ByteArrayOutputStream excelStream = exportExcelToStream(data); ZipEntry zipEntry = new ZipEntry(data.getFileName() + &quot;.xlsx&quot;); zipOut.putNextEntry(zipEntry); zipOut.write(excelStream.toByteArray()); zipOut.closeEntry(); } } return zipOutputStream.toByteArray(); } ``` ### 上传 ZIP 文件流至服务器 最后,将生成的 ZIP 字节流上传至服务器。这一步骤可以使用 HTTP 客户端(如 Apache HttpClient 或 OkHttp)进行上传操作。以 Apache HttpClient 为例: ```java public static void uploadZipFile(byte[] zipData, String serverUrl) throws Exception { CloseableHttpClient httpClient = HttpClients.createDefault(); HttpPost uploadHttpPost = new HttpPost(serverUrl); // 设置上传的文件内容 ByteArrayBody byteArrayBody = new ByteArrayBody(zipData, &quot;exported_files.zip&quot;); MultipartEntityBuilder builder = MultipartEntityBuilder.create(); builder.addPart(&quot;file&quot;, byteArrayBody); HttpEntity entity = builder.build(); uploadHttpPost.setEntity(entity); HttpResponse response = httpClient.execute(uploadHttpPost); if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { System.out.println(&quot;ZIP file uploaded successfully.&quot;); } else { System.out.println(&quot;Failed to upload ZIP file.&quot;); } } ``` ### 注意事项 - 确保所有流对象(如 `ByteArrayOutputStream`、`ZipOutputStream`)在使用完毕后正确关闭,避免资源泄露。 - 在实际应用中,应处理可能出现的异常情况,例如网络中断、内存溢出等[^2]。 - 若需支持大文件导出和压缩,建议优化内存管理,例如使用临时文件或分块写入的方式。
评论
成就一亿技术人!
拼手气红包6.0元
还能输入1000个字符
 
红包 添加红包
表情包 插入表情
 条评论被折叠 查看
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值