当前位置: 首页 > news >正文

JAVA实现文件上传至阿里云

注册阿里云账号后,开通好对象存储服务(OSS),三个月试用

    阿里云登录页 (aliyun.com)

目录

一.创建Bucket

二.获取AccessKey(密钥)

三.参考官方SDK文件,编写入门程序

1.复制阿里云OSS依赖,粘贴到pom.xml文件里

​2. 将上传文件流的Demo测试类复制到test文件里

四.集成OSS(运用于项目中)

1. 在yml文件配置自定义阿里云OSS信息

2.编写阿里云工具类(官方代码改编)

 3.编写文件上传类(接口)

一.创建Bucket

4b00228e84434ba5927d30a0195e9630.png

cbdd7ccfca6e452ca9ed38f4784ca5e5.png

二.获取AccessKey(密钥)

2c799089ee974f2b9df7a1bc807c52a8.png

7df1c3a10bd343bc9facad9998960072.png

78e619a7fc3a45bd90b22e6c74a8b909.png

注意:保存好你的AccessKey ID!!

三.参考官方SDK文件,编写入门程序

d1dbebe7d6b6435abe678933ddeecd5a.pngf2997620b2f644f1b63cbbf7c82b1996.png

1.复制阿里云OSS依赖,粘贴到pom.xml文件里

        <!--阿里云OSS--><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.15.1</version></dependency>

d9a69c2b63b74a158811baf7aae5b1fe.png2. 将上传文件流的Demo测试类复制到test文件里

import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.PutObjectResult;
import java.io.FileInputStream;
import java.io.InputStream;public class Demo {public static void main(String[] args) throws Exception {// Endpoint以华东1(杭州)为例,其它Region请按实际情况填写。String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";// 从环境变量中获取访问凭证。运行本代码示例之前,请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称,例如examplebucket。String bucketName = "examplebucket";// 填写Object完整路径,完整路径中不能包含Bucket名称,例如exampledir/exampleobject.txt。String objectName = "exampledir/exampleobject.txt";// 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。// 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。String filePath= "D:\\localpath\\examplefile.txt";// 创建OSSClient实例。OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);try {InputStream inputStream = new FileInputStream(filePath);// 创建PutObjectRequest对象。PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);// 创建PutObject请求。PutObjectResult result = ossClient.putObject(putObjectRequest);} 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();}}}
} 

注意:需配置环境变量,然后修改为自己的配置!!

①添加系统环境变量,即你的AccesskKyId和accessKeySecret

 750690c7bcdf409d9f6b1bcc308c382a.png

②修改Demo里的endpoint、bucketName、objectName和filePath

e37c50ebf28c402289957e9ae46e3c4b.png

 只需修改这四个用于测试,运行Demo,查看OSS,上传成功!

1fafe605269d4d40a29b1b85938d0e6c.png

四.集成OSS(运用于项目中)

1. 在yml文件配置自定义阿里云OSS信息

①在AliOSSProperties类中,先使用@ConfigurationProperties自动注入到yml中

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;@Data
@Component
@ConfigurationProperties(prefix = "aliyun.oss")
public class AliOSSProperties {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;
}

②然后在yml文件中配置阿里云OSS

fd2604553a8147eb8c65ab13987a6f93.png

2.编写阿里云工具类(官方代码改编)

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.util.UUID;/*** 阿里云 OSS 工具类*/
@Component
@ConfigurationProperties
public class AliOSSUtils {@Autowiredprivate AliOSSProperties aliOSSProperties;/*** 实现上传图片到OSS*/public String upload(MultipartFile file) throws IOException {//获取阿里云OSS参数String endpoint = aliOSSProperties.getEndpoint();String accessKeyId = aliOSSProperties.getAccessKeyId();String accessKeySecret = aliOSSProperties.getAccessKeySecret();String bucketName = aliOSSProperties.getBucketName();// 获取上传的文件的输入流InputStream inputStream = file.getInputStream();// 避免文件覆盖String originalFilename = file.getOriginalFilename();String fileName = UUID.randomUUID().toString() + originalFilename.substring(originalFilename.lastIndexOf("."));//上传文件到 OSSOSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);ossClient.putObject(bucketName, fileName, inputStream);//文件访问路径String url = endpoint.split("//")[0] + "//" + bucketName + "." + endpoint.split("//")[1] + "/" + fileName;// 关闭ossClientossClient.shutdown();return url;// 把上传到oss的路径返回}}

 3.编写文件上传类(接口)

import com.itheima.pojo.Result;
import com.itheima.utils.AliOSSUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;@Slf4j
@RestController
public class UploadController {//注入阿里云工具类@Autowiredprivate AliOSSUtils aliOSSUtils;@PostMapping("/upload")public Result upload(MultipartFile image) throws IOException {log.info("文件上传,文件名:{}", image.getOriginalFilename());//调用阿里云OSS工具类进行文件上传String url = aliOSSUtils.upload(image);log.info("文件上传完成,文件访问的url:{}", url);return Result.success(url);}
}

至此。后端上传文件至阿里云的代码完成!!

 

 

http://www.lryc.cn/news/277646.html

相关文章:

  • 设计模式之外观模式【结构型模式】
  • Qt QCheckBox复选按钮控件
  • 加速科技ST2500 数模混合信号测试设备累计装机量突破500台!
  • ASP.NETCore WebAPI 入门 杨中科
  • 问题 C: 活动选择
  • SpringBoot学习(五)-Spring Security配置与应用
  • Java解决删除子串后的字符串最小长度
  • 日志系统一(elasticsearch+filebeat+logstash+kibana)
  • 游戏版 ChatGPT,要用 AI 角色完善生成工具实现 NPC 自由
  • 加工零件的题解
  • 走进shell
  • 【Python】使用tkinter设计开发Windows桌面程序记事本(2)
  • Flutter DateTime 常用处理
  • 【uniapp】APP打包上架应用商-注意事项
  • 【算法题】43. 字符串相乘
  • CH341 SPI方式烧录BK7231U
  • sd-webui-EasyPhoto win 安装笔记
  • gradient_checkpointing
  • 回溯算法part05 算法
  • 阿里云系统盘测评ESSD、SSD和高效云盘IOPS、吞吐量性能参数表
  • RK3568平台开发系列讲解(Linux系统篇)Linux 内核打印
  • 迁移学习的最新进展和挑战
  • Python基础(二十二、自定义模块和包)
  • C#-数组
  • 机器学习周刊第二期:300个机器学习应用案例集
  • 【华为OD机试真题2023CD卷 JAVAJS】中文分词模拟器
  • 基于YOLOv8-pose的画笔关键点(bic_markers)检测
  • 【实用技巧】Windows 电脑向iPhone或iPad传输视频方法1:无线传输
  • 爬虫实战 - 微博评论数据可视化
  • python装饰器嵌套基础