通过临时url访问obs(java sdk)-九游平台

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.requestbody;
importokhttp3.response;
importjava.util.map;
publicclass createbucket001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.put,expireseconds);
request.setbucketname("examplebucket");
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("creating bucket using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用put请求创建桶
stringlocation="your bucket location";
requesthttprequest=
builder.url(response.getsignedurl())
.put(
requestbody.create(
null,
""
location
"".getbytes()))
.build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("\tstatus:"res.code());
if(res.body()!=null){
system.out.println("\tcontent:"res.body().string()"\n");
}
res.close();
system.out.println("createbucket successfully");
}catch(obsexceptione){
system.out.println("createbucket failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("createbucket failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.mediatype;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.requestbody;
importokhttp3.response;
importjava.util.hashmap;
importjava.util.map;
publicclass putobject001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
map<string,string>headers=newhashmap<>();
stringcontenttype="text/plain";
headers.put("content-type",contenttype);
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.put,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
request.setheaders(headers);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("creating object using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用put请求上传对象
requesthttprequest=
builder.url(response.getsignedurl())
.put(requestbody.create(mediatype.parse(contenttype),"hello obs".getbytes("utf-8")))
.build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("putobject successfully");
}catch(obsexceptione){
system.out.println("putobject failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("putobject failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.response;
importjava.io.inputstream;
importjava.util.map;
publicclass getobject001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.get,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("getting object using temporary signature url:");
system.out.println("signedurl:"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用get请求下载对象
requesthttprequest=builder.url(response.getsignedurl()).get().build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
inputstreamobjectcontent=null;
if(res.body()!=null){
objectcontent=res.body().bytestream();
system.out.println("content:"res.body().string()"\n");
}
if(objectcontent!=null){
// objectcontent 就是获取的要下载的文件的文件流
// 在这里可以读取 objectcontent，长时间不读取这个流会被服务端断开连接
}
res.close();
system.out.println("getobject successfully");
}catch(obsexceptione){
system.out.println("getobject failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("getobject failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.response;
importjava.util.map;
publicclass listobject001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.get,expireseconds);
request.setbucketname("examplebucket");
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("getting object list using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用get请求获取对象列表
requesthttprequest=builder.url(response.getsignedurl()).get().build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("listobject successfully");
}catch(obsexceptione){
system.out.println("listobject failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("listobject failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.response;
importjava.util.map;
publicclass deleteobject001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.delete,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("deleting object using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用delete删除对象
requesthttprequest=builder.url(response.getsignedurl()).delete().build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("\tstatus:"res.code());
if(res.body()!=null){
system.out.println("\tcontent:"res.body().string()"\n");
}
res.close();
system.out.println("deleteobjects successfully");
}catch(obsexceptione){
system.out.println("deleteobjects failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("deleteobjects failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.specialparamenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.requestbody;
importokhttp3.response;
importjava.util.map;
publicclass initiatemultipartupload001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.post,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
request.setspecialparam(specialparamenum.uploads);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("initiate multipart upload using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用post请求初始化分段上传任务
requesthttprequest=builder.url(response.getsignedurl()).post(requestbody.create(null,"")).build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("initiatemultipartupload successfully");
}catch(obsexceptione){
system.out.println("initiatemultipartupload failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("initiatemultipartupload failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.requestbody;
importokhttp3.response;
importjava.util.hashmap;
importjava.util.map;
publicclass uploadpart001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.put,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
map<string,object>queryparams=newhashmap<string,object>();
// 设置partnumber请求参数，例如：queryparams.put("partnumber", "1");
queryparams.put("partnumber","partnumber");
queryparams.put("uploadid","your uploadid");
request.setqueryparams(queryparams);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("upload part using temporary signature url:");
system.out.println("signedurl:"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用put请求上传段
requesthttprequest=
builder.url(response.getsignedurl())
.put(requestbody.create(null,newbyte[6*1024*1024]))
.build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("uploadpart successfully");
}catch(obsexceptione){
system.out.println("uploadpart failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("uploadpart failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.response;
importjava.util.hashmap;
importjava.util.map;
publicclass listuploadedparts001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.get,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
map<string,object>queryparams=newhashmap<string,object>();
queryparams.put("uploadid","your uploadid");
request.setqueryparams(queryparams);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("list parts using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用get请求列举已上传段
requesthttprequest=builder.url(response.getsignedurl()).get().build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("listparts successfully");
}catch(obsexceptione){
system.out.println("listparts failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("listparts failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.mediatype;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.requestbody;
importokhttp3.response;
importjava.util.hashmap;
importjava.util.map;
publicclass completemultipartupload001{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.post,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
map<string,string>headers=newhashmap<>();
stringcontenttype="application/xml";
headers.put("content-type",contenttype);
request.setheaders(headers);
map<string,object>queryparams=newhashmap<>();
queryparams.put("uploadid","your uploadid");
request.setqueryparams(queryparams);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("complete multipart upload using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 以下content为示例代码，需要通过列举已上传段方法的响应结果，拼装以下内容
stringcontent="";
content ="";
content ="1";
content ="da6a0d097e307ac52ed9b4ad551801fc";
content ="";
content ="";
content ="2";
content ="da6a0d097e307ac52ed9b4ad551801fc";
content ="";
content ="";
// 使用post请求合并段
requesthttprequest=
builder.url(response.getsignedurl())
.post(requestbody.create(mediatype.parse(contenttype),content.getbytes("utf-8")))
.build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("\tstatus:"res.code());
if(res.body()!=null){
system.out.println("\tcontent:"res.body().string()"\n");
}
res.close();
}catch(obsexceptione){
system.out.println("completemultipartupload failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("completemultipartupload failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importjava.util.hashmap;
importjava.util.map;
publicclass getobject002{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// 获取图片转码的下载链接
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.get,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
// 设置图片转码参数
map<string,object>queryparams=newhashmap<string,object>();
queryparams.put("x-image-process","image/resize,m_fixed,w_100,h_100/rotate,100");
request.setqueryparams(queryparams);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
// 获取支持图片转码的下载链接
system.out.println("getting object using temporary signature url:");
system.out.println("signedurl:"response.getsignedurl());
}catch(obsexceptione){
system.out.println("getobject failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("getobject failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}

importcom.obs.services.obsclient;
importcom.obs.services.exception.obsexception;
importcom.obs.services.model.httpmethodenum;
importcom.obs.services.model.temporarysignaturerequest;
importcom.obs.services.model.temporarysignatureresponse;
importokhttp3.call;
importokhttp3.okhttpclient;
importokhttp3.request;
importokhttp3.response;
importjava.util.hashmap;
importjava.util.map;
publicclass getobject003{
publicstaticvoidmain(string[]args){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk
stringak=system.getenv("access_key_id");
stringsk=system.getenv("secret_access_key_id");
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
// 您可以通过环境变量获取访问密钥ak/sk/securitytoken，也可以使用其他外部引入方式传入。
// string securitytoken = system.getenv("security_token");
// endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
stringendpoint="https://obs.cn-north-4.myhuaweicloud.com";
// 您可以通过环境变量获取endpoint，也可以使用其他外部引入方式传入。
//string endpoint = system.getenv("endpoint");
// 创建obsclient实例
// 使用永久ak/sk初始化客户端
obsclientobsclient=newobsclient(ak,sk,endpoint);
// 使用临时ak/sk和securitytoken初始化客户端
// obsclient obsclient = new obsclient(ak, sk, securitytoken, endpoint);
try{
// 下载sse-c加密类型的对象
// url有效期，3600秒
longexpireseconds=3600l;
temporarysignaturerequestrequest=newtemporarysignaturerequest(httpmethodenum.get,expireseconds);
request.setbucketname("examplebucket");
request.setobjectkey("objectname");
// 设置sse-c加密方式的头域信息
map<string,string>headers=newhashmap<>();
headers.put("x-obs-server-side-encryption-customer-algorithm","aes256");
// 设置加密使用的密钥，该头域由256-bit的密钥经过base64-encoded得到
headers.put(
"x-obs-server-side-encryption-customer-key",
"your base64 sse-c key generated by aes-256 algorithm");
// 设置加密使用的密钥的md5值，该头域由密钥的128-bit md5值经过base64-encoded得到
headers.put("x-obs-server-side-encryption-customer-key-md5","the md5 value of your sse-c key");
request.setheaders(headers);
temporarysignatureresponseresponse=obsclient.createtemporarysignature(request);
system.out.println("getting object using temporary signature url:");
system.out.println("\t"response.getsignedurl());
request.builderbuilder=newrequest.builder();
for(map.entry<string,string>entry:response.getactualsignedrequestheaders().entryset()){
builder.header(entry.getkey(),entry.getvalue());
}
// 使用get请求下载对象
requesthttprequest=builder.url(response.getsignedurl()).get().build();
okhttpclienthttpclient=
newokhttpclient.builder()
.followredirects(false)
.retryonconnectionfailure(false)
.cache(null)
.build();
callc=httpclient.newcall(httprequest);
responseres=c.execute();
system.out.println("status:"res.code());
if(res.body()!=null){
system.out.println("content:"res.body().string()"\n");
}
res.close();
system.out.println("getobject successfully");
}catch(obsexceptione){
system.out.println("getobject failed");
// 请求失败,打印http状态码
system.out.println("http code:"e.getresponsecode());
// 请求失败,打印服务端错误码
system.out.println("error code:"e.geterrorcode());
// 请求失败,打印详细错误信息
system.out.println("error message:"e.geterrormessage());
// 请求失败,打印请求id
system.out.println("request id:"e.geterrorrequestid());
system.out.println("host id:"e.geterrorhostid());
e.printstacktrace();
}catch(exceptione){
system.out.println("getobject failed");
// 其他异常信息打印
e.printstacktrace();
}
}
}