Spring Boot中从Zip包JSON文件动态转DTO的方案咨询

核心思路 #

通过Java原生Zip流解析上传的压缩包，结合Jackson的自动序列化能力，无需手动读取JSON内容即可将数据映射到目标DTO，同时通过Jackson注解兼容JSON结构的变化。

步骤实现 #

1. DTO类配置（兼容结构变化）

给DTO添加@JsonIgnoreProperties(ignoreUnknown = true)注解，即使JSON新增了DTO未定义的字段，也不会导致解析失败，完美适配结构变化场景：

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

@JsonIgnoreProperties(ignoreUnknown = true)
public class TargetDto {
    private String id;
    private String name;
    
    // 生成Getter、Setter及构造方法
}

2. 编写Zip文件处理逻辑

使用ZipInputStream遍历压缩包中的文件，筛选出JSON文件后，直接用Jackson的ObjectMapper将流数据映射到DTO，全程无需手动读取JSON字符串：

import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

@Service
public class FileImportService {
    private final ObjectMapper objectMapper;

    // 依赖注入Spring默认配置的ObjectMapper
    public FileImportService(ObjectMapper objectMapper) {
        this.objectMapper = objectMapper;
    }

    public List<Object> processZipFile(MultipartFile zipFile) throws IOException {
        List<Object> dtoList = new ArrayList<>();
        // try-with-resources自动关闭流，避免资源泄漏
        try (ZipInputStream zis = new ZipInputStream(zipFile.getInputStream())) {
            ZipEntry entry;
            while ((entry = zis.getNextEntry()) != null) {
                // 跳过文件夹，只处理JSON文件
                if (!entry.isDirectory() && entry.getName().toLowerCase().endsWith(".json")) {
                    // 若需根据不同JSON文件映射不同DTO，可通过文件名判断（如user.json对应UserDto）
                    // 示例中统一映射到TargetDto，实际可扩展为动态匹配
                    TargetDto dto = objectMapper.readValue(zis, TargetDto.class);
                    dtoList.add(dto);
                    zis.closeEntry();
                }
            }
        }
        return dtoList;
    }
}

3. 改造Controller接口

在原有上传接口中调用处理逻辑，返回解析后的DTO列表：

import io.swagger.annotations.ApiOperation;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.util.Collections;
import java.util.List;

@RestController
public class FileExchangeController {
    private final FileImportService fileImportService;

    public FileExchangeController(FileImportService fileImportService) {
        this.fileImportService = fileImportService;
    }

    @ApiOperation(value = "Imports one or more files")
    @PostMapping("/fileExchange/import")
    public ResponseEntity<List<Object>> importFiles(@RequestParam MultipartFile file) {
        try {
            List<Object> result = fileImportService.processZipFile(file);
            return ResponseEntity.ok(result);
        } catch (IOException e) {
            // 可根据实际需求返回更具体的错误信息
            return ResponseEntity.badRequest().body(Collections.emptyList());
        }
    }
}

扩展方案 #

如果需要根据不同JSON文件映射不同的DTO类，可以维护一个文件名与DTO类的映射关系，例如：

private static final Map<String, Class<?>> FILE_DTO_MAPPING = Map.of(
    "user.json", UserDto.class,
    "order.json", OrderDto.class
);

// 在处理时根据文件名获取对应的DTO类
Class<?> dtoClass = FILE_DTO_MAPPING.get(entry.getName());
if (dtoClass != null) {
    Object dto = objectMapper.readValue(zis, dtoClass);
    dtoList.add(dto);
}

内容的提问来源于stack exchange，提问作者hemanth reddy m