| | |
|---|
| | | StaticCredentialsProvider credentialsProvider = StaticCredentialsProvider.create( |
|---|
| | | AwsBasicCredentials.create(properties.getAccessKey(), properties.getSecretKey())); |
|---|
| | | |
|---|
| | | //MinIO 使用 HTTPS 限制使用域名访问，站点填域名。需要启用路径样式访问 |
|---|
| | | boolean isStyle = !StringUtils.containsAny(properties.getEndpoint(), OssConstant.CLOUD_SERVICE); |
|---|
| | | //使用对象存储服务时要求明确配置访问样式（路径样式或虚拟托管样式）。需要启用路径样式访问 |
|---|
| | | boolean isStyle = true; |
|---|
| | | |
|---|
| | | //创建AWS基于 CRT 的 S3 客户端 |
|---|
| | | this.client = S3AsyncClient.crtBuilder() |
|---|
| | |
|---|
| | | .key(key) |
|---|
| | | .contentMD5(StringUtils.isNotEmpty(md5Digest) ? md5Digest : null) |
|---|
| | | .contentType(contentType) |
|---|
| | | .acl(getAccessPolicy().getObjectCannedACL()) |
|---|
| | | .build()) |
|---|
| | | .addTransferListener(LoggingTransferListener.create()) |
|---|
| | | .source(filePath).build()); |
|---|
| | |
|---|
| | | y -> y.bucket(properties.getBucketName()) |
|---|
| | | .key(key) |
|---|
| | | .contentType(contentType) |
|---|
| | | .acl(getAccessPolicy().getObjectCannedACL()) |
|---|
| | | .build()) |
|---|
| | | .build()); |
|---|
| | | |
|---|
