引入包 | 版本 |
---|---|
jdk | 17 |
spring boot | 3.2.4 |
spring-boot-autoconfigure | 3.2.4 |
spring-boot-starter-web | 3.2.4 |
aws-java-sdk-s3 | 1.12.696 |
jakarta.validation-api | 3.0.2 |
{% tabs tag-hide %}
<dependency>
<groupId>cn.allbs</groupId>
<artifactId>allbs-oss</artifactId>
<version>2.0.2</version>
</dependency>
implementation 'cn.allbs:allbs-oss:2.0.2'
implementation("cn.allbs:allbs-oss:2.0.2")
{% endtabs %}
oss:
endpoint: http://xxx.xxx.xxx.xxx:9000
# 所在地区
region: cn-north-1
# minio账号或者
access-key: adadmin
# 密码
secret-key: 123456778
# 设置一个默认的文件桶,比如不同项目使用同一个文件库,以项目为文件桶分隔
bucket-name: test
@PostMapping("/upload")
public R upload(@RequestParam("file") MultipartFile file, String folder) {
folder = Optional.ofNullable(folder).orElse("folder");
String fileName = file.getOriginalFilename();
// 文件夹不存在创建
Map<String, Object> resultMap = new HashMap<>(4);
resultMap.put("fileName", fileName);
resultMap.put("url", String.format("/%s/%s", folder, fileName));
try {
ossTemplate.createBucket(folder);
ossTemplate.putObject(folder, fileName, file.getInputStream());
// el-upload 展示需要
resultMap.put("name", file.getOriginalFilename());
} catch (Exception e) {
log.error("上传失败", e);
return R.fail(e.getLocalizedMessage());
}
return R.ok(resultMap);
}
@ApiOperation(value = "通过文件名称删除文件管理", notes = "通过文件名称删除文件管理")
@DeleteMapping("/deleteFile")
public R removeById(@RequestParam("name") String name, @RequestParam("folder") String folder) throws Exception {
folder = Optional.ofNullable(folder).orElse("folder");
ossTemplate.removeObject(folder, name);
return R.ok();
}
@GetMapping("/{bucket}/{fileName}")
@ApiOperation(value = "文件读取", notes = "文件读取")
public void file(@PathVariable String bucket, @PathVariable String fileName, HttpServletResponse response) {
try (S3Object s3Object = ossTemplate.getObject(bucket, fileName)) {
response.setContentType("application/octet-stream; charset=UTF-8");
IoUtil.copy(s3Object.getObjectContent(), response.getOutputStream());
} catch (Exception e) {
log.error("文件读取异常: {}", e.getLocalizedMessage());
}
}
@GetMapping("/{bucket}/{fileName}")
@ApiOperation(value = "文件读取", notes = "文件读取")
public R<String> fileUrl(@PathVariable String bucket, @PathVariable String fileName) {
return R.ok(ossTemplate.getObjectURL(bucket, fileName));
}
@GetMapping("/{bucket}/{fileName}")
@ApiOperation(value = "文件读取", notes = "文件读取")
public R<String> fileUrl(@PathVariable String bucket, @PathVariable String fileName) {
// 文件十小时过期示例
return R.ok(ossTemplate.getObjectURL(bucket, fileName, Duration.ofHours(10)));
}
@ApiOperation(value = "批量文件上传", notes = "文件批量上传")
@PostMapping(value = "/fileUpload", headers = "content-type=multipart/form-data")
public R save(@Valid @RequestParam(value = "files") MultipartFile[] files, @RequestParam("folder") String folder) {
if (files.length == 0) {
return R.fail("文件内容不能为空");
}
try {
// 获取文件夹名称
for (MultipartFile file : files) {
ossTemplate.putObject(folder, IdUtil.simpleUUID() + StrUtil.DOT + FileUtil.extName(file.getOriginalFilename()), file.getInputStream());
}
} catch (Exception e) {
return R.fail(e.getLocalizedMessage());
}
return R.ok();
}
可不设置,如果需要一个基础文件夹则设置这个属性