圖片存儲方案-MinIo

背景

文件存儲是各個系統中必不可少的一部分，比如在電商系統中的商品圖片存儲，基本需求是大容量存儲、快速訪問、縮略圖自動生成，現在有很多雲服務如阿里的oss可以滿足，在這里我們分享基於minio自建圖片存儲方案

minIO簡介：

Minio 是個基於 Golang 編寫的開源對象存儲套件，雖然輕量，卻擁有着不錯的性能。

 

部署：

創建文件

mkdir -p /opt/data/minIO/datadocker 

啟動命令

docker run -d -p 9000:9000 \
  --name minio \
  -v /opt/data/minIO/data:/data \
  -e "MINIO_ACCESS_KEY=root" \
  -e "MINIO_SECRET_KEY=root1234" \
  minio/minio server /data

用戶名：MINIO_ACCESS_KEY （用戶名最低3位） 
密碼： MINIO_SECRET_KEY （密碼最低8位）

詳細見 ： min.io官網

代碼展示：

javashop商城為了更好的對接更多的平台，所以文件上傳功能實現了插件化，降低代碼耦合，也方便二次開發，

文件上傳接口類：

/**
 * 存儲方案參數接口
 */
public interface Uploader {

    /**
     * 配置各個存儲方案的參數
     * @return 參數列表
     */
    List<ConfigItem> definitionConfigItem();

    /**
     * 上傳文件
     * @param input  上傳對象
     * @param scene  業務場景
     * @param config 配置信息
     * @return
     */
    FileVO upload(FileDTO input, String scene, Map config);

    /**
     * 刪除文件
     * @param filePath 文件地址
     * @param config   配置信息
     */
    void deleteFile(String filePath, Map config);

    /**
     * 獲取插件ID
     * @return 插件beanId
     */
    String getPluginId();

    /**
     * 生成縮略圖路徑
     * @param url    原圖片全路徑
     * @param width  需要生成圖片尺寸的寬
     * @param height 需要生成圖片尺寸的高
     * @return 生成的縮略圖路徑
     */
    String getThumbnailUrl(String url, Integer width, Integer height);

    /**
     * 存儲方案是否開啟
     * @return 0 不開啟  1 開啟
     */
    Integer getIsOpen();

    /**
     * 獲取插件名稱
     * @return 插件名稱
     */
    String getPluginName();
}

minIO的插件類

javashop商城 實現 minIO的插件類：

@Component
public class MinIOPlugin implements Uploader {
    /**
     * 獲取配置參數
     */
    @Override
    public List<ConfigItem> definitionConfigItem() {
        List<ConfigItem> list = new ArrayList();

        ConfigItem endpoint = new ConfigItem();
        endpoint.setType("text");
        endpoint.setName("endpoint");
        endpoint.setText("minIO服務地址");

        ConfigItem accessKey = new ConfigItem();
        accessKey.setType("text");
        accessKey.setName("accessKey");
        accessKey.setText("用戶名");

        ConfigItem SecretKey = new ConfigItem();
        SecretKey.setType("text");
        SecretKey.setName("secretKey");
        SecretKey.setText("密鑰");

        list.add(serviceUrl);
        list.add(accessKey);
        list.add(SecretKey);

        return list;
    }

    /**
     * 獲取連接
     */
    public MinioClient getClient(Map config, String scene) throws InvalidPortException, InvalidEndpointException, IOException, InvalidKeyException, NoSuchAlgorithmException, InsufficientDataException, InternalException, NoResponseException, InvalidBucketNameException, XmlPullParserException, ErrorResponseException, RegionConflictException, InvalidObjectPrefixException {
        String accessKeyId = StringUtil.toString(config.get("accessKey"));
        String accessKeySecret = StringUtil.toString(config.get("secretKey"));
        String endpoint = StringUtil.toString(config.get("endpoint"));
        //進行連接
        MinioClient minioClient = new MinioClient(endpoint, accessKeyId, accessKeySecret);
        //如果桶為空
        if (!minioClient.bucketExists(scene)) {
            //創建桶
            minioClient.makeBucket(scene);
            //創建桶的文件為全部可讀
            minioClient.setBucketPolicy(scene, "*", PolicyType.READ_ONLY);
        }
        return minioClient;
    }

    @Override
    public FileVO upload(FileDTO input, String scene, Map config) {
        // 獲取文件后綴
        String ext = input.getExt();
        //生成隨機圖片名
        String picName = UUID.randomUUID().toString().toUpperCase().replace("-", "") + "." + ext;

        MinioClient minioClient = null;
        try {
            //獲取連接
            minioClient = this.getClient(config, scene);
            //文件上傳
            minioClient.putObject(scene, picName, input.getStream(), input.getStream().available(), "image/" + ext);

        } catch (Exception e) {
            throw new ServiceException(SystemErrorCode.E802.code(), "上傳圖片失敗");
        }
        String serviceUrl = StringUtil.toString(config.get("serviceUrl"));
        FileVO file = new FileVO();
        file.setName(picName);
        file.setExt(ext);
        file.setUrl(serviceUrl + "/" + scene + "/" + picName);
        return file;
    }

    @Override
    public void deleteFile(String filePath, Map config) {
        MinioClient minioClient = null;
        String[] split = filePath.split("/");
        String bucketName = "";
        String objectName = "";
        for (int i = 0; i < split.length; i++) {
            if (i == 3) {
                bucketName = split[i];
            }
        }
        if (bucketName.length() > 3) {
            objectName = filePath.substring(filePath.indexOf(bucketName) + bucketName.length() + 1);
        } else {
            throw new ServiceException(SystemErrorCode.E803.code(), "刪除失敗，無法解析路徑");
        }
        try {
            minioClient = this.getClient(config, bucketName);
            minioClient.removeObject(bucketName, objectName);
        } catch (Exception e) {
            throw new ServiceException(SystemErrorCode.E903.code(),"刪除圖片失敗");
        }

    }

    @Override
    public String getPluginId() {
        return "minIOPlugin";
    }

    @Override
    public String getThumbnailUrl(String url, Integer width, Integer height) {
        // 縮略圖全路徑
        String thumbnailPah = url + "_" + width + "x" + height;
        // 返回縮略圖全路徑
        return thumbnailPah;
    }

    @Override
    public Integer getIsOpen() {
        return 0;
    }

    @Override
    public String getPluginName() {
        return "MinIO存儲";
    }
}

文件上傳入口方法：

 /**
     * 文件上傳<br>
     * 接受POST請求<br>
     * 同時支持多擇文件上傳和截圖上傳
     * @param upfile 文件流
     * @return
     * @throws JSONException
     * @throws IOException
     */
    @PostMapping(value = "/")
    @ApiOperation(value = "ueditor文件/圖片上傳")
    public Map upload( MultipartFile upfile) throws JSONException, IOException {
        Map result = new HashMap(16);
        if (upfile != null && upfile.getOriginalFilename() != null) {
            //文件類型
            String contentType= upfile.getContentType();
            //獲取文件名稱后綴
            String ext = contentType.substring(contentType.lastIndexOf("/") + 1, contentType.length());

            if(!FileUtil.isAllowUpImg(ext)){
                result.put("state","不允許上傳的文件格式，請上傳gif,jpg,png,jpeg,mp4格式文件。");
                return  result;
            }
            FileDTO input  = new FileDTO();
            input.setName(upfile.getOriginalFilename());
            input.setStream(upfile.getInputStream());
            input.setExt(ext);
            FileVO file  = this.fileManager.upload(input, "ueditor");
            String url  = file.getUrl();
            String title = file.getName();
            String original = file.getName();
            result.put("state","SUCCESS");
            result.put("url", url);
            result.put("title", title);
            result.put("name", title);
            result.put("original", original);
            result.put("type","."+file.getExt());
            return  result;
        }else{
            result.put("state","沒有讀取要上傳的文件");
            return  result;
        }
    }
}