前言

开发中,一般都会单独的分离出一个文件服务器,存储对象存储大容量非结构化的数据,例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等。大部分我们还在用FastDFS,我要吐槽几句它部署麻烦,也没有管理界面,所以我推荐另一个对象存储服务Minio,肯定让你眼前一亮,有种相见恨晚的感觉。

推荐理由

  • 开源免费(是我们考虑的首要元素),高性能
  • 长的好看:有漂亮的界面。
  • 为云环境而生:与k8s、etcd、docker等深度集成。
  • 文档详细:提供了Java、JavaScript、Python、Golang、.Net等各种语言的sdk,集成变得更加容易
  • 部署简单

docker部署

将MiniIO的数据和配置文件夹挂在到宿主机上

docker run -p 9090:9000 --name minio   -e MINIO_ACCESS_KEY=admin -e MINIO_SECRET_KEY=123123123   -v /mydata/minio/data:/data   -v /mydata/minio/config:/root/.minio   -d minio/minio server /data;# 如果不创建用户名密码,默认用户名密码: minioadmin:minioadmin
32afc341032f2a393dd9edb060e8374a.png

访问

4a59b442922c51543e9bcdebd1d6e888.png

springboot 使用minio

1 引入maven

  io.minio      minio      7.0.2

2 配置 application.properties

minio.url= http://192.168.3.189:9090minio.accessKey= adminminio.secretKey= 123123123minio.secure=falseminio.bucketName=testminio.configDir=/home/data/

3 注入属性

@Component@ConfigurationProperties(prefix = "minio")public class MinioConfig {   // "endPoint是一个URL,域名,IPv4或者IPv6地址"    private String url;    //("accessKey类似于用户ID,用于唯一标识你的账户")    private String accessKey;    //("secretKey是你账户的密码")    private String secretKey;    //("如果是true,则用的是https而不是http,默认值是true")    private Boolean secure;    //("默认存储桶")    private String bucketName;    //("配置目录")    private String configDir;    @Bean    public MinioClient getMinioClient() throws InvalidEndpointException, InvalidPortException {        MinioClient minioClient = new MinioClient(url, accessKey, secretKey,secure);        return minioClient;    }public String getBucketName() {return bucketName;}public String getConfigDir() {return configDir;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public String getAccessKey() {return accessKey;}public void setAccessKey(String accessKey) {this.accessKey = accessKey;}public String getSecretKey() {return secretKey;}public void setSecretKey(String secretKey) {this.secretKey = secretKey;}public Boolean getSecure() {return secure;}public void setSecure(Boolean secure) {this.secure = secure;}public void setBucketName(String bucketName) {this.bucketName = bucketName;}public void setConfigDir(String configDir) {this.configDir = configDir;}}

4 创建工具类

@Componentpublic class MinioUtil {    @Autowired    private MinioClient minioClient;    /**            * 上传文件    */    public void uploadFile(InputStream inputStream, String objectName) {    String buckName = "test";        try {        if(!minioClient.bucketExists(buckName)) {        minioClient.makeBucket(buckName);        }        minioClient.putObject(buckName, objectName, inputStream, inputStream.available(), "image/jpeg");        } catch (Exception e) {        e.printStackTrace();        }    }        public void downloadFile(String bucketName, String fileName, String originalName, HttpServletResponse response) {        try {            InputStream file = minioClient.getObject(bucketName, fileName);            String filename = new String(fileName.getBytes("ISO8859-1"), StandardCharsets.UTF_8);            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();        }    }}

5 测试

@RestControllerpublic class GreetingsController {@AutowiredMinioUtil minioUtil;    @RequestMapping(value = "/{name}", method = RequestMethod.GET)    @ResponseStatus(HttpStatus.OK)    public String greetingText(@PathVariable String name,HttpServletResponse response) throws FileNotFoundException {    minioUtil.uploadFile(new FileInputStream(new File("C:甥敳獲ctycDesktop1.jpg")), "test1.jpg");    minioUtil.downloadFile("test", "test1.jpg", "t1.jpg", response);        return "Hello " + name + "!";    }}
c1c5ff686534303d6f9c84021f126b2a.png
53572451b56171276d8fd150e5640c46.png
Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐