加速OSS资源远距离上传和下载

1. 登录OSS管理控制台。

2. 单击Bucket 列表，然后单击目标Bucket名称。

3. 在左侧导航栏，选择Bucket 配置>传输加速。

4. 在传输加速页面，打开开启传输加速开关，然后在弹出的对话框单击确定。

   传输加速开启操作会在30分钟内全网生效。关闭传输加速操作也需要在30分钟内全网生效。

以下仅列举常见SDK开启传输加速的代码示例。关于其他SDK的开启传输加速的代码示例，请参见SDK简介。

import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;

public class Demo {

    public static void main(String[] args) throws Exception {
        // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // 填写Bucket名称，例如examplebucket。
        String bucketName = "examplebucket";
        // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
        String region = "cn-hangzhou";

        // 创建OSSClient实例。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);        
        OSS ossClient = OSSClientBuilder.create()
        .endpoint(endpoint)
        .credentialsProvider(credentialsProvider)
        .clientConfiguration(clientBuilderConfiguration)
        .region(region)               
        .build();

        try {
            // 设置Bucket的传输加速状态。
            // 当设置enabled为true时，表示开启传输加速；当设置enabled为false时，表示关闭传输加速。
            boolean enabled = true;
            ossClient.setBucketTransferAcceleration(bucketName, enabled);

        } catch (OSSException oe) {
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
                    + "but was rejected with an error response for some reason.");
            System.out.println("Error Message:" + oe.getErrorMessage());
            System.out.println("Error Code:" + oe.getErrorCode());
            System.out.println("Request ID:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Caught an ClientException, which means the client encountered "
                    + "a serious internal problem while trying to communicate with OSS, "
                    + "such as not being able to access the network.");
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider

# 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
auth = oss2.ProviderAuthV4(EnvironmentVariableCredentialsProvider())

# 填写Bucket所在地域对应的Endpoint。以华东1（杭州）为例，Endpoint填写为https://oss-cn-hangzhou.aliyuncs.com。
endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
# 填写Endpoint对应的Region信息，例如cn-hangzhou。注意，v4签名下，必须填写该参数
region = "cn-hangzhou"

# examplebucket填写存储空间名称。
bucket = oss2.Bucket(auth, endpoint, "examplebucket", region=region)

# 设置Bucket的传输加速状态。
# 当设置enabled为true时，表示开启传输加速；当设置enabled为false时，表示关闭传输加速。
enabled = 'true'
bucket.put_bucket_transfer_acceleration(enabled)

package main

import (
	"context"
	"flag"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

// 定义全局变量
var (
	region     string // 存储区域
	bucketName string // 存储空间名称
)

// init函数用于初始化命令行参数
func init() {
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}

func main() {
	// 解析命令行参数
	flag.Parse()

	// 检查bucket名称是否为空
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	// 检查region是否为空
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}

	// 加载默认配置并设置凭证提供者和区域
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	// 创建OSS客户端
	client := oss.NewClient(cfg)

	// 创建设置存储空间传输加速的请求
	request := &oss.PutBucketTransferAccelerationRequest{
		Bucket: oss.Ptr(bucketName), // 存储空间名称
		TransferAccelerationConfiguration: &oss.TransferAccelerationConfiguration{
			Enabled: oss.Ptr(true), // 启用传输加速
		},
	}

	// 执行设置存储空间传输加速的请求
	result, err := client.PutBucketTransferAcceleration(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to put bucket transfer acceleration %v", err)
	}

	// 打印设置存储空间传输加速的结果
	log.Printf("put bucket transfer acceleration result:%#v\n", result)
}

您可以使用命令行工具ossutil来开启传输加速，ossutil的安装请参见安装ossutil。

以下命令用于为存储空间examplebucket配置传输加速。

ossutil api put-bucket-transfer-acceleration --bucket examplebucket --transfer-acceleration-configuration "{\"Enabled\":\"true\"}"

关于该命令的更多信息，请参见put-bucket-transfer-acceleration。

通过浏览器访问OSS时，将文件URL的Endpoint字段替换为传输加速Endpoint，例如https://test.oss-cn-shenzhen.aliyuncs.com/myphoto.jpg需改为https://test.oss-accelerate.aliyuncs.com/myphoto.jpg。如果文件访问权限为私有，则还需要加上签名信息。

• 通过ossutil访问OSS时持久启用传输加速功能，您可以将配置文件内的Endpoint替换为传输加速Endpoint。

  • 首先，找到并打开ossutil的配置文件。默认情况下，配置文件位于以下路径：

    • Linux: /home/user/.ossutilconfig

    • Windows: C:\Users\user\.ossutilconfig

    • macOS: /Users/user/.ossutilconfig

    如果您在配置ossutil时指定了不同的路径，请使用您指定的路径。

  • 修改Endpoint，在配置文件中，找到endpoint字段，并将其值修改为传输加速Endpoint：

    [Credentials]
    endpoint = oss-accelerate.aliyuncs.com
    accessKeyID = LTAI4Fw2NbDUCV8z********
    accessKeySecret = 67DLVBkH7EamOjy2W5RVAH********
    region=cn-hangzhou

    保存对配置文件的修改。

• 在使用ossutil相关命令时，还可以在命令示例中增加-e oss-accelerate.aliyuncs.com，仅对当前命令有效。以下命令表示在cp命令上传场景中使用了传输加速Endpoint。

  ossutil cp /path/to/local/file oss://examplebucket/exampleobject  -e  oss-accelerate.aliyuncs.com

各配置项说明如下：

配置示例如下：

通过各语言SDK访问OSS时，将Endpoint设置为传输加速Endpoint，此处以简单上传和简单下载为例介绍。

• 简单上传

  Java

  Go

  Java

  import com.aliyun.oss.ClientException;
  import com.aliyun.oss.OSS;
  import com.aliyun.oss.common.auth.*;
  import com.aliyun.oss.OSSClientBuilder;
  import com.aliyun.oss.OSSException;
  import com.aliyun.oss.model.PutObjectRequest;
  import java.io.File;
  
  public class Demo {
  
      public static void main(String[] args) throws Exception {
          // 填写传输加速Endpoint。以全球加速Endpoint为例。
          String endpoint = "https://oss-accelerate.aliyuncs.com";
          // 强烈建议不要把访问凭证保存到工程代码里，否则可能导致访问凭证泄露，威胁您账号下所有资源的安全。本代码示例以从环境变量中获取访问凭证为例。运行本代码示例之前，请先配置环境变量。
          EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
          // 填写Bucket名称，例如examplebucket。
          String bucketName = "examplebucket";
          // 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
          String objectName = "exampledir/exampleobject.txt";
          // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
          // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件。
          String filePath= "D:\\localpath\\examplefile.txt";
  
          // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
          String region = "cn-hangzhou";
  
          // 创建OSSClient实例。
          ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
          // 显式声明使用V4签名
          clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);        
          OSS ossClient = OSSClientBuilder.create()
          .endpoint(endpoint)
          .credentialsProvider(credentialsProvider)
          .clientConfiguration(clientBuilderConfiguration)
          .region(region)               
          .build();
  
          try {
              // 创建PutObjectRequest对象。            
              PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, filePath);
              // 如果需要上传时设置存储类型和访问权限，请参考以下示例代码。
              // ObjectMetadata metadata = new ObjectMetadata();
              // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
              // metadata.setObjectAcl(CannedAccessControlList.Private);
              // putObjectRequest.setMetadata(metadata);
  
              // 上传文件。
              ossClient.putObject(putObjectRequest);
          } catch (OSSException oe) {
              System.out.println("Caught an OSSException, which means your request made it to OSS, "
                      + "but was rejected with an error response for some reason.");
              System.out.println("Error Message:" + oe.getErrorMessage());
              System.out.println("Error Code:" + oe.getErrorCode());
              System.out.println("Request ID:" + oe.getRequestId());
              System.out.println("Host ID:" + oe.getHostId());
          } catch (ClientException ce) {
              System.out.println("Caught an ClientException, which means the client encountered "
                      + "a serious internal problem while trying to communicate with OSS, "
                      + "such as not being able to access the network.");
              System.out.println("Error Message:" + ce.getMessage());
          } finally {
              if (ossClient != null) {
                  ossClient.shutdown();
              }
          }
      }
  }            

  Go

  package main
  
  import (
  	"context"
  	"flag"
  	"log"
  
  	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
  	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
  )
  
  // 定义全局变量
  var (
  	region     string // 存储区域
  	bucketName string // 存储空间名称
  	objectName string // 对象名称
  )
  
  // init函数用于初始化命令行参数
  func init() {
  	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
  	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
  	flag.StringVar(&objectName, "object", "", "The name of the object.")
  }
  
  func main() {
  	// 解析命令行参数
  	flag.Parse()
  
  	// 检查bucket名称是否为空
  	if len(bucketName) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, bucket name required")
  	}
  
  	// 检查region是否为空
  	if len(region) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, region required")
  	}
  
  	// 检查object名称是否为空
  	if len(objectName) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, object name required")
  	}
  
  	// 加载默认配置并设置凭证提供者和区域
  	cfg := oss.LoadDefaultConfig().
  		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
  		WithRegion(region).
  		WithEndpoint("oss-accelerate.aliyuncs.com") // 设置加速域名
  
  	// 创建OSS客户端
  	client := oss.NewClient(cfg)
  
  	// 填写要上传的本地文件路径和文件名称，例如 /Users/localpath/exampleobject.txt
  	localFile := "/Users/localpath/exampleobject.txt"
  
  	// 创建上传对象的请求
  	putRequest := &oss.PutObjectRequest{
  		Bucket:       oss.Ptr(bucketName),      // 存储空间名称
  		Key:          oss.Ptr(objectName),      // 对象名称
  		StorageClass: oss.StorageClassStandard, // 指定对象的存储类型为标准存储
  		Acl:          oss.ObjectACLPrivate,     // 指定对象的访问权限为私有访问
  	}
  
  	// 执行上传对象的请求
  	result, err := client.PutObjectFromFile(context.TODO(), putRequest, localFile)
  	if err != nil {
  		log.Fatalf("failed to put object from file %v", err)
  	}
  
  	// 打印上传对象的结果
  	log.Printf("put object result:%#v\n", result)
  }
  

• 简单下载

  Java

  Go

  Java

  import com.aliyun.oss.ClientException;
  import com.aliyun.oss.OSS;
  import com.aliyun.oss.common.auth.*;
  import com.aliyun.oss.OSSClientBuilder;
  import com.aliyun.oss.OSSException;
  import com.aliyun.oss.model.GetObjectRequest;
  import java.io.File;
  
  public class Demo {
  
      public static void main(String[] args) throws Exception {
          // 填写传输加速Endpoint。以全球加速Endpoint为例。
          String endpoint = "https://oss-accelerate.aliyuncs.com";
          // 强烈建议不要把访问凭证保存到工程代码里，否则可能导致访问凭证泄露，威胁您账号下所有资源的安全。本代码示例以从环境变量中获取访问凭证为例。运行本代码示例之前，请先配置环境变量。
          EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
          // 填写Bucket名称，例如examplebucket。
          String bucketName = "examplebucket";
          // 填写不包含Bucket名称在内的Object完整路径，例如testfolder/exampleobject.txt。
          String objectName = "testfolder/exampleobject.txt";
          String filePath = "D:\\localpath\\examplefile.txt";
  
          // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
          String region = "cn-hangzhou";
  
          // 创建OSSClient实例。
          ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
          // 显式声明使用V4签名
          clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);        
          OSS ossClient = OSSClientBuilder.create()
          .endpoint(endpoint)
          .credentialsProvider(credentialsProvider)
          .clientConfiguration(clientBuilderConfiguration)
          .region(region)               
          .build();
  
          try {
              // 下载Object到本地文件，并保存到指定的本地路径中。如果指定的本地文件存在会覆盖，不存在则新建。
              // 如果未指定本地路径，则下载后的文件默认保存到示例程序所属项目对应本地路径中。
              ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(filePath));
          } catch (OSSException oe) {
              System.out.println("Caught an OSSException, which means your request made it to OSS, "
                      + "but was rejected with an error response for some reason.");
              System.out.println("Error Message:" + oe.getErrorMessage());
              System.out.println("Error Code:" + oe.getErrorCode());
              System.out.println("Request ID:" + oe.getRequestId());
              System.out.println("Host ID:" + oe.getHostId());
          } catch (ClientException ce) {
              System.out.println("Caught an ClientException, which means the client encountered "
                      + "a serious internal problem while trying to communicate with OSS, "
                      + "such as not being able to access the network.");
              System.out.println("Error Message:" + ce.getMessage());
          } finally {
              if (ossClient != null) {
                  ossClient.shutdown();
              }
          }
      }
  }

  Go

  package main
  
  import (
  	"context"
  	"flag"
  	"log"
  
  	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
  	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
  )
  
  // 定义全局变量
  var (
  	region     string // 存储区域
  	bucketName string // 存储空间名称
  	objectName string // 对象名称
  )
  
  // init函数用于初始化命令行参数
  func init() {
  	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
  	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
  	flag.StringVar(&objectName, "object", "", "The name of the object.")
  }
  
  func main() {
  	// 解析命令行参数
  	flag.Parse()
  
  	// 检查bucket名称是否为空
  	if len(bucketName) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, bucket name required")
  	}
  
  	// 检查region是否为空
  	if len(region) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, region required")
  	}
  
  	// 检查object名称是否为空
  	if len(objectName) == 0 {
  		flag.PrintDefaults()
  		log.Fatalf("invalid parameters, object name required")
  	}
  
  	// 加载默认配置并设置凭证提供者和区域
  	cfg := oss.LoadDefaultConfig().
  		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
  		WithRegion(region).
  		WithEndpoint("oss-accelerate.aliyuncs.com") // 设置加速域名
  
  	// 创建OSS客户端
  	client := oss.NewClient(cfg)
  
  	// 填写本地文件路径和文件名称，例如 /Users/localpath/downloadobject.txt
  	localFile := "/Users/localpath/exampleobject.txt"
  
  	// 创建下载对象到本地文件的请求
  	getRequest := &oss.GetObjectRequest{
  		Bucket: oss.Ptr(bucketName), // 存储空间名称
  		Key:    oss.Ptr(objectName), // 对象名称
  	}
  
  	// 执行下载对象到本地文件的操作并处理结果
  	result, err := client.GetObjectToFile(context.TODO(), getRequest, localFile)
  	if err != nil {
  		log.Fatalf("failed to get object to file %v", err)
  	}
  
  	log.Printf("Get object sucessfully, Result: HTTPStatusCode=%d, ContentLength=%d\n", result.StatusCode, result.ContentLength)
  }
  

通过在ossutil命令示例中测试未开启传输加速前（即使用-e oss-us-west-1.aliyuncs.com）以及开启传输加速后（即使用-e oss-accelerate.aliyuncs.com）上传文件所需时间的差异。

您可以通过OSS互联网连通与测速工具测试您本地访问全球各地数据中心时，开启传输加速与未开启传输加速的访问速度。