【SpringBoot项目实践】图片压缩包处理、遍历上传至文件服务器

知识浅谈

发布于 2025-05-18 10:13:24

25500

代码可运行

文章被收录于专栏：分享学习分享学习

运行总次数：0

代码可运行

🎈前言

在常见的Web应用中，图片处理是一个常见的需求，特别是在需要处理大量图片上传的场景下。使用SpringBoot结合文件服务器（如FastDFS、MinIO等）来处理图片压缩包，并遍历上传图片，可以显著提升应用性能和用户体验。本文将详细介绍如何在SpringBoot项目中实现图片压缩包的处理与遍历上传至文件服务器的功能。

🎈技术选型

SpringBoot：用于构建RESTful API和Spring框架的便捷性。
Apache Commons Compress：用于处理压缩文件（如ZIP、RAR等）。
FastDFS/MinIO：作为文件服务器，用于存储上传的图片。
MultipartFile：Spring框架中用于处理文件上传的接口。

🎈项目结构

Controller层：负责接收客户端的请求，包括上传压缩包。
Service层：处理业务逻辑，包括解压压缩包、读取图片、上传图片至文件服务器。
Repository层（可选）：如果需要对上传的图片进行数据库记录，可以设计相应的数据访问层。
Config层：配置相关服务（如文件服务器客户端配置）。

🎈实现步骤

添加依赖首先，在pom.xml中添加必要的依赖项，如Apache Commons Compress和Spring Boot的Web依赖：

<dependencies>
    <!-- Spring Boot Web Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- Apache Commons Compress for handling zip files -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-compress</artifactId>
        <version>1.21</version>
    </dependency>
    <!-- 其他依赖，如文件服务器客户端SDK -->
</dependencies>

配置文件服务器根据所选的文件服务器（如FastDFS、MinIO），在application.properties或application.yml中配置相关参数。
编写Controller

@RestController
@RequestMapping("/image")
public class ImageController {

    @Autowired
    private ImageService imageService;

    @PostMapping("/upload")
    public ResponseEntity<String> uploadZipFile(@RequestParam("file") MultipartFile file) {
        try {
            imageService.processAndUploadImages(file);
            return ResponseEntity.ok("图片上传成功");
        } catch (Exception e) {
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("图片上传失败: " + e.getMessage());
        }
    }
}

实现Service层

@Service
public class ImageService {

    @Autowired
    private FileServerClient fileServerClient; // 假设的文件服务器客户端

    public void processAndUploadImages(MultipartFile file) throws IOException {
        ZipInputStream zipInputStream = new ZipInputStream(file.getInputStream());
        ZipEntry entry;
        while ((entry = zipInputStream.getNextEntry()) != null) {
            if (!entry.isDirectory()) {
                // 假设只处理图片文件
                if (entry.getName().endsWith(".jpg") || entry.getName().endsWith(".png")) {
                    // 读取图片字节流
                    ByteArrayOutputStream buffer = new ByteArrayOutputStream();
                    int len;
                    byte[] data = new byte[2048];
                    while ((len = zipInputStream.read(data, 0, data.length)) != -1) {
                        buffer.write(data, 0, len);
                    }
                    byte[] imgBytes = buffer.toByteArray();
                    
                    // 上传图片到文件服务器
                    fileServerClient.uploadFile(entry.getName(), imgBytes);
                }
            }
            zipInputStream.closeEntry();
        }
        zipInputStream.close();
    }
}