实现 文件上传【头像/图片】
浏览器---->后端服务----->阿里云OSS
工具类
- @Data
- @AllArgsConstructor
- @Slf4j
- public class AliOssUtil {
- private String endpoint;
- private String accessKeyId;
- private String accessKeySecret;
- private String bucketName;
- /**
- * 文件上传
- *
- * @param bytes
- * @param objectName
- * @return
- */
- public String upload(byte[] bytes, String objectName) {
- // 创建OSSClient实例。
- OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
- try {
- // 创建PutObject请求。
- ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));
- } catch (OSSException oe) {
- System.out.println("Caught an OSSException, which means your request made it to OSS, "
- + "but was rejected with an error response for some reason.");
- System.out.println("Error Message:" + oe.getErrorMessage());
- System.out.println("Error Code:" + oe.getErrorCode());
- System.out.println("Request ID:" + oe.getRequestId());
- System.out.println("Host ID:" + oe.getHostId());
- } catch (ClientException ce) {
- System.out.println("Caught an ClientException, which means the client encountered "
- + "a serious internal problem while trying to communicate with OSS, "
- + "such as not being able to access the network.");
- System.out.println("Error Message:" + ce.getMessage());
- } finally {
- if (ossClient != null) {
- ossClient.shutdown();
- }
- }
- //文件访问路径规则 https://BucketName.Endpoint/ObjectName
- StringBuilder stringBuilder = new StringBuilder("https://");
- stringBuilder
- .append(bucketName)
- .append(".")
- .append(endpoint)
- .append("/")
- .append(objectName);
- log.info("文件上传到:{}", stringBuilder.toString());
- return stringBuilder.toString();
- }
- }
复制代码 代码实现
- 在application.yml中编写相关信息
- sky:
- alioss:
- endpoint: oss-cn-hangzhou.aliyuncs.com
- access-key-id: LTAI5tJKk5H21ZmQQ9CgeG8y
- access-key-secret: 90xHhXxKqg6LNnbb4ubp1BeIdw7RAT
- bucket-name: sky-zy2596
复制代码 - 编写AliOssProperties ,将yml文件信息映射到AliOssProperties对象中
- @Component
- @ConfigurationProperties(prefix = "sky.alioss")
- @Data
- public class AliOssProperties {
- private String endpoint;
- private String accessKeyId;
- private String accessKeySecret;
- private String bucketName;
- }
复制代码 - 编写配置类,创建AliOssUtil对象
- /**
- * 配置类,用于创建AliOssUtil对象
- */
- @Configuration
- @Slf4j
- public class OssConfiguration {
- @Bean
- @ConditionalOnMissingBean//保证spring容器只有一个AliOssUtil对象
- public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties ){//将aliOssProperties 中的属性赋给AliOssUtil对象
- log.info("开始创建阿里云文件上传工具类对象:{}",aliOssProperties);
- return new AliOssUtil(aliOssProperties.getEndpoint()
- ,aliOssProperties.getAccessKeyId()
- ,aliOssProperties.getAccessKeySecret()
- ,aliOssProperties.getBucketName());
- }
- }
复制代码 - 编写文件上传接口
- @PostMapping("/upload")
- @ApiOperation("文件上传")
- public Result<String> upload(MultipartFile file){// file 这里的参数名必须和前端提交的参数名保持一致
- log.info("文件上传:{}",file);
- try {
- //原始文件名
- String originalFilename = file.getOriginalFilename();
- //截取原始文件名的后缀
- String extension = originalFilename.substring(originalFilename.lastIndexOf("."));
- //构造新文件名称
- String objectName = UUID.randomUUID().toString() + extension;
- //文件的请求路径
- String filePath = aliOssUtil.upload(file.getBytes(), objectName);
- return Result.success(filePath);
- } catch (IOException e) {
- log.error("文件上传失败:{}",e);
- }
- return Result.error("文件上传失败");
- }
复制代码
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |