public abstract class AbstractClient extends com.obs.services.internal.ObsService implements Closeable, IObsClient, IFSClient
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractClient.ActionCallbackWithResult<T> |
Constructor and Description |
---|
AbstractClient() |
createPostSignatureResponse, createTemporarySignatureResponse, createV4TemporarySignature, initThreadPool, recordBulkTaskStatus
createFetchJobImpl, deleteDisPolicyImpl, deleteExtensionPolicyImpl, deleteReadAheadObjectsImpl, getDisPolicyImpl, putDisPolicyImpl, queryExtensionPolicyImpl, queryFetchJobImpl, queryReadAheadObjectsTaskImpl, readAheadObjectsImpl, setExtensionPolicyImpl
listContentSummaryImpl, renameFileImpl, truncateFileImpl, writeFileImpl
appendObjectImpl, modifyObjectImpl, renameObjectImpl, restoreObjectImpl, restoreObjectV2Impl, truncateObjectImpl
abortMultipartUploadImpl, completeMultipartUploadImpl, copyPartImpl, initiateMultipartUploadImpl, listMultipartUploadsImpl, listPartsImpl, uploadPartImpl
copyObjectImpl, deleteObjectImpl, deleteObjectsImpl, doesObjectExistImpl, getObjectAclImpl, getObjectImpl, getObjectImpl, getObjectMetadataImpl, getObjectUrl, putObjectImpl, setObjectAclImpl, setObjectMetadataImpl
deleteBucketCorsImpl, deleteBucketDirectColdAccessImpl, deleteBucketEncryptionImpl, deleteBucketLifecycleConfigurationImpl, deleteBucketReplicationConfigurationImpl, deleteBucketTaggingImpl, deleteBucketWebsiteConfigurationImpl, getBucketAclImpl, getBucketCorsImpl, getBucketDirectColdAccessImpl, getBucketEncryptionImpl, getBucketLifecycleConfigurationImpl, getBucketLoggingConfigurationImpl, getBucketNotificationConfigurationImpl, getBucketQuotaImpl, getBucketReplicationConfigurationImpl, getBucketRequestPaymentImpl, getBucketTaggingImpl, getBucketVersioningImpl, getBucketWebsiteConfigurationImpl, setBucketAclImpl, setBucketCorsImpl, setBucketDirectColdAccessImpl, setBucketEncryptionImpl, setBucketLifecycleConfigurationImpl, setBucketLoggingConfigurationImpl, setBucketNotificationImpl, setBucketQuotaImpl, setBucketReplicationConfigurationImpl, setBucketRequestPaymentImpl, setBucketTaggingImpl, setBucketVersioningImpl, setBucketWebsiteConfigurationImpl
createBucketImpl, deleteBucketImpl, deleteBucketPolicyImpl, getBucketLocationImpl, getBucketMetadataImpl, getBucketPolicyImpl, getBucketStorageInfoImpl, getBucketStoragePolicyImpl, headBucketImpl, listAllBucketsImpl, listObjectsImpl, listVersionsImpl, optionsImpl, setBucketFSStatusImpl, setBucketPolicyImpl, setBucketStorageImpl
transAppendObjectRequest, transConditionCopyHeaders, transConditionGetObjectHeaders, transCopyObjectRequest, transCopyPartRequest, transCreateBucketRequest, transExtensionPermissions, transGetObjectParams, transGetObjectRequest, transInitiateMultipartUploadRequest, transListContentSummaryRequest, transListObjectsRequest, transListVersionsRequest, transModifyObjectRequest, transPutObjectRequest, transRangeHeader, transRestoreObjectResultToRestoreObjectStatus, transSetObjectMetadataRequest, transSseCHeaders, transSseCSourceHeaders, transSseHeaders, transSseKmsHeaders, transUploadPartRequest, transWriteFileRequest
getCredential, prepareRESTHeaderAcl, prepareRESTHeaderAclObject, putAclImpl
build, build, cleanResponseHeaders, createRequestBody, getApiVersion, getHeaderByMethodName, getOptionInfoResult, getSpecialParamForStorageClass, putHeader, setResponseHeaders, setStatusCode, transRequestPaymentHeaders, transRequestPaymentHeaders, verifyResponseContentType, verifyResponseContentTypeForJson
addRequestHeadersToConnection, authorizeHttpRequest, convertHeadersToMap, getApiVersionCache, getFileSystemDelimiter, getIConvertor, getIHeaders, getProviderCredentials, getRestHeaderPrefix, getRestMetadataPrefix, getXmlResponseSaxParser, isAuthTypeNegotiation, performRequest, performRequest, performRequest, performRequestWithoutSignature, performRestDelete, performRestDelete, performRestDelete, performRestDelete, performRestForApiVersion, performRestGet, performRestGet, performRestGetForListBuckets, performRestHead, performRestOptions, performRestPost, performRestPost, performRestPut, performRestPut, renameMetadataKeys, retryRequest, setCanUseStandardHTTPHeaders, setProviderCredentials, setUserHeaders
addRequestParametersToUrlPath, addRequestParametersToUrlPath, getEndpoint, getHttpPort, getHttpsOnly, getHttpsPort, initHttpClient, isCname, isKeepAlive, isPathStyle, setupConnection, setupConnection, setupConnection, shutdown, shutdownImpl
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
abortMultipartUpload, appendObject, completeMultipartUpload, copyObject, copyObject, copyPart, createBucket, createBucket, createBucket, createBucket, deleteBucket, deleteBucket, deleteBucketCors, deleteBucketCors, deleteBucketDirectColdAccess, deleteBucketDirectColdAccess, deleteBucketEncryption, deleteBucketEncryption, deleteBucketLifecycle, deleteBucketLifecycle, deleteBucketPolicy, deleteBucketPolicy, deleteBucketReplication, deleteBucketReplication, deleteBucketTagging, deleteBucketTagging, deleteBucketWebsite, deleteBucketWebsite, deleteObject, deleteObject, deleteObject, deleteObjects, deleteReadAheadObjects, doesObjectExist, doesObjectExist, downloadFile, getBucketAcl, getBucketAcl, getBucketCors, getBucketCors, getBucketDirectColdAccess, getBucketDirectColdAccess, getBucketEncryption, getBucketEncryption, getBucketLifecycle, getBucketLifecycle, getBucketLocation, getBucketLocation, getBucketLocationV2, getBucketLogging, getBucketLogging, getBucketMetadata, getBucketNotification, getBucketNotification, getBucketPolicy, getBucketPolicy, getBucketPolicyV2, getBucketPolicyV2, getBucketQuota, getBucketQuota, getBucketReplication, getBucketReplication, getBucketRequestPayment, getBucketRequestPayment, getBucketStorageInfo, getBucketStorageInfo, getBucketStoragePolicy, getBucketStoragePolicy, getBucketTagging, getBucketTagging, getBucketVersioning, getBucketVersioning, getBucketWebsite, getBucketWebsite, getObject, getObject, getObject, getObjectAcl, getObjectAcl, getObjectAcl, getObjectMetadata, getObjectMetadata, getObjectMetadata, headBucket, headBucket, initiateMultipartUpload, listBuckets, listBucketsV2, listMultipartUploads, listObjects, listObjects, listParts, listVersions, listVersions, listVersions, listVersions, modifyObject, modifyObject, modifyObject, putObject, putObject, putObject, putObject, putObject, putObjects, queryReadAheadObjectsTask, readAheadObjects, renameObject, renameObject, restoreObject, restoreObjects, restoreObjectV2, setBucketAcl, setBucketAcl, setBucketCors, setBucketCors, setBucketDirectColdAccess, setBucketDirectColdAccess, setBucketEncryption, setBucketEncryption, setBucketLifecycle, setBucketLifecycle, setBucketLogging, setBucketLogging, setBucketLoggingConfiguration, setBucketNotification, setBucketNotification, setBucketPolicy, setBucketPolicy, setBucketQuota, setBucketQuota, setBucketReplication, setBucketReplication, setBucketRequestPayment, setBucketRequestPayment, setBucketStoragePolicy, setBucketStoragePolicy, setBucketTagging, setBucketTagging, setBucketVersioning, setBucketVersioning, setBucketWebsite, setBucketWebsite, setObjectAcl, setObjectAcl, setObjectAcl, setObjectMetadata, truncateObject, truncateObject, uploadFile, uploadPart, uploadPart, uploadPart
appendFile, dropFile, dropFolder, getAttribute, getBucketFSStatus, listContentSummary, newBucket, newFile, newFolder, readFile, renameFile, renameFolder, setBucketFSStatus, truncateFile, writeFile
protected void init(String accessKey, String secretKey, String securityToken, ObsConfiguration config)
@Deprecated public String createSignedUrl(HttpMethodEnum method, String bucketName, String objectKey, SpecialParamEnum specialParam, Date expiryTime, Map<String,String> headers, Map<String,Object> queryParams) throws ObsException
method
- Http请求方法bucketName
- 桶名objectKey
- 对象名specialParam
- 特殊操作符expiryTime
- 临时授权的有效截止日期headers
- 头信息queryParams
- 查询参数信息ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常@Deprecated public String createSignedUrl(HttpMethodEnum method, String bucketName, String objectKey, SpecialParamEnum specialParam, long expires, Map<String,String> headers, Map<String,Object> queryParams)
method
- Http请求方法bucketName
- 桶名objectKey
- 对象名specialParam
- 特殊操作符expires
- 临时授权的有效时间,单位:秒,默认值:300headers
- 头信息queryParams
- 查询参数信息ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常@Deprecated public V4TemporarySignatureResponse createV4TemporarySignature(V4TemporarySignatureRequest request)
@Deprecated public V4PostSignatureResponse createV4PostSignature(String acl, String contentType, long expires, String bucketName, String objectKey) throws ObsException
ObsException
@Deprecated public V4PostSignatureResponse createV4PostSignature(long expires, String bucketName, String objectKey) throws ObsException
ObsException
@Deprecated public V4PostSignatureResponse createV4PostSignature(V4PostSignatureRequest request) throws ObsException
ObsException
public TemporarySignatureResponse createTemporarySignature(TemporarySignatureRequest request)
IObsClient
createTemporarySignature
in interface IObsClient
request
- 临时授权访问的请求参数public TemporarySignatureResponse createGetTemporarySignature(String bucketName, String objectKey, String prefix, Date expiryDate, Map<String,String> headers, Map<String,Object> queryParams)
bucketName
- 桶名objectKey
- 对象名prefix
- 对象名前缀expiryDate
- 有效截止日期(ISO 8601 UTC)headers
- 头信息queryParams
- 查询参数信息ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常public TemporarySignatureResponse createGetTemporarySignature(String bucketName, String objectKey, String prefix, long expires, Map<String,String> headers, Map<String,Object> queryParams)
bucketName
- 桶名objectKey
- 对象名prefix
- 对象名前缀expires
- 有效时间(单位:秒)headers
- 头信息queryParams
- 查询参数信息ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常public PostSignatureResponse createPostSignature(String acl, String contentType, long expires, String bucketName, String objectKey) throws ObsException
acl
- 对象的访问权限contentType
- 对象的MIME类型expires
- 有效时间,单位:秒bucketName
- 桶名objectKey
- 对象名ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常public PostSignatureResponse createPostSignature(long expires, String bucketName, String objectKey) throws ObsException
expires
- 有效时间,单位:秒bucketName
- 桶名objectKey
- 对象名ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常public PostSignatureResponse createPostSignature(PostSignatureRequest request) throws ObsException
IObsClient
createPostSignature
in interface IObsClient
request
- 基于V4的浏览器表单授权访问请求参数ObsException
- OBS SDK自定义异常,当调用接口失败、访问OBS失败时抛出该异常protected <T> T doActionWithResult(String action, String bucketName, AbstractClient.ActionCallbackWithResult<T> callback) throws ObsException
ObsException
public void refresh(String accessKey, String secretKey, String securityToken)
IObsClient
refresh
in interface IObsClient
accessKey
- 临时访问密钥中的AKsecretKey
- 临时访问密钥中的SKsecurityToken
- 安全令牌public void close() throws IOException
IObsClient
close
in interface IFSClient
close
in interface IObsClient
close
in interface Closeable
close
in interface AutoCloseable
IOException
- 客户端关闭异常public String base64Md5(InputStream is, long length, long offset) throws NoSuchAlgorithmException, IOException
NoSuchAlgorithmException
IOException
public String base64Md5(InputStream is) throws NoSuchAlgorithmException, IOException
NoSuchAlgorithmException
IOException
Copyright © 2021. All rights reserved.