Browse Source

Pull request #67: REPORT-76271 修复智能运维->集群配置界面,S3文件仓库无法使用http连接的问题

Merge in PG/plugin-repository-s3 from ~OCEAN.HU/plugin-repository-s3:release/11.0 to release/11.0

* commit '2d554e9a25819e3311a635726964d812f67dd796':
  REPORT-76271 修复智能运维->集群配置界面,S3文件仓库无法使用http连接的问题
release/11.0
Ocean.Hu 3 years ago
parent
commit
4f1873fbfc
  1. 8
      src/main/java/com/fanruan/fs/s3/repository/core/S3ResourceRepository.java

8
src/main/java/com/fanruan/fs/s3/repository/core/S3ResourceRepository.java

@ -47,16 +47,16 @@ public class S3ResourceRepository extends BaseResourceRepository {
BasicAWSCredentials credentials = new BasicAWSCredentials(config.getAccessKeyId(), config.getPassword());
AmazonS3ClientBuilder amazonS3ClientBuilder = AmazonS3ClientBuilder.standard()
.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(config.getEndPoint(), config.getRegion()))
.withCredentials(new AWSStaticCredentialsProvider(credentials));
.withCredentials(new AWSStaticCredentialsProvider(credentials)).disableChunkedEncoding();
if (config.isEnablePathStyleAccess()) {
amazonS3ClientBuilder = amazonS3ClientBuilder.enablePathStyleAccess();
}
ClientConfiguration clientConfiguration = new ClientConfiguration();
if (StringUtils.isNotEmpty(config.getSignerOverride())) {
ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setSignerOverride(config.getSignerOverride());
clientConfiguration.setProtocol(Protocol.HTTP);
amazonS3ClientBuilder = amazonS3ClientBuilder.withClientConfiguration(clientConfiguration);
}
clientConfiguration.setProtocol(Protocol.HTTP);
amazonS3ClientBuilder = amazonS3ClientBuilder.withClientConfiguration(clientConfiguration);
this.s3 = amazonS3ClientBuilder.build();
this.bucket = config.getBucket();
}

Loading…
Cancel
Save