本文介绍如何使用流式下载。

下载文件到流

以下代码用于把指定的OSS文件下载到流：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "io/ioutil"
  7.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  8. )
  10. func main() {
  11.     // 创建OSSClient实例。
  12.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  13.     if err != nil {
  14.         fmt.Println("Error:", err)
  15.         os.Exit(-1)
  16.     }
  18.     // 获取存储空间。
  19.     bucket, err := client.Bucket("<yourBucketName>")
  20.     if err != nil {
  21.         fmt.Println("Error:", err)
  22.         os.Exit(-1)
  23.     }
  25.     // 下载文件到流。
  26.     body, err := bucket.GetObject("<yourObjectName>")
  27.     if err != nil {
  28.         fmt.Println("Error:", err)
  29.         os.Exit(-1)
  30.     }
  31.     // 数据读取完成后，获取的流必须关闭，否则会造成连接泄漏，导致请求无连接可用，程序无法正常工作。
  32.     defer body.Close()
  34.     data, err := ioutil.ReadAll(body)
  35.     if err != nil {
  36.         fmt.Println("Error:", err)
  37.         os.Exit(-1)
  38.     }
  39.     fmt.Println("data:", string(data))
  40. }

下载文件到缓存

以下代码用于把指定的OSS文件下载到本地缓存：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "io"
  7.     "bytes"
  8.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  9. )
  11. func main() {
  12.     // 创建OSSClient实例。
  13.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  14.     if err != nil {
  15.         fmt.Println("Error:", err)
  16.         os.Exit(-1)
  17.     }
  19.     // 获取存储空间。
  20.     bucket, err := client.Bucket("<yourBucketName>")
  21.     if err != nil {
  22.         fmt.Println("Error:", err)
  23.         os.Exit(-1)
  24.     }
  26.     // 下载文件到缓存。
  27.     body, err := bucket.GetObject("<yourObjectName>")
  28.     if err != nil {
  29.         fmt.Println("Error:", err)
  30.         os.Exit(-1)
  31.     }
  32.     defer body.Close()
  34.     buf := new(bytes.Buffer)
  35.     io.Copy(buf, body)
  36.     fmt.Println("buf:", buf)
  37. }

下载文件到本地文件流

以下代码用于把指定的OSS文件下载到本地文件流：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "io"
  7.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  8. )
  10. func main() {
  11.     // 创建OSSClient实例。
  12.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  13.     if err != nil {
  14.         fmt.Println("Error:", err)
  15.         os.Exit(-1)
  16.     }
  18.     // 获取存储空间。
  19.     bucket, err := client.Bucket("<yourBucketName>")
  20.     if err != nil {
  21.         fmt.Println("Error:", err)
  22.         os.Exit(-1)
  23.     }
  25.     // 下载文件到本地文件流。
  26.     body, err := bucket.GetObject("<yourObjectName>")
  27.     if err != nil {
  28.         fmt.Println("Error:", err)
  29.         os.Exit(-1)
  30.     }
  31.     defer body.Close()
  33.     fd, err := os.OpenFile("LocalFile", os.O_WRONLY|os.O_CREATE, 0660)
  34.     if err != nil {
  35.         fmt.Println("Error:", err)
  36.         os.Exit(-1) 
  37.     }
  38.     defer fd.Close()
  40.     io.Copy(fd, body)
  41. }