背景
本文主要介绍如何基于OSS服务和MPS的上传SDK,快速搭建一个音视频文件上传服务。
优势
- 增加文件列表管理功能。
- 增加STS Token 超时更新功能。
- 增加上传过程中网络抖动时的自动重试功能。
- 文件断点续传功能。
- 自动触发MPS服务的媒体工作流。
- 配置媒体标题、标签、描述、类目、封面URL等功能。
说明
- 断点续传的限制条件:不允许跨生命周期。JS端页面不能刷新、关闭,Android和iOS不能关闭APP、手机。
- 同一本地文件只能上传一次。
开通STS
- 开通OSS服务,创建Bucket,并登录 OSS控制台。
- 在概览页,将光标向下滑动在大家都在用模块中,单击 。
- 进入安全令牌快捷配置页面,单击开始授权。
- 系统进行自动授权,请您保存AccessKey ID、AccessKey Secret、RoleArn参数信息。单击保存AK信息,对话框会关闭,STS的开通完成。
搭建一个应用服务器
配置应用服务器示例
{
"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所要拥有的权限列表的文件,默认值可以不修改。
-
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
- 客户端示例代码
- 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];
在文档使用中是否遇到以下问题
更多建议
匿名提交