SpringBoot集成Minio
现在流行的文件服务器基本上有minio,fastdfs,那么今天就说一下minio的安装及集成
安装部署minio
// 首先进入到你的目录
cd /ext/minio
wget https://dl.minio.io/server/minio/release/linux-amd64/minio
//给予可执行
chmod +x minio
//启动
minio server /ext/data
//或
minio server --config-dir=/ext/minio --address=:9000 //ext/data
//安装基本上就这样，启动起来访问一下 http://xxx.xx.xx.xx:9000/minio。一般默认安装的默认用户名密码为：minioadmin/minioadmin
开始和SpringBoot集成
/**
* 文件管理对象 minio_files
* 这里是获取配置文件中的实体信息
* @author xxc
* @date 2020-06-20
*/
public class MinioFiles extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** $column.columnComment */
private Long id;
@Excel(name = "用户id")
private Long userId;
/** 文件路径 */
@Excel(name = "文件路径")
private String backetName;
/** 文件名称 */
@Excel(name = "文件名称")
private String fileName;
/** 文件大小 */
@Excel(name = "文件大小")
private Long fileSize;
/** 文件后缀 */
@Excel(name = "文件后缀")
private String fileSuffix;
/** 删除标志（0代表存在 2代表删除） */
private String delFlag;
/** 文件类型 */
@Excel(name = "文件类型")
private String fileType;
@Excel(name = "文件原名")
private String fileOriginalName;
private String userName;
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getFileOriginalName() {
return fileOriginalName;
}
public void setFileOriginalName(String fileOriginalName) {
this.fileOriginalName = fileOriginalName;
}
public Long getUserId() {
return userId;
}
public void setUserId(Long userId) {
this.userId = userId;
}
public void setId(Long id)
{
this.id = id;
}
public Long getId()
{
return id;
}
public void setBacketName(String backetName)
{
this.backetName = backetName;
}
public String getBacketName()
{
return backetName;
}
public void setFileName(String fileName)
{
this.fileName = fileName;
}
public String getFileName()
{
return fileName;
}
public void setFileSize(Long fileSize)
{
this.fileSize = fileSize;
}
public Long getFileSize()
{
return fileSize;
}
public void setFileSuffix(String fileSuffix)
{
this.fileSuffix = fileSuffix;
}
public String getFileSuffix()
{
return fileSuffix;
}
public void setDelFlag(String delFlag)
{
this.delFlag = delFlag;
}
public String getDelFlag()
{
return delFlag;
}
public void setFileType(String fileType)
{
this.fileType = fileType;
}
public String getFileType()
{
return fileType;
}
@Override
public String toString() {
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId()).append("userId", getUserId())
.append("createBy", getCreateBy())
.append("backetName", getBacketName())
.append("fileName", getFileName())
.append("fileSize", getFileSize())
.append("fileSuffix", getFileSuffix())
.append("createTime", getCreateTime())
.append("delFlag", getDelFlag())
.append("fileType", getFileType()).append("fileOriginalName", getFileOriginalName())
.toString();
}
}
import io.minio.MinioClient;
import io.minio.PutObjectOptions;
import javax.annotation.PostConstruct;
import javax.servlet.ServletOutputStream;
import java.io.InputStream;
@Component
@Configuration
public class MinIoUtils {
private MinioConfig minIo;
public MinIoUtils(MinioConfig minIo) {
this.minIo = minIo;
}
private MinioClient instance;
@PostConstruct
public void init() {
try {
instance = new MinioClient(minIo.getUrl(),minIo.getAccessKey(),minIo.getSecretKey());
} catch (InvalidPortException e) {
e.printStackTrace();
} catch (InvalidEndpointException e) {
e.printStackTrace();
}
}
/**
* 判断 bucket是否存在
* @param bucketName
* @return
*/
public boolean bucketExists(String bucketName){
try {
return instance.bucketExists(bucketName);
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
/**
* 创建 bucket
* @param bucketName
*/
public void makeBucket(String bucketName){
try {
boolean isExist = instance.bucketExists(bucketName);
if(!isExist) {
instance.makeBucket(bucketName);
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 文件上传
* @param bucketName
* @param objectName
* @param filename
*/
public void putObject(String bucketName, String objectName, String filename){
try {
instance.putObject(bucketName,objectName,filename,null);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 文件上传
* @param bucketName
* @param multipartFile
*/
public void putObject(String bucketName, MultipartFile multipartFile,String filename){
try {
// PutObjectOptions，上传配置(文件大小，内存中文件分片大小)
PutObjectOptions putObjectOptions = new PutObjectOptions(multipartFile.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);
// 文件的ContentType
putObjectOptions.setContentType(multipartFile.getContentType());
instance.putObject(bucketName,filename,multipartFile.getInputStream(),putObjectOptions);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 删除文件
* @param objectName
*/
public boolean removeObject(String objectName){
boolean flag=true;
try {
instance.removeObject(minIo.getBucketName(),objectName);
} catch (Exception e) {
flag=false;
}
return flag;
}
public void downloadFile(String fileName,String originalName, HttpServletResponse response){
try {
InputStream file = instance.getObject(minIo.getBucketName(),fileName);
String filename = new String(fileName.getBytes("ISO8859-1"), StandardCharsets.UTF_8);
if(StringUtils.isNotEmpty(originalName)){
fileName=originalName;
}
response.setHeader("Content-Disposition", "attachment;filename=" + filename);
ServletOutputStream servletOutputStream = response.getOutputStream();
int len;
byte[] buffer = new byte[1024];
while((len=file.read(buffer)) > 0){
servletOutputStream.write(buffer, 0, len);
}
servletOutputStream.flush();
file.close();
servletOutputStream.close();
} catch (ErrorResponseException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
//如果想使用直接注入使用既可以了。
@Service
public class MinioFilesServiceImpl implements IMinioFilesService {
@Autowired
private MinioFilesMapper minioFilesMapper;
@Autowired
private MinIoUtils minIoUtils;
、、、、、、
}
