腾讯云COS对象存储

一、腾讯云COS

腾讯云对象存储 COS 是一种存储海量数据的分布式存储服务。COS 提供了多种对象的存储类型：标准存储、低频存储、归档存储。

二、为什么要使用TA

便宜；

个人用户有6个月的免费使用额度50G；

有客户端COSBrowser ，提供图形化操作；

可以设置跨域、防盗链；

可以进行静态网站托管；

支持https访问；

CDN加速，下载速度大幅提高。

以上就是我使用它的原因。

三、开始对接

1、添加SDK

<!-- 腾讯云cos_api -->

<dependency>

    <groupId>com.qcloud</groupId>

    <artifactId>cos_api</artifactId>

    <version>5.4.10</version>

</dependency>

<!-- java开发工具包 https://www.hutool.club/docs/#/ -->

<dependency>

    <groupId>cn.hutool</groupId>

    <artifactId>hutool-all</artifactId>

    <version>4.1.13</version>

</dependency>

2、编写工具类

import cn.hutool.core.exceptions.ValidateException;

import cn.hutool.core.lang.Validator;

import cn.hutool.core.thread.ThreadUtil;

import com.qcloud.cos.COSClient;

import com.qcloud.cos.ClientConfig;

import com.qcloud.cos.auth.BasicCOSCredentials;

import com.qcloud.cos.auth.COSCredentials;

import com.qcloud.cos.exception.CosClientException;

import com.qcloud.cos.model.*;

import com.qcloud.cos.region.Region;

import com.qcloud.cos.transfer.Copy;

import com.qcloud.cos.transfer.Download;

import com.qcloud.cos.transfer.TransferManager;

import com.qcloud.cos.transfer.Upload;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.util.List;

import java.util.concurrent.ExecutorService;

/**

 * 腾讯云对象存储cos帮助类

 *

 * @author lixingwu

 */

public class TxCosUtils {

    /*配置参数自行填写*/

    private static final String APP_ID = "";

    private static final String SECRET_ID = "";

    private static final String SECRET_KEY = "";

    private static final String REGION_NAME = "";

    private TxCosUtils() {

    }

    /**

     * 方法描述：获取cos存储桶客户端.

     * 创建时间：2019-02-27 18:09:46

     *

     * @author "lixingwu"

     */

    private static COSClient getCOSClient() {

        // 1 初始化用户身份信息（secretId, secretKey）。

        COSCredentials cred = new BasicCOSCredentials(SECRET_ID, SECRET_KEY);

        // 2 设置bucket的区域, COS地域的简称请参照 https://cloud.tencent.com/document/product/436/6224

        // clientConfig中包含了设置 region, https(默认 http), 超时, 代理等 set 方法, 使用可参见源码或者接口文档 FAQ 中说明。

        ClientConfig clientConfig = new ClientConfig(new Region(REGION_NAME));

        // 3 生成 cos 客户端。

        return new COSClient(cred, clientConfig);

    }

    /**

     * 方法描述：bucket 的命名规则为{name}-{appid} ，

     * name 仅支持小写字母、数字和 - 的组合，不能超过40字符.

     * 创建时间：2019-02-27 18:09:46

     *

     * @author "lixingwu"

     */

    private static String getBucketName(String bucketName) {

        Validator.validateNotEmpty(bucketName, "bucketName不能为空");

        Validator.validateMatchRegex("^[a-z!-@0-9]+$", bucketName,

                "bucketName仅支持小写字母、数字和 - 的组合");

        if (bucketName.length() > 40) {

            throw new ValidateException("bucketName不能超过40字符");

        }

        return (bucketName + "-" + APP_ID);

    }

    /**

     * 方法描述：创建一个存储桶.

     * 创建时间：2019-02-27 18:09:46

     *

     * @author "lixingwu"

     */

    public static Bucket createBucket(String bucketName) throws CosClientException {

        Bucket bucket = null;

        COSClient client = getCOSClient();

        bucket = createBucket(getBucketName(bucketName));

        //设置存储桶的权限为 公有读私有写

        if (null != bucket) {

            client.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);

        }

        return bucket;

    }

    /**

     * 方法描述：获取存储桶列表.

     * 创建时间：2019-02-27 18:09:46

     *

     * @author "lixingwu"

     */

    public static List<Bucket> listBuckets() throws CosClientException {

        return getCOSClient().listBuckets();

    }

    /**

     * 方法描述：检测存储桶是否存在.

     * 创建时间：2019-02-27 18:09:46

     *

     * @author "lixingwu"

     */

    public static boolean doesBucketExist(String bucketName) throws CosClientException {

        return getCOSClient().doesBucketExist(getBucketName(bucketName));

    }

    /**

     * 方法描述：删除文件.

     * 创建时间：2019-03-05 14:25:08

     * 创建作者：李兴武

     *

     * @param bucketName bucketName

     * @param fileName   文件地址

     * @throws CosClientException the cos client exception

     * @author "lixingwu"

     */

    public static void deleteObject(String bucketName, String fileName)

            throws CosClientException {

        getCOSClient().deleteObject(bucketName, fileName);

    }

    /**

     * 方法描述：获取文件的信息.

     * 创建时间：2019-03-05 14:54:09

     * 创建作者：李兴武

     *

     * @param bucketName bucketName

     * @param fileName   文件地址

     * @return the object metadata

     * @throws CosClientException the cos client exception

     * @author "lixingwu"

     */

    public static ObjectMetadata findObjectMetadata(String bucketName, String fileName)

            throws CosClientException {

        return getCOSClient().getObjectMetadata(getBucketName(bucketName), fileName);

    }

    /**

     * 方法描述：获取一个高级的API TransferManager，项目中应该使用这些接口.

     * 创建时间：2019-03-05 15:35:12

     * 创建作者：李兴武

     *

     * @return the transfer manager

     * @author "lixingwu"

     */

    public static TransferManager cosTransferManager() {

        ExecutorService threadPool = ThreadUtil.newExecutor();

        return new TransferManager(getCOSClient(), threadPool);

    }

    /**

     * 方法描述：上传文件

     * 创建时间：2019-03-05 15:53:54

     * 创建作者：李兴武

     *

     * @param bucketName 存储桶名称

     * @param filePath   文件存储地址

     * @param stream     文件流

     * @return the upload

     * @author "lixingwu"

     */

    public static Upload upload(String bucketName, String filePath, InputStream stream) {

        TransferManager manager = cosTransferManager();

        Upload result = null;

        try {

            result = manager.upload(getBucketName(bucketName), filePath, stream, new ObjectMetadata());

            result.waitForUploadResult();

        } catch (CosClientException | InterruptedException e) {

            e.printStackTrace();

        } finally {

            manager.shutdownNow();

        }

        return result;

    }

    /**

     * 方法描述：下载文件.

     * 创建时间：2019-03-05 16:20:16

     * 创建作者：李兴武

     *

     * @param bucketName 存储桶名称

     * @param filePath   文件存储地址

     * @param destFile   存储到的本地目标文件

     * @return the download

     * @author "lixingwu"

     */

    public static Download download(String bucketName, String filePath, File destFile) {

        TransferManager manager = cosTransferManager();

        Download download = null;

        try {

            download = manager.download(getBucketName(bucketName), filePath, destFile);

            download.waitForCompletion();

        } catch (CosClientException | InterruptedException e) {

            e.printStackTrace();

        } finally {

            manager.shutdownNow();

        }

        return download;

    }

    /**

     * 方法描述：复制文件-不同存储桶.

     * 创建时间：2019-03-05 16:28:11

     * 创建作者：李兴武

     *

     * @param srcBucketName  源存储桶名称

     * @param srcKey         源文件地址

     * @param destBucketName 目标存储桶名称

     * @param destKey        目标件地址

     * @return the copy

     * @author "lixingwu"

     */

    public static Copy copy(String srcBucketName, String srcKey, String destBucketName, String destKey) {

        TransferManager manager = cosTransferManager();

        Copy copy = null;

        try {

            copy = manager.copy(getBucketName(srcBucketName), srcKey, getBucketName(destBucketName), destKey);

            copy.waitForCompletion();

        } catch (CosClientException | InterruptedException e) {

            e.printStackTrace();

        } finally {

            manager.shutdownNow();

        }

        return copy;

    }

    /**

     * 方法描述：复制文件-同存储桶.

     * 创建时间：2019-03-05 16:28:11

     * 创建作者：李兴武

     *

     * @param bucketName 源存储桶名称

     * @param srcKey     源文件地址

     * @param destKey    目标件地址

     * @return the copy

     * @author "lixingwu"

     */

    public static Copy copy(String bucketName, String srcKey, String destKey) {

        return copy(bucketName, srcKey, bucketName, destKey);

    }

    /*测试*/

    public static void main(String[] args) throws IOException {

        // Bucket bucket = TxCosUtils.createBucket("test");

        // List<Bucket> listBuckets = TxCosUtils.listBuckets();

        // boolean test = TxCosUtils.doesBucketExist("web-js-css01");

        // File file = new File("E:\\codeList01.html");

        // BufferedInputStream stream = FileUtil.getInputStream(file);

        // PutObjectResult result = TxCosUtils.putObject("test", "html/codeList01.html", stream);

        // COSObject test = downObject("test", "html/codeList.html");

        // COSObjectInputStream inputStream = test.getObjectContent();

        // ObjectMetadata test = downObject("test", "html/codeList.html", new File("E:\\codeList.xml"));

        // ObjectMetadata metadata = findObjectMetadata("test", "html/codeList.html");

        // CopyObjectResult result = TxCosUtils.copyObject("web-js-css", "css/ch233.min.css", "test", "css/ch233.min.css");

        // CopyObjectResult result = TxCosUtils.copyObject("test", "css/ch233.min.css", "css/ch233.min.css.bak");

        // deleteObject(getBucketName("test"), "html/codeList01.html");

        // 高级API

        // 上传文件

        // File file = new File("E:\\templet.html");

        // BufferedInputStream stream = FileUtil.getInputStream(file);

        // Upload test = TxCosUtils.upload("test", "html/templet.html", stream);

        // Console.log(test);

        // 下载文件

        // Download test = TxCosUtils.download("test", "css/ch233.min.css.bak", new File("E:\\ch233.min.css"));

        // Console.log(test);

        // 复制文件

        // Copy copy = TxCosUtils.copy("web-js-css", "layui/layui.js", "test", "layui/layui.js");

        // Copy copy = TxCosUtils.copy("test", "layui/layui.js", "layui/layui.js.bak");

        // Console.log(copy);

    }

}

巴特西

腾讯云COS对象存储

一、腾讯云COS

二、为什么要使用TA

三、开始对接

1、添加SDK

2、编写工具类

最新文章

热门文章