| | |
| | | import com.amazonaws.services.s3.AmazonS3; |
| | | import com.amazonaws.services.s3.AmazonS3ClientBuilder; |
| | | import com.amazonaws.services.s3.model.*; |
| | | import com.doumee.core.oss.FileContent; |
| | | import com.doumee.core.oss.FileModel; |
| | | import com.doumee.core.utils.FileDigest; |
| | | |
| | | import java.io.*; |
| | | import java.net.URL; |
| | | import java.time.LocalDate; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | import com.doumee.core.utils.ID; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | |
| | | |
| | | if (inputStream != null) { |
| | | ObjectMetadata metadata = new ObjectMetadata(); |
| | | metadata.setContentLength(inputStream.available()); |
| | | |
| | | PutObjectRequest request = new PutObjectRequest(bucketName, key, inputStream,metadata); |
| | | request.setCannedAcl(CannedAccessControlList.PublicRead); |
| | | PutObjectResult result = client.putObject(request); |
| | | return true; |
| | | } |
| | | }catch (Exception e){ |
| | | log.error("对象存储==================== 网络文件上传失败"+e.getMessage()); |
| | | log.error("对象存储==================== 文件上传失败"+e.getMessage()); |
| | | }finally { |
| | | shutDown(); |
| | | } |