HTTP协议下，JAVA WEB怎样实现文件夹上传并保留目录结构源码？

路过了忘了

458人浏览 · 2025-09-19 11:19:50

路过了忘了 · 2025-09-19 11:19:50 发布

大文件传输解决方案 - 专业实施方案

项目背景与技术需求分析

作为公司项目负责人，我们面临的核心需求是构建一个安全可靠、高性能的大文件传输系统。经过深入分析，现有开源组件无法满足以下关键需求：

超大文件处理：单文件100G支持，文件夹结构保持
高稳定性断点续传：浏览器刷新/关闭后进度不丢失
国密加密支持：SM4/AES双算法，传输存储全加密
全面兼容性：IE8+、多框架、多数据库支持
非打包下载：避免服务器内存溢出问题
阿里云集成：OSS对象存储，ECS服务器部署

技术架构设计

前端核心实现（Vue2兼容版本）








export default {
  name: 'EnterpriseFileUploader',
  data() {
    return {
      fileList: [],
      uploadManager: null,
      isIE8: navigator.userAgent.indexOf('MSIE 8.0') > -1
    }
  },
  }
}

后端JSP/Servlet实现

<%@ page import="com.enterprise.file.service.*" %>
<%@ page import="com.enterprise.file.crypto.*" %>
<%@ page import="java.util.*" %>
<%@ page contentType="application/json;charset=UTF-8" language="java" %>

<%
// file-upload.jsp
response.setHeader("X-Content-Type-Options", "nosniff");
response.setHeader("X-Frame-Options", "DENY");

FileUploadService uploadService = new FileUploadService();
CryptoService cryptoService = new CryptoService();

String action = request.getParameter("action");

try {
    if ("initUpload".equals(action)) {
        String fileName = request.getParameter("fileName");
        long fileSize = Long.parseLong(request.getParameter("fileSize"));
        String fileHash = request.getParameter("fileHash");
        String folderPath = request.getParameter("folderPath");
        
        UploadSession session = uploadService.initUploadSession(
            fileName, fileSize, fileHash, folderPath);
        
        out.print("{\"success\":true,\"sessionId\":\"" + session.getSessionId() + "\"}");
    }
} catch (Exception e) {
    out.print("{\"success\":false,\"message\":\"" + e.getMessage() + "\"}");
}
%>

SpringBoot兼容控制器

@RestController
@RequestMapping("/api/enterprise/file")
public class EnterpriseFileController {
    
    @Autowired
    private FileUploadService fileUploadService;
    
    @Autowired
    private CryptoService cryptoService;
    
    @PostMapping("/uploadChunk")
    public ResponseEntity> uploadChunk(
            @RequestParam String sessionId,
            @RequestParam int chunkIndex,
            @RequestParam String chunkHash,
            @RequestParam MultipartFile chunk) {
        try {
            byte[] chunkData = chunk.getBytes();
            
            // 哈希验证
            if (!chunkHash.equals(cryptoService.calculateHash(chunkData))) {
                return ResponseEntity.badRequest()
                    .body(Collections.singletonMap("success", false));
            }
       
    }
}

加密服务实现

@Service
public class EnterpriseCryptoService {
    
    @Value("${encryption.algorithm:SM4}")
    private String defaultAlgorithm;
    
    @Value("${encryption.sm4.key:}")
    private String sm4Key;
    
    @Value("${encryption.aes.key:}")
    private String aesKey;
    
    public byte[] encrypt(byte[] data, String algorithm) throws CryptoException {
        if (algorithm == null) algorithm = defaultAlgorithm;
        
        try {
            if ("SM4".equalsIgnoreCase(algorithm)) {
                return encryptSM4(data);
            } else if ("AES".equalsIgnoreCase(algorithm)) {
                return encryptAES(data);
            } else {
                throw new CryptoException("不支持的加密算法: " + algorithm);
            }
        } catch (Exception e) {
            throw new CryptoException("加密失败", e);
        }
    }
}

数据库多支持配置

@Configuration
public class MultiDatabaseConfig {
    
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource dataSource(Environment env) {
        String dbType = env.getProperty("database.type", "mysql");
        
        HikariDataSource dataSource = new HikariDataSource();
        
        switch (dbType.toLowerCase()) {
            case "mysql":
                dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
                dataSource.setJdbcUrl(env.getProperty("spring.datasource.url"));
                break;
            case "oracle":
                dataSource.setDriverClassName("oracle.jdbc.OracleDriver");
                dataSource.setJdbcUrl(env.getProperty("spring.datasource.url"));
                break;
            case "sqlserver":
                dataSource.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
                dataSource.setJdbcUrl(env.getProperty("spring.datasource.url"));
                break;
            default:
                throw new IllegalArgumentException("不支持的数据库类型: " + dbType);
        }
        
        dataSource.setUsername(env.getProperty("spring.datasource.username"));
        dataSource.setPassword(env.getProperty("spring.datasource.password"));
        
        return dataSource;
    }
}

阿里云OSS集成

@Service
public class AliyunOssService implements StorageService {
    
    @Value("${aliyun.oss.endpoint}")
    private String endpoint;
    
    @Value("${aliyun.oss.accessKeyId}")
    private String accessKeyId;
    
    @Value("${aliyun.oss.accessKeySecret}")
    private String accessKeySecret;
    
    @Value("${aliyun.oss.bucketName}")
    private String bucketName;
    
    private OSS ossClient;
    
    @PostConstruct
    public void init() {
        ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    }
    
    @PreDestroy
    public void destroy() {
        if (ossClient != null) {
            ossClient.shutdown();
        }
    }
    
    @Override
    public void uploadChunk(String fileKey, int chunkIndex, byte[] data) {
        String objectName = "chunks/" + fileKey + "/" + chunkIndex;
        
        try {
            ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(data));
        } catch (Exception e) {
            throw new StorageException("OSS上传失败", e);
        }
    }
    
    @Override
    public InputStream downloadChunk(String fileKey, int chunkIndex) {
        String objectName = "chunks/" + fileKey + "/" + chunkIndex;
        
        try {
            OSSObject object = ossClient.getObject(bucketName, objectName);
            return object.getObjectContent();
        } catch (Exception e) {
            throw new StorageException("OSS下载失败", e);
        }
    }
}

部署配置示例

# application-prod.yml
server:
  port: 8080
  servlet:
    context-path: /file-service

spring:
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/file_db?useSSL=false&serverTimezone=UTC
    username: root
    password: password
    hikari:
      maximum-pool-size: 20
      minimum-idle: 5

encryption:
  algorithm: SM4
  sm4:
    key: ${SM4_ENCRYPTION_KEY}
  aes:
    key: ${AES_ENCRYPTION_KEY}

aliyun:
  oss:
    endpoint: https://oss-cn-beijing.aliyuncs.com
    accessKeyId: ${OSS_ACCESS_KEY_ID}
    accessKeySecret: ${OSS_ACCESS_KEY_SECRET}
    bucketName: enterprise-file-bucket

storage:
  chunk-size: 10485760 # 10MB
  max-concurrent: 5
  retry-times: 3