devbox
我家小花儿
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

阿里云视频点播+项目实战_com.aliyun.vod.upload.impl.uploadvideoimpl.uploads

作者：我家小花儿 | 2024-03-16 01:15:34

赞

踩

com.aliyun.vod.upload.impl.uploadvideoimpl.uploadstream(uploadvideoimpl.java

目录

整合阿里云Vod实现视频上传

整合阿里云视频播放器

 前端方面

场景：

功能十分多，可以对视频进行加密，防止盗链，并且节省了资源，覆盖了加速节点，安全系数高

 流程：

  • 用户获取上传授权。
  • VoD下发 上传地址和凭证 及 VideoId。
  • 用户上传视频保存视频ID(VideoId)。
  • 用户服务端获取播放凭证。
  • VoD下发带时效的播放凭证。
  • 用户服务端将播放凭证下发给客户端完成视频播放。

 设置转码格式

 配置域名

 

 项目实战

配置文件 

  1. <dependencies>
  2.     <dependency>
  3.         <groupId>com.aliyun</groupId>
  4.         <artifactId>aliyun-java-sdk-core</artifactId>
  5.     </dependency>
  6.     <dependency>
  7.         <groupId>com.aliyun.oss</groupId>
  8.         <artifactId>aliyun-sdk-oss</artifactId>
  9.     </dependency>
  10.     <dependency>
  11.         <groupId>com.aliyun</groupId>
  12.         <artifactId>aliyun-java-sdk-vod</artifactId>
  13.     </dependency>
  14.     <dependency>
  15.         <groupId>com.aliyun</groupId>
  16.         <artifactId>aliyun-sdk-vod-upload</artifactId>
  17.     </dependency>
  18.     <dependency>
  19.         <groupId>com.alibaba</groupId>
  20.         <artifactId>fastjson</artifactId>
  21.     </dependency>
  22.     <dependency>
  23.         <groupId>org.json</groupId>
  24.         <artifactId>json</artifactId>
  25.     </dependency>
  26.     <dependency>
  27.         <groupId>com.google.code.gson</groupId>
  28.         <artifactId>gson</artifactId>
  29.     </dependency>
  30.  
  31.     <dependency>
  32.         <groupId>joda-time</groupId>
  33.         <artifactId>joda-time</artifactId>
  34.     </dependency>
  35. </dependencies>
  1. # 服务端口
  2. server.port=8003
  3. # 服务名
  4. spring.application.name=service-vod
  5.  
  6. # 环境设置：dev、test、prod
  7. spring.profiles.active=dev
  8.  
  9. #阿里云 vod
  10. #不同的服务器，地址不同
  11. aliyun.vod.file.keyid=your accessKeyId
  12. aliyun.vod.file.keysecret=your accessKeySecret
  13.  
  14. # 最大上传单个文件大小：默认1M
  15. spring.servlet.multipart.max-file-size=1024MB
  16. # 最大置总上传的数据大小 ：默认10M
  17. spring.servlet.multipart.max-request-size=1024MB

启动类

  1. package com.guli.vod;
  2.  
  3. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
  4. @ComponentScan(basePackages={"com.atguigu"})
  5. public class VodApplication {
  6.  
  7. 	public static void main(String[] args) {
  8. 		SpringApplication.run(VodApplication.class, args);
  9. 	}
  10. }

整合阿里云Vod实现视频上传

1.创建一个常量类读取配置文件配置的视频点播的密钥

  1. package com.guli.vod.util;
  2.  
  3. @Component
  4. //@PropertySource("classpath:application.properties")
  5. public class ConstantPropertiesUtil implements InitializingBean {
  6.  
  7. 	@Value("${aliyun.vod.file.keyid}")
  8. 	private String keyId;
  9.  
  10. 	@Value("${aliyun.vod.file.keysecret}")
  11. 	private String keySecret;
  12.  
  13. 	public static String ACCESS_KEY_ID;
  14. 	public static String ACCESS_KEY_SECRET;
  15.  
  16. 	@Override
  17. 	public void afterPropertiesSet() throws Exception {
  18. 		ACCESS_KEY_ID = keyId;
  19. 		ACCESS_KEY_SECRET = keySecret;
  20. 	}
  21. }

2.创建一个VodClient客户端

通过地域节点，key和密钥塑造一个客户端client

  1. package com.atguigu.vod.Utils;
  2.  
  3. import com.aliyuncs.DefaultAcsClient;
  4. import com.aliyuncs.exceptions.ClientException;
  5. import com.aliyuncs.profile.DefaultProfile;
  6.  
  7. public class InitVodClient {
  8.  
  9.     //填入AccessKey信息
  10.     public static DefaultAcsClient initVodClient(String accessKeyId, String accessKeySecret) throws ClientException {
  11.         String regionId = "cn-shanghai";  // 点播服务接入地域
  12.         DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
  13.         DefaultAcsClient client = new DefaultAcsClient(profile);
  14.         return client;
  15.     }
  16. }

3.创建Service接口，并创建对应的业务逻辑

  1. package com.guli.vod.service;
  2. public interface VideoService {
  3. 	String uploadVideo(MultipartFile file);
  4. }

4.业务类，上传视频到阿里云

根据我们的demo写法就行，1.首先是得到上传文件的名称，定义一个流——>2.然后将key和密钥，文件名称，流封装到UploadStreamRequest中——>3.根据UploadVideoImpl定义的上传api：uploadStream（）将请求封装起来得到响应UploadStreamResponse——>4.最后判断响应状态，返回响应的vido的id

删除阿里云视频，业务类似，只是说用的request请求不再是上传了，用的是删除

  1. package com.atguigu.vod.service.impl;
  2.  
  3. import com.aliyun.vod.upload.impl.UploadVideoImpl;
  4. import com.aliyun.vod.upload.req.UploadFileStreamRequest;
  5. import com.aliyun.vod.upload.req.UploadStreamRequest;
  6. import com.aliyun.vod.upload.resp.UploadFileStreamResponse;
  7. import com.aliyun.vod.upload.resp.UploadStreamResponse;
  8. import com.aliyuncs.DefaultAcsClient;
  9. import com.aliyuncs.exceptions.ClientException;
  10. import com.aliyuncs.vod.model.v20170321.DeleteVideoRequest;
  11. import com.atguigu.eduservice.R;
  12. import com.atguigu.eduservice.exceptionHandler.GuliException;
  13. import com.atguigu.vod.Utils.ConstantVodUtils;
  14. import com.atguigu.vod.Utils.InitVodClient;
  15. import com.atguigu.vod.service.VodService;
  16. import org.apache.commons.lang3.StringUtils;
  17. import org.springframework.stereotype.Service;
  18. import org.springframework.web.multipart.MultipartFile;
  19.  
  20. import java.io.InputStream;
  21. import java.util.List;
  22.  
  23. @Service
  24. public class VodServiceImpl implements VodService {
  25.  
  26.     /**
  27.      * 上传视频到阿里云
  28.      * @param file
  29.      * @return
  30.      */
  31.     @Override
  32.     public String uploadVideoAly(MultipartFile file) {
  33.  
  34.         try {
  35.             //accessKeyId, accessKeySecret
  36.             //fileName：上传文件原始名称
  37.             String fileName = file.getOriginalFilename();
  38.             //title：上传之后显示名称
  39.             String title = fileName.substring(0, fileName.lastIndexOf("."));
  40.             //inputStream：上传文件输入流
  41.             InputStream inputStream = file.getInputStream();
  42.             UploadStreamRequest request = new UploadStreamRequest(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET, title, fileName, inputStream);
  43.  
  44.             UploadVideoImpl uploader = new UploadVideoImpl();
  45.             UploadStreamResponse response = uploader.uploadStream(request);
  46.  
  47.             String videoId = null;
  48.             if (response.isSuccess()) {
  49.                 videoId = response.getVideoId();
  50.             } else { //如果设置回调URL无效，不影响视频上传，可以返回VideoId同时会返回错误码。其他情况上传失败时，VideoId为空，此时需要根据返回错误码分析具体错误原因
  51.                 videoId = response.getVideoId();
  52.             }
  53.             return videoId;
  54.         } catch (Exception e) {
  55.             e.printStackTrace();
  56.             return null;
  57.         }
  58.     }
  59.  
  60.     /**
  61.      * 删除多个云视频
  62.      * @param videoIdList
  63.      */
  64.     @Override
  65.     public void removeMoreAlyVideo(List<String> videoIdList) {
  66.         try {
  67.             //初始化对象(连接我们的云客户端)
  68.             DefaultAcsClient client = InitVodClient.initVodClient(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET);
  69.             //创建删除视频的request对象
  70.             DeleteVideoRequest request = new DeleteVideoRequest();
  71.             //将videoIdList值转为1，2，3这种
  72.             String videoIds = StringUtils.join(videoIdList.toArray(), ",");
  73.  
  74.             //然后向request设置视频id
  75.             request.setVideoIds(videoIds);
  76.             //返回response
  77.             client.getAcsResponse(request);
  78.         } catch (ClientException e) {
  79.             e.printStackTrace();
  80.             throw new GuliException(20001,"删除视频失败");
  81.         }
  82.     }
  83.  
  84. }

5.控制层

  1. package com.atguigu.vod.controller;
  2.  
  3. import com.aliyuncs.DefaultAcsClient;
  4. import com.aliyuncs.exceptions.ClientException;
  5. import com.aliyuncs.vod.model.v20170321.DeleteVideoRequest;
  6. import com.aliyuncs.vod.model.v20170321.GetVideoPlayAuthRequest;
  7. import com.aliyuncs.vod.model.v20170321.GetVideoPlayAuthResponse;
  8. import com.atguigu.eduservice.R;
  9. import com.atguigu.eduservice.exceptionHandler.GuliException;
  10. import com.atguigu.vod.Utils.ConstantVodUtils;
  11. import com.atguigu.vod.Utils.InitVodClient;
  12. import com.atguigu.vod.service.VodService;
  13. import io.swagger.annotations.Api;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.web.bind.annotation.*;
  16. import org.springframework.web.multipart.MultipartFile;
  17.  
  18. import java.util.List;
  19.  
  20. @Api(description = "上传视频")
  21. @RestController
  22. @RequestMapping("/eduvod/video")
  23. @CrossOrigin
  24. public class CodController {
  25.  
  26.     @Autowired
  27.     private VodService vodService;
  28.  
  29.     /**
  30.      * 1.上传视频到阿里云
  31.      */
  32.     @PostMapping("uploadAlyiVideo")
  33.     public R uploadAlyiVideo(MultipartFile file){
  34.        String vodId=vodService.uploadVideoAly(file);
  35.         return R.ok().data("vodId",vodId);
  36.     }
  37.  
  38.     /**
  39.      * 2.根据id删除阿里云视频
  40.      * 这里需要注意，我们只是删除了阿里云的东西，如果数据库中小节里面的视频id要删除还需要再前端调用接口进行思考
  41.      */
  42.     @DeleteMapping("removeAlyVideo/{id}")
  43.     public R removeAlyVideo(@PathVariable String id){
  44.         try {
  45.             //初始化对象(连接我们的云客户端)
  46.             DefaultAcsClient client = InitVodClient.initVodClient(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET);
  47.             //创建删除视频的request对象
  48.             DeleteVideoRequest request = new DeleteVideoRequest();
  49.             //然后向request设置视频id
  50.             request.setVideoIds(id);
  51.             //返回response
  52.             client.getAcsResponse(request);
  53.             return R.ok();
  54.         } catch (ClientException e) {
  55.             e.printStackTrace();
  56.             throw new GuliException(20001,"删除视频失败");
  57.         }
  58.     }
  59.  
  60.     /**
  61.      * 3.删除多个阿里云视频
  62.      * 参数：多个视频id
  63.      */
  64.     @DeleteMapping("delete-batch")
  65.     public R deleteBatch(@RequestParam("videoIdList") List<String> videoIdList){
  66.         vodService.removeMoreAlyVideo(videoIdList);
  67.  
  68.         return R.ok();
  69.     }
  70.  
  71.  
  72.     /**
  73.      * 4.根据视频id获取视频凭证
  74.      */
  75.     @GetMapping("getPlayAuth/{vid}")
  76.     public R getPlayAuth(@PathVariable String vid){
  77.         try {
  78.             //1.初始化对象client
  79.             DefaultAcsClient client = InitVodClient.initVodClient(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET);
  80.             //2.创建获取凭证的request和resp对象
  81.             GetVideoPlayAuthRequest request = new GetVideoPlayAuthRequest();
  82.             //3.向req中设置视频id
  83.             request.setVideoId(vid);
  84.             //4.调用方法得到凭证
  85.             GetVideoPlayAuthResponse response = client.getAcsResponse(request);
  86.  
  87.             String playAuth = response.getPlayAuth();
  88.             return R.ok().data("playAuth",playAuth);
  89.         } catch (Exception e) {
  90.           throw new GuliException(20001,"获取凭证失败");
  91.         }
  92.  
  93.     }
  94.  
  95. }

整合阿里云视频播放器

 1.首先根据VodClient利用key和密钥初始化一个client——>2.然后定义一个获取视频凭证的request，里面封装视频id——>3.然后client通过这个reuqest请求得到response凭证——>4.最后根据response去getPlayAuth凭证并且进行响应

  1. package com.guli.vod.controller;
  2.  
  3. @Api(description="阿里云视频点播微服务")
  4. @CrossOrigin //跨域
  5. @RestController
  6. @RequestMapping("/vod/video")
  7. public class VideoController {
  8.  
  9. 	@GetMapping("get-play-auth/{videoId}")
  10. 	public R getVideoPlayAuth(@PathVariable("videoId") String videoId) throws Exception {
  11.  
  12. 		//获取阿里云存储相关常量
  13. 		String accessKeyId = ConstantPropertiesUtil.ACCESS_KEY_ID;
  14. 		String accessKeySecret = ConstantPropertiesUtil.ACCESS_KEY_SECRET;
  15.  
  16. 		//初始化
  17. 		DefaultAcsClient client = AliyunVodSDKUtils.initVodClient(accessKeyId, accessKeySecret);
  18.  
  19. 		//请求
  20. 		GetVideoPlayAuthRequest request = new GetVideoPlayAuthRequest();
  21. 		request.setVideoId(videoId);
  22.  
  23. 		//响应
  24. 		GetVideoPlayAuthResponse response = client.getAcsResponse(request);
  25.  
  26. 		//得到播放凭证
  27. 		String playAuth = response.getPlayAuth();
  28.  
  29. 		//返回结果
  30. 		return R.ok().message("获取凭证成功").data("playAuth", playAuth);
  31. 	}	
  32. }

 前端方面

1.点击之后进入这个url，并且传入视频的id，这个视频也就是我们的小节，小节上面是我们的章节，章节上面是课程，层层封装，我们只需要再页面中获取我们的课程信息就可以进而获取章节和视频id了

  1.  <ol class="lh-menu-ol" style="display: block">
  2.                               <li
  3.                                 class="lh-menu-second ml30"
  4.                                 v-for="video in chapter.children"
  5.                                 :key="video.id"
  6.                               >
  7.                                 <a
  8.                                   :href="'/player/' + video.videoSourceId"
  9.                                   target="_blank"
  10.                                 >
  11.                                   <span class="fr">
  12.                                     <i class="free-icon vam mr10">在线观看</i>
  13.                                   </span>
  14.                                   <em class="lh-menu-i-2 icon16 mr5">&nbsp;</em
  15.                                   >{{ video.title }}
  16.                                 </a>
  17.                               </li>
  18.                             </ol>

2.从这个api中调用后台接口获取视频凭证

  1. const api_name = '/vod/video'
  2.  
  3. export default {
  4.  
  5.   getPlayAuth(vid) {
  6.     return request({
  7.       url: `${api_name}/get-play-auth/${vid}`,
  8.       method: 'get'
  9.     })
  10.   }
  11.  
  12. }

3.创建播放的页面

  1. <template>
  2.   <div>
  3.  
  4.     <!-- 阿里云视频播放器样式 -->
  5.     <link rel="stylesheet" href="https://g.alicdn.com/de/prismplayer/2.8.1/skins/default/aliplayer-min.css" >
  6.     <!-- 阿里云视频播放器脚本 -->
  7.     <script charset="utf-8" type="text/javascript" src="https://g.alicdn.com/de/prismplayer/2.8.1/aliplayer-min.js" />
  8.  
  9.     <!-- 定义播放器dom -->
  10.     <div id="J_prismPlayer" class="prism-player" />
  11.   </div>
  12. </template>

4.通过异步方法根据视频id获取播放凭证

  1. <script>
  2. import vod from '@/api/vod'
  3. export default {
  4.     
  5.   layout: 'video',//应用video布局
  6.   asyncData({ params, error }) {
  7.     return vod.getPlayAuth(params.vid).then(response => {
  8.       // console.log(response.data.data)
  9.       return {
  10.         vid: params.vid,
  11.         playAuth: response.data.data.playAuth
  12.       }
  13.     })
  14.   }
  15. }
  16. </script>

5.创建播放器

  1.  /**
  2.  * 页面渲染完成时：此时js脚本已加载，Aliplayer已定义，可以使用
  3.  * 如果在created生命周期函数中使用，Aliplayer is not defined错误
  4.  */
  5. mounted() {
  6.     
  7.     new Aliplayer({
  8.         id: 'J_prismPlayer',
  9.         vid: this.vid, // 视频id
  10.         playauth: this.playAuth, // 播放凭证
  11.         encryptType: '1', // 如果播放加密视频，则需设置encryptType=1，非加密视频无需设置此项
  12.         width: '100%',
  13.         height: '500px'
  14.     }, function(player) {
  15.         console.log('播放器创建成功')
  16.     })
  17. }

其他选项

  1. // 以下可选设置
  2. cover: 'http://guli.shop/photo/banner/1525939573202.jpg', // 封面
  3. qualitySort: 'asc', // 清晰度排序
  4.  
  5. mediaType: 'video', // 返回音频还是视频
  6. autoplay: false, // 自动播放
  7. isLive: false, // 直播
  8. rePlay: false, // 循环播放
  9. preload: true,
  10. controlBarVisibility: 'hover', // 控制条的显示方式：鼠标悬停
  11. useH5Prism: true, // 播放器类型：html5

功能展示：阿里云Aliplayer播放器

本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号