cover

flutter_oss_aliyun

你可以传入自定义的Dio在init函数中，你可以传入dio，做到dio的定制化。比如日志或者其他的interceptors.

2301_76429513

464人浏览 · 2023-07-16 09:45:00

2301_76429513 · 2023-07-16 09:45:00 发布

一个访问阿里云oss并且支持STS临时访问凭证访问OSS的flutter库，基本上涵盖阿里云oss sdk的所有功能。⭐

flutter pub: flutter_oss_aliyun | Dart Package

github : https://github.com/huhx/flutter_oss_aliyun

oss sts document: 使用STS临时访问凭证访问OSS_对象存储-阿里云帮助中心

🐱 初始化Client

添加依赖

dependencies:
  flutter_oss_aliyun: ^6.2.2

初始化oss client, 这里我们提供两种方式

1. 提供sts server地址，需要后端添加这个api

Client.init(
    stsUrl: "server url get sts token",
    ossEndpoint: "oss-cn-beijing.aliyuncs.com",
    bucketName: "bucket name",
);

后端api至少需要返回以下数据:

{
  "AccessKeyId": "AccessKeyId",
  "AccessKeySecret": "AccessKeySecret",
  "SecurityToken": "SecurityToken",
  "Expiration": "2022-03-22T11:33:06Z"
}

2. 自定义authGetter得到Auth

Client.init(
    ossEndpoint: "oss-cn-beijing.aliyuncs.com",
    bucketName: "bucketName",
    authGetter: _authGetter
);

Auth _authGetter() {
  return Auth(
      accessKey: "accessKey",
      accessSecret: 'accessSecret',
      expire: '2023-02-23T14:02:46Z',
      secureToken: 'token',
  );
}

你可以传入自定义的Dio

在init函数中，你可以传入dio，做到dio的定制化。比如日志或者其他的interceptors.

Client.init(
    stsUrl: "server url get sts token",
    ossEndpoint: "oss-cn-beijing.aliyuncs.com",
    bucketName: "bucket name",
    dio: Dio(BaseOptions(connectTimeout: 9000)),
);

🎨 使用

文件上传

关于callback的使用: Callback_对象存储-阿里云帮助中心

final bytes = "file bytes".codeUnits;

await Client().putObject(
  bytes,
  "test.txt",
  option: PutRequestOption(
    onSendProgress: (count, total) {
      print("send: count = $count, and total = $total");
    },
    onReceiveProgress: (count, total) {
      print("receive: count = $count, and total = $total");
    },
    override: false,
    aclModel: AclMode.publicRead,
    storageType: StorageType.ia,
    headers: {"cache-control": "no-cache"},
    callback: Callback(
      callbackUrl: "callback url",
      callbackBody: "{\"mimeType\":\${mimeType}, \"filepath\":\${object},\"size\":\${size},\"bucket\":\${bucket},\"phone\":\${x:phone}}",
      callbackVar: {"x:phone": "android"},
      calbackBodyType: CalbackBodyType.json,
    ),       
  ),
);

PutRequestOption 字段说明,字段皆为非必需

Filed	Default value	Description
override	true	true: 允许覆盖同名Object false: 禁止覆盖同名Object
aclModel	inherited	1. publicWrite: 任何人（包括匿名访问者）都可以对该Object进行读写操作 2. publicRead: 只有该Object的拥有者可以对该Object进行写操作，任何人（包括匿名访问者）都可以对该Object进行读操作 3. private: 只有Object的拥有者可以对该Object进行读写操作，其他人无法访问该Object 4. inherited: 该Object遵循Bucket的读写权限，即Bucket是什么权限，Object就是什么权限参考文档: 如何设置ObjectACL_对象存储-阿里云帮助中心
storageType	Standard	参考文档: 什么是存储类型_对象存储-阿里云帮助中心

追加文件上传

final Response<dynamic> resp = await Client().appendObject(
  Uint8List.fromList(utf8.encode("Hello World")),
  "test_append.txt",
);

final Response<dynamic> resp2 = await Client().appendObject(
  position: int.parse(resp.headers["x-oss-next-append-position"]?[0]),
  Uint8List.fromList(utf8.encode(", Fluter.")),
  "test_append.txt",
);

跨bucket复制文件

final Response<dynamic> resp = await Client().copyObject(
  const CopyRequestOption(
    sourceFileKey: 'test.csv',
    targetFileKey: "test_copy.csv",
    targetBucketName: "bucket_2"
  ),
);

取消文件上传

final CancelToken cancelToken = CancelToken();
final bytes = ("long long bytes" * 1000).codeUnits;

Client().putObject(
  Uint8List.fromList(utf8.encode(string)),
  "cancel_token_test.txt",
  cancelToken: cancelToken,
  option: PutRequestOption(
    onSendProgress: (count, total) {
      if (kDebugMode) {
        print("send: count = $count, and total = $total");
      }
      if (count > 56) {
        cancelToken.cancel("cancel the uploading.");
      }
    },
  ),
).then((response) {
  // success
  print("upload success = ${response.statusCode}");
}).catchError((err) {
  if (CancelToken.isCancel(err)) {
    print("error message = ${err.message}");
  } else {
    // handle other errors
  }
});

批量文件上传

await Client().putObjects([
  AssetEntity(
    filename: "filename1.txt",
    bytes: "files1".codeUnits,
    option: PutRequestOption(
      onSendProgress: (count, total) {
        print("send: count = $count, and total = $total");
      },
      onReceiveProgress: (count, total) {
        print("receive: count = $count, and total = $total");
      },
      aclModel: AclMode.private,
    ),
  ),
  AssetEntity(filename: "filename2.txt", bytes: "files2".codeUnits),
]);

本地文件上传

final Response<dynamic> resp = await Client().putObjectFile(
  "/Users/aaa.pdf",
  fileKey: "aaa.png",
  option: PutRequestOption(
    onSendProgress: (count, total) {
      print("send: count = $count, and total = $total");
    },
    onReceiveProgress: (count, total) {
      print("receive: count = $count, and total = $total");
    },
    aclModel: AclMode.private,
  ),
);

批量本地文件上传

final List<Response<dynamic>> resp = await Client().putObjectFiles(
  [
    AssetFileEntity(
      filepath: "//Users/private.txt",
      option: PutRequestOption(
        onSendProgress: (count, total) {
          print("send: count = $count, and total = $total");
        },
        onReceiveProgress: (count, total) {
          print("receive: count = $count, and total = $total");
        },
        override: false,
        aclModel: AclMode.private,
      ),
    ),
    AssetFileEntity(
      filepath: "//Users/splash.png",
      filename: "aaa.png",
      option: PutRequestOption(
        onSendProgress: (count, total) {
          print("send: count = $count, and total = $total");
        },
        onReceiveProgress: (count, total) {
          print("receive: count = $count, and total = $total");
        },
        override: true,
      ),
    ),
  ],
);

文件下载

await Client().getObject(
  "test.txt",
  onReceiveProgress: (count, total) {
    debugPrint("received = $count, total = $total");
  },
);

文件下载并保存

await Client().downloadObject(
  "test.txt",
  "./example/test.txt",
  onReceiveProgress: (count, total) {
    debugPrint("received = $count, total = $total");
  },
);

文件删除

await Client().deleteObject("test.txt");

批量文件删除

await Client().deleteObjects(["filename1.txt", "filename2.txt"]);

获取已签名的文件url

需要注意的是: 这个操作并不安全，因为url包含security-token信息，即使过期时间比较短. 这个url可以直接在浏览器访问

final String url = await Client().getSignedUrl("filename1.txt");

获取多个已签名的文件url

需要注意的是: 这个操作并不安全，因为url包含security-token信息，即使过期时间比较短

final Map<String, String> result = await Client().getSignedUrls(["test.txt", "filename1.txt"]);

列举所有的存储空间

列举请求者拥有的所有存储空间（Bucket）。您还可以通过设置prefix、marker或者max-keys参数列举满足指定条件的存储空间。参考: 调用GetService（ListBuckets）列举Bucket_对象存储-阿里云帮助中心

final Response<dynamic> resp = await Client().listBuckets({"max-keys": 2});

列举存储空间中所有文件

接口用于列举存储空间（Bucket）中所有文件（Object）的信息。请求参数和返回结果，请参考: 调用GetBucketV2列举存储空间_对象存储-阿里云帮助中心

final Response<dynamic> resp = await Client().listFiles({});

获取bucket信息

查看存储空间（Bucket）的相关信息。返回结果请参考: 调用GetBucketInfo查看存储空间信息_对象存储-阿里云帮助中心

final Response<dynamic> resp = await Client().getBucketInfo();

获取bucket的储容量以及文件数量

获取指定存储空间（Bucket）的存储容量以及文件（Object）数量。返回结果请参考: 调用GetBucketStat接口获取指定存储空间Bucket的存储容量以及文件Object数量_对象存储-阿里云帮助中心

final Response<dynamic> resp = await Client().getBucketStat();

获取文件元信息

final Response<dynamic> resp = await Client().getObjectMeta("huhx.csv");

regions的查询

查询所有

final Response<dynamic> resp = await Client().getAllRegions();

查询特定

final Response<dynamic> resp = await Client().getRegion("oss-ap-northeast-1");

bucket acl的操作

查询

final Response<dynamic> resp = await Client().getBucketAcl(
  bucketName: "bucket-name",
);

更新

final Response<dynamic> resp = await Client().putBucketAcl(
  AciMode.publicRead, 
  bucketName: "bucket-name",
);

bucket policy的操作

查询

final Response<dynamic> resp = await Client().getBucketPolicy(
  bucketName: "bucket-name",
);

更新

final Response<dynamic> resp = await Client().putBucketPolicy(
  {}, 
  bucketName: "bucket-name",
);

删除

final Response<dynamic> resp = await Client().deleteBucketPolicy(
  bucketName: "bucket-name",
);

华为云开发者联盟

为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。

更多推荐

cover

通过HPA+CronHPA组合应对业务复杂弹性伸缩场景

华为云开发者联盟

cover

FT-FMEA融合混沌演练，零售运营系统韧性架构在线验证实践

华为云开发者联盟

cover

如何利用 Seaborn 实现高级统计图表

华为云开发者联盟

所有评论(0)

查看更多评论

2301_76429513

已为社区贡献1条内容