OCI Java SDK实现自定义REST API请求签名

import com.oracle.bmc.ConfigFileReader;
import com.oracle.bmc.auth.AuthenticationDetailsProvider;
import com.oracle.bmc.auth.ConfigFileAuthenticationDetailsProvider;
import com.oracle.bmc.Region;

import java.io.IOException;

public class OciAuthUtil {

    public static AuthenticationDetailsProvider getAuthenticationDetailsProvider() throws IOException {
        // 假设您的OCI配置文件在默认路径 (~/.oci/config)
        // 并且使用了默认的配置文件profile (DEFAULT)
        // 如果有其他profile，可以指定 ConfigFileReader.parseDefault(profileName)
        ConfigFileReader.ConfigFile config = ConfigFileReader.parseDefault();

        return new ConfigFileAuthenticationDetailsProvider(config);
    }

    public static AuthenticationDetailsProvider getAuthenticationDetailsProvider(String configFilePath, String profile) throws IOException {
        ConfigFileReader.ConfigFile config = ConfigFileReader.parse(configFilePath, profile);
        return new ConfigFileAuthenticationDetailsProvider(config);
    }
}

import com.oracle.bmc.auth.AuthenticationDetailsProvider;
import com.oracle.bmc.http.internal.DefaultRequestSigner;
import com.oracle.bmc.http.internal.HttpRequest;
import com.oracle.bmc.http.internal.RequestTarget;
import com.oracle.bmc.model.BmcException;
import com.oracle.bmc.util.StreamUtils;
import com.oracle.bmc.util.internal.Consumer;
import com.oracle.bmc.util.internal.InternalEndpointUtils;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.util.HashMap;
import java.util.Map;

public class OciRequestSigningExample {

    public static void main(String[] args) {
        try {
            // 1. 获取认证详情提供者
            AuthenticationDetailsProvider provider = OciAuthUtil.getAuthenticationDetailsProvider();

            // 2. 创建请求签名器
            // DefaultRequestSigner是RequestSigner接口的一个实现
            DefaultRequestSigner requestSigner = new DefaultRequestSigner(provider);

            // 3. 构建一个模拟的HttpRequest对象
            // 这是一个OCI SDK内部的HttpRequest，用于演示
            // 实际应用中，您可能需要将您使用的HTTP客户端库的请求对象进行适配
            String endpoint = "https://objectstorage.us-ashburn-1.oraclecloud.com";
            String namespace = "your_namespace"; // 替换为您的对象存储命名空间
            String bucketName = "your_bucket";   // 替换为您的桶名称
            String objectName = "test_object.txt"; // 替换为您的对象名称

            URI uri = URI.create(endpoint + "/n/" + namespace + "/b/" + bucketName + "/o/" + objectName);

            // 假设我们要做一个PUT请求上传一个对象
            String requestBodyContent = "Hello, OCI Object Storage!";
            InputStream requestBodyStream = new ByteArrayInputStream(requestBodyContent.getBytes());
            long contentLength = requestBodyContent.getBytes().length;

            HttpRequest.Builder requestBuilder = HttpRequest.builder()
                    .method(com.oracle.bmc.http.internal.Method.PUT) // HTTP方法
                    .uri(uri) // 请求URI
                    .header("Content-Type", "text/plain") // Content-Type
                    .header("Content-Length", String.valueOf(contentLength)) // Content-Length
                    .body(HttpRequest.Body.fromInputStream(requestBodyStream, contentLength)); // 请求体

            HttpRequest request = requestBuilder.build();

            // 4. 签署请求
            // signRequest方法会修改传入的HttpRequest对象，添加Authorization和Date头部
            // 它返回一个Consumer，用于处理请求体（如果需要计算哈希）
            Consumer<InputStream> bodyConsumer = requestSigner.signRequest(request);

            // 如果请求有body，并且签名需要body的哈希，这里需要消费body流
            // 对于PUT/POST请求，通常需要。对于GET/DELETE，则不需要。
            if (request.getBody().isPresent()) {
                bodyConsumer.accept(request.getBody().get().getInputStream());
            }

            // 5. 获取签署后的头部信息
            Map<String, String> signedHeaders = new HashMap<>();
            request.getHeaders().forEach((key, values) -> {
                // 通常Authorization和Date只有一个值
                if (!values.isEmpty()) {
                    signedHeaders.put(key, values.get(0));
                }
            });

            System.out.println("--- 签署后的请求头部 ---");
            signedHeaders.forEach((key, value) -> System.out.println(key + ": " + value));

            // 您现在可以使用这些signedHeaders中的Authorization和Date头部，
            // 结合您自己的HTTP客户端库来发送请求。
            // 例如，使用Apache HttpClient:
            // HttpPut httpPut = new HttpPut(uri);
            // httpPut.setHeader("Authorization", signedHeaders.get("Authorization"));
            // httpPut.setHeader("Date", signedHeaders.get("Date"));
            // ... 其他headers ...
            // httpPut.setEntity(new StringEntity(requestBodyContent));
            // CloseableHttpClient httpClient = HttpClients.createDefault();
            // CloseableHttpResponse response = httpClient.execute(httpPut);
            // ... 处理响应 ...

        } catch (IOException e) {
            System.err.println("认证或IO错误: " + e.getMessage());
            e.printStackTrace();
        } catch (BmcException e) {
            System.err.println("OCI SDK错误: " + e.getMessage());
            e.printStackTrace();
        } catch (Exception e) {
            System.err.println("未知错误: " + e.getMessage());
            e.printStackTrace();
        }
    }
}