阿里云OSS文件上传案例-编程实验室

OSS 文件上传流程详解

以下是基于提供代码实现的 OSS 文件上传完整流程，包含配置、核心代码及步骤说明：

一、前期准备

阿里云 OSS 配置
- 需在阿里云控制台创建 Bucket，获取endpoint、accessKeyId、accessKeySecret和bucketName
- 配置文件位置：src/main/resources/oss.properties

properties

# oss.properties配置示例 aliyun.oss.endpoint=oss-cn-beijing.aliyuncs.com aliyun.oss.accessKeyId=LTAI5tGRHc12i6A4ZEnrUaRR aliyun.oss.accessKeySecret=EEeB0vBuvmDlXK1fkX2cBMWcsztlx0 aliyun.oss.bucketName=zjc-java-spring

二、核心组件配置

OSS 客户端配置（OssConfig.java）

java

运行

@Configuration public class OssConfig { // 从配置文件注入OSS连接参数 @Value("${aliyun.oss.endpoint}") private String endpoint; @Value("${aliyun.oss.accessKeyId}") private String accessKeyId; @Value("${aliyun.oss.accessKeySecret}") private String accessKeySecret; // 创建OSS客户端实例并交给Spring管理 @Bean(destroyMethod = "shutdown") public OSS ossClient() { return new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); } }

文件上传工具类（OssUtils.java）

java

运行

@Component public class OssUtils { @Autowired private OSS ossClient; @Value("${aliyun.oss.bucketName}") private String bucketName; @Value("${aliyun.oss.endpoint}") private String endpoint; /** * 文件上传到OSS * @param file 要上传的文件 * @param folder OSS存储文件夹 * @return 外网访问URL */ public String upload(MultipartFile file, String folder) throws Exception { // 1. 校验文件是否为空 if (file.isEmpty()) { throw new Exception("上传文件不能为空"); } // 2. 处理文件名和后缀 String originalFilename = file.getOriginalFilename(); String suffix = ""; if (originalFilename != null && originalFilename.contains(".")) { suffix = originalFilename.substring(originalFilename.lastIndexOf(".")); } String fileName = originalFilename; // 使用原始文件名 // 3. 处理文件夹路径 if (!folder.endsWith("/")) { folder += "/"; } String objectName = folder + fileName; // 最终OSS存储路径 // 4. 上传文件到OSS InputStream inputStream = file.getInputStream(); try { ossClient.putObject(bucketName, objectName, inputStream); } finally { inputStream.close(); // 确保流关闭 } // 5. 构建文件访问URL String endpointWithoutProtocol = endpoint.replaceFirst("^https?://", ""); return "https://" + bucketName + "." + endpointWithoutProtocol + "/" + objectName; } }

三、业务层实现

服务接口（FileService.java）

java

运行

public interface FileService { // 上传文件并返回文件信息 File uploadFile(MultipartFile file, String fileName); }

服务实现类（FileServiceImpl.java）

java

运行

@Service public class FileServiceImpl implements FileService { @Autowired private FileMapper fileMapper; @Autowired private OssUtils ossUtils; @Override public File uploadFile(MultipartFile file, String fileName) { try { // 1. 上传文件到OSS，指定存储文件夹 String folder = "file/"; String fileUrl = ossUtils.upload(file, folder); // 2. 构建文件实体对象 File fileEntity = new File(); fileEntity.setName(fileName); fileEntity.setUrl(fileUrl); // 提取文件标识（用于后续删除） String keyPoints = fileUrl.substring(fileUrl.lastIndexOf("/") + 1); fileEntity.setKeyPoints(keyPoints); // 3. 保存文件信息到数据库 fileMapper.insert(fileEntity); return fileEntity; } catch (Exception e) { throw new RuntimeException("文件上传失败：" + e.getMessage()); } } }

四、控制器层（接收前端请求）

java

运行

@Controller @RequestMapping("/file") public class FileController { @Autowired private FileService fileService; @PostMapping("/upload") @ResponseBody public Map<String, Object> upload( @RequestParam("file") MultipartFile file, @RequestParam("fileName") String fileName) { Map<String, Object> result = new HashMap<>(); try { // 1. 校验参数 if (file == null || file.isEmpty()) { result.put("success", false); result.put("message", "请选择文件"); return result; } // 2. 调用服务层上传 File fileEntity = fileService.uploadFile(file, fileName); // 3. 返回结果 result.put("success", true); result.put("data", fileEntity); result.put("message", "上传成功"); } catch (Exception e) { result.put("success", false); result.put("message", "上传失败：" + e.getMessage()); } return result; } }

五、SpringMVC 文件上传配置

在springmvc.xml中配置文件上传解析器：

xml

<!-- 文件上传解析器 --> <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"> <property name="maxUploadSize" value="10485760"/> <!-- 最大10MB --> <property name="defaultEncoding" value="UTF-8"/> </bean>