com.aliyun.odps.storage.internal

Class HttpClient

java.lang.Object

com.aliyun.odps.storage.internal.HttpClient

public class HttpClient
extends Object

HTTP client for making requests to the MaxCompute Storage API.

This class provides methods for making HTTP requests to the MaxCompute Storage API, including regular requests, stream uploads, and stream downloads. It handles connection pooling, timeouts, and authentication through a signature interceptor.

This is an internal class and is not intended for public use.

Field Summary

Fields

Modifier and Type	Field and Description
static okhttp3.MediaType	HTML
static okhttp3.MediaType	JSON
static okhttp3.MediaType	OCTET_STREAM

Constructor Summary

Constructors

Constructor and Description
HttpClient(StubSettings settings) Constructs a new HttpClient with the provided settings.

Method Summary

Modifier and Type	Method and Description
HttpResponse	request(okhttp3.Request request) Makes a generic, one-time request (used for metadata operations).
HttpResponse	request(String path, String method, Map<String,String> params, Map<String,String> headers, String body) Makes a generic, one-time request (used for metadata operations).
HttpResponse	requestWithoutRetry(okhttp3.Request request) Makes a generic, one-time request without automatic retry.
void	shutdown()
HttpResponse	streamDownload(String path, String method, Map<String,String> params, Map<String,String> headers, String body) Stream download request (replaces connect + getInputStream).
HttpResponse	streamUpload(String path, String method, Map<String,String> params, Map<String,String> headers, okhttp3.RequestBody requestBody) Uploads data using a stream.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JSON

public static final okhttp3.MediaType JSON

HTML

public static final okhttp3.MediaType HTML

OCTET_STREAM

public static final okhttp3.MediaType OCTET_STREAM

Constructor Detail

HttpClient

public HttpClient(StubSettings settings)

Constructs a new HttpClient with the provided settings.

Parameters:

settings - The settings for configuring the HTTP client

Method Detail

request

public HttpResponse request(okhttp3.Request request)

Makes a generic, one-time request (used for metadata operations).

Parameters:

request - The request

Returns:

The response body as a string

Throws:

MaxStorageException - if the request fails

requestWithoutRetry

public HttpResponse requestWithoutRetry(okhttp3.Request request)

Makes a generic, one-time request without automatic retry.

This method executes the request exactly once without any retry logic. Use this when you need to handle retry logic yourself or when retry is not desired.

Parameters:

request - The request

Returns:

The response body as a string

Throws:

MaxStorageException - if the request fails

request

public HttpResponse request(String path,
                            String method,
                            Map<String,String> params,
                            Map<String,String> headers,
                            String body)

Makes a generic, one-time request (used for metadata operations).

Parameters:

path - The API path

method - The HTTP method

params - The query parameters

headers - The HTTP headers

body - The request body

Returns:

The response body as a string

Throws:

MaxStorageException - if the request fails

streamUpload

public HttpResponse streamUpload(String path,
                                 String method,
                                 Map<String,String> params,
                                 Map<String,String> headers,
                                 okhttp3.RequestBody requestBody)

Uploads data using a stream.

Note: This method does not perform automatic retry. Retry logic should be implemented at the StorageStub layer where the business logic and stream reset capability can be managed.

Parameters:

path - The API path

method - The HTTP method

params - The query parameters

headers - The HTTP headers

Returns:

The response body as a byte array

Throws:

MaxStorageException - if the request fails

streamDownload

public HttpResponse streamDownload(String path,
                                   String method,
                                   Map<String,String> params,
                                   Map<String,String> headers,
                                   String body)

Stream download request (replaces connect + getInputStream).

Parameters:

path - The API path

method - The HTTP method

params - The query parameters

headers - The HTTP headers

body - The request body

Returns:

An InputStream containing the response data. The caller is responsible for closing it!

Throws:

MaxStorageException - if the request fails

shutdown

public void shutdown()