2. 报表导出基础架构：单体架构下的导出流程、异步导出与同步导出对比、技术栈选型

2.1 单体架构下的导出流程全景

在大多数中小规模业务系统中，报表导出功能最初都构建在单体应用之上。用户发起导出请求后，请求经过 Controller、Service、Mapper 三层，最终从数据库拉取数据并生成文件返回给浏览器。下图展示了典型的同步导出请求-响应流程：

单体架构同步导出流程图 用户浏览器 ExportController ExportService DataMapper HTTP GET/POST 调用 SQL查询 MySQL 查询 结果集 文件生成 数据组装 HTTP响应 文件流 下载 ⚠ 同步导出痛点： • 请求线程长时间阻塞（大报表可能耗时 30s+） • Tomcat 线程池耗尽 → 其他接口无法响应 → 服务雪崩
关键观察：同步导出模式下，一个耗时 30 秒的报表请求会独占一个 Tomcat 工作线程。当并发导出请求达到 10 个时，若线程池最大线程数为 200，则 5% 的线程被长期占用，严重影响系统吞吐量。

2.2 同步导出 vs 异步导出：核心对比

异步导出将“请求”与“执行”解耦：用户提交导出任务后立即获得一个任务 ID，后台线程池或独立进程负责生成文件，用户通过轮询或回调获取结果。两种模式在多个维度存在显著差异：

对比维度 同步导出 异步导出
用户体验 页面一直等待，超时后可能白屏 立即返回，用户可继续操作，完成后通知
线程占用 请求线程全程阻塞，直到文件生成完毕 请求线程仅处理提交逻辑（毫秒级），释放迅速
超时处理 依赖 HTTP 超时（通常 30s~60s），超时后任务中断 任务在后台继续执行，不受 HTTP 超时影响
并发能力 受限于 Tomcat 线程池大小，大报表易导致线程耗尽 受限于后台任务队列和线程池，可弹性扩展
失败重试 失败后用户需重新发起请求，无自动重试 可记录失败任务，支持手动或自动重试
实现复杂度 低，Controller 直接返回文件流 中高，需要任务表、轮询接口或 WebSocket 推送
适用场景 数据量小（< 1 万行）、查询快（< 5s） 数据量大（> 10 万行）、查询慢（> 10s）、高并发
选型建议：对于行数超过 5 万或查询时间超过 5 秒的报表，强制使用异步导出。同步导出仅保留给“预览前 100 条”等轻量场景。

2.3 异步导出流程详解

异步导出引入“任务表”和“后台线程池”两个核心组件。用户提交导出请求后，系统立即返回任务 ID，后台线程异步完成数据查询、文件生成和存储。下图展示了异步导出的完整生命周期：

异步导出完整生命周期图 用户 Controller 任务表 后台线程池 提交导出 插入任务 返回任务ID 任务ID 轮询状态 查询状态 查询 执行导出 消费任务 MySQL 查询数据 文件存储 生成文件 更新状态 完成
异步导出核心步骤：
  1. 用户提交导出请求 → Controller 向任务表插入一条状态为 PENDING 的记录，返回任务 ID。
  2. 后台线程池定时扫描任务表，取出 PENDING 任务，更新状态为 PROCESSING。
  3. 线程执行数据查询、文件生成，将文件写入磁盘或对象存储。
  4. 更新任务状态为 COMPLETED，记录文件路径。
  5. 用户通过任务 ID 轮询状态，状态为 COMPLETED 时触发文件下载。

2.4 技术栈选型：Spring Boot + MyBatis + Redis

本课程选用的技术栈是经过生产验证的经典组合，各组件在报表导出场景中承担明确职责：

组件 版本 在导出场景中的核心职责
Spring Boot 2.7.x / 3.x 提供异步任务支持（@Async）、线程池管理、定时任务调度（@Scheduled）、REST 接口暴露
MyBatis 3.5.x 复杂报表 SQL 查询、分页查询、流式查询（避免 OOM）、动态 SQL 拼接
Redis 6.x / 7.x 任务状态缓存（替代频繁查询任务表）、导出请求计数（热点削峰）、分布式锁（防止重复导出）、临时数据缓存

2.5 各组件在导出流程中的协作关系

下图展示了 Spring Boot + MyBatis + Redis 在异步导出流程中的具体协作位置：

技术栈协作架构图 Spring Boot @Async 线程池 @Scheduled 调度 MyBatis 流式查询 分页 + 动态SQL Redis 任务状态缓存 请求计数 / 分布式锁 调用 缓存/限流 MySQL 数据库 SQL 💡 协作要点： Spring Boot 调度异步任务 → MyBatis 流式读取数据库 → Redis 缓存任务进度并控制并发请求量

2.6 关键代码片段：异步导出核心配置

以下代码展示了 Spring Boot 中启用异步导出所需的最小配置：

// 1. Spring Boot 主类启用异步支持
@SpringBootApplication
@EnableAsync
public class ReportApplication {
    public static void main(String[] args) {
        SpringApplication.run(ReportApplication.class, args);
    }

    // 2. 自定义异步线程池（避免使用默认 SimpleAsyncTaskExecutor）
    @Bean("exportExecutor")
    public Executor exportExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);          // 核心线程数
        executor.setMaxPoolSize(20);          // 最大线程数
        executor.setQueueCapacity(100);       // 队列容量
        executor.setThreadNamePrefix("export-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

// 3. 异步导出 Service 方法
@Service
public class ExportService {

    @Async("exportExecutor")
    public void exportAsync(Long taskId, ExportRequest request) {
        // 1. 更新任务状态为 PROCESSING
        taskService.updateStatus(taskId, TaskStatus.PROCESSING);

        try {
            // 2. 流式查询数据（MyBatis 游标）
            try (Cursor<ReportRow> cursor = reportMapper.streamQuery(request)) {
                // 3. 生成 Excel 文件
                File file = excelWriter.write(cursor);
                // 4. 更新任务状态为 COMPLETED，记录文件路径
                taskService.complete(taskId, file.getAbsolutePath());
            }
        } catch (Exception e) {
            // 5. 异常时更新状态为 FAILED
            taskService.fail(taskId, e.getMessage());
        }
    }
}
⚠ 重要提醒：异步导出必须配置独立的线程池，切勿使用 Spring 默认的 SimpleAsyncTaskExecutor（它为每个任务创建新线程，高并发下会耗尽系统资源）。建议设置合理的队列容量和拒绝策略，防止任务堆积导致内存溢出。

2.7 本章小结

  • 单体架构同步导出流程简单但存在线程阻塞、超时中断、并发能力差等严重问题，仅适合小数据量场景。
  • 异步导出通过任务表 + 后台线程池实现请求与执行解耦，支持超时免疫、失败重试、弹性扩展，是大数据量导出的首选方案。
  • 技术栈选型中 Spring Boot 负责调度与接口、MyBatis 负责数据查询与流式读取、Redis 负责缓存与热点削峰，三者各司其职。
  • 下一章将深入讲解 Redis 在导出场景中的热点削峰原理与实战配置，包括令牌桶限流、请求队列削峰、分布式锁防重复导出等核心技巧。
← 上一章 📖 返回目录 下一章 →