背景

本文主要介绍如何基于OSS服务和MTS的上传SDK,快速搭建一个音视频文件上传服务。

优势

使用MPS的上传SDK上传音视频文件,具有以下优势:
  • 增加文件列表管理功能。

  • 增加STS Token 超时更新功能。

  • 增加上传过程中网络抖动时的自动重试功能。

  • 文件断点续传功能。

  • 自动触发MPS服务的媒体工作流。

  • 配置媒体标题、标签、描述、类目、封面URL、等功能。

    说明
    • 断点续传的限制条件:不允许跨生命周期。JS端页面不能刷新、关闭,android/iOS不能关闭APP、手机。
    • 同一本地文件只能上传一次。

上传服务架构图



服务端搭建

考虑移动端AK安全性问题,选用STS的方式上传文件。关于STS如何增加上传的安全性,参见 RAM和STS使用指南

开通STS

  1. 开通OSS服务,创建Bucket,并登录 OSS控制台
  2. 在OSS概览页中找到基础配置区域,单击 安全令牌,如下图所示:

  3. 进入到 安全令牌快捷配置 页面。

  4. 系进行自动授权,请务必保存下图中三个红框内的参数。单击 保存AK信息 后,对话框会关闭,STS的开通完成。


搭建一个应用服务器

配置应用服务器示例

为了方便开发,本教程提供了三个语言的版本示例程序供您下载。
每个语言包下载下来后,都会有一个配置文件config.json如下所示:

{
"AccessKeyID" : "",
"AccessKeySecret" : "",
"RoleArn" : "",
"TokenExpireTime" : "900",
"PolicyFile": "policy/all_policy.txt"
}
说明
  • AccessKeyID:填写上述图标红的参数1的内容。

  • AccessKeySecret:填写上述图标红的参数2的内容。

  • RoleArn:填写上述图标红的参数3的内容。

  • TokenExpireTime:指Android/iOS应用取到这个Token的失效时间。注意:最少是900s,默认值可以不修改。

  • PolicyFile:填写的是该Token所要拥有的权限列表的文件,默认值可以不修改。

本文档准备了三种最常用token权限文件,放于policy目录下面。分别是:
  • all_policy.txt:指定了该token拥有对该账号下创建Bucket、删除Bucket、上传文件、下载文件、删除文件的权限 。

  • bucket_read_policy.txt:指定了该token拥有该账号下对指定Bucket的读权限。

  • bucket_read_write_policy.txt:指定了该token拥有该账号下对指定Bucket的读写权限。

如果您想要指定这个Token只能对指定的bucket有读写权限,请把(bucket_read_policy.txt、 bucket_read_write_policy.txt)这些文件里面$BUCKET_NAME直接替换成指定的bucket名字。

  • 返回的格式解析
    
    {
    "status":200,
    "AccessKeyId":"STS.3pYjsdgdgagdasdg",
    "AccessKeySecret":"rpnwO9kvEgetGdrddgsR2YrTtI",
    "Security":"CAES+wMIARKAAZhjH0EUOIhJMQBMjRywXq7MQ/cjLYg80Aho1ek0Jm63XMhr9Oc5s3qaPer8p1YaX1NTDiCFZWFkvlHf1pQhuxfKBc+mRR9KAbHUefqH+rdjZqjTF7p2m1wJXP8S6k+G2MpHrUe6TYBkJ43GhhTVFMuM3BZajY3VjZWOXBIODRIR1FKZjIiEjMzMzE0MjY0NzM5MTE4NjkxMSoLY2xpZGSSDgSDGAGESGTETqOio6c2RrLWRlbW8vKgoUYWNzOm9zczoqOio6c2RrLWRlbW9KEDExNDg5MzAxMDcyNDY4MThSBTI2ODQyWg9Bc3N1bWVkUm9sZVVzZXJgAGoSMzMzMTQyNjQ3MzkxMTg2OTExcglzZGstZGVtbzI=",
    "Expiration":"2015-12-12T07:49:09Z",
    }
    说明
    下面四个变量将构成了一个Token:
    • status:表示获取Token的状态,获取成功时,返回值是200。

    • AccessKeyId:表示Android/iOS应用初始化OSSClient获取的 AccessKeyId。

    • AccessKeySecret:表示Android/iOS应用初始化OSSClient获取AccessKeySecret。

    • SecurityToken:表示Android/iOS应用初始化的Token。

    • Expiration:表示该Token失效的时间。主要在Android SDK会自动判断是否失效,自动获取Token。

  • 代码示例的运行方法
    • 对于JAVA版本 (依赖于java 1.7),将包下载解压后,

      运行方法:java -jar oss-token-server.jar (port)。如果不指定port(端口),直接运行java –jar oss-token-server.jar,程序会监听7080端口。如果想让程序执行在9000端口,运行java –jar app-token-server.jar 9000,其他端口也类似。

    • 对于PHP版本,将包下载解压后,修改config.json这个文件,直接运行php sts.php 即能生成Token,将程序部署到指定的地址。

使用MPS客户端SDK

  • 客户端示例代码
    为了方便开发,本教程提供了三个语言的版本示例程序供您下载。
  • SDK核心代码

    JS端

    在使用JS SDK之前,先对要上传视频的OSS Bucket 已经开启了 CORS访问权限。下载JS的Demo,在浏览器中打开,在页面上进行参数配置:
    • 配置“HTTP地址”为上面配置的应用服务器地址,如:http://127.0.0.1:7080/。
    • 配置用户Bucket。
    • 配置Bucket的endpoint。
    • 单击选择文件,选中要上传的文件。
    • 单击开始上传按钮。
    
    // 初始化客户端
    var uploader = new VODUpload({
    // 开始上传
    'onUploadstarted': function (uploadInfo) {;},
    // 文件上传成功
    'onUploadSucceed': function (uploadInfo) {console.log("上传成功");},
    // 文件上传失败
    'onUploadFailed': function (uploadInfo, code, message) {console.log("上传失败");},
    // 文件上传进度,单位:字节
    'onUploadProgress': function (uploadInfo, totalSize, uploadedSize) {console.log("上传进度");},
    // 安全令牌超时
    'onUploadTokenExpired': function (uploadInfo) {console.log("token超时");}
    });
    // 获取sts信息
    result = httpGet(httpServer);
    stsToken = JSON.parse(result);
    uploader.init(stsToken.AccessKeyId, stsToken.AccessKeySecret, stsToken.SecurityToken, stsToken.Expiration);
    // 添加文件
    uploader.addFile(event.target.files[i], endpoint, bucket, object, userData);
    // 开始上传
    uploader.startUpload();

    Android端

    确保Android端已经添加如下权限:
    <uses-permission android:name="android.permission.INTERNET"></uses-permission>
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"></uses-permission>
    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE"></uses-permission>
    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"></uses-permission>
    下载Android端Demo,进行如下修改:
    • 修改MainActivity里面的serverUrl为应用服务器配置地址,如:http://192.168.0.2:7080/。
    • 配置用户Bucket。
    • 配置用户Bucket对应的endpoint。
    • 运行Demo,单击添加文件。
    • 单击上传,在OSS对应Bucket的uploadtest/目录下查看文件是否已经上传成功。
    主要代码:
    
    VODUploadClient uploader = new VODUploadClientImpl(getApplicationContext());
    VODUploadCallback callback = new VODUploadCallback() {
    @Override
    public void onUploadSucceed(UploadFileInfo info) {;}
    @Override
    public void onUploadFailed(UploadFileInfo info, String code, String message) {;}
    @Override
    public void onUploadProgress(UploadFileInfo info, long uploadedSize, long totalSize) {;}
    @Override
    public void onUploadTokenExpired(UploadFileInfo info) {
    // 获取并更新 sts token。
    uploader.resumeWithToken("", "", "", "");
    }
    @Override
    public void onUploadRetry(UploadFileInfo info, String code, String message) {;}
    @Override
    public void onUploadRetryResume(UploadFileInfo info) {;}
    @Override
    public boolean onUploadStarted(UploadFileInfo uploadFileInfo) {;}
    };
    // 获取sts token并初始化
    uploader.init("", "", "", "", callback);
    // 添加文件
    uploader.addFile("", "", "", "");
    // 开始上传
    uploader.start();

    IOS端

    下载iOS端Demo,进行如下修改:
    • 修改VODUploadDemo.m里面的serverUrl为应用服务器配置地址,如:http://192.168.0.2:7080/。
    • 配置用户Bucket。
    • 配置用户Bucket对应的endpoint。
    • 运行Demo,单击添加文件。
    • 单击上传,在OSS对应Bucket的uploadtest/目录下查看文件是否已经上传成功。
    主要代码:
    
    // 回调初始化
    OnUploadStartedListener testUploadStartedCallbackFunc = ^(UploadFileInfo* fileInfo) {;};
    OnUploadSucceedListener testSuccessCallbackFunc = ^(NSString* filePath){;};
    OnUploadFailedListener testFailedCallbackFunc = ^(NSString* filePath, NSString* code, NSString* message){;};
    OnUploadProgressListener testProgressCallbackFunc = ^(NSString* filePath, long uploadedSize, long totalSize) {;};
    OnUploadTokenExpiredListener testTokenExpiredCallbackFunc = ^{
    // 获取并更新sts token
    [uploader resumeWithToken:
    accessKeySecret:
    secretToken:
    expireTime:]
    };
    OnUploadRertyListener testUploadRertyListener = ^{;};
    OnUploadRertyResumeListener testUploadRertyResumeListener = ^{;};
    VODUploadListener *listener;
    listener = [[VODUploadListener alloc] init];
    listener.started = testUploadStartedCallbackFunc;
    listener.success = testSuccessCallbackFunc;
    listener.failure = testFailedCallbackFunc;
    listener.progress = testProgressCallbackFunc;
    listener.expire = testTokenExpiredCallbackFunc;
    listener.retry = testUploadRertyListener;
    listener.retryResume = testUploadRertyResumeListener;
    // 获取Token
    // 上传客户端初始化
    VODUploadClient *uploader;
    [uploader init:
    accessKeySecret:
    secretToken:
    expireTime:
    listener:listener];
    // 添加文件
    [uploader addFile:
    endpoint:
    bucket:
    object:];
    // 开始上传
    [uploader start];