网站策划与网页设计,网站开发 英语,全国建设市场公共服务网站,做财经类网站要许可吗官方文档 https://help.aliyun.com/zh/oss/developer-reference/java 准备工作 windows安装好JDK#xff0c;这里使用JDK1.8为例 windows安装好IDEA#xff0c;这里使用IDEA2022 登录阿里云控制台#xff0c;通过免费试用OSS或开通OSS
步骤
配置访问凭证
有临时和长期…官方文档 https://help.aliyun.com/zh/oss/developer-reference/java 准备工作 windows安装好JDK这里使用JDK1.8为例 windows安装好IDEA这里使用IDEA2022 登录阿里云控制台通过免费试用OSS或开通OSS
步骤
配置访问凭证
有临时和长期访问凭证简单起见这里使用长期访问凭证。
配置RAM用户的访问密钥
1.创建RAM用户
登录阿里云搜索访问控制进入RAM 访问控制
在RAM 访问控制中创建RAM用户 填写用户信息勾选相关访问方式点击确定 安全验证根据提示进行其中一个验证。 得到RAM用户的相关信息例如登录名称、登录密码、AccessKey ID和Access Secret
点击用户找到刚创建的RAM用户一行点击添加权限 添加AliyunOSSFullAccess权限
2.配置RAM用户的访问密钥。
有两种方式配置RAM用户的访问密钥
设置环境变量代码嵌入 把AccessKey ID和Access Secret设置在环境变量里比直接代码嵌入的方式更加安全些两种方式选择其中之一即可。
设置环境变量
打开cmd命令行。
执行以下命令配置RAM用户的访问密钥。
set OSS_ACCESS_KEY_IDLTAI4GDty8ab9W4Y1D****
set OSS_ACCESS_KEY_SECRETIrVTNZNy5yQelTETg0cZML3TQn**** 注意 OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET修改为对应AccessKey ID和Access Secret的值。
执行以下命令以使更改生效。
setx OSS_ACCESS_KEY_ID %OSS_ACCESS_KEY_ID%
setx OSS_ACCESS_KEY_SECRET %OSS_ACCESS_KEY_SECRET%这个过程其实是往用户的环境变量里设置相应的值(用图形界面设置也一样)
执行以下命令验证环境变量配置。
echo %OSS_ACCESS_KEY_ID%
echo %OSS_ACCESS_KEY_SECRET%成功返回示例如下
LTAI4GDty8ab9W4Y1D****
IrVTNZNy5yQelTETg0cZML3TQn**** 从环境变量中获取RAM用户的访问密钥。
// 使用环境变量中获取的RAM用户的访问密钥配置访问凭证。
EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();注意设置环境变量后如果之前已经打开IDEA后面使用代码去获取环境变量时需要重启IDEA才能获取到新的环境变量设置。否则获取到的环境变量为null
代码嵌入
// RAM用户的访问密钥AccessKey ID和AccessKey Secret。
String accessKeyId yourAccessKeyId;
String accessKeySecret yourAccessKeySecret;
// 使用代码嵌入的RAM用户的访问密钥配置访问凭证。
CredentialsProvider credentialsProvider new DefaultCredentialProvider(accessKeyId, accessKeySecret);代码开发
1. 创建maven工程
打开IDEA-点击File-New Project
2. 添加sdk依赖 dependenciesdependencygroupIdcom.aliyun.oss/groupIdartifactIdaliyun-sdk-oss/artifactIdversion3.15.1/version/dependency/dependencies刷新依赖
3. 功能代码开发
使用SDK API实现创建Bucket、列举Bucket文件、上传文件、下载文件、删除文件。代码参考官方帮助文档。 代码结构如下
创建Bucket
package org.example;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;public class CreateBucketDemo {public static void main(String[] args) throws Exception {// Endpoint以华东1杭州为例其它Region请按实际情况填写。String endpoint https://oss-cn-shenzhen.aliyuncs.com;// 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称例如examplebucket。String bucketName examplebucket-test-test900;// 创建OSSClient实例。OSS ossClient new OSSClientBuilder().build(endpoint, credentialsProvider);try {// 创建存储空间。ossClient.createBucket(bucketName);} 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();}}}
}*注意修改endpoint、bucketName bucketName 不能有重复。
运行后在阿里云控制台查看到bucket创建成功如下 可以手动上传一些文件到bucket里点击Bucket名称 进入bucket文件列表页面通过上传文件、创建目录等方式让Bucket里得到一些目录和文件。
列举Bucket文件
package org.example;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.common.auth.CredentialsProvider;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.DefaultCredentialProvider;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;
import com.aliyun.oss.model.OSSObjectSummary;
import com.aliyun.oss.model.ObjectListing;public class ListFileDemo {public static void main(String[] args) throws Exception {// Endpoint以华东1杭州为例其它Region请按实际情况填写。String endpoint https://oss-cn-shenzhen.aliyuncs.com;// 嵌入代码// RAM用户的访问密钥AccessKey ID和AccessKey Secret。注意修改xxx的值String accessKeyId xxx;String accessKeySecret xxx;// 使用代码嵌入的RAM用户的访问密钥配置访问凭证。CredentialsProvider credentialsProvider new DefaultCredentialProvider(accessKeyId, accessKeySecret);// 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
// EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称例如examplebucket。String bucketName examplebucket-test-test900;// 创建OSSClient实例。OSS ossClient new OSSClientBuilder().build(endpoint, credentialsProvider);try {// ossClient.listObjects返回ObjectListing实例包含此次listObject请求的返回结果。ObjectListing objectListing ossClient.listObjects(bucketName);// objectListing.getObjectSummaries获取所有文件的描述信息。for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) {System.out.println( - objectSummary.getKey() (size objectSummary.getSize() ));}} 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();}}}
}
使用代码嵌入的方式得到RAM用户的访问密钥。 注意修改accessKeyId和accessKeySecret的值。 运行代码能看到一些文件
上传文件
package org.example;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;
import java.io.ByteArrayInputStream;public class UploadFileDemo {public static void main(String[] args) throws Exception {// Endpoint以华东1杭州为例其它Region请按实际情况填写。String endpoint https://oss-cn-shenzhen.aliyuncs.com;// 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称例如examplebucket。String bucketName examplebucket-test-test900;// 填写Object完整路径例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。String objectName file/uploadobject1.txt;// 创建OSSClient实例。OSS ossClient new OSSClientBuilder().build(endpoint, credentialsProvider);try {String content Hello OSS;ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));} 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();}}}
}
运行后查看阿里云控制台多了一个uploadobject1.txt文件 可以验证uploadobject1.txt的内容为
Hello OSS下载文件
package org.example;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;
import com.aliyun.oss.model.OSSObject;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;public class DownloadFileDemo {public static void main(String[] args) throws Exception {// Endpoint以华东1杭州为例其它Region请按实际情况填写。String endpoint https://oss-cn-shenzhen.aliyuncs.com;// 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称例如examplebucket。String bucketName examplebucket-test-test900;// 填写Object完整路径例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。String objectName file/emp.sql;// 创建OSSClient实例。OSS ossClient new OSSClientBuilder().build(endpoint, credentialsProvider);try {// 调用ossClient.getObject返回一个OSSObject实例该实例包含文件内容及文件元信息。OSSObject ossObject ossClient.getObject(bucketName, objectName);// 调用ossObject.getObjectContent获取文件输入流可读取此输入流获取其内容。InputStream content ossObject.getObjectContent();if (content ! null) {BufferedReader reader new BufferedReader(new InputStreamReader(content));while (true) {String line reader.readLine();if (line null) {break;}System.out.println(\n line);//这里简单打印每行内容}// 数据读取完成后获取的流必须关闭否则会造成连接泄漏导致请求无连接可用程序无法正常工作。content.close();}} 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();}}}
}
运行程序看到emp.sql的内容
删除文件
package org.example;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;public class DeleteFileDemo {public static void main(String[] args) throws Exception {// Endpoint以华东1杭州为例其它Region请按实际情况填写。String endpoint https://oss-cn-shenzhen.aliyuncs.com;// 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();// 填写Bucket名称例如examplebucket。String bucketName examplebucket-test-test900;// 填写Object完整路径例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。String objectName file/uploadobject1.txt;// 创建OSSClient实例。OSS ossClient new OSSClientBuilder().build(endpoint, credentialsProvider);try {// 删除文件。ossClient.deleteObject(bucketName, objectName);} 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();}}}
}
运行程序后刷新Bucket列表看到file/uploadobject1.txt被删除了。 代码总结 在使用OSS SDK时需要先创建OSSClient实例ossClient然后调用对应API方法。例如
创建Bucket ossClient.createBucket(bucketName)列举Bucket文件 ossClient.listObjects(bucketName)上传文件ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes()))下载文件ossClient.getObject(bucketName, objectName).getObjectContent()删除文件ossClient.deleteObject(bucketName, objectName)
完成enjoy it
