告别 OOM:EasyExcel 百万数据导出最佳实践(附开箱即用增强工具类)

@GetMapping("/export/simple")public void exportSimple(HttpServletResponse response) throws IOException {    // 1️⃣【风险点】全量查询！数据量大必OOM！    List<User> allUsers = userService.findAllUsers();     // 2️⃣ 设置响应头 (固定套路)    response.setContentType("application/vnd.ms-excel");    response.setCharacterEncoding("utf-8");    String fileName = URLEncoder.encode("用户列表", "UTF-8");    response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx");    // 3️⃣ EasyExcel 一键写入    EasyExcel.write(response.getOutputStream(), User.class)            .sheet("用户信息")            .doWrite(allUsers); // 全量数据一次性写入}

import com.alibaba.excel.EasyExcel;import com.alibaba.excel.ExcelWriter;import com.alibaba.excel.write.metadata.WriteSheet;import java.io.OutputStream;import java.util.List;/** * 【核心武器】分页写入Excel工具 - 专治各种不服(OOM) */public class PageWriteExcelHelper<T> {    // 🎯 关键接口：定义如何分页获取数据 (由调用方实现)    public interface PageQuerySupplier<T> {        List<T> getPage(int pageNum, int pageSize); // 第几页? 每页几条?    }    /**     * 执行分页写入     * @param outputStream  输出流 (响应OutputStream)     * @param head          数据模型Class (如 User.class)     * @param pageSize      【重要】每批次处理条数 (建议 1000~5000)     * @param totalCount    总数据量 (用于计算总页数)     * @param supplier      分页数据提供器 (你的业务查询逻辑)     */    public static <T> void writeByPage(OutputStream outputStream,                                      Class<T> head,                                      int pageSize,                                      int totalCount,                                      PageQuerySupplier<T> supplier) {        // 🔧 1. 初始化 ExcelWriter (EasyExcel 核心写入器)        ExcelWriter excelWriter = EasyExcel.write(outputStream, head).build();        WriteSheet writeSheet = EasyExcel.writerSheet("Sheet1").build(); // 默认Sheet        try {            // 📐 2. 计算总页数 (小心除0)            int totalPage = totalCount > 0 ? (int) Math.ceil((double) totalCount / pageSize) : 1;            // 🔁 3. 分页循环：查询 -> 写入 -> 释放for (int pageNum = 1; pageNum <= totalPage; pageNum++) {                // 🚚 3.1 获取当前页数据 (你的分页查询)                List<T> pageData = supplier.getPage(pageNum, pageSize);                // ✍️ 3.2 写入当前页到 Excel                excelWriter.write(pageData, writeSheet);                // 🗑️ 3.3 【关键】立即清空释放当前页内存！                pageData.clear();            }        } finally {            // 🔒 4. 【务必关闭】释放资源 (防止内存泄漏)if (excelWriter != null) {                excelWriter.finish(); // 重要！！！            }        }    }}

@GetMapping("/export/million")public void exportMassiveData(HttpServletResponse response) throws IOException {    // 1️⃣ 获取总数据量 (用于计算分页)    int totalUsers = userService.countTotalUsers();    // 2️⃣ 设置响应头 (固定套路)    response.setContentType("application/vnd.ms-excel");    response.setCharacterEncoding("utf-8");    String fileName = URLEncoder.encode("百万用户数据", "UTF-8");    response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx");    // 3️⃣ 【核心调用】使用分页工具类导出    PageWriteExcelHelper.writeByPage(            response.getOutputStream(), // 响应输出流            User.class,                 // 导出数据模型            2000,                      // 每页2000条 (根据业务调整)            totalUsers,                 // 总数据量            // 🚀 Lambda 实现分页查询逻辑 (优雅!)            (pageNum, pageSize) -> userService.findByPage(pageNum, pageSize)    );}

import com.alibaba.excel.EasyExcel;import com.alibaba.excel.ExcelWriter;import com.alibaba.excel.write.metadata.WriteSheet;import javax.servlet.http.HttpServletResponse;import java.io.IOException;import java.io.OutputStream;import java.net.URLEncoder;/** * 【开箱即用】EasyExcel 导出增强工具类 (支持普通/分页模式) */public class ExcelExporter {    // ============== 【1. 分页写入 (大数据量首选)】 ==============    public static <T> void exportByPage(HttpServletResponse response,                                       String fileName,    // 下载文件名                                       String sheetName,   // Sheet名称                                       Class<T> dataModel, // 数据类 (User.class)                                       int pageSize,       // 每页条数                                       int totalCount,     // 总条数                                       PageQuerySupplier<T> pageSupplier) { // 分页查询逻辑        setupResponse(response, fileName); // 设置响应头        try (OutputStream out = response.getOutputStream()) {            // 🎯 委托给核心分页工具执行            PageWriteExcelHelper.writeByPage(out, dataModel, pageSize, totalCount, pageSupplier);        } catch (Exception e) {            throw new RuntimeException("导出失败: " + e.getMessage(), e); // 统一异常处理        }    }    // ============== 【2. 普通导出 (小数据量)】 ==============    public static <T> void exportSimple(HttpServletResponse response,                                       String fileName,                                       String sheetName,                                       Class<T> dataModel,                                       List<T> dataList) { // 全量数据List        setupResponse(response, fileName);        try (OutputStream out = response.getOutputStream()) {            EasyExcel.write(out, dataModel)                    .sheet(sheetName)                    .doWrite(dataList); // 全量写入        } catch (Exception e) {            throw new RuntimeException("导出失败: " + e.getMessage(), e);        }    }    // ============== 【私有方法：响应头设置 (复用)】 ==============    private static void setupResponse(HttpServletResponse response, String fileName) {        try {            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");            response.setCharacterEncoding("UTF-8");            String encodedFileName = URLEncoder.encode(fileName, "UTF-8").replaceAll("\\+", "%20"); // 处理空格            response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + encodedFileName + ".xlsx");        } catch (Exception e) {            throw new RuntimeException("设置响应头失败", e);        }    }    // ============== 【内部接口：分页查询供应商】 ==============    @FunctionalInterface    public interface PageQuerySupplier<T> {        List<T> getPage(int pageNum, int pageSize); // 函数式接口    }}

// 场景1: 导出小数据量 (<1万)@GetMapping("/export/users/small")public void exportSmallUserList(HttpServletResponse response) {    List<User> smallList = userService.findRecentUsers(5000); // 查5000条    ExcelExporter.exportSimple(            response,"最近用户","用户数据",            User.class,            smallList    );}// 场景2: 导出大数据量 (10万+)@GetMapping("/export/users/large")public void exportLargeUserList(HttpServletResponse response) {    int total = userService.countTotalUsers();    ExcelExporter.exportByPage(            response,"全量用户数据","用户清单",            User.class,            3000, // 每批3000条            total,            (pageNum, pageSize) -> userService.findByPage(pageNum, pageSize) // 你的分页查询    );}

public static int calculateOptimalPageSize(Class<?> clazz) {    // 1. 估算单条数据大小 (字节) - 根据业务模型调整逻辑    long approxBytesPerRow = 500; // 保守估计500字节/行    // 2. 获取当前JVM可用内存 (转成字节)    long freeMemoryBytes = Runtime.getRuntime().freeMemory();    // 3. 【安全策略】仅使用一部分可用内存 (例如 40%)    long safeMemoryToUse = (long) (freeMemoryBytes * 0.4);    // 4. 计算建议分页条数    int suggestedPageSize = (int) (safeMemoryToUse / approxBytesPerRow);    // 5. 设置合理范围 (防止太大或太小)return Math.max(1000, Math.min(suggestedPageSize, 10000)); // 限制在1000~10000条/页}// 使用动态分页int dynamicPageSize = calculateOptimalPageSize(User.class);ExcelExporter.exportByPage(..., dynamicPageSize, ...);

// 1. 异步导出接口@GetMapping("/export/async")public ResultVo<String> triggerAsyncExport() {    String taskId = "EXPORT_" + System.currentTimeMillis(); // 生成唯一任务ID    // 🚀 提交异步任务 (使用线程池)    asyncTaskExecutor.execute(() -> doExportTask(taskId));return ResultVo.success("导出任务已提交，请稍后查询进度", taskId);}// 2. 实际导出任务private void doExportTask(String taskId) {    try {        // 2.1 保存任务状态 (进行中/0%)        exportTaskService.save(new ExportTask(taskId, "PROCESSING", 0));        // 2.2 执行分页导出 (使用我们的ExcelExporter)        int total = userService.countTotalUsers();        AtomicInteger exported = new AtomicInteger(0); // 已导出计数器        ExcelExporter.exportByPage(                ..., // response 需要特殊处理 (写文件)                ...,                (pageNum, pageSize) -> {                    List<User> page = userService.findByPage(pageNum, pageSize);                    // 🎯 更新进度                    int currentExported = exported.addAndGet(page.size());                    int progress = (int) ((currentExported / (double) total) * 100);                    exportTaskService.updateProgress(taskId, progress);return page;                }        );        // 2.3 任务完成 (100%)        exportTaskService.updateStatus(taskId, "SUCCESS", 100, filePath); // 存储文件路径    } catch (Exception e) {        // 2.4 任务失败        exportTaskService.updateStatus(taskId, "FAILED", 0, e.getMessage());    }}// 3. 进度查询接口@GetMapping("/export/progress/{taskId}")public ResultVo<ExportProgress> getExportProgress(@PathVariable String taskId) {    ExportProgress progress = exportTaskService.getProgress(taskId);return ResultVo.success(progress);}// 4. 文件下载接口 (任务成功后)@GetMapping("/export/download/{taskId}")public void downloadExportFile(@PathVariable String taskId, HttpServletResponse response) {    String filePath = exportTaskService.getFilePath(taskId);    // ... 实现文件下载逻辑 ...}

try (ExcelWriter excelWriter = EasyExcel.write(outputStream).build()) {    List<String> sheetNames = Arrays.asList("用户信息", "订单记录", "操作日志");for (int i = 0; i < sheetNames.size(); i++) {        WriteSheet sheet = EasyExcel.writerSheet(i, sheetNames.get(i)).head(User.class).build(); // 根据Sheet设置不同head        // 对该Sheet进行分页写入 (复用前面的分页逻辑)...        PageWriteExcelHelper.writeForSheet(excelWriter, sheet, ...);    }} // try-with-resources自动关闭excelWriter

// 1. 提前准备好带样式的 template.xlsx 放在资源目录// 2. 模板导出代码String templateFile = "/templates/complex-report-template.xlsx";try (InputStream templateStream = getClass().getResourceAsStream(templateFile);     ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream())                                    .withTemplate(templateStream)                                    .build()) {    WriteSheet writeSheet = EasyExcel.writerSheet().build();    // 填充单个数据    excelWriter.fill(new TemplateData(...), writeSheet);    // 填充列表数据 (支持分页填充!)    excelWriter.fill(new FillWrapper("dataList", pageData), writeSheet); // 'dataList' 是模板里的变量名    // ... 填充更多数据 ...}