Java 使用OSS 文件分片上传MultipartFile

以下是Java SpringBoot框架下实现OSS文件分片上传和进度条展示的示例代码： 1. 首先在pom.xml文件中引入OSS SDK依赖： ```xml <dependency> <groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>2.9.2</version> </dependency> ``` 2. 创建一个名为OSSUtil的工具类，用于连接OSS服务并实现分片上传和进度查询： ```java import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.model.*; import org.springframework.stereotype.Component; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.List; @Component public class OSSUtil { // 阿里云OSS服务的Endpoint private static final String ENDPOINT = "your_endpoint"; // 阿里云OSS服务的AccessKeyId private static final String ACCESS_KEY_ID = "your_access_key_id"; // 阿里云OSS服务的AccessKeySecret private static final String ACCESS_KEY_SECRET = "your_access_key_secret"; // 阿里云OSS服务的BucketName private static final String BUCKET_NAME = "your_bucket_name"; // OSS客户端实例 private OSS ossClient; // 初始化OSS客户端 public void init() { ossClient = new OSSClientBuilder().build(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET); } // 关闭OSS客户端 public void close() { ossClient.shutdown(); } // 分片上传文件 public void multipartUpload(String objectName, InputStream inputStream, long fileSize) throws IOException { // 初始化MultipartUploadRequest InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(BUCKET_NAME, objectName); InitiateMultipartUploadResult result = ossClient.initiateMultipartUpload(request); // 获取UploadId String uploadId = result.getUploadId(); // 设置每个Part的大小，最小为100KB final long partSize = 1024 * 100L; // 计算文件的Part个数 int partCount = (int) (fileSize / partSize); if (fileSize % partSize != 0) { partCount++; } List<PartETag> partETags = new ArrayList<>(); for (int i = 0; i < partCount; i++) { long startPos = i * partSize; long curPartSize = Math.min(partSize, fileSize - startPos); InputStream partInputStream = new FilePartInputStream(inputStream, startPos, curPartSize); UploadPartRequest uploadPartRequest = new UploadPartRequest(); uploadPartRequest.setBucketName(BUCKET_NAME); uploadPartRequest.setKey(objectName); uploadPartRequest.setUploadId(uploadId); uploadPartRequest.setPartNumber(i + 1); uploadPartRequest.setInputStream(partInputStream); uploadPartRequest.setPartSize(curPartSize); UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest); partETags.add(uploadPartResult.getPartETag()); } // 完成分片上传 CompleteMultipartUploadRequest completeMultipartUploadRequest = new CompleteMultipartUploadRequest(BUCKET_NAME, objectName, uploadId, partETags); ossClient.completeMultipartUpload(completeMultipartUploadRequest); } // 获取文件上传进度 public long getUploadProgress(String objectName) { // 获取文件大小 ObjectMetadata metadata = ossClient.getObjectMetadata(BUCKET_NAME, objectName); long fileSize = metadata.getContentLength(); // 获取已上传的Part信息 ListPartsRequest listPartsRequest = new ListPartsRequest(BUCKET_NAME, objectName, null); PartListing partListing = ossClient.listParts(listPartsRequest); List<PartSummary> partSummaries = partListing.getParts(); // 计算已上传的大小 long uploadedSize = 0; for (PartSummary partSummary : partSummaries) { uploadedSize += partSummary.getSize(); } // 计算上传进度 long progress = (long) ((double) uploadedSize / fileSize * 100); return progress; } // 自定义的输入流，用于分片上传文件 private static class FilePartInputStream extends InputStream { private InputStream inputStream; private long startPos; private long curPartSize; private long pos; public FilePartInputStream(InputStream inputStream, long startPos, long curPartSize) { this.inputStream = inputStream; this.startPos = startPos; this.curPartSize = curPartSize; this.pos = 0; } @Override public int read() throws IOException { if (pos >= curPartSize) { return -1; } int read = inputStream.read(); pos++; return read; } @Override public int read(byte[] b, int off, int len) throws IOException { if (pos >= curPartSize) { return -1; } int readLen = (int) Math.min(len, curPartSize - pos); int read = inputStream.read(b, off, readLen); pos += read; return read; } @Override public void close() throws IOException { super.close(); inputStream.close(); } } } ``` 3. 创建一个名为UploadController的控制器，用于处理文件上传和进度查询请求： ```java import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.io.IOException; @RestController @RequestMapping("/upload") public class UploadController { @Autowired private OSSUtil ossUtil; // 处理文件上传请求 @PostMapping("/file") public String uploadFile(@RequestParam("file") MultipartFile file) throws IOException { // 初始化OSS客户端 ossUtil.init(); // 分片上传文件 String objectName = file.getOriginalFilename(); ossUtil.multipartUpload(objectName, file.getInputStream(), file.getSize()); // 关闭OSS客户端 ossUtil.close(); return "success"; } // 处理进度查询请求 @GetMapping("/progress") public long getUploadProgress(@RequestParam("objectName") String objectName) { // 获取上传进度 long progress = ossUtil.getUploadProgress(objectName); return progress; } } ``` 4. 在前端页面中使用HTML5的进度条组件，结合后端实现的上传进度查询接口，展示文件上传的进度。例如，以下是一个基于Vue.js的示例代码： ```html <template> <div> <input type="file" @change="handleFileChange"> <button @click="uploadFile">上传</button> <div v-show="showProgress"> <progress :value="progress" max="100"></progress> <span>{{ progress }}%</span> </div> </div> </template> <script> export default { data() { return { file: null, showProgress: false, progress: 0, intervalId: null } }, methods: { handleFileChange(event) { this.file = event.target.files[0] }, uploadFile() { this.showProgress = true let formData = new FormData() formData.append('file', this.file) axios.post('/upload/file', formData) .then(response => { console.log(response) }) .catch(error => { console.log(error) }) this.intervalId = setInterval(() => { axios.get('/upload/progress', { params: { objectName: this.file.name }}) .then(response => { this.progress = response.data if (this.progress >= 100) { clearInterval(this.intervalId) } }) .catch(error => { console.log(error) }) }, 1000) } } } </script> ``` 以上就是Java SpringBoot框架下实现OSS文件分片上传和进度条展示的全代码示例。

<think>好的，用户想了解如何在Spring Boot中使用MultipartFile接收文件，需要代码示例或相关文档。首先，我得回忆一下相关的知识点。记得在Spring Boot中处理文件上传通常是通过MultipartFile类来实现的，用户可能在前端通过表单上传文件，后端用@RequestParam或者@RequestPart来接收。 首先，我需要确认用户的需求，他们可能想要一个简单的示例，展示如何接收上传的文件。可能需要包括控制器的代码，以及相关的依赖配置。比如，Spring Boot的starter-web已经包含了文件上传的支持，但可能需要检查是否配置了multipart的相关属性，比如文件大小限制，这在application.properties中设置。 然后，考虑用户可能的场景，比如上传单个文件或多个文件。示例代码应该覆盖这两种情况。记得在控制器方法中使用MultipartFile参数，并且处理可能的异常，比如IOException。同时，需要提到保存文件的方法，比如transferTo()，或者转换为临时文件。 另外，用户可能对文件的大小限制有疑问，所以需要提到如何配置spring.servlet.multipart.max-file-size和max-request-size。可能还需要提醒用户注意临时文件的清理，避免占用过多磁盘空间。 参考提供的引用内容，引用[1]、[3]、[5]提到了使用@RequestParam接收文件，MultipartFile的方法如getOriginalFilename()和transferTo()。引用[2]展示了如何将MultipartFile转换为File，引用[4]提到了前端和后端的交互注意事项。 需要确保代码示例正确，比如控制器的注解是@RestController还是@Controller，POST映射是否正确。另外，示例中的异常处理是否需要显式捕获，或者由Spring统一处理。可能还需要提到使用Postman或前端表单进行测试的方法。 最后，生成相关问题，考虑用户接下来可能会问的内容，比如文件大小限制、保存路径配置、异常处理、多文件上传等。确保问题覆盖常见的后续疑问，帮助用户进一步学习。</think>### Spring Boot中使用MultipartFile接收文件示例 #### 1. 基础代码实现 在Spring Boot中接收文件，需使用`MultipartFile`类型参数，并配合`@RequestParam`或`@RequestPart`注解。以下为两种典型场景的实现： **场景1：单文件上传** ```java @RestController public class FileUploadController { @PostMapping("/upload") public String handleFileUpload(@RequestParam("file") MultipartFile file) { try { String fileName = file.getOriginalFilename(); byte[] bytes = file.getBytes(); // 保存到本地路径（示例路径需替换） Path path = Paths.get("/uploads/" + fileName); Files.write(path, bytes); return "文件上传成功：" + fileName; } catch (IOException e) { return "文件上传失败：" + e.getMessage(); } } } ``` **场景2：多文件上传** ```java @PostMapping("/multi-upload") public String handleMultiUpload(@RequestParam("files") MultipartFile[] files) { Arrays.stream(files).forEach(file -> { if (!file.isEmpty()) { try { Files.copy(file.getInputStream(), Paths.get("/uploads/", file.getOriginalFilename())); } catch (IOException e) { throw new RuntimeException("文件保存失败", e); } } }); return "成功上传" + files.length + "个文件"; } ``` #### 2. 关键配置 在`application.properties`中添加文件大小限制配置： ```properties spring.servlet.multipart.max-file-size=10MB spring.servlet.multipart.max-request-size=50MB ``` #### 3. 技术要点说明 - **文件元数据获取**：通过`file.getOriginalFilename()`获取原始文件名，`file.getContentType()`获取MIME类型[^1] - **文件存储方式**： - 直接转存到本地：`file.transferTo(new File("/path/to/file"))`[^3] - 转为临时文件：`File convertedFile = Files.createTempFile(...)`[^2] - **异常处理**：必须处理`IOException`，推荐使用全局异常处理机制 #### 4. 前端配合示例 HTML表单应设置`enctype="multipart/form-data"`： ```html <form method="POST" action="/upload" enctype="multipart/form-data"> <input type="file" name="file"> <button>提交</button> </form> ``` #### 5. 最佳实践建议 - 文件保存路径建议使用绝对路径 - 生产环境建议使用云存储（参考阿里云OSS集成示例[^5]） - 大文件上传需考虑分片上传方案 - 临时文件应及时清理（可通过`File.deleteOnExit()`实现）