一、工具类
package com.yzpnb.video.util;
import com.aliyun.vod.upload.impl.UploadVideoImpl;
import com.aliyun.vod.upload.req.UploadStreamRequest;
import com.aliyun.vod.upload.resp.UploadStreamResponse;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.vod.model.v20170321.*;
import java.io.InputStream;
import java.util.List;
public class AliyunVideoUtil {
private String accessKeyId="LTAI4GGf4cjh4zZdNeKqUUGw";//id
private String accessKeySecret="oQpda38y0cCUql5TOmaYiSJYDz32OP";//密钥
private DefaultAcsClient client;
/**
* 初始化方法
* @param accessKeyId 你的证书id
* @param accessKeySecret 你的密钥
* @return
* @throws ClientException
*/
public 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;
}
/**
* 本地文件上传接口，并使用模板组转码(流形式)
*
* @paramT accessKeyId 已经封装到工具类，无需声明
* @paramT accessKeySecret 已经封装到工具类，无需声明
* @param title 上传之后文件名
* @param fileName 本地文件的路径和名称，就是你要上传的文件路径
* @param inputStream 上传文件流
*/
public String uploadVideo(String title, String fileName, InputStream inputStream) {
/**设置上传请求头，包含转码*/
UploadStreamRequest request = new UploadStreamRequest(accessKeyId, accessKeySecret, title, fileName,inputStream);
/* 视频分类ID(可选) */
//request.setCateId(0);
/* 模板组ID(可选) */
request.setTemplateGroupId("fc4c9920e7332c6c8d9518d4c00aaf54");
/**执行流上传，获取响应体*/
UploadVideoImpl uploader = new UploadVideoImpl();
UploadStreamResponse response = uploader.uploadStream(request);
if (response.isSuccess()) {
/* 如果设置回调URL无效，不影响视频上传，可以返回VideoId同时会返回错误码。其他情况上传失败时，VideoId为空，此时需要根据返回错误码分析具体错误原因 */
if(response.getVideoId()!=null) return response.getVideoId();
}
/****如果上传成功就将视频id返回****/
return response.getVideoId();
}
/**
* 提交媒体处理作业,视频转码
*/
public SubmitTranscodeJobsResponse submitTranscodeJobs(String id) throws Exception {
client=initVodClient(accessKeyId,accessKeySecret);
SubmitTranscodeJobsRequest request = new SubmitTranscodeJobsRequest();
//需要转码的视频ID
request.setVideoId(id);
//转码模板ID
request.setTemplateGroupId("fc4c9920e7332c6c8d9518d4c00aaf54");
return client.getAcsResponse(request);
}
/*获取播放地址函数*/
public String getPlayInfo(String id) throws Exception {
client=initVodClient(accessKeyId,accessKeySecret);
GetPlayInfoRequest request = new GetPlayInfoRequest();
GetPlayInfoResponse response = new GetPlayInfoResponse();
request.setVideoId(id);
response=client.getAcsResponse(request);
try {
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");
} catch (Exception e) {
System.out.print("ErrorMessage = " + e.getLocalizedMessage());
}
System.out.print("RequestId = " + response.getRequestId() + "\n");
return response.getRequestId();
}
/*获取播放凭证函数*/
public String getVideoPlayAuth(String id) throws Exception {
client=initVodClient(accessKeyId,accessKeySecret);
/***获取播放凭证***/
GetVideoPlayAuthRequest requestAuth = new GetVideoPlayAuthRequest();
GetVideoPlayAuthResponse responseAuth = new GetVideoPlayAuthResponse();
requestAuth.setVideoId(id);
responseAuth=client.getAcsResponse(requestAuth);
//播放凭证
System.out.println("PlayAuth = " + responseAuth.getPlayAuth() + "\n");
return responseAuth.getPlayAuth();
}
/**
* 删除视频
* @paramT client 发送请求客户端
* @return DeleteVideoResponse 删除视频响应数据
* @throws Exception
*/
public void deleteVideo(String ...idList) throws Exception {
client=initVodClient(accessKeyId,accessKeySecret);
DeleteVideoRequest request = new DeleteVideoRequest();
DeleteVideoResponse response = new DeleteVideoResponse();
StringBuffer stringBuffer=new StringBuffer();
for (String id:idList) {
stringBuffer.append(id + ",");//将所有视频id用逗号拼接
}
stringBuffer.deleteCharAt(stringBuffer.length()-1);//删除最后多余的逗号
//支持传入多个视频ID，多个用逗号分隔 request.setVideoIds("VideoId1,VideoId2");
request.setVideoIds(stringBuffer.toString());
try {
response=client.getAcsResponse(request);
} catch (Exception e) {
System.out.print("ErrorMessage = " + e.getLocalizedMessage());
}
System.out.print("RequestId = " + response.getRequestId() + "\n");
}
/**
* 删除多个视频
* @paramT client 发送请求客户端
* @return DeleteVideoResponse 删除视频响应数据
* @throws Exception
*/
public void deleteVideo(List<String> idList) throws Exception {
client=initVodClient(accessKeyId,accessKeySecret);
DeleteVideoRequest request = new DeleteVideoRequest();
DeleteVideoResponse response = new DeleteVideoResponse();
StringBuffer stringBuffer=new StringBuffer();
for (String id:idList) {
stringBuffer.append(id + ",");//将所有视频id用逗号拼接
}
stringBuffer.deleteCharAt(stringBuffer.length()-1);//删除最后多余的逗号
//支持传入多个视频ID，多个用逗号分隔 request.setVideoIds("VideoId1,VideoId2");
request.setVideoIds(stringBuffer.toString());
try {
response=client.getAcsResponse(request);
} catch (Exception e) {
System.out.print("ErrorMessage = " + e.getLocalizedMessage());
}
System.out.print("RequestId = " + response.getRequestId() + "\n");
}
}
二、service
package com.yzpnb.video.service.impl;
import com.yzpnb.service_base_handler.CustomExceptionHandler;
import com.yzpnb.video.service.VideoService;
import com.yzpnb.video.util.AliyunVideoUtil;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
@Service
public class VideoServiceImpl implements VideoService {
/**
*
* 上传本地视屏到阿里云
* @param videoFile
* @return
*/
@Override
public String uploadVideo(MultipartFile videoFile) {
/**1、上传**/
//1、创建封装阿里云视频操作的对象
AliyunVideoUtil aliyunVideoUtil=new AliyunVideoUtil();
String videoId = null;
//2、获取输入流，文件名等等
try {
InputStream inputStream = videoFile.getInputStream();
String fileName=videoFile.getOriginalFilename();//获取文件名
/**
* 设置上传文件名，获取文件名中第一个字符到“.”的前一个字符
* substring：字符串截取函数，截取起始索引到末尾索引的前一个字符
* lastIndexOf：从字符串最后面往前找，找我们指定的字符，找到的第一匹配的字符，返回字符的下标
*/
String title=fileName.substring(0,fileName.lastIndexOf("."));
videoId=aliyunVideoUtil.uploadVideo(title,fileName,inputStream);
} catch (IOException e) {
e.printStackTrace();
}
return videoId;
}
/**
* 根据id删除视频
* @param videoId
*/
@Override
public void removeVideo(String videoId) {
//1、创建封装阿里云视频操作的对象
AliyunVideoUtil aliyunVideoUtil=new AliyunVideoUtil();
//2、删除视频
try {
aliyunVideoUtil.deleteVideo(videoId);
} catch (Exception e) {
throw new CustomExceptionHandler(20001,"删除失败");
}
}
/**
* 根据id集合批量删除视频
* @param videoIdList
*/
@Override
public void removeVideoList(List<String> videoIdList) {
//1、创建封装阿里云视频操作的对象
AliyunVideoUtil aliyunVideoUtil=new AliyunVideoUtil();
//2、删除视频
try {
aliyunVideoUtil.deleteVideo(videoIdList);
} catch (Exception e) {
throw new CustomExceptionHandler(20001,"删除失败");
}
}
}
三、controller
package com.yzpnb.video.controller;
import com.yzpnb.common_utils.Result;
import com.yzpnb.video.service.VideoService;
import com.yzpnb.video.util.AliyunVideoUtil;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.apache.ibatis.io.ResolverUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.ws.rs.Path;
import java.util.List;
@RestController
@RequestMapping("/videoservice/")
@CrossOrigin
public class VideoController {
@Autowired
VideoService videoService;
@ApiOperation("上传视频（以流形式上传，并且直接转码）")
@PostMapping("uploadVideo")
public Result uploadVideo(@ApiParam(name = "videoFile",value = "用户上传的文件") MultipartFile file){
System.out.println(file.toString());
String videoId=videoService.uploadVideo(file);
return Result.ok().data("videoId",videoId);
}
@ApiOperation("根据视频id删除视频")
@DeleteMapping("{videoId}")
public Result removeVideo(@ApiParam(name = "videoId", value = "云端视频id", required = true)
@PathVariable String videoId){
videoService.removeVideo(videoId);
return Result.ok().message("视频删除成功");
}
@ApiOperation("批量删除视频")
@DeleteMapping("removeVideoList")
public Result removeVideoList(@ApiParam(name = "videoId", value = "云端视频id", required = true)
@RequestBody List<String> videoIdList){
videoService.removeVideoList(videoIdList);
return Result.ok().message("视频删除成功");
}
@ApiOperation("根据视频id获取视频凭证")
@GetMapping("getVideoPlayAuth/{id}")
public Result getVideoPlayAuth(@ApiParam(name = "id",value = "视频id")
@PathVariable String id){
try {
String playAuth=new AliyunVideoUtil().getVideoPlayAuth(id);
return Result.ok().message("视频凭证获取成功").data("playAuth",playAuth);
} catch (Exception e) {
return Result.error().message("视频凭证获取失败");
}
}
}
![Java小案例——随机数猜测随机数猜测[图]](data:image/gif;base64,R0lGODlhAQABAIAAAP///wAAACwAAAAAAQABAAACAkQBADs=)