兰宝车间质量管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
AprilWind
2024-10-16 6727f3e6a41aad84235a705b224ed025e7570d7e 
 ruoyi-common/ruoyi-common-oss/src/main/java/org/dromara/common/oss/core/OssClient.java


@@ -15,12 +15,12 @@


import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;


import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;


import software.amazon.awssdk.core.ResponseInputStream;


import software.amazon.awssdk.core.async.AsyncRequestBody;


import software.amazon.awssdk.core.async.AsyncResponseTransformer;


import software.amazon.awssdk.core.async.BlockingInputStreamAsyncRequestBody;


import software.amazon.awssdk.regions.Region;


import software.amazon.awssdk.services.s3.S3AsyncClient;


import software.amazon.awssdk.services.s3.S3Configuration;


import software.amazon.awssdk.services.s3.crt.S3CrtHttpConfiguration;


import software.amazon.awssdk.services.s3.model.GetObjectResponse;


import software.amazon.awssdk.services.s3.model.NoSuchBucketException;


import software.amazon.awssdk.services.s3.model.S3Exception;


@@ -95,6 +95,9 @@


                .minimumPartSizeInBytes(10 * 1025 * 1024L)


                .checksumValidationEnabled(false)


                .forcePathStyle(isStyle)


                .httpConfiguration(S3CrtHttpConfiguration.builder()


                    .connectionTimeout(Duration.ofSeconds(60)) // 设置连接超时


                    .build())


                .build();




            //AWS基于 CRT 的 S3 AsyncClient 实例用作 S3 传输管理器的底层客户端


@@ -178,7 +181,9 @@


                            .key(key)


                            .contentMD5(StringUtils.isNotEmpty(md5Digest) ? md5Digest : null)


                            .contentType(contentType)


                            .acl(getAccessPolicy().getObjectCannedACL())


                            // 用于设置对象的访问控制列表（ACL）。不同云厂商对ACL的支持和实现方式有所不同，


                            // 因此根据具体的云服务提供商，你可能需要进行不同的配置（自行开启，阿里云有acl权限配置，腾讯云没有acl权限配置）


                            //.acl(getAccessPolicy().getObjectCannedACL())


                            .build())


                    .addTransferListener(LoggingTransferListener.create())


                    .source(filePath).build());


@@ -215,7 +220,10 @@


        }


        try {


            // 创建异步请求体（length如果为空会报错）


            BlockingInputStreamAsyncRequestBody body = AsyncRequestBody.forBlockingInputStream(length);


            BlockingInputStreamAsyncRequestBody body = BlockingInputStreamAsyncRequestBody.builder()


                .contentLength(length)


                .subscribeTimeout(Duration.ofSeconds(30))


                .build();




            // 使用 transferManager 进行上传


            Upload upload = transferManager.upload(


@@ -224,7 +232,9 @@


                        y -> y.bucket(properties.getBucketName())


                            .key(key)


                            .contentType(contentType)


                            .acl(getAccessPolicy().getObjectCannedACL())


                            // 用于设置对象的访问控制列表（ACL）。不同云厂商对ACL的支持和实现方式有所不同，


                            // 因此根据具体的云服务提供商，你可能需要进行不同的配置（自行开启，阿里云有acl权限配置，腾讯云没有acl权限配置）


                            //.acl(getAccessPolicy().getObjectCannedACL())


                            .build())


                    .build());