阿里云--云存储OSS
云存储OSS申请步骤和我上一篇短信一致
依赖
com.aliyun.oss aliyun-sdk-oss application.yml
server:port: 8130
spring:application:name: service-oss
aliyun:oss:endpoint: oss-cn-beijing.aliyuncs.comaccessKeyId: XXXXXsecret: XXXXXXXbucket: XXXXXX #Bucket 名称
config
package com.lizheng.config;import lombok.Data;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;/*** @author 笑起来和猫是似的先生* @ClassName OssProperties* @description: TODO* @datetime 2023年 08月 03日 11:12* @version: 1.0*/
@Data
@Component
public class OssProperties implements InitializingBean {@Value("${aliyun.oss.endpoint}")private String endpoint;//站点@Value("${aliyun.oss.accessKeyId}")private String accessKeyId;//管理的key@Value("${aliyun.oss.secret}")private String secret;//密钥@Value("${aliyun.oss.bucket}")private String bucket;//节点 目录public static String END_POINT;//站点public static String ACCESS_KEY_ID;//管理的keypublic static String KEY_SECRET;//密钥public static String BUCKET_NAME;//节点 目录@Overridepublic void afterPropertiesSet() throws Exception {END_POINT=endpoint;ACCESS_KEY_ID=accessKeyId;KEY_SECRET=secret;BUCKET_NAME=bucket;}
}
package com.lizheng.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;/*** @author 笑起来和猫似的先生* @ClassName SwaggerConfig* @description: TODO* @datetime 2023年 08月 01日 18:46* @version: 1.0*/
@Configuration
@EnableSwagger2
public class SwaggerConfig {@Beanpublic Docket creatRestapi(){return new Docket(DocumentationType.SWAGGER_2).pathMapping("/").select().apis(RequestHandlerSelectors.basePackage("com.lizheng")).paths(PathSelectors.any()).build().apiInfo(new ApiInfoBuilder().title("SpringBoot整合Swagger").description("上班用").version("1.0").contact(new Contact("lizheng","http://www.lizheng.com","lizheng@163.com")).license("The Apache license").licenseUrl("http://www.lizheng.com").build());}
}
controller
package com.lizheng.controller;import com.lizheng.exception.BusinessException;
import com.lizheng.result.ResponseEnum;
import com.lizheng.result.Result;
import com.lizheng.service.FileService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import java.io.InputStream;/*** @author 笑起来和猫似的先生* @ClassName FileController* @description: TODO* @datetime 2023年 08月 03日 11:09* @version: 1.0*/
@Api(tags = "阿里云OSS 对象存储")
@RestController
@RequestMapping("/api/oss/file")
public class FileController {@Autowiredprivate FileService fileService;@ApiOperation("文件上传")@PostMapping("/upload")public Result upload(@ApiParam(value = "文件",required = true)@RequestParam("file")MultipartFile file,@ApiParam(value = "模块",required = true)@RequestParam( "module") String module){try {InputStream inputStream = file.getInputStream();//获取原始文件名String originalFilename= file.getOriginalFilename();//上传String url = fileService.upload(inputStream,module,originalFilename);//上传成功return Result.ok().message("上传成功了").data("url",url);}catch (Exception ex){ex.printStackTrace();try {throw new BusinessException(ResponseEnum.UPLOAD_ERROR,ex.getMessage());}catch (Exception e){e.printStackTrace();}}return null;}@ApiOperation("文件删除")@DeleteMapping("/remove")public Result remove(@ApiParam(value = "要删除的文件的路径",required = true)@RequestParam("url") String url){fileService.removeFile(url);return Result.ok().message("删除成功");}}
service
package com.lizheng.service;import java.io.InputStream;/*** @author 笑起来和猫似的先生* @ClassName FileService* @description: TODO* @datetime 2023年 08月 03日 11:09* @version: 1.0*/public interface FileService {//上传String upload(InputStream inputStream, String module, String filename);//删除void removeFile(String url);
}
serviceImpl
package com.lizheng.service.impl;import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.lizheng.config.OssProperties;
import com.lizheng.service.FileService;
import org.joda.time.DateTime;
import org.springframework.stereotype.Service;import java.io.InputStream;
import java.util.UUID;/*** @author 笑起来和猫似的先生* @ClassName FileServiceImpl* @description: TODO* @datetime 2023年 08月 03日 11:10* @version: 1.0*/
@Service
public class FileServiceImpl implements FileService {@Overridepublic String upload(InputStream inputStream, String module, String filename) {OSS ossClient = new OSSClientBuilder().build(OssProperties.END_POINT, OssProperties.ACCESS_KEY_ID, OssProperties.KEY_SECRET);// 创建OSS客户端对象，使用OssProperties中的配置参数// 生成日期路径，格式为yyyy/MM/ddString timeFolder = new DateTime().toString("yyyy/MM/dd");// 文件名处理：在原始文件名基础上生成一个唯一的UUID并保留文件扩展名filename = UUID.randomUUID().toString() + filename.substring(filename.lastIndexOf("."));// 构建OSS对象的存储路径，格式为module/日期路径/文件名String key = module + "/" + timeFolder + "/" + filename;// 将输入流上传到OSS指定的Bucket中，使用生成的存储路径作为文件的唯一标识ossClient.putObject(OssProperties.BUCKET_NAME, key, inputStream);// 关闭OSS客户端连接if (ossClient != null) {ossClient.shutdown();}// 返回上传后的文件URL，格式为https://Bucket名称.Endpoint/存储路径return "https://" + OssProperties.BUCKET_NAME + "." + OssProperties.END_POINT + "/" + key;}@Overridepublic void removeFile(String url) {//创建OSSClient实例OSS ossClient = new OSSClientBuilder().build(OssProperties.END_POINT,OssProperties.ACCESS_KEY_ID,OssProperties.KEY_SECRET);String host = "https://" + OssProperties.BUCKET_NAME + "." + OssProperties.END_POINT + "/";String objectName = url.substring(host.length());ossClient.deleteObject(OssProperties.BUCKET_NAME,objectName);if (ossClient!=null){ossClient.shutdown();}}}本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！