阿里云视频上传实战

简介: 最近在做项目优化,关于阿里云视频上传方面一直存在视频上传过慢问题.由于之前采用的是服务端进行视频上传,主要的逻辑是客户端上传视频到服务端进行视频文件暂存,然后服务端上传视频到阿里云.

背景说明


   最近在做项目优化,关于阿里云视频上传方面一直存在视频上传过慢问题.由于之前采用的是服务端进行视频上传,主要的逻辑是客户端上传视频到服务端进行视频文件暂存,然后服务端上传视频到阿里云.上传过慢猜测是上传视频到服务端要受到带宽的影响,决定直接采用客户端(项目是web项目)直接上传到阿里云,不经过服务端这个环节,猜测上传速度会快一些.两种上传方案流程图如下:

a3f805366896c5833cd43f000ed19e82_70dc00ef47ce4c78ab111ad0fffc2004.png

下面对客户端上传视频流程简要梳理,其中罗列服务端需要支持的api

6b43150f4e6da968a41bf4e2fc16b884_ea2f5d7957e64bf5919e1c70665af7f9.png


   web客户端上传视频链接:https://help.aliyun.com/document_detail/52204.html,这里选择上传地址和凭证方式,也是官方推荐方式.简单对服务端涉及接口进行简单说明:

   CreateUploadVideo-获取音视频上传地址和凭证:

主要作用是客户端上传api中需要服务端传递指定的上传凭证、videoId等信息。官方文档地址:https://help.aliyun.com/document_detail/436543.html

注意返回的参数中官方文档中需要进行base解密,这里踩过坑,实际上不需要进行解密.

4480c66d794974e7898d62ebfe7a4670_5acd990bf4d7491dae18bd2eb4278da5.png

另外上传的音视频源文件不需要绝对路径,直接用文件名.mp4即可,这里前端的小伙伴也踩过坑,不清楚怎么获取客户端盘符路径,文档的示例确实有误导.

1cfade0cbdd52d2b3e5b4285157d48b3_8b7c762058704ba9baf39dc7bf65fed3.png


   RefreshUploadVideo - 刷新视频上传凭证:

主要作用视频文件上传超时后重新获取视频上传凭证。官方文档地址:https://help.aliyun.com/document_detail/436550.html

   GetUploadDetails - 获取媒体上传详情:

主要作用:获取媒体上传详情(如上传时间、已上传比例、上传来源等信息),用于决定前端调用获取视频播放地址接口的触发时机.就是说客户端调用阿里云上传接口响应成功之后不代表视频上传成功,其中可能会在转码,所以需要调用此接口查询一下上传完成的状态、上传完成的百分比或是转码是否完成。

官方地址:https://help.aliyun.com/document_detail/436548.html?spm=5176.8465980.help.dexternal.35f21450u0vJif&scm=20140722.S_help%40%40%E6%96%87%E6%A1%A3%40%40436548.S_os%2Bhot.ID_436548-RL_GetUploadDetails-LOC_consoleUNDhelp-OR_ser-V_2-P0_0

接口判断逻辑如下:

8b0abdd981ed17820ccba1139940d9ff_3c7d7b6cf8c74c9e8929d66b9a938307.png

关于视频转码问题,如果代码中没有关于转码的设置,一般是音视频点播控制台中进行了设置,具体查看路径如下:

b5edf64714cac1a6b0755d7b026f8497_435b2690155947fa9c004f0c9a55de65.png

对播放格式无特殊要求,可以不进行转码或是仅支持部分播放格式,原因是视频上传完成之后如果有预览的需求,进行转码的时间会很长。所以调用获取视频详情接口会有问题,并非视频上传失败,而是处于转码中。

   GetPlayInfo - 获取音视频播放地址:

主要作用是用于视频播放,如果上传视频支持转码操作,会返回标清、流畅、高清等格式的视频信息。调用顺序是在GetUploadDetails - 获取媒体上传详情之后。


服务端相关代码


客户端配置类:

@Component
@Data
public class TrainConfig {
    // 视频相关参数
    @Value("${aliyun.videoAccessKeyId}")
    private String videoAccessKeyId;
    @Value("${aliyun.videoAccessKeySecret}")
    private String videoAccessKeySecret;
    @Value("${aliyun.videoEndpoint}")
    private String videoEndpoint;
    @Bean
    public Client initUploadVideoClient() throws Exception {
        Config config = new Config()
                .setAccessKeyId(videoAccessKeyId)
                .setAccessKeySecret(videoAccessKeySecret);
        config.endpoint = videoEndpoint;
        Client client = new Client(config);
        return client;
    }
}


配置文件:application-dev.yml


aliyun:
  #视频上传相关参数
  videoAccessKeyId: xxxxxxxxxxxxxxxxxx
  videoAccessKeySecret: xxxxxxxxxxxxxxxxxx
  videoEndpoint: vod.cn-xxx.aliyuncs.com


视频上传逻辑:


@RequestMapping("/upload")
@RestController
@Validated
public class UploadFile {
    @Autowired
    private Client client;
    @ApiOperation("根据videoId获取视频信息(视频上传成功之后调用,响应参数说明:duration--视频时长,单位秒;playInfoList中playURL视频播放地址,支持根据不同清晰度获取)")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "videoId", value = "视频videoId", required = true, dataType = "String", paramType = "query",example = "1"),
    })
    @GetMapping("/findVideoInfo")
    public ResultVo<com.aliyun.vod20170321.models.GetPlayInfoResponseBody> findVideoInfo(@NotBlank(message = "视频id不允许为空!") String videoId) throws Exception {
        com.aliyun.vod20170321.models.GetPlayInfoRequest getPlayInfoRequest = new GetPlayInfoRequest().setVideoId(videoId);
        RuntimeOptions runtime = new RuntimeOptions();
        GetPlayInfoResponseBody getPlayInfoResponseBody=null;
        com.aliyun.vod20170321.models.GetPlayInfoResponse getPlayInfoResponse = client.getPlayInfoWithOptions(getPlayInfoRequest, runtime);
        if(ObjectUtil.isNotNull(getPlayInfoResponse)){
            getPlayInfoResponseBody  = getPlayInfoResponse.getBody();
        }
        return ResultVoUtil.success(getPlayInfoResponseBody);
    }
    @ApiOperation("获取上传凭证(web客户端上传)")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "fileName", value = "文件所在路径,示例:test2.mp4", required = true, dataType = "String", paramType = "query",example = "1"),
            @ApiImplicitParam(name = "title", value = "视频标题", required = true, dataType = "String", paramType = "query",example = "1"),
    })
    @GetMapping("/getUploadAuth")
    public ResultVo getUploadAuth(@NotBlank(message = "文件名不允许为空!") String fileName,@NotBlank(message = "视频标题不允许为空!")String title) throws Exception {
        CreateUploadVideoRequest createUploadVideoRequest = new CreateUploadVideoRequest().setFileName(fileName).setTitle(title);
        RuntimeOptions runtime = new RuntimeOptions();
        CreateUploadVideoResponse uploadVideoWithOptions=null;
        try {
            uploadVideoWithOptions = client.createUploadVideoWithOptions(createUploadVideoRequest, runtime);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
           throw new BussinessExcption(error.message);
        }
        CreateUploadVideoResponseBody createUploadVideoResponseBody = uploadVideoWithOptions.getBody();
        return ResultVoUtil.success(createUploadVideoResponseBody);
    }
    @ApiOperation("刷新上传凭证(web客户端上传)")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "videoId", value = "视频id", required = true, dataType = "String", paramType = "query",example = "1"),
    })
    @GetMapping("/refreshUploadVideo")
    public ResultVo RefreshUploadVideo(@NotBlank(message = "videoId不允许为空!") String videoId) throws Exception {
        RefreshUploadVideoRequest refreshUploadVideoRequest = new RefreshUploadVideoRequest().setVideoId(videoId);
        RuntimeOptions runtime = new RuntimeOptions();
        RefreshUploadVideoResponse refreshUploadVideoResponse=null;
        RefreshUploadVideoResponseBody refreshUploadVideoResponseBody=null;
        try {
           refreshUploadVideoResponse = client.refreshUploadVideoWithOptions(refreshUploadVideoRequest, runtime);
        }  catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            throw new BussinessExcption(error.message);
        }
        if(ObjectUtil.isNotNull(refreshUploadVideoResponse)){
           refreshUploadVideoResponseBody = refreshUploadVideoResponse.getBody();
        }
        return ResultVoUtil.success(refreshUploadVideoResponseBody);
    }
    @ApiOperation("获取视频上传详情信息(web客户端上传)Status为normal即为上传成功")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "videoId", value = "视频id", required = true, dataType = "String", paramType = "query",example = "1"),
    })
    @GetMapping("/getUploadDetails")
    public ResultVo getUploadDetails(@NotBlank(message = "videoId不允许为空!") String videoId) throws Exception {
        com.aliyun.vod20170321.models.GetUploadDetailsRequest getUploadDetailsRequest = new com.aliyun.vod20170321.models.GetUploadDetailsRequest().setMediaIds(videoId);
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        GetUploadDetailsResponse uploadDetailsWithOptions=null;
        try {
            uploadDetailsWithOptions = client.getUploadDetailsWithOptions(getUploadDetailsRequest, runtime);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            throw new BussinessExcption(error.message);
        }
        return ResultVoUtil.success(uploadDetailsWithOptions);
    }
}


相关依赖没有进行展示,可以直接从api调试控制台中进行复制,里面的依赖一定是最新的,官方文档更新很不及时,已经发现多次了,也算是踩过的坑!!!官方api调试地址:https://next.api.aliyun.com/api,可以直接下载项目复制最新的依赖信息.

449ee0d4799d7517dfed38e4eaadc21a_4d5c5461582f4aeebfbf735c07d286a5.png


   以上是阿里云上传视频客户端上传流程,希望对有相同需求的小伙伴有所帮助!欢迎评论区留言交流!


相关文章
|
监控 NoSQL 网络协议
使用cpolar内网穿透随时查看家中监控摄像头
使用cpolar内网穿透随时查看家中监控摄像头
|
存储 安全 机器人
如何下载阿里云视频点播数据
如何下载阿里云视频点播(VOD)数据
841 0
|
人工智能 机器人 开发者
AppFlow:为您的任意模型赋能——上下文连续会话能力
通过AppFlow,无需任何开发工作,即可使大型语言模型具备上下文连续对话的能力。本文以钉钉会话机器人为例,详细介绍如何配置这一功能:首先选择触发器,如钉钉机器人收到文本消息;接着配置上下文组件,组合当前和历史会话;然后选择模型,例如通义千问,并配置相应参数;更新上下文,设置对话内容和会话ID;最后将模型回答发送至钉钉。整个过程简单快捷,适用于多种触发器和模型。
550 1
AppFlow:为您的任意模型赋能——上下文连续会话能力
|
安全 网络安全 数据安全/隐私保护
|
前端开发 API Android开发
Flutter Canvas绘制快速入门
Flutter Canvas绘制快速入门
181 2
|
安全 网络安全 CDN
阿里云CDN HTTPS 证书配置流程
阿里云CDN HTTPS 证书配置流程
1557 1
|
网络协议 Java 开发工具
【 OSS 排查方案-9 上传 OSS 延迟超时】
基础排查 一、 上传 OSS 出现慢的场景,OSS 会返回一个 requestID 属性,请保留这个 requestID 这是 OSS 所有信息的查询入口,升级阿里云时可以快速定位问题,如果上传超时的话时没有这个属性的。
10600 1
|
SQL Java 大数据
5款开源BI工具优缺点及介绍
【4月更文挑战第15天】对比了几款开源BI报表工具:Superset以其高性能和高度可定制化受青睐,适合复杂分析;Metabase以其简洁易用和广泛兼容性脱颖而出,适合快速构建报表;DataEase以其轻量级和易部署特点吸引中小型企业;JasperReports擅长复杂报表生成,适合Java环境;Pentaho CE则是一体化平台,适合需要全面企业级功能的用户。选择时应结合公司需求、技术背景和数据规模来决定。
4640 6
|
人工智能 搜索推荐 Cloud Native
又发现一款 IT 人员必备的工具箱
又发现一款 IT 人员必备的工具箱
307 1
|
应用服务中间件 Linux nginx
NGINX配置HTTPS及PSF证书转换为PEM与KEY
NGINX配置HTTPS及PSF证书转换为PEM与KEY
1227 1