minio+nginx实现图片实时缩略

cd opt/minio
#再执行下面的命令，下载minio文件
wget https://dl.minio.io/server/minio/release/linux-amd64/minio

[root@wlc-node-1 minio]# ./start.sh

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>4.0.0</version>
</dependency>

minio:
  endpoint: http://localhost:9000
  accesskey: xxxxxxx
  secretKey: xxxxxxx

package com.wlc.doc.util.file;
 
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
 
/**
 * minio配置类
 */
@Data
@Component
@ConfigurationProperties(prefix = "minio")
public class MinioProp {
    /**
     * 连接url
     */
    private String endpoint;
    /**
     * 用户名
     */
    private String accesskey;
    /**
     * 密码
     */
    private String secretKey;
}

package com.wlc.doc.util.file;
 
import io.minio.MinioClient;
import io.minio.errors.InvalidEndpointException;
import io.minio.errors.InvalidPortException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * minio的配置 并注入bean  MinioClient
 */
@Configuration
@EnableConfigurationProperties(MinioProp.class)
public class MinioConfiguration {
    @Autowired
    private MinioProp minioProp;
 
    @Bean
    public MinioClient minioClient() throws InvalidPortException, InvalidEndpointException {
        MinioClient  client =new MinioClient(minioProp.getEndpoint(),minioProp.getAccesskey(),minioProp.getSecretKey());
        return  client;
    }
}

package com.wlc.doc.util.file;
 
/**
 * minio的bucket配置类
 */
public class CommonConstants {
    //bucket的名字
    public static final String MINIO_BUCKET="wlcfile";
}

package com.wlc.doc.util.file;
 
import com.google.api.client.util.IOUtils;
import com.wlc.doc.exception.BusinessException;
import io.minio.MinioClient;
import io.minio.ObjectStat;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
 
 
/**
 * 描述: minio的util </br>
 * 时间: 2022-02-26 15:10  </br>
 * 作者：王林冲
 */
@Component
public class MinioUtil {
    @Autowired
    private MinioClient minioClient;
 
    /**
     * 上传文件，
     * @param fileName 文件名
     * @param inputStream 文件输入流
     * @param size 文件大小
     * @param contentType 类型
     * @return String - 路径 = bucket名字 + "/" + 文件名
     */
    public String uploadByInputStream(String fileName, InputStream inputStream, long size, String contentType){
 
        try {
            minioClient.putObject(CommonConstants.MINIO_BUCKET, fileName, inputStream, size, contentType);
            return StringUtils.join(CommonConstants.MINIO_BUCKET, "/", fileName) ;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }finally {
            if (inputStream != null){
                try {
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
 
    /**
     * 上传文件
     * @param file MultipartFile
     * @return
     */
    public String uploadByFile(MultipartFile file) {
 
        if(file==null || file.getSize()==0){
            throw new BusinessException("上传文件不能为空");
        }
        String orgfileName = file.getOriginalFilename();
        orgfileName = orgfileName;
        InputStream in = null;
        try {
            in = file.getInputStream();
            String contentType= file.getContentType();
            minioClient.putObject(CommonConstants.MINIO_BUCKET, orgfileName, in, file.getSize(), contentType);
            return StringUtils.join(CommonConstants.MINIO_BUCKET, "/", orgfileName);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
        finally {
            if (in != null){
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
 
    }
 
    /**
     * 下载
     * @param response
     * @param fileName 文件名
     */
    public void download( HttpServletResponse response, String fileName) {
        InputStream in = null;
        try {
            //获取文件对象 stat原信息
            ObjectStat stat = minioClient.statObject(CommonConstants.MINIO_BUCKET, fileName);
            response.setContentType(stat.contentType());
            in = minioClient.getObject(CommonConstants.MINIO_BUCKET, fileName);
            IOUtils.copy(in, response.getOutputStream());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
 
 
}

@RestController
@RequestMapping("/file")
public class FileController {
 
    @Autowired
    MinioUtil minioUtil;
 
    //上传
    @PostMapping("/minioUpload")
    public String minioUpload(@RequestParam(name = "file",required = false) MultipartFile file, HttpServletRequest request){
        String path = minioUtil.uploadByFile(file);
        return path;
    }
 
    //下载
    @GetMapping("/minioDownload")
    public void minioDownload(String fileName, HttpServletResponse response){
        minioUtil.download(response,fileName);
    }
 
 
}

#user  nobody;
worker_processes  1;


#error_log  logs/error.log;
#error_log  logs/error.log  notice;
#error_log  logs/error.log  info;


#pid        logs/nginx.pid;




events {
    worker_connections  1024;
}




http {
    include       mime.types;
    default_type  application/octet-stream;


    #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
    #                  '$status $body_bytes_sent "$http_referer" '
    #                  '"$http_user_agent" "$http_x_forwarded_for"';


    #access_log  logs/access.log  main;


    sendfile        on;
    #tcp_nopush     on;


    #keepalive_timeout  0;
    keepalive_timeout  65;


    #gzip  on;


    server {
        listen       80;
        server_name  localhost;


        #charset koi8-r;


        #access_log  logs/host.access.log  main;


        location  {
            root   html;
            index  index.html index.htm;
        }


        
    #这段往下为生成缩略图的配置
        location ~ wlcfile/(.+)_([0-9]+)x([0-9]+)\.(JPG|GIF|PNG|JPEG|jpg|gif|png|jpeg) {  
            #设置root的路径，其实就是minio的文件存储路径，相当于cd到/opt/minio进行代码的运行
            root opt/minio;
            set $w $2;
            set $h $3;


            if ($w != "0") {
                rewrite wlcfile/(.+)_(\d+)x(\d+)\.(JPG|GIF|PNG|JPEG|jpg|gif|png|jpeg)$ wlcfile/$1.$4
       break;
            }


            if ($h != "0") {
                rewrite wlcfile/(.+)_(\d+)x(\d+)\.(JPG|GIF|PNG|JPEG|jpg|gif|png|jpeg)$ wlcfile/$1.$4
          break;
            }


            #根据给定的长宽生成缩略图
            image_filter resize $w $h;
            #原图最大50M，要裁剪的图片超过2M返回415错误
            image_filter_buffer 50M;


            try_files wlcfile/$1.$4 $1.jpg;
        }


          
    #这段往下为原图配置
        location ~ wlcfile/(.*)$ { 
            root opt/minio;          
        }      
        #error_page  404              404.html;


        # redirect server error pages to the static page 50x.html
        #
        error_page   500 502 503 504  50x.html;
        location = 50x.html {
            root   html;
        }


       
    }




}

#user  nobody;
worker_processes  1;


#error_log  logs/error.log;
#error_log  logs/error.log  notice;
#error_log  logs/error.log  info;


#pid        logs/nginx.pid;




events {
    worker_connections  1024;
}




http {
    include       mime.types;
    default_type  application/octet-stream;


    #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
    #                  '$status $body_bytes_sent "$http_referer" '
    #                  '"$http_user_agent" "$http_x_forwarded_for"';


    #access_log  logs/access.log  main;


    sendfile        on;
    #tcp_nopush     on;


    #keepalive_timeout  0;
    keepalive_timeout  65;


    #gzip  on;


    server {
        listen       80;
        server_name  localhost;


        #charset koi8-r;


        #access_log  logs/host.access.log  main;


#        location / {
#            root   html;
#            index  index.html index.htm;
#        }
#        




      location /download {
        proxy_pass http://10.100.232.172:80/;
        proxy_set_header Host $http_host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
        proxy_set_header X-NginX-Proxy true;
    }


        #error_page  404              /404.html;


        # redirect server error pages to the static page /50x.html
        #
        error_page   500 502 503 504  /50x.html;
        location = /50x.html {
            root   html;
        }


    }


}