文档首页/ 对象存储服务 OBS/ SDK参考/ Java/ 临时授权访问(Java SDK)/ 通过Header鉴权访问OBS(Java SDK)
更新时间：2024-06-18 GMT+08:00
查看PDF
分享

通过Header鉴权访问OBS(Java SDK)

代码示例：上传对象

通过Header鉴权访问OBS，将“Hello OBS”字符串上传到桶examplebucket里的objectName中。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
import com.obs.services.internal.Constants;
import com.obs.services.internal.utils.AbstractAuthentication;
import com.obs.services.model.AuthTypeEnum;
import shade.okhttp3.Call;
import shade.okhttp3.MediaType;
import shade.okhttp3.OkHttpClient;
import shade.okhttp3.Request;
import shade.okhttp3.RequestBody;
import shade.okhttp3.Response;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
public class PutObjectTemporaryHeaderToObs {
    // 您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
    // 您可以登录访问管理控制台获取访问密钥AK/SK
    private static String ak = System.getenv("ACCESS_KEY_ID");
    private static String sk = System.getenv("SECRET_ACCESS_KEY_ID");
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
    // 您可以通过环境变量获取访问密钥AK/SK/SecurityToken，也可以使用其他外部引入方式传入。
    private static String securityToken = System.getenv("SECURITY_TOKEN");
    // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
    //private static String endPoint = System.getenv("ENDPOINT");
    // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    private static String endPoint = "obs.cn-north-4.myhuaweicloud.com";
    private static String bucketName = "examplebucket";
    private static String objectName = "objectName";
    private static String contentType = "application/xml";
    private static Map<String, String> headers = new HashMap<>();
    public static void main(String[] args) throws Exception {
        headers.put("Content-Type", contentType);
        DateFormat dateFormat = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
        dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
        Date now = new Date(System.currentTimeMillis());
        headers.put("x-obs-date", dateFormat.format(now));
        sign("PUT", "/" + bucketName + "/" + objectName);
        Request.Builder builder = new Request.Builder();
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            builder.header(entry.getKey(), entry.getValue());
        }
        String url = "https://" + bucketName + "." + endPoint + "/" + objectName;
        //使用PUT请求上传对象
        Request httpRequest = builder.url(url).put(RequestBody.create(MediaType.parse(contentType), "Hello OBS".getBytes("UTF-8"))).build();
        OkHttpClient httpClient = new OkHttpClient.Builder().followRedirects(false).retryOnConnectionFailure(false)
                .cache(null).build();
        Call c = httpClient.newCall(httpRequest);
        Response res = c.execute();
        System.out.println("\tStatus:" + res.code());
        if (res.body() != null) {
            System.out.println("\tContent:" + res.body().string() + "\n");
        }
        res.close();
    }
    public static void sign(String method, String url) throws Exception {
        AbstractAuthentication authentication =
                Constants.AUTHTICATION_MAP.get(AuthTypeEnum.OBS);
        String stringToSign = authentication.makeServiceCanonicalString(method, url, headers, null, Constants.ALLOWED_RESOURCE_PARAMTER_NAMES);
        System.out.println("stringToSign: " + stringToSign);
        String auth = "OBS " + ak + ":" + AbstractAuthentication.calculateSignature(stringToSign, sk);
        headers.put("Authorization", auth);
    }
}

代码示例：初始化分段上传任务

通过Header鉴权访问OBS，初始化多段上传任务，上传的桶名为examplebucket，对象为objectName。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
import com.obs.services.internal.Constants;
import com.obs.services.internal.utils.AbstractAuthentication;
import com.obs.services.model.AuthTypeEnum;
import com.obs.services.model.SpecialParamEnum;
import shade.okhttp3.Call;
import shade.okhttp3.MediaType;
import shade.okhttp3.OkHttpClient;
import shade.okhttp3.Request;
import shade.okhttp3.RequestBody;
import shade.okhttp3.Response;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
public class initiateMultipartUpload {
    // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
    //private static String endPoint = System.getenv("ENDPOINT");
    // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    private static String endPoint = "obs.cn-north-4.myhuaweicloud.com";
    private static String ak = System.getenv("ACCESS_KEY_ID");
    private static String sk = System.getenv("SECRET_ACCESS_KEY_ID");
    private static String bucketName = "examplebucket";
    private static String objectName = "objectName";
    private static String contentType = "application/xml";
    private static Map<String, String> headers = new HashMap<>();
    public static void main(String[] args) throws Exception {
        DateFormat dateFormat = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
        dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
        Date now = new Date(System.currentTimeMillis());
        headers.put("x-obs-date", dateFormat.format(now));
        sign("POST", "/" + bucketName + "/" + objectName + "?uploads");
        Request.Builder builder = new Request.Builder();
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            builder.header(entry.getKey(), entry.getValue());
        }
        String url = "https://" + bucketName + "." + endPoint + "/" + objectName + "?uploads";
        //使用POST请求初始化分段上传任务
        Request httpRequest = builder.url(url).post(RequestBody.create(null, "")).build();
        OkHttpClient httpClient = new OkHttpClient.Builder().followRedirects(false).retryOnConnectionFailure(false)
                .cache(null).build();
        Call c = httpClient.newCall(httpRequest);
        Response res = c.execute();
        System.out.println("\tStatus:" + res.code());
        if (res.body() != null) {
            System.out.println("\tContent:" + res.body().string() + "\n");
        }
        res.close();
    }
    public static void sign(String method, String url) throws Exception {
        AbstractAuthentication authentication =
                Constants.AUTHTICATION_MAP.get(AuthTypeEnum.OBS);
        String stringToSign = authentication.makeServiceCanonicalString(method, url, headers, null, Constants.ALLOWED_RESOURCE_PARAMTER_NAMES);
        System.out.println("stringToSign: " + stringToSign);
        String auth = "OBS " + ak + ":" + AbstractAuthentication.calculateSignature(stringToSign, sk);
        headers.put("Authorization", auth);
    }
}

代码示例：上传段

通过Header鉴权访问OBS，将单段上传到桶examplebucket中的对象objectName。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
import com.obs.services.internal.Constants;
import com.obs.services.internal.utils.AbstractAuthentication;
import com.obs.services.model.AuthTypeEnum;
import shade.okhttp3.Call;
import shade.okhttp3.MediaType;
import shade.okhttp3.OkHttpClient;
import shade.okhttp3.Request;
import shade.okhttp3.RequestBody;
import shade.okhttp3.Response;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
public class UploadPart {
    // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
    //private static String endPoint = System.getenv("ENDPOINT");
    // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    private static String endPoint = "obs.cn-north-4.myhuaweicloud.com";
    private static String ak = System.getenv("ACCESS_KEY_ID");
    private static String sk = System.getenv("SECRET_ACCESS_KEY_ID");
    private static String bucketName = "examplebucket";
    private static String objectName = "objectName";
    private static String contentType = "application/xml";
    private static Map<String, String> headers = new HashMap<>();
    public static void main(String[] args) throws Exception {
        DateFormat dateFormat = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
        dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
        Date now = new Date(System.currentTimeMillis());
        headers.put("x-obs-date", dateFormat.format(now));
        sign("PUT", "/" + bucketName + "/" + objectName + "?partNumber=1&uploadId=0000018A0CA7D2144015626C08A6067A");
        Request.Builder builder = new Request.Builder();
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            builder.header(entry.getKey(), entry.getValue());
        }
        String url = "https://" + bucketName + "." + endPoint + "/" + objectName + "?partNumber=1&uploadId=0000018A0CA7D2144015626C08A6067A";
        //使用PUT请求上传对象
        Request httpRequest = builder.url(url).put(RequestBody.create(null, new byte[6 * 1024 * 1024])).build();
        OkHttpClient httpClient = new OkHttpClient.Builder().followRedirects(false).retryOnConnectionFailure(false)
                .cache(null).build();
        Call c = httpClient.newCall(httpRequest);
        Response res = c.execute();
        System.out.println("\tStatus:" + res.code());
        if (res.body() != null) {
            System.out.println("\tContent:" + res.body().string() + "\n");
        }
        res.close();
    }
    public static void sign(String method, String url) throws Exception {
        AbstractAuthentication authentication =
                Constants.AUTHTICATION_MAP.get(AuthTypeEnum.OBS);
        String stringToSign = authentication.makeServiceCanonicalString(method, url, headers, null, Constants.ALLOWED_RESOURCE_PARAMTER_NAMES);
        System.out.println("stringToSign: " + stringToSign);
        String auth = "OBS " + ak + ":" + AbstractAuthentication.calculateSignature(stringToSign, sk);
        headers.put("Authorization", auth);
    }
}

代码示例：合并段

通过Header鉴权访问OBS，实现多段上传时段的合并。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
import com.obs.services.internal.Constants;
import com.obs.services.internal.utils.AbstractAuthentication;
import com.obs.services.model.AuthTypeEnum;
import shade.okhttp3.Call;
import shade.okhttp3.MediaType;
import shade.okhttp3.OkHttpClient;
import shade.okhttp3.Request;
import shade.okhttp3.RequestBody;
import shade.okhttp3.Response;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
public class CompeletePart {
    // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
    //private static String endPoint = System.getenv("ENDPOINT");
    // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    private static String endPoint = "obs.cn-north-4.myhuaweicloud.com";
    private static String ak = System.getenv("ACCESS_KEY_ID");
    private static String sk = System.getenv("SECRET_ACCESS_KEY_ID");
    private static String bucketName = "examplebucket";
    private static String objectName = "objectName";
    private static String contentType = "application/xml";
    private static Map<String, String> headers = new HashMap<>();
    public static void main(String[] args) throws Exception {
        headers.put("Content-Type", contentType);
        DateFormat dateFormat = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
        dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
        Date now = new Date(System.currentTimeMillis());
        headers.put("x-obs-date", dateFormat.format(now));
        sign("POST", "/" + bucketName + "/" + objectName + "?uploadId=0000018A0CA7D2144015626C08A6067A");
        Request.Builder builder = new Request.Builder();
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            builder.header(entry.getKey(), entry.getValue());
        }
        String url = "https://" + bucketName + "." + endPoint + "/" + objectName + "?uploadId=0000018A0CA7D2144015626C08A6067A";
        //使用POST请求初始化分段上传任务
        // 以下content为示例代码，需要通过列举已上传段方法的响应结果，拼装以下内容
        String content = "<CompleteMultipartUpload>";
        content += "<Part>";
        content += "<PartNumber>1</PartNumber>";
        content += "<ETag>da6a0d097e307ac52ed9b4ad551801fc</ETag>";
        content += "</Part>";
        content += "</CompleteMultipartUpload>";
        Request httpRequest = builder.url(url).post(RequestBody.create(MediaType.parse(contentType), content.getBytes("UTF-8"))).build();
        OkHttpClient httpClient = new OkHttpClient.Builder().followRedirects(false).retryOnConnectionFailure(false)
                .cache(null).build();
        Call c = httpClient.newCall(httpRequest);
        Response res = c.execute();
        System.out.println("\tStatus:" + res.code());
        if (res.body() != null) {
            System.out.println("\tContent:" + res.body().string() + "\n");
        }
        res.close();
    }
    public static void sign(String method, String url) throws Exception {
        AbstractAuthentication authentication =
                Constants.AUTHTICATION_MAP.get(AuthTypeEnum.OBS);
        String stringToSign = authentication.makeServiceCanonicalString(method, url, headers, null, Constants.ALLOWED_RESOURCE_PARAMTER_NAMES);
        System.out.println("stringToSign: " + stringToSign);
        String auth = "OBS " + ak + ":" + AbstractAuthentication.calculateSignature(stringToSign, sk);
        headers.put("Authorization", auth);
    }
}

示例代码：下载对象

通过Header鉴权访问OBS，下载examplebucket里的objectName对象。

import com.obs.services.internal.Constants;
import com.obs.services.internal.utils.AbstractAuthentication;
import com.obs.services.model.AuthTypeEnum;
import shade.okhttp3.Call;
import shade.okhttp3.OkHttpClient;
import shade.okhttp3.Request;
import shade.okhttp3.Response;
import java.io.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.time.ZoneId;
import java.time.ZoneOffset;
import java.util.*;

public class Header_Get_Object_test {
    private static String ak = System.getenv("ACCESS_KEY_ID");
    private static String sk = System.getenv("SECRET_ACCESS_KEY_ID");
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
    // 您可以通过环境变量获取访问密钥AK/SK/SecurityToken，也可以使用其他外部引入方式传入。
    private static String securityToken = System.getenv("SECURITY_TOKEN");
    // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
    //private static String endPoint = System.getenv("ENDPOINT");
    // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    private static String endPoint = "obs.cn-north-4.myhuaweicloud.com";
    private static String bucketName = "examplebucket" ;
    private static String objectName = "objectkname";
    private static String contentType = "application/xml";
    private static String method = "GET";
    private static Map<String, String> headers = new HashMap<>();

    public static void main(String[] args) throws Exception { 
        headers.put("Content-Type", contentType);
        DateFormat dateFormat = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
        ZoneId zoneId = ZoneId.ofOffset("UTC", ZoneOffset.ofHours(8));
        TimeZone timeZone = TimeZone.getTimeZone(zoneId);
        dateFormat.setTimeZone(timeZone);
        String now = dateFormat.format(new Date(System.currentTimeMillis()));
        headers.put("x-obs-date", now);
        sign(method, "/" + bucketName + "/" + objectName);
        Request.Builder builder = new Request.Builder();
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            builder.header(entry.getKey(), entry.getValue());
        }
        String url = "https://" + bucketName + "." + endPoint + "/" + objectName ;
        //使用get请求下载对象
        Request httpRequest = builder.url(url).get().build();
        OkHttpClient httpClient =
                new OkHttpClient.Builder()
                        .followRedirects(false)
                        .retryOnConnectionFailure(false)
                        .cache(null)
                        .build();
        Call c = httpClient.newCall(httpRequest);
        Response res = c.execute();
        if (res.code() < 300)
            System.out.println("Status:" + res.code());
            System.out.println("getObject successfully");
        InputStream objectContent = null;
        if (res.body() != null) {
            objectContent = res.body().byteStream();
            System.out.println("Content:" + res.body().string() + "\n");
        }
        if(objectContent != null) {
            // objectContent 就是获取的要下载的文件的文件流
            // 在这里可以读取 objectContent，长时间不读取这个流会被服务端断开连接
        }
        res.close();

    }
    public static void sign(String method, String url) throws Exception {
        AbstractAuthentication authentication =
                Constants.AUTHTICATION_MAP.get(AuthTypeEnum.OBS);
        String stringToSign = authentication.makeServiceCanonicalString(method, url, headers, null, Constants.ALLOWED_RESOURCE_PARAMTER_NAMES);
        System.out.println("stringToSign: " + stringToSign);
        String auth = "OBS " + ak + ":" + AbstractAuthentication.calculateSignature(stringToSign, sk);
        headers.put("Authorization", auth);

    }
}

相关文档