浏览代码

设置s3客户端 连接数

dsx 2 年之前
父节点
当前提交
4c852df27d
共有 1 个文件被更改,包括 7 次插入1 次删除
  1. 7 1
      4dkankan-utils-fyun-s3/src/main/java/com/fdkankan/fyun/s3/config/S3Config.java

+ 7 - 1
4dkankan-utils-fyun-s3/src/main/java/com/fdkankan/fyun/s3/config/S3Config.java

@@ -1,5 +1,6 @@
 package com.fdkankan.fyun.s3.config;
 package com.fdkankan.fyun.s3.config;
 
 
+import com.amazonaws.ClientConfiguration;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.regions.Regions;
 import com.amazonaws.regions.Regions;
@@ -25,7 +26,12 @@ public class S3Config {
     @Bean
     @Bean
     public AmazonS3 amazonS3(){
     public AmazonS3 amazonS3(){
         BasicAWSCredentials awsCreds = new BasicAWSCredentials(fYunFileConfig.getKey(), fYunFileConfig.getSecret());
         BasicAWSCredentials awsCreds = new BasicAWSCredentials(fYunFileConfig.getKey(), fYunFileConfig.getSecret());
-        return AmazonS3ClientBuilder.standard().withCredentials(new AWSStaticCredentialsProvider(awsCreds))
+        ClientConfiguration clientConfiguration = new ClientConfiguration();
+        clientConfiguration.setMaxErrorRetry(4);
+        clientConfiguration.setMaxConnections(100);
+        return AmazonS3ClientBuilder.standard()
+                .withCredentials(new AWSStaticCredentialsProvider(awsCreds))
+                .withClientConfiguration(clientConfiguration)
                 .withRegion(Regions.EU_WEST_2).build();
                 .withRegion(Regions.EU_WEST_2).build();
     }
     }
 }
 }