pig-mesh / oss-spring-boot-starter Goto Github PK

View Code? Open in Web Editor NEW

237.0 12.0 80.0 66 KB

兼容S3协议的通用文件存储工具类

License: Other

Java 100.00%

oss s3 s3-storage spring-boot

oss-spring-boot-starter's Introduction

oss-spring-boot-starter

兼容S3 协议的通用文件存储工具类，支持兼容S3 协议的云存储

MINIO
阿里云
华为云
腾讯云
京东云

...

spring boot starter依赖

版本	支持
3.0.0	适配 SpringBoot3.x
1.0.5	适配 SpringBoot2.x

方便在 web 环境下使用 oss ，已上传至 maven 仓库

<dependency>
    <groupId>com.pig4cloud.plugin</groupId>
    <artifactId>oss-spring-boot-starter</artifactId>
    <version>${lastVersion}</version>
</dependency>

使用方法

配置文件

oss:
  endpoint: http://minio.pig4cloud.com
  access-key: lengleng
  secret-key: lengleng

代码使用

@Autowired
private OssTemplate template;
/**
 * 上传文件
 * 文件名采用uuid,避免原始文件名中带"-"符号导致下载的时候解析出现异常
 *
 * @param file 资源
 * @return R(bucketName, filename)
 */
@PostMapping("/upload")
public R upload(@RequestParam("file") MultipartFile file, HttpServletRequest request) {
	template.putObject(CommonConstants.BUCKET_NAME, fileName, file.getInputStream());
	return R.ok(resultMap);
}

oss-spring-boot-starter's People

Contributors

Stargazers

Watchers

oss-spring-boot-starter's Issues

示例依赖少写一个d

@Autowired
private MinioTemplate minioTemplate;

请问此仓库使用的是何种开源协议，是否可以改造为个人starter

RT
会保留原作者信息

文件上传到自建minio服务失败

前提：minio服务通过nginx映射，minio的web管理页面可以正常访问。通过minio的web管理页面创建了一个bucket：test
步骤：1、引入本项目依赖，配置minio服务地址、秘钥等信息，配置bucket为test
2、项目注入ossTemplate，调用上传文件方法 putObject

异常堆栈：
com.amazonaws.services.s3.model.AmazonS3Exception: Your previous request to create the named bucket succeeded and you already own it. (Service: Amazon S3; Status Code: 409; Error Code: BucketAlreadyOwnedByYou; Request ID: 163FFBDBC1BF6CB8; S3 Extended Request ID: 01ae3220-608a-4188-83eb-7e50e266f2e7; Proxy: null) , S3 Extended Request ID: 01ae3220-608a-4188-83eb-7e50e266f2e7 at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1828) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleServiceErrorResponse(AmazonHttpClient.java:1412) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1374) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1145) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:802) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:770) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:744) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:704) at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:686) at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:550) at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:530) at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5219) at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5165) at com.amazonaws.services.s3.AmazonS3Client.access$300(AmazonS3Client.java:405) at com.amazonaws.services.s3.AmazonS3Client$PutObjectStrategy.invokeServiceCall(AmazonS3Client.java:6180) at com.amazonaws.services.s3.AmazonS3Client.uploadObject(AmazonS3Client.java:1824) at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1784) at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1722) at com.pig4cloud.plugin.oss.service.OssTemplate.putObject(OssTemplate.java:214) at com.pig4cloud.plugin.oss.service.OssTemplate.putObject(OssTemplate.java:192)

阿里云 OSS 使用 getObjectURL 生成 URL 签名错误问题

配置

oss:
  path-style-access: false
  custom-domain: https://oss-cn-beijing.aliyuncs.com
  access-key: 
  secret-key: 
  bucket-name: lab
  endpoint: oss-cn-beijing.aliyuncs.com

使用

ossTemplate.getObjectURL("lab", "my.docx", Duration.ofDays(1))

生成 URL 直接访问报错信息

<Error>
<Code>SignatureDoesNotMatch</Code>
<Message>The request signature we calculated does not match the signature you provided. Check your key and signing method.</Message>
<RequestId>6112359B1253C53433EDB182</RequestId>
<HostId>lab.oss-cn-beijing.aliyuncs.com</HostId>
<AWSAccessKeyId>access-key</AWSAccessKeyId>
<SignatureProvided>56d64fb1346532e9f303a01e1ac22c3e2c52c430a780fc05151e6c2bb6f9f174</SignatureProvided>
<StringToSign>AWS4-HMAC-SHA256 20210810T081338Z 20210810/us-east-1/s3/aws4_request bf9ed58d81cc063ea3f2ce3d30cd2f084f387e80dc871861197ad364ffd1fb1c</StringToSign>
<StringToSignBytes>41 57 53 34 2D 48 4D 41 43 2D 53 48 41 32 35 36 0A 32 30 32 31 30 38 31 30 54 30 38 31 33 33 38 5A 0A 32 30 32 31 30 38 31 30 2F 75 73 2D 65 61 73 74 2D 31 2F 73 33 2F 61 77 73 34 5F 72 65 71 75 65 73 74 0A 62 66 39 65 64 35 38 64 38 31 63 63 30 36 33 65 61 33 66 32 63 65 33 64 33 30 63 64 32 66 30 38 34 66 33 38 37 65 38 30 64 63 38 37 31 38 36 31 31 39 37 61 64 33 36 34 66 66 64 31 66 62 31 63 </StringToSignBytes>
</Error>

public PutObjectResult putObject(String bucketName, String objectName, InputStream stream, long size,
			String contextType) throws Exception {
		// String fileName = getFileName(objectName);
		byte[] bytes = IOUtils.toByteArray(stream);
		ObjectMetadata objectMetadata = new ObjectMetadata();
		objectMetadata.setContentLength(size);
		objectMetadata.setContentType(contextType);
		ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
		// 上传
		return amazonS3.putObject(bucketName, objectName, byteArrayInputStream, objectMetadata);

	}

byte[] bytes = IOUtils.toByteArray(stream); 超过了最大数组长度限度.
stream 可不处理直接传入S3对象即可.