minio
安装部署
官方文档: http://docs.minio.org.cn/docs
- 下载安装
- 网站地址：https://min.io/download
- 下载地址：https://dl.min.io/server/minio/release/linux-amd64/minio
- 安装和启动：
# 创建data目录 mkdir /minio/data # 添加可执行权限 chmod +x minio # 设置登录minio的 access key,可以在shell中设置 export MINIO_ACCESS_KEY=minioadmin # 设置登录minio的 secret key,可以在shell中设置 export MINIO_SECRET_KEY=minioadmin # 启动 minio ./minio server /minio/data # 修改端口号需要添加 --address=0.0.0.0:9006 参数 ./minio server /minio/data --address=0.0.0.0:9006 >> /minio/info.log 2> error.log - 安装后使用浏览器访问 http://ip:9000
- 设置永久访问策略：
# mc 下载地址：http://dl.minio.org.cn/client/mc/release/linux-amd64/mc # 添加云服务 mc config host add minio http://ip:9000 minioadmin minioadmin # 设置永久访问 mc policy set download minio/{bucketName}
整合java
- 依赖
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>${minio.version}</version>
</dependency>
- 配置
@Component
@ConfigurationProperties(prefix = "minio")
public class MinioProperties {
/**
* 服务器地址
*/
private String endpoint;
/**
* 访问账户
*/
private String accessKey;
/**
* 访问秘钥
*/
private String secretKey;
/**
* 是否启用https，需要服务端配置
*/
private Boolean secure;
}
minio:
endpoint: http://ip:9000
accessKey: accessKey
secretKey: secretKey
secure: false
@Configuration
public class MinioConfig {
@Bean
public MinioClient minioClient(MinioProperties properties) throws InvalidPortException, InvalidEndpointException {
return new MinioClient(properties.getEndpoint(),properties.getAccessKey(),properties.getSecretKey(),properties.getSecure());
}
}
- 工具类
/**
* 上传文件所用操作类
*/
@Component
public class MinioClientOpt {
private static Logger logger = LoggerFactory.getLogger(MinioClientOpt.class);
@Autowired
private MinioClient minioClient;
/**
* 检查bucket是否存在
* @param bucketName
* @return
*/
public boolean bucketExists(String bucketName) {
boolean flag = false;
try {
flag = minioClient.bucketExists(bucketName);
} catch (Exception e) {
logger.error("check bucket is exists",e);
}
return flag;
}
/**
* 创建存储桶
*
* @param bucketName 存储桶名称
*/
public boolean createBucket(String bucketName) {
boolean flag = bucketExists(bucketName);
if (!flag) {
try {
minioClient.makeBucket(bucketName);
} catch (Exception e) {
logger.error("create bucket fail",e);
}
return true;
} else {
return false;
}
}
/**
* 上传文件
* @param bucketName 存储桶名称
* @param objectName 对象名称（对象名称相同会覆盖）
* @param file 上传文件对象
* @param create 是否自动创建bucket
* @return
*/
public String putObject(String bucketName, String objectName, MultipartFile file, boolean create){
boolean exists = bucketExists(bucketName);
if (!exists && create){
createBucket(bucketName);
}
try {
minioClient.putObject(bucketName,objectName,file.getInputStream(),file.getSize(),file.getContentType());
String url = getObjectUrl(bucketName,objectName);
return url;
}catch (Exception e){
logger.error("put object fail",e);
}
return "";
}
/**
* 上传文件
* @param bucketName 存储桶名称
* @param objectName 对象名称（对象名称相同会覆盖）
* @param file 上传文件对象
* @return
*/
public String putObject(String bucketName, String objectName, MultipartFile file){
return putObject(bucketName,objectName,file,false);
}
/**
* 通过InputStream上传对象
*
* @param bucketName 存储桶名称
* @param objectName 存储桶里的对象名称
* @param in 要上传的流
* @return
*/
public void putObject(String bucketName, String objectName, InputStream in) {
boolean flag = bucketExists(bucketName);
if (flag) {
try {
String contentType = new MimetypesFileTypeMap().getContentType(objectName);
minioClient.putObject(bucketName, objectName, in, in.available(), contentType);
}catch (Exception e){
logger.error("put object fail",e);
}
}
}
/**
* 获取对象的元数据
*
* @param bucketName 存储桶名称
* @param objectName 存储桶里的对象名称，如果有前缀如 /2020/abc.file需要将前缀一起传，否则不识别文件
* @return
*/
public ObjectStat statObject(String bucketName, String objectName) {
boolean flag = bucketExists(bucketName);
if (flag) {
ObjectStat statObject = null;
try {
statObject = minioClient.statObject(bucketName, objectName);
} catch (Exception e) {
logger.error("stat object fail",e);
}
return statObject;
}
return null;
}
/**
* 删除一个对象
*
* @param bucketName 存储桶名称
* @param objectName 存储桶里的对象名称
*/
public boolean removeObject(String bucketName, String objectName) {
boolean flag = bucketExists(bucketName);
if (flag) {
try {
minioClient.removeObject(bucketName, objectName);
} catch (Exception e) {
logger.error("remove object fail",e);
}
return true;
}
return false;
}
/**
* 生成一个GET请求的分享链接。
* 失效时间默认是7天。
*
* @param bucketName 存储桶名称
* @param objectName 存储桶里的对象名称
* @param expires 失效时间（以秒为单位），默认是7天，不得大于七天
* @return
*/
public String presignedGetObject(String bucketName, String objectName, Integer expires) {
boolean flag = bucketExists(bucketName);
String url = "";
if (flag) {
try {
if (expires == null){
expires = 604800;
}
url = minioClient.presignedGetObject(bucketName, objectName, expires);
} catch (Exception e) {
logger.error("presigned get object fail",e);
}
}
return url;
}
/**
* 文件访问路径
*
* @param bucketName 存储桶名称
* @param objectName 存储桶里的对象名称
* @return
*/
public String getObjectUrl(String bucketName, String objectName) {
boolean flag = bucketExists(bucketName);
String url = "";
if (flag) {
try {
url = minioClient.getObjectUrl(bucketName, objectName);
} catch (Exception e) {
logger.error("get object url fail",e);
}
}
return url;
}
/**
* 下载存储桶中的文件
* @param bucketName 存储桶名称
* @param objectName 对象名称
* @param originalName 下载文件名称
* @param response
*/
public void downloadFile(String bucketName, String objectName, String originalName, HttpServletResponse response) {
try {
InputStream in = minioClient.getObject(bucketName, objectName);
ObjectStat stat = statObject(bucketName, objectName);
response.setContentType(stat.contentType());
response.setContentLength((int) stat.length());
response.setHeader("Content-disposition", "attachment;filename=" + URLEncoder.encode(originalName,"utf-8"));
IOUtils.copy(in,response.getOutputStream());
} catch (Exception e) {
logger.error("download object fail",e);
}
}
}
