<dependency>
       <groupId>com.alibaba</groupId>
       <artifactId>easyexcel</artifactId>
       <version>3.1.1</version>
   </dependency>
 
    <!-- 簡化實體類的get，set操作 --> 
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.16.20</version>
    </dependency>
 
 
    <!-- Commons IO（用于壓縮文件操作） -->    
    <dependency>        
        <groupId>commons-io</groupId>        
        <artifactId>commons-io</artifactId>        
        <version>2.11.0</version>    
    </dependency>

@Data
public class Order {
    
    private Long id;    
    private String productName;    
    private Integer quantity;    
    private BigDecimal price;    
 
}

import com.alibaba.excel.EasyExcel;
import java.io.File;
import java.util.List;
 
public class ExcelExportUtil {
    public static void writeToExcel(List<Order> orders, String filePath) {
        try {
            // 使用 EasyExcel 進行 Excel 文件寫入操作
            // 指定輸出文件路徑 filePath、數(shù)據(jù)類型 Order.class 和工作表名稱 "訂單數(shù)據(jù)"
            EasyExcel.write(filePath, Order.class)
                   .sheet("訂單數(shù)據(jù)")
                   .doWrite(orders);
        } catch (Exception e) {
            // 如果在寫入過程中出現(xiàn)異常，打印異常信息
            e.printStackTrace();
        }
    }
}

import java.util.List;
 
public interface ExportService {
 
    // 并行導(dǎo)出訂單的方法
    void exportOrdersInParallel(List<List<Order>> ordersList, String outputDir);
 
}

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.IntStream;
 
@Service
public class ExportServiceImpl implements ExportService{
 
    // 創(chuàng)建一個固定大小為 10 的線程池
    private final ExecutorService executor = Executors.newFixedThreadPool(10);
 
    // 并行導(dǎo)出訂單的方法
    public void exportOrdersInParallel(List<List<Order>> ordersList, String outputDir) {
        // 創(chuàng)建一個 CompletableFuture 數(shù)組來存儲每個任務(wù)的 Future 對象
        CompletableFuture<Void>[] futures = new CompletableFuture[ordersList.size()];
 
        // 遍歷訂單列表，為每個子列表創(chuàng)建一個異步任務(wù)
        IntStream.range(0, ordersList.size()).forEach(index -> {
            List<Order> orders = ordersList.get(index);
            futures[index] = CompletableFuture.runAsync(() -> {
                // 生成文件名
                String fileName = "訂單_" + Thread.currentThread().getId() + ".xlsx";
                try {
                    // 調(diào)用工具方法將訂單寫入 Excel 文件
                    ExcelExportUtil.writeOrdersToExcel(orders, outputDir + fileName);
                } catch (Exception e) {
                    // 如果出現(xiàn)異常，打印異常信息
                    e.printStackTrace();
                }
            }, executor);
        });
 
        // 等待所有任務(wù)完成
        CompletableFuture.allOf(futures).join();
    }
}

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
 
public class ZipUtil {
    public static void zipFiles(String sourceDir, String zipFile) throws IOException {
        // 創(chuàng)建輸出的 ZIP 文件流
        try (FileOutputStream fos = new FileOutputStream(zipFile);
             ZipOutputStream zipOut = new ZipOutputStream(fos)) {
 
            // 獲取要壓縮的源目錄下的文件列表
            File fileToZip = new File(sourceDir);
            if (fileToZip.isDirectory()) {
                for (File file : fileToZip.listFiles()) {
                    if (file.isFile()) {
                        try (FileInputStream fis = new FileInputStream(file)) {
                            // 創(chuàng)建 ZIP 條目，表示要添加到 ZIP 文件中的文件
                            ZipEntry zipEntry = new ZipEntry(file.getName());
                            zipOut.putNextEntry(zipEntry);
 
                            byte[] bytes = new byte[1024];
                            int length;
                            // 循環(huán)讀取文件內(nèi)容并寫入 ZIP 文件
                            while ((length = fis.read(bytes)) >= 0) {
                                zipOut.write(bytes, 0, length);
                            }
                        }
                    }
                }
            }
        }
    }
}

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import org.springframework.core.io.InputStreamResource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class FileDownloadController {
    @GetMapping("/downloadZip")
    public ResponseEntity<InputStreamResource> downloadZip() throws IOException {
        // 定義源目錄路徑，這里假設(shè)是 /tmp/excel_files
        String sourceDir = "/tmp/excel_files";
        // 定義生成的 ZIP 文件路徑，這里假設(shè)是 /tmp/orders.zip
        String zipFilePath = "/tmp/orders.zip";
 
        try {
            // 調(diào)用 ZipUtil 類的方法來壓縮源目錄中的文件到指定的 ZIP 文件
            ZipUtil.zipFiles(sourceDir, zipFilePath);
 
            // 創(chuàng)建一個 File 對象表示要下載的 ZIP 文件
            File file = new File(zipFilePath);
 
            // 創(chuàng)建一個 InputStreamResource 對象，從文件輸入流中讀取數(shù)據(jù)
            InputStreamResource resource = new InputStreamResource(new FileInputStream(file));
 
            // 設(shè)置 HTTP 響應(yīng)頭信息
            HttpHeaders headers = new HttpHeaders();
            // 設(shè)置內(nèi)容處置頭，指示瀏覽器下載文件，并指定文件名
            headers.add(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=" + file.getName());
            // 設(shè)置內(nèi)容類型為 application/octet-stream，表示二進制數(shù)據(jù)
            headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
            // 設(shè)置內(nèi)容長度，以便瀏覽器正確顯示下載進度
            headers.setContentLength(file.length());
 
            // 返回一個包含 InputStreamResource 的 ResponseEntity 對象，
            // 表示成功的 HTTP 響應(yīng)，包含要下載的文件數(shù)據(jù)和設(shè)置好的響應(yīng)頭
            return ResponseEntity.ok()
                   .headers(headers)
                   .body(resource);
        } catch (IOException e) {
            // 如果在壓縮文件或讀取文件過程中出現(xiàn) IOException，返回內(nèi)部服務(wù)器錯誤響應(yīng)
            return ResponseEntity.status(500).build();
        } finally {
            // 在方法結(jié)束時，無論是否發(fā)生異常，嘗試刪除生成的 ZIP 文件
            File zipFile = new File(zipFilePath);
            if (zipFile.exists()) {
                zipFile.delete();
            }
        }
    }
}