如何上传视频 - 媒体处理

背景

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

优势

使用MPS的上传SDK上传音视频文件，具有以下优势：

增加文件列表管理功能。
增加STS Token 超时更新功能。
增加上传过程中网络抖动时的自动重试功能。
文件断点续传功能。
自动触发MPS服务的媒体工作流。
配置媒体标题、标签、描述、类目、封面URL等功能。
说明
- 断点续传的限制条件：不允许跨生命周期。JS端页面不能刷新、关闭，Android和iOS不能关闭APP、手机。
- 同一本地文件只能上传一次。

开通STS

开通OSS服务，创建Bucket，并登录 OSS控制台。
在概览页，将光标向下滑动在大家都在用模块中，单击安全令牌 > 前往RAM控制台。
进入安全令牌快捷配置页面，单击开始授权。
系统进行自动授权，请您保存AccessKey ID、AccessKey Secret、RoleArn参数信息。单击保存AK信息，对话框会关闭，STS的开通完成。

搭建一个应用服务器

配置应用服务器示例

为了方便开发，本教程提供了三个语言的版本示例程序供您下载。

Java：下载地址。
PHP：下载地址。
Ruby：下载地址。

语言包下载后，会有一个配置文件config.json如下所示：

{
"AccessKeyID" : "",
"AccessKeySecret" : "",
"RoleArn" : "",
"TokenExpireTime" : "900",
"PolicyFile": "policy/all_policy.txt"
}

说明

AccessKey ID：填写AccessKey ID参数。
AccessKey Secret：填写AccessKey Secret参数。
RoleArn：填写RoleArn参数。
TokenExpireTime：指Android和iOS应用取到这个Token的失效时间。注意：最少是900秒，默认值可以不修改。
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":"test",
"AccessKeySecret":"test",
"Security":"CAES+wMIARKAAZhjH0EUOIhJMQBMjRywXq7MQ/cjLYg80Aho1ek0Jm63XMhr9Oc5s3qaPer8p1YaX1NTDiCFZWFkvlHf1pQhuxfKBc+mRR9KAbHUefqH+rdjZqjTF7p2m1wJXP8S6k+G2MpHrUe6TYBkJ43GhhTVFMuM3BZajY3VjZWOXBIODRIR1FKZjIiEjMzMzE0MjY0NzM5MTE4NjkxMSoLY2xpZGSSDgSDGAGESGTETqOio6c2RrLWRlbW8vKgoUYWNzOm9zczoqOio6c2RrLWRlbW9KEDExNDg5MzAxMDcyNDY4MThSBTI2ODQyWg9Bc3N1bWVkUm9sZVVzZXJgAGoSMzMzMTQyNjQ3MzkxMTg2OTExcglzZGstZGVtbzI=",
"Expiration":"2015-12-12T07:49:09Z",
}

说明

下面四个变量将构成了一个Token：

status：表示获取Token的状态，获取成功时，返回值是200。
AccessKey ID：表示Android和iOS应用初始化OSSClient获取的 AccessKey ID。
AccessKey Secret：表示Android和iOS应用初始化OSSClient获取AccessKey Secret。
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

客户端示例代码
为了方便开发，本教程提供了三个语言的版本示例程序供您下载。
- H5：下载地址
- Android：下载地址
- iOS：下载地址

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];