从minio中读取文件流进行下载文件-蒲公英云

从minio中读取文件流进行下载文件

蔚落 2023-10-18 09:21 176阅读 0赞

一、获取Minio连接

 public static String minioUrl;    
    public static String minioUsername; 
    public static String minioPassword; 
    @Value("${system.minioUrl}")  
    private String minioUrlTmp;
    @Value("${system.minioUsername}")  
    private String minioUsernameTmp;
    @Value("${system.minioPassword}")  
    private String minioPasswordTmp;
    @PostConstruct  
    public void init() {  
        minioUrl = minioUrlTmp;  
        minioUsername = minioUsernameTmp;
        minioPassword = minioPasswordTmp;
    }  
    public static MinioClient getInstance() {
        if (minioClient == null) {  
            synchronized (FileUtils.class) {  
                if (minioClient == null) {  
                    try {
                        //new FileUtils(); 
                        minioClient = new MinioClient(minioUrl,minioUsername,minioPassword);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }  
            }  
        }  
        return minioClient;  
    }

二、读取文件流

 InputStream in = null;
        OutputStream out = null;
        ExamineFileList examineFileList = examineFileListRepository.findOne(guid);
        MinioClient minioClient = FileUtils.getInstance();
        try {
            in = minioClient.getObject(examineFileList.getFileDirectory(), examineFileList.getFilePath()+examineFileList.getFileNameUuid());
            int len = 0;
            byte[] buffer = new byte[1024];
            out = response.getOutputStream();
            response.reset();
            response.addHeader("Content-Disposition",    
                    " attachment;filename=" + new String(examineFileList.getFileName().getBytes(),"iso-8859-1"));
            response.setContentType("application/octet-stream");
            while ((len = in.read(buffer)) > 0) {
               out.write(buffer, 0, len);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (in != null){
               try {
                  in.close();
               } catch (Exception e) {
                  throw new RuntimeException(e);
               }
            }
            if (out != null) {
               try {
                   out.close();
                } catch (IOException e) {
                   e.printStackTrace();
                }
            }
        }