Java中⽂件上传下载--使⽤Minio Minio模板类:
@RequiredArgsConstructor
public class MinioTemplate implements InitializingBean {
private final String endpoint;
private final String accessKey;
外贸模板建站private final String secretKey;
private MinioClient client;
/**
浏览器的activex控件* 创建bucket
*
* @param bucketName bucket名称
*/
@SneakyThrows
public void createBucket(String bucketName) {
if (!client.bucketExists(bucketName)) {
client.makeBucket(bucketName);
}
}
/**
* 获取全部bucket
* <p>
* docs.minio.io/cn/java-client-api-reference.html#listBuckets
*/
@SneakyThrows
public List<Bucket> getAllBuckets() {
return client.listBuckets();
}
/**
* 根据bucketName获取信息
* @param bucketName bucket名称
*/
@SneakyThrows
public Optional<Bucket> getBucket(String bucketName) {
return client.listBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();
}
/**
* 根据bucketName删除信息
* @param bucketName bucket名称
*/
@SneakyThrows
public void removeBucket(String bucketName) {
}
/**
* 根据⽂件前置查询⽂件
*
* @param bucketName bucket名称
* @param prefix    前缀
nginx 动态反向代理* @param recursive  是否递归查询
* @return MinioItem 列表
*/
@SneakyThrows
public List<MinioItem> getAllObjectsByPrefix(String bucketName, String prefix, boolean recursive) {
List<MinioItem> objectList = new ArrayList<>();
Iterable<Result<Item>> objectsIterator = client
.
listObjects(bucketName, prefix, recursive);
while (objectsIterator.iterator().hasNext()) {
objectList.add(new MinioItem(objectsIterator.iterator().next().get()));
}
return objectList;
}
/**
* 获取⽂件外链
*
* @param bucketName bucket名称
* @param objectName ⽂件名称
* @param expires    过期时间 <=7
* @return url
*/
@SneakyThrows
public String getObjectURL(String bucketName, String objectName, Integer expires) {
return client.presignedGetObject(bucketName, objectName, expires);
}
/**
* 获取⽂件
*
* @param bucketName bucket名称
* @param objectName ⽂件名称
* @return ⼆进制流
*/
@SneakyThrows
public InputStream getObject(String bucketName, String objectName) {
Object(bucketName, objectName);
}
/**
* 上传⽂件
*
* @param bucketName bucket名称
* @param objectName ⽂件名称
* @param stream    ⽂件流
* @throws Exception docs.minio.io/cn/java-client-api-reference.html#putObject
*/
public void putObject(String bucketName, String objectName, InputStream stream) throws Exception {
client.putObject(bucketName, objectName, stream, stream.available(), "application/octet-stream");
}
/**
* 上传⽂件
*
* @param bucketName  bucket名称
* @param objectName  ⽂件名称
* @param stream      ⽂件流
* @param size        ⼤⼩
* @param contextType 类型
* @throws Exception docs.minio.io/cn/java-client-api-reference.html#putObject
*/
public void putObject(String bucketName, String objectName, InputStream stream, long size, String contextType) throws Exception {      client.putObject(bucketName, objectName, stream, size, contextType);
}
/**
* 获取⽂件信息
*
* @param bucketName bucket名称
* @param objectName ⽂件名称iframe嵌套页面报错
* @throws Exception docs.minio.io/cn/java-client-api-reference.html#statObject
*/
public ObjectStat getObjectInfo(String bucketName, String objectName) throws Exception {
return client.statObject(bucketName, objectName);
}
/**
* 删除⽂件
*
* @param bucketName bucket名称
* @param objectName ⽂件名称
* @throws Exception docs.minio.io/cn/java-client-api-reference.html#removeObject
*/
public void removeObject(String bucketName, String objectName) throws Exception {
}
@Override
public void afterPropertiesSet() throws Exception {
Assert.hasText(endpoint, "Minio url 为空");
Assert.hasText(accessKey, "Minio accessKey为空");
description
Assert.hasText(secretKey, "Minio secretKey为空");
this.client = new MinioClient(endpoint, accessKey, secretKey);
}
⽂件上传⽅法:
public String upload(@RequestParam("file") MultipartFile file) {
String fileName  = OriginalFilename();
Map<String, String> resultMap = new HashMap<>(4);
resultMap.put("bucketName", "bucketName");
resultMap.put("fileName", fileName);
try {
minioTemplate.putObject("bucketName", fileName, InputStream());
  } catch (Exception e) {
java下载过程return "上传失败";
}
return "上传成功";
}
⽂件下载⽅法:
public void download(String fileName, HttpServletResponse response, HttpServletRequest request) {    String userAgent = Header("User-Agent");
String[] nameArray = StrUtil.split(fileName, "-");
try (InputStream inputStream = Object(nameArray[0], nameArray[1])) {
//解决乱码
if ( //IE 8 ⾄ IE 10
//IE 11
fileName = de(nameArray[1], "UTF-8");
} else{
fileName = new String(nameArray[1].getBytes("UTF-8"),"iso-8859-1");
}
response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
response.setContentType("application/force-download");
response.setCharacterEncoding("UTF-8");
} catch (Exception e) {
<("⽂件读取异常", e);
}
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。