Java調用阿里雲OSS下載文件

參考：https://blog.csdn.net/haiyanghan/article/details/106771047

阿里雲官方指導：https://help.aliyun.com/document_detail/84822.html

1、准備工作

　　具體細節參考https://blog.csdn.net/haiyanghan/article/details/106771047。

2、項目需求

　　我這里只需要根據文件名稱把文件從oss下載下來即可，參考阿里雲官網指導：https://help.aliyun.com/document_detail/84822.html

　　首先需要引入阿里雲的依賴包，如下所示：

<!--阿里雲oss -->
<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.10.2</version>
</dependency>

　　如果只是想將oss文件下載到服務器的磁盤里面，可以使用下面的案例。需要注意的就是OSS的文件目錄下面的文件，指定下載路徑的時候一定要寫正常，不然會報NoSuchKey的異常信息。

package com.controller;

import java.io.File;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.OSSObject;

@Controller
@RequestMapping(value = "/oss")
public class ServiceMattersOSSController {

    // 日志記錄器
    private static final Logger logger = LoggerFactory.getLogger(ServiceMattersOSSController.class);

    // 地域節點
    @Value("${aliyun.oss.file.endpoint}")
    private String endpoint;

    // 創建accesskey生成的keyid
    @Value("${aliyun.oss.file.keyid}")
    private String accessKeyId;

    // 創建accesskey生成的secret
    @Value("${aliyun.oss.file.keysecret}")
    private String accessKeySecret;

    // 創建bucket時輸入的名稱
    @Value("${aliyun.oss.file.bucketname}")
    private String bucketName;

    // 阿里雲OSS規范,Object絕對路徑名前面不需要加斜杠
    @Value("${aliyun.oss.file.folder}")
    private String folder;

    /**
     * 下載文件到本地路徑
     * 
     * fwsx庫的clwj字段取字段。
     * 
     * @param fileName
     */
    @RequestMapping(value = "/downOSSFileLocal")
    @ResponseBody
    public void downOSSFileLocal(String fileName) {
54　　　　  // 創建OSSClient實例
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        OSSObject object = ossClient.getObject(bucketName, folder + fileName);63         // 下載Object到本地文件，並保存到指定的本地路徑中。如果指定的本地文件存在會覆蓋，不存在則新建。
        // 如果未指定本地路徑，則下載后的文件默認保存到示例程序所屬項目對應本地路徑中。
        ossClient.getObject(new GetObjectRequest(bucketName, folder + fileName),
                new File("/data/apache/apache-tomcat-9.0.36/webapps/" + fileName));
        // 關閉OSSClient。
        ossClient.shutdown();70     }

}

　　如果只是想將oss文件響應給前端瀏覽器，可以使用下面的案例。

package com.controller;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.IOException;
import java.io.OutputStream;

import javax.servlet.http.HttpServletResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.OSSObject;

@Controller
@RequestMapping(value = "/oss")
public class ServiceMattersOSSController {

    // 日志記錄器
    private static final Logger logger = LoggerFactory.getLogger(ServiceMattersOSSController.class);

    // 地域節點
    @Value("${aliyun.oss.file.endpoint}")
    private String endpoint;

    // 創建accesskey生成的keyid
    @Value("${aliyun.oss.file.keyid}")
    private String accessKeyId;

    // 創建accesskey生成的secret
    @Value("${aliyun.oss.file.keysecret}")
    private String accessKeySecret;

    // 創建bucket時輸入的名稱
    @Value("${aliyun.oss.file.bucketname}")
    private String bucketName;

    // 阿里雲OSS規范,Object絕對路徑名前面不需要加斜杠
    @Value("${aliyun.oss.file.folder}")
    private String folder;

    /**
     * 下載OSS服務器的文件
     * 
     * @param fileName
     * @param response
     */
    @RequestMapping(value = "/downOSSFile")
    @ResponseBody
    public void downOSSFile(String fileName, HttpServletResponse response) { 59         BufferedInputStream input = null;
        OutputStream outputStream = null;
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); 64         OSSObject ossObject = ossClient.getObject(bucketName, folder + fileName); 68         try {
            response.reset();
            response.setCharacterEncoding("utf-8");
            response.setContentType("application/x-msdownload");
            response.addHeader("Content-Disposition",
                    "attachment;filename=" + new String(fileName.getBytes("gb2312"), "ISO8859-1"));

            input = new BufferedInputStream(ossObject.getObjectContent());
            byte[] buffBytes = new byte[1024];
            outputStream = response.getOutputStream();
            int read = 0;
            while ((read = input.read(buffBytes)) != -1) {
                outputStream.write(buffBytes, 0, read);
            }
            outputStream.flush();
            // 數據讀取完成后，獲取的流必須關閉，否則會造成連接泄漏，導致請求無連接可用，程序無法正常工作。
            ossObject.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            try {
                if (outputStream != null) {
                    outputStream.close();
                }
                if (input != null) {
                    input.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        ossClient.shutdown();101     }


}