对象存储服务MinIO快速入门(集成项目的详细过程)_Java

对象存储服务minio

minio简介

minio基于apache license v2.0开源协议的对象存储服务，可以做为云存储的解决方案用来保存海量的图片，视频，文档。由于采用golang实现，服务端可以工作在windows,linux, os x和freebsd上。配置简单，基本是复制可执行程序，单行命令可以运行起来。

minio特点

数据保护

minio使用minio erasure code（纠删码）来防止硬件故障。即便损坏一半以上的driver，但是仍然可以从中恢复。

高性能

作为高性能对象存储，在标准硬件条件下它能达到55gb/s的读、35gb/s的写速率

可扩容

不同minio集群可以组成联邦，并形成一个全局的命名空间，并跨越多个数据中心

sdk支持

基于minio轻量的特点，它得到类似java、python或go等语言的sdk支持

有操作页面

面向用户友好的简单操作界面，非常方便的管理bucket及里面的文件资源

功能简单

这一设计原则让minio不容易出错、更快启动

丰富的api

支持文件资源的分享连接及分享链接的过期策略、存储桶操作、文件列表访问及文件上传下载的基本功能等。

文件变化主动通知

存储桶（bucket）如果发生改变,比如上传对象和删除对象，可以使用存储桶事件通知机制进行监控，并通过以下方式发布出去:amqp、mqtt、elasticsearch、redis、nats、mysql、kafka、webhooks等。

一、安装启动

我采用的是docker安装

docker pull minio/minio

mkdir -p /home/minio/configmkdir -p /home/minio/data

启动容器

docker run -p 9000:9000 -p 9090:9090 \
     --net=host \
     --name minio \
     -d --restart=always \
     -e "minio_access_key=admin" \
     -e "minio_secret_key=admin123456" \
     -v /home/minio/data:/data \
     -v /home/minio/config:/root/.minio \
     minio/minio server \
     /data --console-address ":9090" -address ":9000"

假设我们的服务器地址为http://192.168.200.100:9000，我们在地址栏输入：http://http://192.168.200.100:9000/ 即可进入登录界面。

access key为admin ，secret_key 为admin123456进入系统后可以看到主界面

一、快速入门

创建springboot项目

1 导入依赖

<dependencies>
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-autoconfigure</artifactid>
    </dependency>
    <dependency>
        <groupid>io.minio</groupid>
        <artifactid>minio</artifactid>
        <version>7.1.0</version>
    </dependency>
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter</artifactid>
    </dependency>
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-configuration-processor</artifactid>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-actuator</artifactid>
    </dependency>
</dependencies>

在配置文件中导入

minio:
  accesskey: admin
  secretkey: admin123456
  bucket: text
  endpoint: http://192.168.200.100:9000
  readpath: http://192.168.200.100:9000

2 配置类

minioproperties

@configuration
@data
@configurationproperties(prefix = "minio")
public class minioproperties {
    private string accesskey;
    private string secretkey;
    private string bucket;
    private string endpoint;
    private string readpath;
}

minioclientconfig

@data
@primary
@configuration
public class minioclientconfig {
   @autowired
   private minioproperties minioproperties;
    @bean
    public minioclient buildminioclient(){
        return minioclient
                .builder()
                .credentials(minioproperties.getaccesskey(), minioproperties.getsecretkey())
                .endpoint(minioproperties.getendpoint())
                .build();
    }
}

3 开始业务

controller

@restcontroller
@requestmapping("minio")
public class uploadcontroller {
    @autowired
    private fileservice fileservice;
    @postmapping("/upload")
    public string uploadminio(@requestpart("file") multipartfile file) {
        return fileservice.uploadminio(file);
    }
}

service

public interface fileservice {
    public string uploadminio(multipartfile file) ;
}

serviceimpl

@slf4j
@service
public class fileserviceimpl implements fileservice {
    @autowired
    private minioclient minioclient;
    @autowired
    private minioproperties minioproperties;
    @override
    public string uploadminio(multipartfile file) {
        system.out.println(minioproperties);
        try {
            // 判断桶是否存在
            boolean found = minioclient.bucketexists(bucketexistsargs.builder().bucket(minioproperties.getbucket()).build());
            if (!found) {       // 如果不存在，那么此时就创建一个新的桶
                minioclient.makebucket(makebucketargs.builder().bucket(minioproperties.getbucket()).build());
            } else {  // 如果存在打印信息
                system.out.println("bucket 'daijia' already exists.");
            }
            // 设置存储对象名称
            string extfilename = file.getoriginalfilename().substring(file.getoriginalfilename().lastindexof("."));
            string filename = new simpledateformat("yyyymmdd")
                    .format(new date()) + "/" + uuid.randomuuid().tostring().replace("-" , "") + "." + extfilename;
            putobjectargs putobjectargs = putobjectargs.builder()
                    .bucket(minioproperties.getbucket())
                    .stream(file.getinputstream(), file.getsize(), -1)
                    .object(filename)
                    .build();
            minioclient.putobject(putobjectargs) ;
            return minioproperties.getendpoint() + "/" + minioproperties.getbucket() + "/" + filename ;
        } catch (exception e) {
            e.printstacktrace();
        }
        return "error";
    }
}

4 测试

点击连接，就可以开始下载图片

如果发现图片报错，去控制台把access policy 改成pubilc

完成。

不用web的方式也可以上传图片：

service

public interface filestorageservice {
    /**
     *  上传图片文件
     * @param prefix  文件前缀
     * @param filename  文件名
     * @param inputstream 文件流
     * @return  文件全路径
     */
    public string uploadimgfile(string prefix, string filename,inputstream inputstream);
  	/**
     * 删除文件
     * @param pathurl  文件全路径
     */
    public void delete(string pathurl);
}

serviceimpl

@slf4j
@service
public class miniofilestorageserviceimpl implements filestorageservice {
    @autowired
    private minioclient minioclient;
    @autowired
    private minioproperties minioconfigproperties;
    private final static string separator = "/";
    /**
     *  上传图片文件
     * @param prefix  文件前缀
     * @param filename  文件名
     * @param inputstream 文件流
     * @return  文件全路径
     */
    @override
    public string uploadimgfile(string prefix, string filename, inputstream inputstream) {
        string filepath = builderfilepath(prefix, filename);
        try {
            putobjectargs putobjectargs = putobjectargs.builder()
                    .object(filepath)
                    .contenttype("image/jpg")
                    .bucket(minioconfigproperties.getbucket()).stream(inputstream,inputstream.available(),-1)
                    .build();
            minioclient.putobject(putobjectargs);
            stringbuilder urlpath = new stringbuilder(minioconfigproperties.getreadpath());
            urlpath.append(separator+minioconfigproperties.getbucket());
            urlpath.append(separator);
            urlpath.append(filepath);
            return urlpath.tostring();
        }catch (exception ex){
            log.error("minio put file error.",ex);
            throw new runtimeexception("上传文件失败");
        }
    }
    /**
     * 删除文件
     * @param pathurl  文件全路径
     */
    @override
    public void delete(string pathurl) {
        string key = pathurl.replace(minioconfigproperties.getendpoint()+"/","");
        int index = key.indexof(separator);
        string bucket = key.substring(0,index);
        string filepath = key.substring(index+1);
        // 删除objects
        removeobjectargs removeobjectargs = removeobjectargs.builder().bucket(bucket).object(filepath).build();
        try {
            minioclient.removeobject(removeobjectargs);
        } catch (exception e) {
            log.error("minio remove file error.  pathurl:{}",pathurl);
            e.printstacktrace();
        }
    }
}

测试类：

@springboottest
class miniodemoapplicationtests {
    @autowired
   private miniofilestorageserviceimpl miniofilestorageserviceimpl;
    @test
    void imagefilestorage() throws ioexception {
        string filename = uuid.randomuuid().tostring().replaceall("-", "");
        string path = miniofilestorageserviceimpl.uploadimgfile("text", filename, files.newinputstream(new file("d:\\图片\\1.jpg").topath()));
        system.out.println(path);
    }
    @test
    void deleteimagefile() throws ioexception {
        miniofilestorageserviceimpl.delete("");//这里填上传的文件路径
    }
}

完成。

到此这篇关于对象存储服务minio快速入门(集成项目的详细过程)的文章就介绍到这了,更多相关对象存储服务minio内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！