526互联

通过Maven将文件上传到阿里云对象存储OSS

发布时间 2023-08-25 21:01:54作者: 何平安

首先在阿里云开通对象存储OSS功能（免费的），然后在Bucket列表中创建一个Bucket，地域建议选择华东1（杭州），因为这样后面就不用修改Endpoint,或者你直接记住Endpoint也行，读写仅限为公共读，其他的选项就默认的就行了。

然后在右上角的头像初点击AccessKey管理，选择继续使用AccessKey，点击创建AccessKey，然后务必记住你的id和sericet，复制到你的电脑上最好，因为阿里云现在不支持查询密钥了。

阿里云官方的上传文件教程：如何使用JavaSDK上传文件_对象存储 OSS-阿里云帮助中心 (aliyun.com)

但是我搞了半天都配置不来环境变量，所以我推荐一个比较通俗易懂的方法，就是直接定义ID和密码然后传递给OSS对象就行了。

先下载阿里云的SDK:SDK安装包，解压后将首目录下的jar文件和lib里面的所有文件添加到项目模块里面去。

在Maven工程中使用OSS Java SDK，只需在pom.xml中加入相应依赖即可。以3.15.1版本为例，在<dependencies>中加入如下内容：

<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.15.1</version>
</dependency>

如果使用的是Java 9及以上的版本，则需要添加jaxb相关依赖。添加jaxb相关依赖示例代码如下：

<dependency>
    <groupId>javax.xml.bind</groupId>
    <artifactId>jaxb-api</artifactId>
    <version>2.3.1</version>
</dependency>
<dependency>
    <groupId>javax.activation</groupId>
    <artifactId>activation</artifactId>
    <version>1.1.1</version>
</dependency>
<!-- no more than 2.3.3-->
<dependency>
    <groupId>org.glassfish.jaxb</groupId>
    <artifactId>jaxb-runtime</artifactId>
    <version>2.3.3</version>
</dependency>

测试上传文件：在test测试里面的软件包直接粘贴下面的代码：

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.*;
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。
 String accessKeyId="yourid";
String accessKeySecret="yoursecret";
 // 填写Bucket名称，例如examplebucket。
 String bucketName = "picture-hepingan";
// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
 String objectName = "1.jpg";
// 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
 // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
 String filePath= "D:\\My photos\\图片5\\1.jpg";

// 创建OSSClient实例。
 OSSClient ossClient = new OSSClient(endpoint,accessKeyId,accessKeySecret);

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();
}
}
}
}

该修改的参数还是要修改下，比如accessid,accesssecret,buketName,filePath，都有注释，看注释就行。这是不配置环境变量的方法，阿里云官方的教程是要配置环境变量的。然后运行就可以在阿里云OSS里面的bucket列表对应的bucket里面看到你上传的文件。参考文章：oss文件上传时报错：Exception in thread “main” com.aliyun.oss.OSSException: You have no right to – 恶霸李士士 – 博客园 (cnblogs.com)

通过Java代码上传文件到阿里云OSS：

在top.hepingan下创建一个软件包utils，然后直接粘贴下面的代码：注意修改那几个参数。

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.util.UUID;
/**
 * 阿里云 OSS 工具类
 */
@Component
public class AliOSSUtils {

private String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
private String accessKeyId = "LTAI5tLfTLzZSwnWjgi5m3C5";
private String accessKeySecret = "es0pyJIFLFCPBwGuwZnqd7Ct7JWp7j";
private String bucketName = "picture-hepingan";

/**
 * 实现上传图片到OSS
 */
 public String upload(MultipartFile file) throws IOException {
// 获取上传的文件的输入流
 InputStream inputStream = file.getInputStream();

// 避免文件覆盖
 String originalFilename = file.getOriginalFilename();
String fileName = UUID.randomUUID().toString() + originalFilename.substring(originalFilename.lastIndexOf("."));

//上传文件到 OSS
 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
ossClient.putObject(bucketName, fileName, inputStream);

//文件访问路径
 String url = endpoint.split("//")[0] + "//" + bucketName + "." + endpoint.split("//")[1] + "/" + fileName;
// 关闭ossClient
 ossClient.shutdown();
return url;// 把上传到oss的路径返回
 }

}

然后再在UploadController里面编写方法：

@Autowired
private 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();
}

然后在postman 请求upload，POST的请求方式，选择Body中的from-date:

最后在阿里云OSS的对应Bucket里就可以看到上传的文件了