开发场景:基于阿里云的云点播技术,实现上传、编辑、在线播放视频

开通阿里云点播

搜索阿里云官网,搜素视频点播,开通服务(按量计费)。开启存储管理。

SDK文档

查看服务端API、服务端SDK、上传SDK

API: 阿里云提供固定的地址,只需要调用这个固定的地址,向地址传递参数、实现功能 (httpclient技术可以调用api地址)
SDK: sdk对api方法进行封装,更方便使用。之前使用EasyExcel调用调用阿里云提供类或则接口里面的方法是实现视频功能

由于上传视频可以进行加密,加密之后,使用加密之后地址不能进行视频播放,在数据库存储不存地址,而是存储视频id

视频播放

1.在service创建子模块serice_vod引入相关依赖

<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
<version>4.3.3</version>
</dependency>
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.1.0</version>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-vod</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.28</version>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20170516</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.2</version>
</dependency>

2.初始化操作,创建DefaultAcsClient对象

public static DefaultAcsClient initVodClient(String accessKeyId, String accessKeySecret) throws ClientException {
String regionId = "cn-shanghai"; // 点播服务接入区域
DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
DefaultAcsClient client = new DefaultAcsClient(profile);
return client;
}

获取视频播放地址 (根据视频id获取到)

//1 根据视频ID获取视频播放地址
//创建初始化对象
DefaultAcsClient client = InitObject.initVodClient("************", "************");

//创建获取视频地址request和response
GetPlayInfoRequest request = new GetPlayInfoRequest();
GetPlayInfoResponse response = new GetPlayInfoResponse();

//向request对象里面设置视频id
request.setVideoId("e64d6b55f7194941bd94481dcfa1b5d5");


//调用初始化对象里面的方法,传递request,获取数据
response = client.getAcsResponse(request);


List<GetPlayInfoResponse.PlayInfo> playInfoList = response.getPlayInfoList();
//播放地址
for (GetPlayInfoResponse.PlayInfo playInfo : playInfoList) {
System.out.print("PlayInfo.PlayURL = " + playInfo.getPlayURL() + "\n");
}
//Base信息 视频名
System.out.print("VideoBase.Title = " + response.getVideoBase().getTitle() + "\n");

获取视频播放凭证 (根据视频id获取到视频播放凭证)

//根据视频id获取视频播放凭证
//创建初始化对象
DefaultAcsClient client = InitObject.initVodClient("************", "************");
//创建获取视频凭证request和response
GetVideoPlayAuthRequest request = new GetVideoPlayAuthRequest();
GetVideoPlayAuthResponse response = new GetVideoPlayAuthResponse();
//向request设置视频id
request.setVideoId("e64d6b55f7194941bd94481dcfa1b5d5");
//调用初始化对象的方法得到凭证
response = client.getAcsResponse(request);
System.out.println("playauth:"+response.getPlayAuth());

上传视频到阿里云视频点播服务

由于aliyun-sdk-vod-upload没有开源,所以不能直接在pom文件中直接引用依赖。
解决:将依赖安装在本地maven仓库

  1. 去官网下载 测试样例aliyun,网址:
    https://help.aliyun.com/document_detail/51992.html?spm=a2c4g.11186623.6.1029.2dab6cecZfMGvO
  2. 将测试样例解压,进入lib目录下,在命令行执行下面的命令
    mvn install:install-file -DgroupId=com.aliyun -DartifactId=aliyun-java-vod-upload -Dversion=1.4.11 -Dpackaging=jar -Dfile=aliyun-java-vod-upload-1.4.11.jar

    ==在这个命令中,我在网上看到的都是错的,很搞笑的错误,多注意下面的对应关系==

  • DgroupId 对应 — < groupId >

  • DartifactId 对应 – < artifactId >

  • Dversion 对应 – < version >

  • Dfile 对应jar包在你电脑上的路径

其次你必须配置好maven的环境变量不然无法运行该命令(会安装到maven设置好的本地仓库中)

  1. pom文件引入依赖

    <dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-sdk-vod-upload</artifactId>
    <version>1.4.11</version>
    </dependency>
  2. 上传视频

    //上传视频的方法
    String accessKeyId="************";
    String accessKeySecret="************";
    String title="3 - How Does Project Submission Work - upload by sdk"; //上传之后文件名称
    String fileName="F:\\java\\课件笔记源码资料\\1_课件\\在线教育平台\\谷里\\项目资料\\1-阿里云上传测试视频\\6 - What If I Want to Move Faster.mp4"; //本地文件路径和名称
    UploadVideoRequest request = new UploadVideoRequest(accessKeyId, accessKeySecret, title, fileName);
    /* 可指定分片上传时每个分片的大小,默认为2M字节 */
    request.setPartSize(2 * 1024 * 1024L);
    /* 可指定分片上传时的并发线程数,默认为1,(注:该配置会占用服务器CPU资源,需根据服务器情况指定)*/
    request.setTaskNum(1);
    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadVideoResponse response = uploader.uploadVideo(request);
    System.out.print("RequestId=" + response.getRequestId() + "\n"); //请求视频点播服务的请求ID
    if (response.isSuccess()) {
    System.out.print("VideoId=" + response.getVideoId() + "\n");
    } else {
    /* 如果设置回调URL无效,不影响视频上传,可以返回VideoId同时会返回错误码。其他情况上传失败时,VideoId为空,此时需要根据返回错误码分析具体错误原因 */
    System.out.print("VideoId=" + response.getVideoId() + "\n");
    System.out.print("ErrorCode=" + response.getCode() + "\n");
    System.out.print("ErrorMessage=" + response.getMessage() + "\n");
    }

删除阿里云点播视频

//创建初始化对象
DefaultAcsClient client = InitObject.initVodClient("********", "********");

//创建删除视频的request和response
DeleteVideoRequest request = new DeleteVideoRequest();
DeleteVideoResponse response = new DeleteVideoResponse();

//支持传入多个视频ID,多个用逗号分隔
//request.setVideoIds("VideoId1,VideoId2");
request.setVideoIds("e64d6b55f7194941bd94481dcfa1b5d5");


//调用初始化对象里面的方法,传递request,获取数据
try {
response = client.getAcsResponse(request);
} catch (Exception e) {
System.out.print("ErrorMessage = " + e.getLocalizedMessage());
}


System.out.print("RequestId = " + response.getRequestId() + "\n");

视频点播微服务的创建(实践)

创建微服务模块

Artifact:service-vod

pom文件引入依赖

<dependencies>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
</dependency>
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-vod</artifactId>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-sdk-vod-upload</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>

<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
</dependency>
</dependencies>

application.properties

# 服务端口
server.port=8003
# 服务名
spring.application.name=service-vod

# 环境设置:dev、test、prod
spring.profiles.active=dev

#阿里云 vod
#不同的服务器,地址不同
aliyun.vod.file.keyid=your accessKeyId
aliyun.vod.file.keysecret=your accessKeySecret

# 最大上传单个文件大小:默认1M
spring.servlet.multipart.max-file-size=1024MB
# 最大置总上传的数据大小 :默认10M
spring.servlet.multipart.max-request-size=1024MB

创建启动类

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@ComponentScan(basePackages = {"com.zzf"})
public class ServiceVodApplication {

public static void main(String[] args) {
SpringApplication.run(ServiceVodApplication.class, args);
}

}

创建ConstantVodUtils

//当项目已启动,spring接口,spring加载之后,执行接口一个方法
@Component
public class ConstantVodUtils implements InitializingBean {

//读取配置文件内容
@Value("${aliyun.vod.file.keyid}")
private String accessKeyId;
@Value("${aliyun.vod.file.keysecret}")
private String accessKeySecret;


//定义公开静态常量
public static String ACCESS_KEY_ID;
public static String ACCESS_KEY_SECRET;


//在Spring容器加载完上面的属性之后执行
@Override
public void afterPropertiesSet() throws Exception {
ACCESS_KEY_ID = accessKeyId;
ACCESS_KEY_SECRET = accessKeySecret;
}
}

上传视频应用

创建Controller、Serivce层,此处主要记录serviceImpl的内容

  1. 后端代码实现
    //上传视频到阿里云
    @Override
    public String uploadAlyVideo(MultipartFile file) {

    try {
    //accessKeyId, accessKeySecret,
    // title:上传之后显示名称 获取文件名字(去掉文件格式名字 .mp4)
    String originalFilename = file.getOriginalFilename();
    //lastIndexOf(String str) 获取某字符串起始索引
    String title = originalFilename.substring(0,originalFilename.lastIndexOf("."));

    // fileName:上传文件原始名称
    // 01.MP4
    String fileName = file.getOriginalFilename();
    // inputStream:上传文件输入流
    InputStream inputStream = file.getInputStream();

    UploadStreamRequest request = new UploadStreamRequest(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET, title, fileName, inputStream);
    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadStreamResponse response = uploader.uploadStream(request);

    String videoId = null;
    if (response.isSuccess()) {
    videoId = response.getVideoId();
    } else { //如果设置回调URL无效,不影响视频上传,可以返回VideoId同时会返回错误码。其他情况上传失败时,VideoId为空,此时需要根据返回错误码分析具体错误原因
    videoId = response.getVideoId();
    }
    return videoId;
    } catch (Exception e) {
    e.printStackTrace();
    return null;
    }
    }

  2. 前端实现
  • 整合上传组件

    <el-form-item label="上传视频">
    <el-upload
    :on-success="handleVodUploadSuccess"
    :on-remove="handleVodRemove"
    :before-remove="beforeVodRemove"
    :on-exceed="handleUploadExceed"
    :file-list="fileList"
    :action="BASE_API+'/admin/vod/video/upload'"
    :limit="1"
    class="upload-demo">
    <el-button size="small" type="primary">上传视频</el-button>
    <el-tooltip placement="right-end">
    <div slot="content">最大支持1G,<br>
    支持3GP、ASF、AVI、DAT、DV、FLV、F4V、<br>
    GIF、M2T、M4V、MJ2、MJPEG、MKV、MOV、MP4、<br>
    MPE、MPG、MPEG、MTS、OGG、QT、RM、RMVB、<br>
    SWF、TS、VOB、WMV、WEBM 等视频格式上传</div>
    <i class="el-icon-question">
    </el-tooltip>
    </el-upload>
    </el-form-item>
  • 数据定义

    fileList: [],//上传文件列表
    BASE_API: process.env.BASE_API // 接口API地址
  • 配置nginx反向代理
    将接口地址加入nginx配置

    location ~ /vod/ {           
    proxy_pass http://localhost:8003;
    }

配置nginx上传文件大小,否则上传时会有 413 (Request Entity Too Large) 异常
打开nginx主配置文件nginx.conf,找到http{},添加

client_max_body_size 1024m;

重启nginx

nginx -s reload

删除视频应用

  1. 后端接口
  • 初始化DefaultAcsClient

    public class InitVodClient {

    public static DefaultAcsClient initVodClient(String accessKeyId, String accessKeySecret) {
    String regionId = "cn-shanghai"; // 点播服务接入区域
    DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
    DefaultAcsClient client = new DefaultAcsClient(profile);
    return client;
    }
    }
  • 根据视频id删除阿里云视频

    //根据视频id删除阿里云视频
    @DeleteMapping("removeAlyVideo/{id}")
    public R removeAlyVideo(@PathVariable String id){
    try{
    //初始化对象
    DefaultAcsClient client = InitVodClient.initVodClient(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET);
    //创建删除视频request对象
    DeleteVideoRequest request = new DeleteVideoRequest();
    //向request设置视频id
    request.setVideoIds(id);
    //调用初始化对象的方法实现删除
    client.getAcsResponse(request);
    return R.ok();

    }catch(Exception e){
    e.printStackTrace();
    throw new GuliException(20001,"删除视频失败");
    }
    }
  1. 前端实现
  • video.js 代码实现

    //删除视频
    deleteAliyunvod(id){
    return request({
    url:`/eduvod/video/removeAlyVideo/${id}`,
    method:"delete"
    })
    },
  • 页面调用

    //点击确定调用的方法
    handleVodRemove(){
    //调用接口的删除视频的方法
    video.deleteAliyunvod(this.video.videoSourceId)
    .then(reponse =>{
    //提示信息
    this.$message({
    type: 'success',
    message: '删除视频成功!'
    });

    //把文件列表清空
    this.fileList = []
    //把video视频id和视频名称值清空
    //上传视频id赋值
    this.video.videoSourceId = ''
    //上传视频名称赋值
    this.video.videoOriginalName = ''
    })
    },
    //点击x调用这个方法
    beforeVodRemove(file,fileList){
    return this.$confirm(`确定移除${file.name}?`);
    },