• 腾讯云文件SDK

    安装 SDK

     

    用户可以通过 maven 和源码两种方式安装 Java SDK：

    • maven 安装
      在 maven 工程的 pom.xml 文件中添加相关依赖，内容如下： 
      1. <dependency>
      2.        <groupId>com.qcloud</groupId>
      3.        <artifactId>cos_api</artifactId>
      4.        <version>5.6.89</version>
      5. </dependency>
    • 源码安装
      从 Github XML Java SDK 或 快速下载地址 下载源码，通过 maven 导入。例如 eclipse，依次选择 File > Import > maven > Existing Maven Projects。

    卸载 SDK

    通过删除 pom 依赖或源码即可卸载 SDK。

    开始使用

    正式使用前，先别急着书写第一行代码，请先花两分钟做下面的测试，确保发送的请求能够到达 COS 服务，这可以帮助您确认是否遇到了大部分用户在使用 Java SDK 时碰到的问题。
    下面测试中假设您尝试访问广州地域的 COS 服务。

    使用 ping 测试

    1. [root@VM_centos /data/home/]# ping cos.ap-guangzhou.myqcloud.com
    2. PING cos.ap-guangzhou.myqcloud.com (9.*.*.*) xx(xx) bytes of data.
    3. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=1 ttl=xx time=0.xxx ms
    4. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=2 ttl=xx time=0.xxx ms
    5. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=3 ttl=xx time=0.xxx ms
    6. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=4 ttl=xx time=0.xxx ms
    7. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=5 ttl=xx time=0.xxx ms
    8. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=6 ttl=xx time=0.xxx ms
    9. 64 bytes from 9.*.*.* (9.*.*.*): icmp_seq=7 ttl=xx time=0.xxx ms
    10. ^C
    11. --- cos.ap-guangzhou.myqcloud.com ping statistics ---
    12. x packets transmitted, x received, 0% packet loss, time xxxms
    13. rtt min/avg/max/mdev = 0.xxx/0.xxx/0.xxx/0.xxx ms

    如果显示类似上面结果，则基本网络连通与名字服务都是正常的。如果返回其他异常结果，请优先排查环境网络问题或者联系本地网络管理员，确认全部正常后，再继续下一步。
    如果是在 Windows 下，也可以单击开始 （或快捷键：Win+R）> 运行 （输入 cmd）> 确定（或按 Enter 键），输入命令ping cos.ap-guangzhou.myqcloud.com并回车进行测试。

    使用 curl 测试

    如果使用 HTTP 访问：

    1. [root@VM_centos /data/home/]# curl http://cos.ap-guangzhou.myqcloud.com -v
    2. * About to connect() to cos.ap-guangzhou.myqcloud.com port 80 (#0)
    3. *   Trying 9.*.*.*...
    4. * Connected to cos.ap-guangzhou.myqcloud.com (9.*.*.*) port 80 (#0)
    5. > GET / HTTP/1.1
    6. > User-Agent: curl/*.*.0
    7. > Host: cos.ap-guangzhou.myqcloud.com
    8. > Accept: */*
    9. > 
    10. < HTTP/1.1 403 Forbidden
    11. < Content-Type: application/xml
    12. < Content-Length: XXX
    13. < Connection: keep-alive
    14. < Date: XXX XXX GMT
    15. < Server: tencent-cos
    16. < x-cos-request-id: NWE2MWQ5MjZfMTBhYzM1MGFfMTA5ODVfMTVj****
    17. < 
    18. <?xml version='1.0' encoding='utf-8' ?>
    19. <Error>
    20.         <Code>AccessDenied</Code>
    21.         <Message>Check auth failure because signture empty.</Message>
    22.         <ServerTime>XXX XXX</ServerTime>
    23.         <Resource>cos.ap-guangzhou.myqcloud.com/</Resource>
    24.         <RequestId>NWE2MWQ5MjZfMTBhYzM1MGFfMTA5ODVfMTVj****==</RequestId>    
    25. </Error>
    26.  
    27. * Connection #0 to host cos.ap-guangzhou.myqcloud.com left intact

    如果使用 HTTPS 访问：

    1. [root@VM_centos /data/home/]# curl https://cos.ap-guangzhou.myqcloud.com -vk
    2. * About to connect() to cos.ap-guangzhou.myqcloud.com port 443 (#0)
    3. *   Trying 9.*.*.*...
    4. * Connected to cos.ap-guangzhou.myqcloud.com (9.*.*.*) port 443 (#0)
    5. * Initializing NSS with certpath: XXXX
    6. * skipping SSL peer certificate verification
    7. * SSL connection using ******
    8. * Server certificate:
    9. *       subject: CN=*.*.*.
    10. *       start date: XXX XXX GMT
    11. *       expire date: XXX XXX GMT
    12. *       common name: *.cos.ap-guangzhou.myqcloud.com
    13. *       issuer: XXX
    14. > GET / HTTP/1.1
    15. > User-Agent: curl/*.*.0
    16. > Host: cos.ap-guangzhou.myqcloud.com
    17. > Accept: */*
    18. > 
    19. < HTTP/1.1 403 Forbidden
    20. < Content-Type: application/xml
    21. < Content-Length: XXX
    22. < Connection: keep-alive
    23. < Date: XXX XXX GMT
    24. < Server: tencent-cos
    25. < x-cos-request-id: NWE2MWQ5MjZfMTBhYzM1MGFfMTA5ODVfMTVj****
    26. < 
    27. <?xml version='1.0' encoding='utf-8' ?>
    28. <Error>
    29.         <Code>AccessDenied</Code>
    30.         <Message>Check auth failure because signture empty.</Message>
    31.         <ServerTime>XXX XXX</ServerTime>
    32.         <Resource>cos.ap-guangzhou.myqcloud.com/</Resource>
    33.         <RequestId>NWE2MWQ5MjZfMTBhYzM1MGFfMTA5ODVfMTVj****</RequestId>        
    34. </Error>
    35.  
    36. * Connection #0 to host cos.ap-guangzhou.myqcloud.com left intact

    如果显示类似上面结果，则说明端口连接正常。如果返回其他异常结果，请优先排查环境网络问题或者联系本地网络管理员，确认全部正常后，再继续下一步。
    在 Windows 环境下，某些版本可能需要额外安装 curl 工具才能测试。

    下面为您介绍如何使用 COS Java SDK 完成一个基础操作，例如初始化客户端、创建存储桶、查询存储桶列表、上传对象、查询对象列表、下载对象和删除对象。对于示例中出现的类，在 IDE 中，您可以单击该类，查看该类的所有字段和函数定义，类中有较为详细的注释。

    导入类名

    COS Java SDK 的包名为com.qcloud.cos.*，您可以通过 Eclipse 或者 Intellij 等 IDE 工具，导入程序运行所需要的类。

    初始化客户端

    在执行任何和 COS 服务相关请求之前，都需要先生成 COSClient 类的对象， COSClient 是调用 COS API 接口的对象。

    注意：

    COSClient 是线程安全的类，允许多线程访问同一实例。因为实例内部维持了一个连接池，创建多个实例可能导致程序资源耗尽，请确保程序生命周期内实例只有一个，并在不再需要使用时，调用 shutdown 方法将其关闭。如果需要新建实例，请先将之前的实例关闭。

    若您使用永久密钥初始化 COSClient，可以先在访问管理控制台中的 API 密钥管理 页面获取 APPId、SecretId、SecretKey，使用永久密钥适用于大部分的应用场景，参考示例如下：

    1. // 1 初始化用户身份信息（secretId, secretKey）。
    2. // SECRETID和SECRETKEY请登录访问管理控制台 https://console.cloud.tencent.com/cam/capi 进行查看和管理
    3. String secretId = "SECRETID";
    4. String secretKey = "SECRETKEY";
    5. COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);
    6. // 2 设置 bucket 的地域, COS 地域的简称请参照 https://cloud.tencent.com/document/product/436/6224
    7. // clientConfig 中包含了设置 region, https(默认 http), 超时, 代理等 set 方法, 使用可参见源码或者常见问题 Java SDK 部分。
    8. Region region = new Region("COS_REGION");
    9. ClientConfig clientConfig = new ClientConfig(region);
    10. // 这里建议设置使用 https 协议
    11. // 从 5.6.54 版本开始，默认使用了 https
    12. clientConfig.setHttpProtocol(HttpProtocol.https);
    13. // 3 生成 cos 客户端。
    14. COSClient cosClient = new COSClient(cred, clientConfig);

    您也可以使用临时密钥初始化 COSClient，临时密钥生成和使用可参见 临时密钥生成及使用指引，参考示例如下：

    1. // 1 传入获取到的临时密钥 (tmpSecretId, tmpSecretKey, sessionToken)
    2. String tmpSecretId = "SECRETID";
    3. String tmpSecretKey = "SECRETKEY";
    4. String sessionToken = "TOKEN";
    5. BasicSessionCredentials cred = new BasicSessionCredentials(tmpSecretId, tmpSecretKey, sessionToken);
    6. // 2 设置 bucket 的地域, COS 地域的简称请参阅 https://cloud.tencent.com/document/product/436/6224
    7. // clientConfig 中包含了设置 region, https(默认 http), 超时, 代理等 set 方法, 使用可参阅源码或者常见问题 Java SDK 部分
    8. Region region = new Region("COS_REGION");
    9. ClientConfig clientConfig = new ClientConfig(region);
    10. // 3 生成 cos 客户端
    11. COSClient cosClient = new COSClient(cred, clientConfig);

    ClientConfig 类为配置信息类，主要的成员如下：

    成员名设置方法描述类型
    region构造函数或 set 方法存储桶所在的地域，COS 地域的简称请参见 地域和访问域名 文档Region
    httpProtocolset 方法请求所使用的协议，默认使用 HTTPS 协议与 COS 交互HttpProtocol
    signExpiredset 方法请求签名的有效时间，单位：秒，默认为3600slong
    connectionTimeoutset 方法连接 COS 服务的超时时间，单位：毫秒，默认为30000msint
    socketTimeoutset 方法客户端读取数据的超时时间，单位：毫秒，默认为30000msint
    httpProxyIpset 方法代理服务器的 IPString
    httpProxyPortset 方法代理服务器的端口int

    创建存储桶

    用户确定地域和存储桶名称后，参考如下示例创建存储桶：

    1. String bucket = "examplebucket-1250000000"; //存储桶名称，格式：BucketName-APPID
    2. CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucket);
    3. // 设置 bucket 的权限为 Private(私有读写)、其他可选有 PublicRead（公有读私有写）、PublicReadWrite（公有读写）
    4. createBucketRequest.setCannedAcl(CannedAccessControlList.Private);
    5. try{
    6.     Bucket bucketResult = cosClient.createBucket(createBucketRequest);
    7. } catch (CosServiceException serverException) {
    8.     serverException.printStackTrace();
    9. } catch (CosClientException clientException) {
    10.     clientException.printStackTrace();
    11. }

    查询存储桶列表

    查询用户的存储桶列表，参考示例如下：

    1. List<Bucket> buckets = cosClient.listBuckets();
    2. for (Bucket bucketElement : buckets) {
    3.     String bucketName = bucketElement.getName();
    4.     String bucketLocation = bucketElement.getLocation();
    5. }

    上传对象

    将本地文件或者已知长度的输入流内容上传到 COS，适用于20M以下图片类小文件上传，最大支持上传不超过5GB文件。5GB以上的文件必须使用分块上传或高级 API 接口上传。

    说明：

    高级 API 接口在 com.qcloud.cos.transfer.* 子包下。

    • 若本地文件大部分在20M以上，建议您参考使用高级 API 接口进行上传。
    • 若 COS 上已存在同样 Key 的对象，上传时则会覆盖旧的对象。
    • 若要创建目录对象，请参见 SDK 如何创建目录。
    • 对象键（Key）是对象在存储桶中的唯一标识。例如，在对象的访问域名 examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com/images/picture.jpg 中，对象键为 images/picture.jpg，详情请参见 对象键 的说明。

    上传不超过5GB的文件，参考示例如下：

    1. // 指定要上传的文件
    2. File localFile = new File(localFilePath);
    3. // 指定文件将要存放的存储桶
    4. String bucketName = "examplebucket-1250000000";
    5. // 指定文件上传到 COS 上的路径，即对象键。例如对象键为folder/picture.jpg，则表示将文件 picture.jpg 上传到 folder 路径下
    6. String key = "exampleobject";
    7. PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key, localFile);
    8. PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);

    查询对象列表

    查询存储桶中对象列表，参考示例如下：

    1. // Bucket的命名格式为 BucketName-APPID ，此处填写的存储桶名称必须为此格式
    2. String bucketName = "examplebucket-1250000000";
    3. ListObjectsRequest listObjectsRequest = new ListObjectsRequest();
    4. // 设置bucket名称
    5. listObjectsRequest.setBucketName(bucketName);
    6. // prefix表示列出的object的key以prefix开始
    7. listObjectsRequest.setPrefix("images/");
    8. // deliter表示分隔符, 设置为/表示列出当前目录下的object, 设置为空表示列出所有的object
    9. listObjectsRequest.setDelimiter("/");
    10. // 设置最大遍历出多少个对象, 一次listobject最大支持1000
    11. listObjectsRequest.setMaxKeys(1000);
    12. ObjectListing objectListing = null;
    13. do {
    14.     try {
    15.         objectListing = cosClient.listObjects(listObjectsRequest);
    16.     } catch (CosServiceException e) {
    17.         e.printStackTrace();
    18.         return;
    19.     } catch (CosClientException e) {
    20.         e.printStackTrace();
    21.         return;
    22.     }
    23.     // common prefix表示表示被delimiter截断的路径, 如delimter设置为/, common prefix则表示所有子目录的路径
    24.     List<String> commonPrefixs = objectListing.getCommonPrefixes();
    25.  
    26.     // object summary表示所有列出的object列表
    27.     List<COSObjectSummary> cosObjectSummaries = objectListing.getObjectSummaries();
    28.     for (COSObjectSummary cosObjectSummary : cosObjectSummaries) {
    29.         // 文件的路径key
    30.         String key = cosObjectSummary.getKey();
    31.         // 文件的etag
    32.         String etag = cosObjectSummary.getETag();
    33.         // 文件的长度
    34.         long fileSize = cosObjectSummary.getSize();
    35.         // 文件的存储类型
    36.         String storageClasses = cosObjectSummary.getStorageClass();
    37.     }
    38.  
    39.     String nextMarker = objectListing.getNextMarker();
    40.     listObjectsRequest.setMarker(nextMarker);
    41. } while (objectListing.isTruncated());

    下载对象

    上传对象后，您可以用同样的 key，调用 GetObject 接口将对象下载到本地，也可以生成预签名链接（下载请指定 method 为 GET，详情请参见 预签名 URL），分享到其他终端来进行下载。但如果您的文件设置了私有读权限，那么请注意预签名链接的有效期。
    将文件下载到本地指定路径，参考示例如下：

    1. // Bucket的命名格式为 BucketName-APPID ，此处填写的存储桶名称必须为此格式
    2. String bucketName = "examplebucket-1250000000";
    3. // 指定文件在 COS 上的路径，即对象键。例如对象键为folder/picture.jpg，则表示下载的文件 picture.jpg 在 folder 路径下
    4. String key = "exampleobject";
    5. // 方法1 获取下载输入流
    6. GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, key);
    7. COSObject cosObject = cosClient.getObject(getObjectRequest);
    8. COSObjectInputStream cosObjectInput = cosObject.getObjectContent();
    9. // 下载对象的 CRC64
    10. String crc64Ecma = cosObject.getObjectMetadata().getCrc64Ecma();
    11. // 关闭输入流
    12. cosObjectInput.close();
    13.  
    14. // 方法2 下载文件到本地的路径，例如 D 盘的某个目录
    15. String outputFilePath = "exampleobject";
    16. File downFile = new File(outputFilePath);
    17. getObjectRequest = new GetObjectRequest(bucketName, key);
    18. ObjectMetadata downObjectMeta = cosClient.getObject(getObjectRequest, downFile);

    删除对象

    删除 COS 上指定路径的对象，代码如下：

    1. // Bucket的命名格式为 BucketName-APPID ，此处填写的存储桶名称必须为此格式
    2. String bucketName = "examplebucket-1250000000";
    3. // 指定被删除的文件在 COS 上的路径，即对象键。例如对象键为folder/picture.jpg，则表示删除位于 folder 路径下的文件 picture.jpg
    4. String key = "exampleobject";
    5. cosClient.deleteObject(bucketName, key);

    默认请求重试策略

    使用 SDK 生成的 cosClient 发起的请求，默认已经对响应错误的请求进行了重试。重试规则如下：

    • 重试的次数：默认值为 3，可以通过 clientConfig.setMaxErrorRetry 进行设置。
      如果设置为 0，则所有类型的错误请求都不进行重试。
    • 重试的错误类型：客户端异常中所有的报 IOException 的错误。服务端异常中状态码为 500, 502, 503 504 的错误。

    用户也可以根据自己的需求，设置重试策略。代码如下：

    设置重试次数：

    1. Region region = new Region("COS_REGION");
    2. ClientConfig clientConfig = new ClientConfig(region);
    3. // 设置最大重试次数为 4 次
    4. clientConfig.setMaxErrorRetry = 4;

    设置重试策略：

    1. // 自定义重试策略
    2. public class OnlyIOExceptionRetryPolicy extends RetryPolicy {
    3.     @Override
    4.     public <X extends CosServiceRequest> boolean shouldRetry(CosHttpRequest<X> request,
    5.             HttpResponse response,
    6.             Exception exception,
    7.             int retryIndex) {
    8.         // 如果是客户端的 IOException 异常则重试，否则不重试
    9.         if (exception.getCause() instanceof IOException) {
    10.             return true;
    11.         }
    12.         return false;
    13.     }
    14. }
    15.  
    16. Region region = new Region("COS_REGION");
    17. ClientConfig clientConfig = new ClientConfig(region);
    18. RetryPolicy myRetryPolicy = new OnlyIOExceptionRetryPolicy();
    19. // 设置自定义的重试策略
    20. clientConfig.setRetryPolicy(myRetryPolicy);

    关闭客户端

    关闭 cosClient，并释放 HTTP 连接的后台管理线程，代码如下：

    1. // 关闭客户端(关闭后台线程)
    2. cosClient.shutdown();
  • 相关阅读:
    gpio模拟spi读写寄存器示例代码
    golang waitGroup（1）
    网络协议学习地图分享
    【零基础学Python】后端开发篇 第二十一节--Python Web开发二：Django的安装和运行
    Java模拟双向链表，增删操作
    80211 TIM流量指示图 附C语言实现
    嵌入式系统开发笔记88：认识51微控制器系统架构
    Linux磁盘分区机制及虚拟机扩容案例
    优漫动游设计解决了哪些问题
    linux常用命令
  • 原文地址：https://blog.csdn.net/stone_tomcate/article/details/127772083