设置镜像回源规则(Java SDK)

本示例用于设置examplebucket桶的镜像回源配置。

import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.mirrorback.MirrorBackCondition;
import com.obs.services.model.mirrorback.MirrorBackHttpHeader;
import com.obs.services.model.mirrorback.MirrorBackHttpHeaderSet;
import com.obs.services.model.mirrorback.MirrorBackPublicSource;
import com.obs.services.model.mirrorback.MirrorBackRedirect;
import com.obs.services.model.mirrorback.MirrorBackSourceEndpoint;
import com.obs.services.model.mirrorback.MirrorBackToSourceConfiguration;
import com.obs.services.model.mirrorback.MirrorBackToSourceRule;
import com.obs.services.model.mirrorback.SetBucketMirrorBackToSourceRequest;
import java.util.Arrays;
import java.util.Collections;
public class SetBucketMirrorBackToSource {
    public static void main(String[] args) {
        // 您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
        // 您可以登录访问管理控制台获取访问密钥AK/SK
        String ak = System.getenv("ACCESS_KEY_ID");
        String sk = System.getenv("SECRET_ACCESS_KEY_ID");
        // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。
        // 您可以通过环境变量获取访问密钥AK/SK/SecurityToken，也可以使用其他外部引入方式传入。
        String securityToken = System.getenv("SECURITY_TOKEN");
        // endpoint填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
        // 您可以通过环境变量获取endPoint，也可以使用其他外部引入方式传入。
        String endPoint = System.getenv("ENDPOINT");
        ObsConfiguration obsConfiguration = new ObsConfiguration();
        obsConfiguration.setEndPoint(endPoint);
        ObsClient obsClient = new ObsClient(ak, sk, securityToken, obsConfiguration);
        try {
            String exampleBucket = "examplebucket";

            // Step 1: 指定触发回源功能的条件
            MirrorBackCondition condition = new MirrorBackCondition();
            // 触发回源功能的错误码，当下载请求返回此错误码时，会触发回源功能
            condition.setHttpErrorCodeReturnedEquals("404");
            // 触发回源功能的对象名前缀，当触发回源的请求里对象名满足此前缀，才会继续执行回源功能
            condition.setObjectKeyPrefixEquals("images/");

            // Step 2【可选】: 指定公共可访问的源端地址
            MirrorBackSourceEndpoint endpoint = new MirrorBackSourceEndpoint();
            // 主源端地址。如果源端为HTTP公共可访问的桶，则此地址为桶域名地址。如果源端为其他云厂商的私有桶，则此地址为区域域名地址
            endpoint.setMaster(Collections.singletonList("https://source-bucket.obs.example.com"));
            // 备源端地址。如果源端为HTTP公共可访问的桶，则此地址为桶域名地址。如果源端为其他云厂商的私有桶，则此地址为区域域名地址
            endpoint.setSlave(Collections.singletonList("https://backup-bucket.obs.example.com"));
            MirrorBackPublicSource publicSource = new MirrorBackPublicSource();
            publicSource.setSourceEndpoint(endpoint);

            // Step 3: 指定HTTP header传递规则
            MirrorBackHttpHeader httpHeader = new MirrorBackHttpHeader();
            // 是否透传全部HTTP header到源端
            httpHeader.setPassAll(false);
            // 指定透传的HTTP header列表
            httpHeader.setPass(Arrays.asList("content-type", "cache-control"));
            // 不允许透传的HTTP header列表
            httpHeader.setRemove(Collections.singletonList("authorization"));
            // 设置透传的HTTP header值列表, set优先级高于remove，pass和passAll
            httpHeader.setSet(Collections.singletonList(
                new MirrorBackHttpHeaderSet("x-custom-header", "custom-value")));

            // Step 4: 指定实现回源功能的相关参数
            MirrorBackRedirect redirect = new MirrorBackRedirect();
            // 委托名。客户通过委托赋予OBS服务“查询用户桶内指定对象是否存在”以及“向用户桶内上传对象”的权限
            redirect.setAgency("your-agency");
            // 公共可访问的源端配置。当源端为公共可访问的资源时，必选。publicSource是sourceEndpoint的父节点
            redirect.setPublicSource(publicSource);
            // 是否携带请求字符串
            redirect.setPassQueryString(true);
            // 是否跟随源站3xx重定向请求获取到资源
            redirect.setMirrorFollowRedirect(false);
            // 指定HTTP header传递规则，即Step 3
            redirect.setMirrorHttpHeader(httpHeader);
            // 替换前缀objectKeyPrefixEquals的字符串。如果去源端下载对象时，需要替换当前的对象名前缀，则修改此项配置
            redirect.setReplaceKeyPrefixWith("backup/");
            // 支持透传的请求方法
            redirect.setMirrorAllowHttpMethod(Arrays.asList("GET", "HEAD"));

            // Step 5: 指定单条回源规则
            MirrorBackToSourceRule rule = new MirrorBackToSourceRule();
            rule.setId("mirror-rule-001");
            // 指定触发回源功能的条件,即Step 1
            rule.setCondition(condition);
            // 实现回源功能的相关参数，即Step 4
            rule.setRedirect(redirect);

            // Step 6: 指定镜像回源规则列表
            MirrorBackToSourceConfiguration policyConfig = new MirrorBackToSourceConfiguration();
            policyConfig.setRules(Collections.singletonList(rule));

            // Step 7: 发送请求
            SetBucketMirrorBackToSourceRequest request =
                new SetBucketMirrorBackToSourceRequest(exampleBucket, policyConfig);
            obsClient.setBucketMirrorBackToSource(request);
            System.out.println("SetBucketMirrorBackToSource successfully");
        } catch (ObsException e) {
            System.out.println("SetBucketMirrorBackToSource 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 (Exception e) {
            System.out.println("SetBucketMirrorBackToSource failed");
            // 其他异常信息打印
            e.printStackTrace();
        }
    }
}