winhc_task/src/main/java/com/winhc/task/util/OssUtils.java

package com.winhc.task.util;


import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.*;

import java.io.BufferedReader;
import java.io.InputStreamReader;

/**
 * @author π
 * @Description:
 * @date 2022/11/14 18:02
 */

public class OssUtils {

    public static OSS ossClient;
    public static String accessKeyId = "LTAI5tDrbWcjKkzTnJXCrwkC";
    public static String accessKeySecret = "AWDvBsQc16AYMszNVRga5ANbzuLowy";
    public static String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
    public static String bucketName = "data-exchange-as";


    public static OSS getOssClient(){
        return new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    }
    public static void main(String[] args) {

        try {
            String objectName = "anshuo/new_company/20221113/new_company.json";
            // 封装GetObject请求。
            GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, objectName);
            // ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流。
            OSSObject ossObject = ossClient.getObject(getObjectRequest);

            BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
            while (true) {
                String line = reader.readLine();
                if (line == null) break;
                System.out.println("\n" + line);
            }

        } catch (Exception ce) {
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            // 关闭OSSClient。
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}