java中上传文件_Java中文件上传下载 --使用Minio
Minio模板類:
@RequiredArgsConstructor
public class MinioTemplate implements InitializingBean {
private final String endpoint;
private final String accessKey;
private final String secretKey;
private MinioClient client;
/**
* 創(chuàng)建bucket
*
* @param bucketName bucket名稱
*/
@SneakyThrows
public void createBucket(String bucketName) {
if (!client.bucketExists(bucketName)) {
client.makeBucket(bucketName);
}
}
/**
* 獲取全部bucket
*
* https://docs.minio.io/cn/java-client-api-reference.html#listBuckets
*/
@SneakyThrows
public List getAllBuckets() {
return client.listBuckets();
}
/**
* 根據(jù)bucketName獲取信息
* @param bucketName bucket名稱
*/
@SneakyThrows
public Optional getBucket(String bucketName) {
return client.listBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();
}
/**
* 根據(jù)bucketName刪除信息
* @param bucketName bucket名稱
*/
@SneakyThrows
public void removeBucket(String bucketName) {
client.removeBucket(bucketName);
}
/**
* 根據(jù)文件前置查詢文件
*
* @param bucketName bucket名稱
* @param prefix 前綴
* @param recursive 是否遞歸查詢
* @return MinioItem 列表
*/
@SneakyThrows
public List getAllObjectsByPrefix(String bucketName, String prefix, boolean recursive) {
List objectList = new ArrayList<>();
Iterable> 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 二進(jìn)制流
*/
@SneakyThrows
public InputStream getObject(String bucketName, String objectName) {
return client.getObject(bucketName, objectName);
}
/**
* 上傳文件
*
* @param bucketName bucket名稱
* @param objectName 文件名稱
* @param stream 文件流
* @throws Exception https://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 https://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 文件名稱
* @throws Exception https://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 https://docs.minio.io/cn/java-client-api-reference.html#removeObject
*/
public void removeObject(String bucketName, String objectName) throws Exception {
client.removeObject(bucketName, objectName);
}
@Override
public void afterPropertiesSet() throws Exception {
Assert.hasText(endpoint, "Minio url 為空");
Assert.hasText(accessKey, "Minio accessKey為空");
Assert.hasText(secretKey, "Minio secretKey為空");
this.client = new MinioClient(endpoint, accessKey, secretKey);
}
文件上傳方法:
public String upload(@RequestParam("file") MultipartFile file) {
String fileName = file.getOriginalFilename();
Map resultMap = new HashMap<>(4);
resultMap.put("bucketName", "bucketName");
resultMap.put("fileName", fileName);
try {
minioTemplate.putObject("bucketName", fileName, file.getInputStream());
} catch (Exception e) {
return "上傳失敗";
}
return "上傳成功";
}文件下載方法:
public void download(String fileName, HttpServletResponse response, HttpServletRequest request) {
String userAgent = request.getHeader("User-Agent");
String[] nameArray = StrUtil.split(fileName, "-");
try (InputStream inputStream = minioTemplate.getObject(nameArray[0], nameArray[1])) {
//解決亂碼
if ( //IE 8 至 IE 10
userAgent.toUpperCase().contains("MSIE") ||
//IE 11
userAgent.contains("Trident/7.0")) {
fileName = java.net.URLEncoder.encode(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");
IoUtil.copy(inputStream, response.getOutputStream());
} catch (Exception e) {
log.error("文件讀取異常", e);
}
}
總結(jié)
以上是生活随笔為你收集整理的java中上传文件_Java中文件上传下载 --使用Minio的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： java dbtype_Java实现数据
- 下一篇： java美元兑换,（Java实现） 美元