文章目錄
- 1、依賴POM
- 2、配置檔案(application.yml)
- 3、讀取配置類
- 4、初始化檔案
- 5、Controller
- 6、Service
- 7、impl
注意:阿裡雲開通視訊點播自行開通
1、依賴POM
<dependencies>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
<version>4.5.1</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.11</version>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-sdk-vod-upload</artifactId>
<version>1.4.13</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.62</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>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
<version>2.10.1</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>sonatype-nexus-staging</id>
<name>Sonatype Nexus Staging</name>
<url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
2、配置檔案(application.yml)
#服務端口
server:
port: 8003
#服務名
spring:
application:
name: service-vod
profiles:
active: dev # 環境設定:dev、test、prod
servlet:
multipart:
max-file-size: 1024MB # 最大上傳單個檔案大小,m預設1M
max-request-size: 1024MB # 最大總上傳的資料大小,預設10M
#阿裡雲vod
# 不同的伺服器,位址不同
aliyun:
vod:
file:
keyid: 自己的keyid
keysecret: 自己的keysecret
3、讀取配置類
package com.zhz.vod.config.properties;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
/**
* @author zhouhengzhe
* @Description: 視訊讀取配置類
* @date 2021/8/1下午4:57
*/
@Component
public class VodPropertiesConfiguration implements InitializingBean {
@Value("${aliyun.vod.file.keyid}")
private String keyid;
@Value("${aliyun.vod.file.keysecret}")
private String keysecret;
public static String ACCESS_KEY_SECRET;
public static String ACCESS_KEY_ID;
@Override
public void afterPropertiesSet() throws Exception {
ACCESS_KEY_ID=keyid;
ACCESS_KEY_SECRET=keysecret;
}
}
4、初始化檔案
package com.zhz.vod.utils;
import com.aliyun.oss.ClientException;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
/**
* @author zhouhengzhe
* @Description: 建立視訊初始化連接配接對象
* @date 2021/8/1下午10:33
*/
public class InitVodClient {
public static DefaultAcsClient initAcsClient (String accessKeyId,String accessKeySecret) throws ClientException {
String regionId="cn-shanghai";// 點播服務接入區域
DefaultProfile profile=DefaultProfile.getProfile(regionId,accessKeyId,accessKeySecret);
DefaultAcsClient defaultAcsClient = new DefaultAcsClient(profile);
return defaultAcsClient;
}
}
5、Controller
package com.zhz.vod.controller;
import com.zhz.common.utils.R;
import com.zhz.vod.service.VodService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
/**
* @author zhouhengzhe
* @Description: 視訊控制器
* @date 2021/8/1下午4:42
*/
@RestController
@RequestMapping("/eduvod//video")
public class VodController {
@Autowired
private VodService vodService;
//上傳視訊到阿裡雲
@PostMapping("uploadAliyunVideo")
public R uploadAliyunVideo(MultipartFile file){
String videoId=vodService.uploadAliyunVideo(file);
return R.ok().data("videoId",videoId);
}
}
6、Service
package com.zhz.vod.service;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @author zhouhengzhe
* @Description: 視訊服務處理接口
* @date 2021/8/1下午4:46
*/
public interface VodService {
/**
* 上傳視訊到阿裡雲
* @param file 檔案對象
* @return 上傳的視訊id
* @date 2021/8/1 下午4:51
* @author zhouhengzhe
*/
String uploadAliyunVideo(MultipartFile file);
/**
* 根據id删除多個視訊
* @param videoIdList 視訊id集合
* @return
* @date 2021/8/1 下午6:14
* @author zhouhengzhe
*/
void removeMoreAlyVideo(List videoIdList);
}
7、impl
package com.zhz.vod.service.impl;
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.vod.model.v20170321.DeleteVideoRequest;
import com.zhz.servicebase.execptionhandler.GuliException;
import com.zhz.vod.config.properties.VodPropertiesConfiguration;
import com.zhz.vod.service.VodService;
import com.zhz.vod.utils.InitVodClient;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
/**
* @author zhouhengzhe
* @Description: 視訊服務處理實作類
* @date 2021/8/1下午4:47
*/
@Service
@Slf4j
public class VodServiceImpl implements VodService {
/**
* 上傳視訊到阿裡雲
*
* @param file 檔案對象
* @return 上傳的視訊id
* @date 2021/8/1 下午4:51
* @author zhouhengzhe
*/
@Override
public String uploadAliyunVideo(MultipartFile file) {
try {
//accessKeyId, accessKeySecret
//fileName:上傳檔案原始名稱
// 01.03.09.mp4
String originalFilename = file.getOriginalFilename();
//title:上傳之後顯示名稱 01.03.09
String title = originalFilename.substring(0, originalFilename.lastIndexOf("."));
//inputStream:上傳檔案輸入流
InputStream inputStream = file.getInputStream();
//上傳檔案請求對象
UploadStreamRequest uploadStreamRequest = new UploadStreamRequest(VodPropertiesConfiguration.ACCESS_KEY_ID,VodPropertiesConfiguration.ACCESS_KEY_SECRET,title,originalFilename,inputStream);
UploadVideoImpl uploadVideo=new UploadVideoImpl();
UploadStreamResponse uploadStreamResponse=uploadVideo.uploadStream(uploadStreamRequest);
//如果設定回調URL無效,不影響視訊上傳,可以傳回VideoId同時會傳回錯誤碼。其他情況上傳失敗時,VideoId為空,此時需要根據傳回錯誤碼分析具體錯誤原因
return uploadStreamResponse.getVideoId();
}catch (Exception e){
log.info("視訊上傳異常:{}",e.getMessage());
return null;
}
}
/**
* 根據id删除多個視訊
*
* @param videoIdList 視訊id集合
* @return
* @date 2021/8/1 下午6:14
* @author zhouhengzhe
*/
@Override
public void removeMoreAlyVideo(List videoIdList) {
try {
//初始化對象
DefaultAcsClient defaultAcsClient = InitVodClient.initAcsClient(VodPropertiesConfiguration.ACCESS_KEY_ID, VodPropertiesConfiguration.ACCESS_KEY_SECRET);
//建立删除視訊request對象
DeleteVideoRequest deleteVideoRequest = new DeleteVideoRequest();
//videoIdList值轉換成 1,2,3
String videoIds = StringUtils.join(videoIdList.toArray(), ",");
//向request設定視訊id
deleteVideoRequest.setVideoIds(videoIds);
//調用初始化對象的方法實作删除
defaultAcsClient.getAcsResponse(deleteVideoRequest);
} catch (ClientException e) {
log.info("根據id删除多個視訊删除異常:{}",e.getMessage());
throw new GuliException(20001,"删除視訊失敗");
}
}
public static void main(String[] args) {
List<String> list = new ArrayList<>();
list.add("11");
list.add("22");
list.add("33");
// 11,22,33
String join = StringUtils.join(list.toArray(), ",");
System.out.println(join);
}
}