天天看點

SpringBoot實作阿裡雲視訊點播技術1、依賴POM2、配置檔案(application.yml)3、讀取配置類4、初始化檔案5、Controller6、Service7、impl

文章目錄

  • 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);
    }
}