1 oss笔记记录

基本使用

public class UploadHelper {


    private static final String TAG = "UploadHelper";

    //与个人的存储区域有关
    private String ENDPOINT = "你的END_POINT ";
    //上传仓库名
    private String BUCKET_NAME = "你的BUCKET_NAME ";
    public String OSS_ACCESS_KEY_ID = "你的OSS_ACCESS_KEY_ID";
    public String OSS_ACCESS_KEY_SECRET = "你的OSS_ACCESS_KEY_SECRET";
    // 上传文件目录名称
    public String uploadFilePath = "uploadFilePath";

    public OSSUploadHelperCallback callback;
    private OSS client;
  
    List<String> successPath = new ArrayList<>();

    public UploadHelper() {

    }

    public UploadHelper(String endPoint, String ducketName, String uploadFilePath, String AccessKeyId, String AccessKeySecret) {
        this.ENDPOINT = endPoint;
        this.BUCKET_NAME = ducketName;
        this.OSS_ACCESS_KEY_ID = AccessKeyId;
        this.OSS_ACCESS_KEY_SECRET = AccessKeySecret;
        this.uploadFilePath = uploadFilePath;
        //得到client
        client = getOSSClient();
    }

    private OSS getOSSClient() {
        if (true) {
            OSSLog.enableLog();
        }
        ClientConfiguration conf = new ClientConfiguration();
        conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒
        conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒
        conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个
        conf.setMaxErrorRetry(1); // 失败后最大重试次数，默认2次
        LogUtils.logd(ENDPOINT + "  :  " + OSS_ACCESS_KEY_ID + "  : " + OSS_ACCESS_KEY_SECRET);
        OSSCredentialProvider credentialProvider = new OSSStsTokenCredentialProvider(OSS_ACCESS_KEY_ID, OSS_ACCESS_KEY_SECRET, "");
        return new OSSClient(App.getAppContext(), ENDPOINT, credentialProvider, conf);
    }


    int number;
    /**
     * 多图片上传方法
     * @param paths   需上传文件的路径
     */
    private void uploads(List<String> paths) {
        if (client == null) {
            return;
        }
        successPath.clear();
        number = 1;
        for (String path : paths) {
            // 构造上传请求
            PutObjectRequest request =
                    new PutObjectRequest(BUCKET_NAME,
                            getObjectKey(path), path);
            request.setProgressCallback(new OSSProgressCallback<PutObjectRequest>() {
                @Override
                public void onProgress(PutObjectRequest request, long currentSize, long totalSize) {
//                    LogUtils.logd("currentSize: " + currentSize + " totalSize: " + totalSize);
                }
            });
            // 本地异常如网络异常等
            //  服务异常
            OSSAsyncTask ptask = client.asyncPutObject(request, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
                @Override
                public void onSuccess(PutObjectRequest request, PutObjectResult result) {
                    successPath.add(getAllPath(request.getObjectKey()));
                    if (number == paths.size() && callback != null) {
                        callback.onSuccess(successPath);
                    }
                    number++;
                }

                @Override
                public void onFailure(PutObjectRequest request, ClientException clientException, ServiceException serviceException) {
                    LogUtils.logd("onFailure");
                    if (callback != null) {
                        callback.onFailure(request, clientException, serviceException);
                    }
                    if (clientException != null) {
                        // 本地异常如网络异常等
                        clientException.printStackTrace();
                        LogUtils.logd(clientException.toString());
                    }
                    if (serviceException != null) {
                        //  服务异常
                        LogUtils.logd("ErrorCode" + serviceException.getErrorCode());
                    }
                }

            });
            ptask.waitUntilFinished();

        }
    }

    // 拼接自己服务器的URL
    private String getAllPath(String objectKey) {
        String imageUrl = "";
        if (!TextUtils.isEmpty(objectKey)) {
            int i = objectKey.lastIndexOf("/");
            String substring = objectKey.substring(i + 1, objectKey.length());
            imageUrl = "http://app-linktalk-web.oss-cn-beijing.aliyuncs.com/" + uploadFilePath + substring;
            LogUtils.logd(substring);
            LogUtils.logd(imageUrl);
        }
        return imageUrl;
    }

  
    /**
     * 上传单个文件   (图片,视频,gif,.....)
     *
     * @param path     本地地址
     * @param callback 成功回调
     */
    public void uploadImage(String path, OSSUploadHelperCallback callback) {
        this.callback = callback;
        List<String> strings = new ArrayList<>();
        strings.add(path);
        uploads(strings);
    }

    /**
     * 上传多文件   (图片,视频,gif,.....)
     *
     * @param paths    本地地址
     * @param callback 成功回调
     */
    public void uploadImages(List<String> paths, OSSUploadHelperCallback callback) {
        this.callback = callback;
        uploads(paths);
    }


    /**
     *      获取OssToken    并上传文件
     * @param path     本地地址
     * @param callback 成功回调
     */
    public void uploadImageT(Context context,String path, OSSUploadHelperCallback callback) {
        this.callback = callback;
        OkGo.<BaseRespose<OSSTokenBean>>post(Api.formatUrl("/XinBu/OssValues?user=lianyou-oss&token=5c413c4158db33132824a16e"))
                .tag(context)
                .execute(new DialogCallback<BaseRespose<OSSTokenBean>>(context, false) {
                    @Override
                    public void onSuccess(Response<BaseRespose<OSSTokenBean>> response) {
                        OSSTokenBean ossTokenBean = response.body().data;
                        ENDPOINT = ossTokenBean.getPoint();
                        BUCKET_NAME = ossTokenBean.getDucketName();
                        OSS_ACCESS_KEY_ID = ossTokenBean.getAccessKeyId();
                        OSS_ACCESS_KEY_SECRET = ossTokenBean.getAccessKeySecret();
                        uploadFilePath = ossTokenBean.getUploadFilePath();
                        //得到client
                        client = getOSSClient();
                        List<String> strings = new ArrayList<>();
                        strings.add(path);
                        uploads(strings);
                    }
                });
    }


    /**
     * 取得系统时间
     * @return 时间戳
     */
    private String getDateString() {
        return System.currentTimeMillis() + "";
    }

    /**
     * 返回key
     *
     * @param path 本地路径
     * @return key
     */
    //格式: portrait/201805/sfdsgfsdvsdfdsfs.jpg
    private String getObjectKey(String path) {
        LogUtils.logd(path);
        return String.format(uploadFilePath + "%s." + getFormatName(path), getDateString());
    }

    /**
     * 获取文件格式名
     */
    private  String getFormatName(String fileName) {
        //去掉首尾的空格
        fileName = fileName.trim();
        String s[] = fileName.split("\\.");
        if (s.length >= 2) {
            return s[s.length - 1];
        }
        return "";
    }


    public interface OSSUploadHelperCallback {
        void onSuccess(List<String> allPath);

        void onFailure(PutObjectRequest request, ClientException clientException, ServiceException serviceException);
    }

}