示例

@RestController
public class FileController {private static final Logger logger = LoggerFactory.getLogger(FileController.class);private static final String filePath = "/fileTemp";@Autowiredprivate ObjectMapper objectMapper;@GetMapping("/v1/file/add")public void add() {}@GetMapping("/v1/file/zip")public ResponseEntity<byte[]> zip() {File tempJSONFile, tempPngFile;String outputFileName = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));try {// 創建臨時文件根目錄File tempFileDirectory = new File(filePath);if (!tempFileDirectory.exists()) {boolean dirCreateFlag = tempFileDirectory.mkdirs();logger.info("臨時文件目錄創建成功: {}", dirCreateFlag);}// JSON數據Map<String, String> data = new HashMap<>();data.put("1", "1");for (int i = 0; i < 10; i++) {// json文件tempJSONFile = createJsonFile(i, "deviceId_" + i + ".json", objectMapper.writeValueAsString(data));if (tempJSONFile.exists()) {logger.info("JSON文件已創建");} else {logger.info("JSON文件未創建");}// 圖片文件 http://app.test.stesh.cn/images/zjlogo.pngImageTool.downloadImage("http://app.test.stesh.cn/images/zjlogo.png", filePath + "/" + i ,"deviceId_" + i + ".png");}ByteArrayOutputStream baos = new ByteArrayOutputStream();
//            ZipOutputStream zos = new ZipOutputStream(baos);
//            zipDirectory(tempFileDirectory, zos);
//            zos.close();ZipTool.createZipFile(tempFileDirectory, baos);// 刪除目錄deleteDirectory(tempFileDirectory);HttpHeaders headers = new HttpHeaders();headers.add("Content-Disposition", "attachment; filename=" + outputFileName + ".zip");return ResponseEntity.ok().headers(headers).contentLength(baos.size()).body(baos.toByteArray());} catch (IOException e) {e.printStackTrace();logger.info("error: {}", e.getMessage());} finally {}return null;}public void zipDirectory(File directory, ZipOutputStream zos) throws IOException {// zipFiles(directory, directory.getName(), zos);// 壓縮時不帶根目錄zipFiles(directory, "", zos);zos.close();}private void zipFiles(File directory, String baseName, ZipOutputStream zos) throws IOException {File[] files = directory.listFiles();byte[] buffer = new byte[1024];int length;for (File file : files) {if (file.isDirectory()) {// 如果baseName不為空，則保留除根目錄外的子目錄結構// 否則，不添加任何前綴到子目錄的zip條目中logger.info("baseName:{}", baseName);String subDirName = (baseName.isEmpty() ? "" : baseName + "/") + file.getName();zipFiles(file, subDirName, zos);continue;}// 直接使用文件名作為ZipEntry的名稱，去掉根目錄部分ZipEntry zipEntry = new ZipEntry(baseName.isEmpty() ? file.getName() : baseName + "/" + file.getName());zos.putNextEntry(zipEntry);try (FileInputStream fis = new FileInputStream(file)) {while ((length = fis.read(buffer)) > 0) {zos.write(buffer, 0, length);}}zos.closeEntry();}}public File createJsonFile(Integer i, String fileName, String jsonString) throws IOException {// 創建本地臨時文件// 創建文件目錄File tempFileDirectory = new File(filePath + "/" + i);if (!tempFileDirectory.exists()) {boolean dirCreateFlag = tempFileDirectory.mkdirs();logger.info("臨時文件目錄創建成功: {}", dirCreateFlag);}File jsonFile = new File(filePath + "/" + i + "/" + fileName);try (FileWriter fileWriter = new FileWriter(jsonFile)) {fileWriter.write(jsonString);} catch (IOException e) {e.printStackTrace();}return jsonFile;}public static void deleteDirectory(File directory) {if (directory.exists()) {File[] files = directory.listFiles();if (files != null) {for (File file : files) {if (file.isDirectory()) {// 遞歸刪除子目錄deleteDirectory(file);} else {// 刪除文件file.delete();}}}// 最后刪除目錄本身directory.delete();}}private String get(String url, Map<String, String> headers, Map<String, String> querys) {HttpClient httpClient = null;HttpGet httpGet = null;String result = null;try {httpClient = new SSLClient();URIBuilder builder = new URIBuilder(url);if (!CollectionUtils.isEmpty(querys)) {for (String key : querys.keySet()) {builder.setParameter(key, String.valueOf(querys.get(key)));}}httpGet = new HttpGet(builder.build());if (!CollectionUtils.isEmpty(headers)) {// 設置headerfor (String headerName : headers.keySet()) {httpGet.addHeader(headerName, headers.get(headerName));}}// 設置超時時間RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(3000).setConnectionRequestTimeout(1000).setSocketTimeout(10000).build();httpGet.setConfig(requestConfig);HttpResponse response = httpClient.execute(httpGet);if (response != null) {HttpEntity resEntity = response.getEntity();if (resEntity != null) {result = EntityUtils.toString(resEntity, "UTF-8");}}} catch (Exception ex) {ex.printStackTrace();}return result;}
}

http下載圖片并寫入文件

public class ImageTool {public static void downloadImage(String imageUrl, String saveFilePath, String fileName) {CloseableHttpClient httpClient = HttpClients.createDefault();HttpGet httpGet = new HttpGet(imageUrl);try {CloseableHttpResponse response = httpClient.execute(httpGet);File tempFileDirectory = new File(saveFilePath);System.out.println("path:" + tempFileDirectory.getAbsolutePath());if (!tempFileDirectory.exists()) {boolean dirCreateFlag = tempFileDirectory.mkdirs();}FileOutputStream fos = new FileOutputStream(saveFilePath + "/" + fileName);HttpEntity entity = response.getEntity();if (entity != null) {// 將圖片內容寫入文件entity.writeTo(fos);System.out.println("Image downloaded successfully!");}} catch (IOException e) {e.printStackTrace();} finally {try {if (httpClient != null) {httpClient.close();}} catch (IOException e) {e.printStackTrace();}}}
}

將文件壓縮為zip文件

public class ZipTool {public static void zipFiles(File directory, String baseName, ZipArchiveOutputStream zos) throws IOException {File[] files = directory.listFiles();if (files == null) {return; // 可能是目錄不存在或沒有讀取權限}for (File file : files) {Path filePath = file.toPath();String entryName = baseName.isEmpty() ? filePath.getFileName().toString() : baseName + "/" + filePath.getFileName().toString();if (Files.isDirectory(filePath)) {// 遞歸處理子目錄ZipArchiveEntry dirEntry = new ZipArchiveEntry(entryName + "/"); // 注意添加斜杠以表示目錄zos.putArchiveEntry(dirEntry);zos.closeArchiveEntry();zipFiles(file, entryName, zos);continue;}// 處理文件ZipArchiveEntry fileEntry = new ZipArchiveEntry(entryName);zos.putArchiveEntry(fileEntry);try (InputStream fis = Files.newInputStream(filePath)) {byte[] buffer = new byte[1024];int length;while ((length = fis.read(buffer)) > 0) {zos.write(buffer, 0, length);}}zos.closeArchiveEntry();}}// 示例方法，用于創建ZIP文件并調用zipFiles方法public static void createZipFile(File directory, ByteArrayOutputStream byteArrayOutputStream) {ZipArchiveOutputStream zos = null;try {zos = new ZipArchiveOutputStream(byteArrayOutputStream);// 假設我們不想在ZIP中包含根目錄本身zipFiles(directory, "", zos);} catch (IOException e){e.printStackTrace();} finally {try {if (zos != null) {zos.close();}} catch (IOException e) {e.printStackTrace();}}}
}