文档首页> > 上传SDK> 服务端上传SDK> Java

Java

分享
更新时间: 2019/04/26 15:59

前提条件

兼容性

支持的JDK版本:JDK 1.8.0_65版本及以上。

安装SDK

  1. Java环境配置。

    说明:

    本SDK包要求的JDK版本高于JDK8版本,以下步骤以win7环境配置JDK8 64位为例,若已经下载JDK并配置好环境请忽略本章节。

    1. 下载JDK文件:JDK官网
    2. 下载完成后按照提示安装,位置自选,比如安装到本地“C:\Program Files\Java\jdk1.8.0_131”。
    3. 配置Java环境变量:右键“计算机>属性>高级系统设置>环境变量”,进行如下操作。
      1. 新建系统变量JAVA_HOME,变量值为实际JDK安装位置。
      2. 在path中添加%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin (注意用英文分号分隔)。
      3. 新建系统变量CLASSPATH,变量值为%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar 。
    4. 打开命令行窗口,输入“java -version”,显示如下图所示表示配置成功。

  2. 获取SDK。

    如果您当前还没有下载SDK,请下载SDK。

  3. Eclipse安装与SDK工程导入。

    1. Eclipse官网下载对应平台的eclipse版本,比如:eclipse-jee-mars-R-win32-x86_64.zip。
    2. 解压后直接打开eclipse。
    3. 确保 “Windows>Preferences>Java>Installed JREs”配置正确的JRE路径。
    4. 在左侧工程上点击右键,择“Build path->Configure Build Path...”,在弹出框中左边选择"Java Build Path",在右边选择"Libraries"页签,然后点击右边的"Add External JARs...",选择点播sdk的所在的本地位置。

    5. 单击OK,导入SDK,导入后打开工程,工程目录如下:

代码示例

断点续传

支持断点续传,大文件上传持续时间长,当上传过程中出现网络异常程序崩溃等导致上传中断情况时,可以调用断点续传接口继续上传,断点续传是将文件分成若干段进行上传,当所有段上传完成时会合并成完整文件,完成整个文件上传。文件上传时断点续传接口将会自动记录当前上传进度信息,当发生异常中断时,不需要用户手动调用,再次上传时会从上次中断记录点继续上传,节省时间和流量成本。

/*
* 业务流程:
* 1、首先需要导入点播sdk包cloud-java-sdk-vod-upload-1.1.0.jar和其他相关依赖jar包
* 2、设置点播服务配置项,包括点播服务节点地址、AK、SK和ProjectId等,用于连接点播服务和进行授权等。
* 3、设置OBS对象存储服务的配置项,用于进行对象上传
* 4、构造媒资上传请求参数。
* 5、发送媒资上传请求。
* 6、返回处理信息。
*/

import com.google.gson.Gson;
import com.huawei.upload.common.obs.ObsConfig;
import com.huawei.upload.common.obs.model.FileMeta;
import com.huawei.upload.vod.client.VodClient;
import com.huawei.upload.vod.client.VodConfig;
import com.huawei.upload.vod.service.ObsService;
import com.obs.services.model.CompleteMultipartUploadResult;
import com.obs.services.model.PartEtag;

//设置点播服务配置项构造方法
VodConfig vodConfig = new VodConfig();
//设置用户项目编号ProjectId,查看项目ID参考 "查看项目ID"章节
vodConfig.setProjectId("projectId");
//设置点播服务节点地址,保持默认值“vod.cn-north-1.myhuaweicloud.com”,不需要修改

vodConfig.setEndPoint("vod.cn-north-1.myhuaweicloud.com");
//设置临时AK、SK, 临时AK、SK需要由租户服务端调用服务端SDK获取
vodConfig.setAk("ak");
vodConfig.setSk("sk");w 

/*if you need proxy*/
//设置代理,根据实际需要是否设置,非必须
/*
ClientConfig clientConfig = new ClientConfig();
//设置代理服务器主机IP
clientConfig.setProxyHost(proxyHost);
//设置代理服务器端口号
clientConfig.setProxyPort(Integer.parseInt(proxyPort));
//设置代理服务器用户名
clientConfig.setProxyUserName(proxyUserName);
//设置代理服务器用户密码
clientConfig.setProxyPassword(proxyPassword);

//设置连接OBS的相关配置,必须
ObsConfig obsConfig = new ObsConfig();
//设置OBS服务节点地址,保持默认值“obs.cn-north-1.myhuaweicloud.com”,不需要修改

obsConfig.setEndPoint("obs.cn-north-1.myhuaweicloud.com");
//设置上传文件时每个分段的大小,单位为M,最小5M
obsConfig.setPartSize(5);
//设置是否分段并发上传,传入参数为并发数量,当入参小于等于1时代表串行上传。
obsConfig.setConcurrencyLevel(0);


*/      
//点播服务构造方法,在没有配置代理的情况下使用该构造方法
VodClient vodClient=new VodClient(VodConfig, obsConfig);

/*
* proxy provided
* //点播服务构造方法,在需要配置代理的情况下使用该构造方法
* VodClient vodClient=new VodClient(VodConfig, clientConfig, obsConfig);
*/

/**初始化上传信息,需要传入待上传文件的本地文件地址(绝对路径)、媒资所在的桶名、媒资所在的ObjectKey
*    此处的filePath指本地文件的文件地址的绝对路径,如 d://test.mp4
*    bucket、objectKey 需要服务端调用创建媒资接口后获得并返回给客户端,详情需要参考点播服务端的创建媒资接口
*/
FileMeta fileMeta = new FileMeta("filePath", "bucket", "objectKey");

/*
 * 传入FileMeta后开始上传,不支持回调
 * CompleteMultipartUploadResult result = vodClient.multipartUploadFile(fileMeta);
 */

// 开始上传,可以传入一个回调内部类来实时获取上传信息。
CompleteMultipartUploadResult result = vodClient.multipartUploadFile(fileMeta, new ObsService.OnPartEtagUploadedListener() {
      
      @Override  //初始化段结束时回调
      public void onInitMultiUploadPart(String uploadId) {
      System.out.println("Init end, uploadId is : " + uploadId);
      }

      @Override   //上传完每一段时回调,可以获取回调时的PartEtag,上传进度。 
      public void onUploadEachPart(PartEtag partEtag, String uploadId, int progess) {
      System.out.println("The partEtag " + partEtag.toString() + " is end !  Current progress: " + uploadId);
      }      

      @Override   // 上传完成时回调
      public void onCompleteMultiUpload(String uploadId) {
      System.out.println("Complete end: " + uploadId);
      }

      @Override
      public void onError(Throwable e) {
      e.printStackTrace();
      }});
//返回处理消息
System.out.println(new Gson().toJson(result));
说明:
  • 此处是断点续传示例,租户客户端在调用前需要从租户服务端获取媒资上传需要的bucket、objectKey、临时AK、SK。
  • 客户端可以在初始化ObsConfig时设置分段大小以及并发数。但再次调用断点续传上传剩余段时设置分段大小无效,默认第一次设置的分段大小
  • 断点续传前需要与第一次上传一致的bucket、objectKey、文件,否则默认为未上传过从第一段开始上传

错误处理

在使用Java SDK时,当服务端或者SDK端出错时,SDK会返回相应的异常信息。这些异常信息有两种,一种是和VOD进行交互获取临时授权时产生的错误,这种错误一般会以抛异常方式抛出,用户需要注意捕获。还有一种是上传过程中产生的错误,可以在调用上传接口的时候传入回调内部类,并在onError(Throwable th)中捕获处理。

如果您需要对SDK的错误进行处理,可以参考如下示例编写代码:

import com.google.gson.Gson;
import com.huawei.upload.common.obs.ObsConfig;
import com.huawei.upload.common.obs.model.FileMeta;
import com.huawei.upload.vod.client.VodClient;
import com.huawei.upload.vod.client.VodConfig;
import com.huawei.upload.vod.service.ObsService;
import com.obs.services.model.CompleteMultipartUploadResult;
import com.obs.services.model.PartEtag;

//设置点播服务配置项构造方法
VodConfig vodConfig = new VodConfig();
//设置用户项目编号ProjectId,查看项目ID参考 "查看项目ID"章节
vodConfig.setProjectId("projectId");
//设置点播服务节点地址,保持默认值“vod.cn-north-1.myhuaweicloud.com”,不需要修改

vodConfig.setEndPoint("vod.cn-north-1.myhuaweicloud.com");
//设置临时AK、SK, 临时AK、SK需要由租户服务端调用服务端SDK获取
vodConfig.setAk("ak");
vodConfig.setSk("sk");

/*if you need proxy*/
//设置代理,根据实际需要是否设置,非必须
/*
ClientConfig clientConfig = new ClientConfig();
//设置代理服务器主机IP
clientConfig.setProxyHost(proxyHost);
//设置代理服务器端口号
clientConfig.setProxyPort(Integer.parseInt(proxyPort));
//设置代理服务器用户名
clientConfig.setProxyUserName(proxyUserName);
//设置代理服务器用户密码
clientConfig.setProxyPassword(proxyPassword);

//设置连接OBS的相关配置,必须
ObsConfig obsConfig = new ObsConfig();
//设置OBS服务节点地址,保持默认值“obs.cn-north-1.myhuaweicloud.com”,不需要修改

obsConfig.setEndPoint("obs.cn-north-1.myhuaweicloud.com");
//设置上传文件时每个分段的大小,单位为M,最小5M
obsConfig.setPartSize(5);
//设置是否分段并发上传,传入参数为并发数量,当入参小于等于1时代表串行上传。
obsConfig.setConcurrencyLevel(0);


*/      
//点播服务构造方法,在没有配置代理的情况下使用该构造方法
VodClient vodClient=new VodClient(VodConfig, obsConfig);

/*
* proxy provided
* //点播服务构造方法,在需要配置代理的情况下使用该构造方法
* VodClient vodClient=new VodClient(VodConfig, clientConfig, obsConfig);
*/

// 初始化上传信息,需要传入待上传文件的文件地址、媒资所在的桶名、媒资所在的ObjectKey
FileMeta fileMeta = new FileMeta("filePath", "bucket", "objectKey");

/*
 * 传入FileMeta后开始上传,不支持回调
 * CompleteMultipartUploadResult result = vodClient.multipartUploadFile(fileMeta);
 */

// 开始上传,可以传入一个回调内部类来实时获取上传信息。如需要断点续传,则需要记录下上传任务的uploadID和所有已上传的PartEtag,用于断点续传时告诉sdk已有哪些段已上传
try{
  CompleteMultipartUploadResult result = vodClient.multipartUploadFile(fileMeta, new ObsService.OnPartEtagUploadedListener() {
      
      @Override  //初始化段结束时回调
      public void onInitMultiUploadPart(String uploadId) {
      System.out.println("Init end, uploadId is : " + uploadId);
      }

      @Override   //上传完每一段时回调,可以获取回调时的PartEtag,上传进度。 若需要断点续传则需要保留该PartEtag
      public void onUploadEachPart(PartEtag partEtag, String uploadId, int progess) {
      System.out.println("The partEtag " + partEtag.toString() + " is end !  Current progress: " + uploadId);
      }      

      @Override   // 上传完成时回调
      public void onCompleteMultiUpload(String uploadId) {
      System.out.println("Complete end: " + uploadId);
      }

      @Override
      public void onError(Throwable e) {
      // 处理上传过程中产生的错误
      e.printStackTrace();
      }});
  } catch(Exception ex)
      {  // 处理和VOD交互产生的错误
         ex.printStackTrace();
       } 

//返回处理消息
System.out.println(new Gson().toJson(result));
如果您喜欢这篇文档,您还可以:

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区