人脸识别（基于阿里云）

超、凢脫俗 2022-12-27 01:48 146阅读 0赞

### pom.xml ###

<dependency>
    			<groupId>com.aliyun</groupId>
    			<artifactId>aliyun-java-sdk-core</artifactId>
    			<version>4.4.8</version>
    		</dependency>
    		<dependency>
    			<groupId>com.aliyun</groupId>
    			<artifactId>aliyun-java-sdk-facebody</artifactId>
    			<version>1.1.1</version>
    		</dependency>
            
    		<dependency>
    			<groupId>org.bytedeco</groupId>
    			<artifactId>javacv-platform</artifactId>
    			<version>1.4.4</version>
    		</dependency>

/**
         * 活体检测
         * @param fileUrl 照片
         * @param messge 提示消息
         * @return
         */
        public Boolean VideoVivoDetection(String fileUrl,String messge){
            try {
                Results results = FaceRecognition.VideoVivoDetectionPhoto(fileUrl,messge);
                Float faceConfidence = Float.valueOf(sysUserRoleMapper.getSysDictItem("活体检测-人脸的置信度"));//置信度 从数据字典表中读取，实现动态调整
                if(faceConfidence > results.getRate()){
                    throw new BadRequestException(messge + "【人脸的置信度】较低，系统要求置信度为：【" + faceConfidence + "】，本次检查置信度【" + results.getRate() + "】");
                }
                return true;
            }catch (Exception e){
                throw new BadRequestException(messge + "活体检测识别");
            }
        }

package org.jeecg.modules.exam.utils.face;
    
    import com.aliyuncs.DefaultAcsClient;
    import com.aliyuncs.IAcsClient;
    import com.aliyuncs.exceptions.ClientException;
    import com.aliyuncs.exceptions.ServerException;
    import com.aliyuncs.facebody.model.v20191230.*;
    import com.aliyuncs.profile.DefaultProfile;
    import lombok.extern.slf4j.Slf4j;
    import org.jeecg.common.util.tzf.BadRequestException;
    import org.jeecg.modules.exam.utils.face.entity.Results;
    import org.springframework.beans.factory.annotation.Value;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * @author ：admin
     * @date ：Created in 2020/7/7 17:54
     * @Time: 17:54
     * @description：人脸识别
     * @modified By：
     * @version: 1.0$
     */
    @Slf4j
    public class FaceRecognition {
    
        @Value(value="${face.accessKeyId}")
        private static String accessKeyId;
        @Value(value="${face.secret}")
        private static String secret;
    
        /**
         * 人脸比对
         * CompareFace可以基于您输入的两张图片，检测两张图片中的人脸，并分别挑选两张图片中的最大人脸进行比较，判断是否为同一人。同时返回这两个人脸的矩形框坐标、比对的置信度，以及不同误识率的置信度阈值。
         * https://help.aliyun.com/document_detail/151891.html?spm=a2c4g.11186623.6.589.56705de3kX1diD
         * @param ImageURLA 图片URL地址。当前仅支持上海地域的OSS链接
         * @param ImageURLB 图片URL地址。当前仅支持上海地域的OSS链接
         */
        public static Confidence FaceThan(String ImageURLA,String ImageURLB) {
    
            DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKeyId, secret);
            IAcsClient client = new DefaultAcsClient(profile);
    
            CompareFaceRequest request = new CompareFaceRequest();
            request.setRegionId("cn-shanghai");
            request.setImageURLA(ImageURLA);
            request.setImageURLB(ImageURLB);
    
            try {
                CompareFaceResponse response = client.getAcsResponse(request);
                Confidence confidence = new Confidence();
                confidence.copy(response.getData().getConfidence(),
                        response.getData().getRectAList(),
                        response.getData().getRectBList(),
                        response.getData().getThresholds());
                //System.out.println(new Gson().toJson(response));
                return confidence;
            } catch (ServerException e) {
                e.printStackTrace();
            } catch (ClientException e) {
                log.error(e.getMessage());
            }
            return null;
        }
    
        /**
         * 视频活体检测
         * 文档地址 https://help.aliyun.com/document_detail/167847.html?spm=5176.12901015.0.i12901015.2932525cEVM3hb&accounttraceid=50ed0f85458549a3aeed92836ee86a3fcdfe
         * @param VideoUrl
         */
        public static Elements VideoVivoDetection(String VideoUrl) {
    
            DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKeyId, secret);
            IAcsClient client = new DefaultAcsClient(profile);
    
            DetectVideoLivingFaceRequest request = new DetectVideoLivingFaceRequest();
            request.setRegionId("cn-shanghai");
            request.setVideoUrl(VideoUrl);
    
            try {
                DetectVideoLivingFaceResponse response = client.getAcsResponse(request);
               // System.out.println(response.getData().getElements().toString());
                Elements elements = new Elements();
                elements.copy(response.getData().getElements().get(0).getFaceConfidence(),
                        response.getData().getElements().get(0).getLiveConfidence(),
                        response.getData().getElements().get(0).getRect());
               // System.out.println(new Gson().toJson(response));
                return elements;
            } catch (ServerException e) {
                e.printStackTrace();
            } catch (ClientException e) {
                log.error(e.getMessage());
    //            System.out.println("ErrCode:" + e.getErrCode());
    //            System.out.println("ErrMsg:" + e.getErrMsg());
    //            System.out.println("RequestId:" + e.getRequestId());
            }
            return null;
        }
    
        /**
         * 照片活体检测
         * 文档地址 https://help.aliyun.com/document_detail/155006.html?spm=a2c4g.11186623.6.587.75876c6cq8RdaW
         * @param PhotoUrl 照片地址
         * @param messge 提示消息
         * @return
         */
        public static Results VideoVivoDetectionPhoto(String PhotoUrl,String messge) {
    
            DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKeyId, secret);
            IAcsClient client = new DefaultAcsClient(profile);
    
            DetectLivingFaceRequest request = new DetectLivingFaceRequest();
            request.setRegionId("cn-shanghai");
    
            List<DetectLivingFaceRequest.Tasks> tasksList = new ArrayList<DetectLivingFaceRequest.Tasks>();
    
            DetectLivingFaceRequest.Tasks tasks1 = new DetectLivingFaceRequest.Tasks();
            tasks1.setImageURL(PhotoUrl);
            tasksList.add(tasks1);
            request.setTaskss(tasksList);
            try {
                DetectLivingFaceResponse response = client.getAcsResponse(request);
                Results results = new Results();
                results.copy(response.getData().getElements().get(0).getResults().get(0).getLabel(),
                        response.getData().getElements().get(0).getResults().get(0).getRate(),
                        response.getData().getElements().get(0).getResults().get(0).getSuggestion());
                if("liveness".equals(results.getLabel())){
                    throw new BadRequestException(messge + "请勿上传翻拍照片");
                }
                if("review".equals(results.getSuggestion())){
                    throw new BadRequestException(messge + "照片可能来自翻拍，请重新上传");
                }
                if("block".equals(results.getSuggestion())){
                    throw new BadRequestException(messge + "照片大概率来自翻拍，请重新上传");
                }
                return results;
            } catch (ServerException e) {
                e.printStackTrace();
                log.error("服务器异常 {}" + e.getMessage());
            } catch (ClientException e) {//客户端异常
                e.printStackTrace();
                log.error("客户端异常 异常信息{} ErrCode {} \nErrMsg{} \n RequestId{}" , e.getMessage(), e.getErrCode(), e.getErrMsg(), e.getRequestId());
            } catch (BadRequestException e) {
                log.error("自定义异常");
                return null;
            }
            return null;
        }
    
        /**
         * 地址转换
         * @param URL
         */
        public static String AddressTranslation(String URL) {
            //String file = /home/admin/file/1.jpg  或者本地上传
            //String file = "https://fuss10.elemecdn.com/5/32/c17416d77817f2507d7fbdf15ef22jpeg.jpeg";
            try {
                FileUtils fileUtils = FileUtils.getInstance(accessKeyId,secret);
                String ossurl = fileUtils.upload(URL);
                System.out.println(ossurl);
                return ossurl;
            }catch (ClientException e){
                System.out.println(e.getMessage());
            }catch (IOException e){
                System.out.println(e.getMessage());
            }
          return null;
        }
    
    
    }

package org.jeecg.modules.exam.utils.face;
    
    import cn.hutool.core.io.FileUtil;
    import org.bytedeco.javacv.FFmpegFrameGrabber;
    import org.bytedeco.javacv.Frame;
    import org.bytedeco.javacv.FrameGrabber;
    import org.bytedeco.javacv.Java2DFrameConverter;
    import org.springframework.util.ResourceUtils;
    
    import javax.imageio.ImageIO;
    import java.awt.*;
    import java.awt.image.BufferedImage;
    import java.io.File;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    
    /**
     * @author ：admin
     * @date ：Created in 2020/7/9 11:28
     * @Time: 11:28
     * @description：视频截取
     * @modified By：
     * @version: 1.0$
     */
    public class VideoCapture {
    //    public static void main(String[] args) {
    //        String videoPath = "C:\\Users\\admin\\Pictures\\rz\\hz.mp4";
    //
    //        /**
    //         * 1.活体检测
    //         * 2.视频截取
    //         * 3.相似度认证
    //         */
    //        Elements elements = FaceRecognition.VideoVivoDetection(videoPath);
    //        System.out.println("人脸的置信度--------------" + elements.getFaceConfidence());
    //        System.out.println("活体的置信度--------------" + elements.getLiveConfidence());
    //        System.out.println("检测出的人脸位置--------------" + elements.getRect());
    //        System.out.println("------------------------------活体检测通过");
    //        System.out.println("------------------------------活体检测通过");
    //        File video = null;
    //        try {
    //            video = ResourceUtils.getFile(videoPath);
    //        } catch (FileNotFoundException e) {
    //            e.printStackTrace();
    //        }
    //        for (int i = 0; i < 50; i++) {
    //            String picPath = "C:\\Users\\admin\\Pictures\\rz\\"+ i +".jpg";
    //            getVideoPic(video, picPath,i*10);
    //        }
    //        long duration = getVideoDuration(video);
    //        System.out.println("\n\n\n\n\n\nvideoDuration ************************************** " + duration);
    //        System.out.println("\n\n\n\n\n\nvideoDuration ************************************** " + duration);
    //        System.out.println("------------------------------视频截取完成");
    //        String picPath = "C:\\Users\\admin\\Pictures\\rz\\20200709115814.png";
    //        for (int i = 0; i < 1; i++) {
    //            String picPath1 = "C:\\Users\\admin\\Pictures\\rz\\"+ i +".jpg";
    //            System.out.println("------------------------------对比地址1【" + picPath1 + "】\n【" + picPath + "】");
    //            FaceRecognition.FaceThan(picPath1,picPath);
    //        }
    //        System.out.println("------------------------------相似度认证通过");
    //
    //
    //
    //    }
    
        /**
         * 截取视频获得指定帧的图片
         *
         * @param video  源视频文件
         * @param picPath 截图存放路径
         */
        public static void getVideoPic(File video, String picPath,int i) {
            FFmpegFrameGrabber ff = new FFmpegFrameGrabber(video);
            try {
                ff.start();
                // 截取中间帧图片(具体依实际情况而定)
               // int i = 0;
                int length = ff.getLengthInFrames();
                int middleFrame = length / 2;
                Frame frame = null;
                while (i < length) {
                    frame = ff.grabFrame();
                    if ((i > middleFrame) && (frame.image != null)) {
                        break;
                    }
                    i++;
                }
                // 截取的帧图片
                Java2DFrameConverter converter = new Java2DFrameConverter();
                BufferedImage srcImage = converter.getBufferedImage(frame);
                int srcImageWidth = srcImage.getWidth();
                int srcImageHeight = srcImage.getHeight();
                // 对截图进行等比例缩放(缩略图)
                int width = 480;
                int height = (int) (((double) width / srcImageWidth) * srcImageHeight);
                BufferedImage thumbnailImage = new BufferedImage(width, height, BufferedImage.TYPE_3BYTE_BGR);
                thumbnailImage.getGraphics().drawImage(srcImage.getScaledInstance(width, height, Image.SCALE_SMOOTH), 0, 0, null);
                File picFile = new File(picPath);
                ImageIO.write(thumbnailImage, "jpg", picFile);
                ff.stop();
                //删除临时文件
                FileUtil.del(picFile);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        /**
         * 获取视频时长，单位为秒
         * @param video 源视频文件
         * @return 时长（s）
         */
        public static long getVideoDuration(File video) {
            long duration = 0L;
            FFmpegFrameGrabber ff = new FFmpegFrameGrabber(video);
            try {
                ff.start();
                duration = ff.getLengthInTime() / (1000 * 1000);
                ff.stop();
            } catch (FrameGrabber.Exception e) {
                e.printStackTrace();
            }
            return duration;
        }
    
    /**
         *
         * 截取视频获得指定帧的图片     *
         * @param video  源视频文件
         * @param picPath 截图存放路径
         * @param i 帧
         */
        public static String getVideoPic(File video, String picPath,int i) {
            FFmpegFrameGrabber ff = new FFmpegFrameGrabber(video);
            try {
                ff.start();
                // 截取中间帧图片(具体依实际情况而定)
                // int i = 0;
                int length = ff.getLengthInFrames();
                int middleFrame = length / 2;
                Frame frame = null;
                while (i < length) {
                    frame = ff.grabFrame();
                    if ((i > middleFrame) && (frame.image != null)) {
                        break;
                    }
                    i++;
                }
                // 截取的帧图片
                Java2DFrameConverter converter = new Java2DFrameConverter();
                BufferedImage srcImage = converter.getBufferedImage(frame);
                int srcImageWidth = srcImage.getWidth();
                int srcImageHeight = srcImage.getHeight();
                // 对截图进行等比例缩放(缩略图)
                int width = 480;
                int height = (int) (((double) width / srcImageWidth) * srcImageHeight);
                BufferedImage thumbnailImage = new BufferedImage(width, height, BufferedImage.TYPE_3BYTE_BGR);
                thumbnailImage.getGraphics().drawImage(srcImage.getScaledInstance(width, height, Image.SCALE_SMOOTH), 0, 0, null);
    
                File picFile = new File( "/tang/file/upFiles/"+ picPath + "/" + StringUtils.UUIDNanoTime() + ".jpg");
                if (!picFile.exists()) {
                    picFile.mkdirs();
                }
                //File picFile = new File(LinuxUpload + "\\"+ picPath + "\\" + StringUtils.UUIDNanoTime() + ".jpg");
                ImageIO.write(thumbnailImage, "jpg", picFile);
                ff.stop();
               String OssUrl = getOssUrl(picFile,picPath);//阿里云地址
                //删除临时文件
                FileUtil.del(picFile);
                return OssUrl;
            } catch (IOException e) {
                e.printStackTrace();
                log.info("视频截取异常" + e.getMessage());
            }catch (Exception e) {
                e.printStackTrace();
                log.info("视频截取上传异常" + e.getMessage());
            }
            return null;
        }
    }

### 视频处理 ###

### 依赖 ###

<dependency>
        <groupId>com.aliyun.oss</groupId>
        <artifactId>aliyun-sdk-oss</artifactId>
    	<version>3.6.0</version>
    </dependency>

[https://www.alibabacloud.com/help/zh/doc-detail/44297.htm][https_www.alibabacloud.com_help_zh_doc-detail_44297.htm]

package org.jeecg.modules.exam.controller;
    
    import com.aliyun.oss.model.LiveChannelInfo;
    import com.aliyun.oss.model.LiveChannelListing;
    import com.aliyun.oss.model.LiveRecord;
    import io.swagger.annotations.Api;
    import io.swagger.annotations.ApiOperation;
    import lombok.extern.slf4j.Slf4j;
    import org.jeecg.common.system.api.ISysBaseAPI;
    import org.jeecg.common.util.tzf.ResponseEntityT;
    import org.jeecg.modules.exam.utils.LiveChannelAdd;
    import org.jeecg.modules.exam.utils.LiveChannelUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import java.util.List;
    
    /**
     * @author ：admin
     * @date ：Created in 2020/9/10 16:43
     * @Time: 16:43
     * @description：LiveChannel 工具类
     * @modified By：
     * @version: 1.0$
     */
    
    @Slf4j
    @Controller
    @RequestMapping("/oss/LiveChannel")
    @Api(tags="LiveChannel工具")
    public class LiveChannelController {
    
        @ResponseBody
        @GetMapping("/createLiveChannel")
        @ApiOperation(value="创建 LiveChannel", notes="")
        public ResponseEntityT<LiveChannelAdd> createLiveChannel(@RequestParam(name = "liveChannelName") String liveChannelName) {
            return ResponseEntityT.ok(LiveChannelUtils.createLiveChannel(liveChannelName));
        }
    
        @ResponseBody
        @GetMapping("/listLiveChannels")
        @ApiOperation(value="列举 LiveChannel", notes="")
        public ResponseEntityT<LiveChannelListing> listLiveChannels() {
            return ResponseEntityT.ok(LiveChannelUtils.listLiveChannels());
        }
    
    //    @ResponseBody
    //    @GetMapping("/deleteLiveChannel")
    //    @ApiOperation(value="删除 LiveChannel", notes="")
    //    public ResponseEntityT deleteLiveChannel(@RequestParam(name = "liveChannelName") String liveChannelName) {
    //        LiveChannelUtils.deleteLiveChannel(liveChannelName);
    //        return ResponseEntityT.ok();
    //    }
    
        @ResponseBody
        @GetMapping("/setLiveChannelStatus")
        @ApiOperation(value="设置 LiveChannel 状态", notes=" stu 二种状态 enabled disabled ")
        public ResponseEntityT setLiveChannelStatus(@RequestParam(name = "liveChannelName") String liveChannelName, String stu) {
            LiveChannelUtils.setLiveChannelStatus(liveChannelName,stu);
            return ResponseEntityT.ok("操作成功");
        }
    
        @ResponseBody
        @GetMapping("/getLiveChannelInfo")
        @ApiOperation(value="获取 LiveChannel 配置信息")
        public ResponseEntityT<LiveChannelInfo> getLiveChannelInfo(@RequestParam(name = "liveChannelName") String liveChannelName) {
            return ResponseEntityT.ok(LiveChannelUtils.getLiveChannelInfo(liveChannelName));
        }
    
        @ResponseBody
        @GetMapping("/postVodPlaylist")
        @ApiOperation(value="生成 LiveChannel 播放列表")
        public ResponseEntityT<?> getLiveChannelInfo(@RequestParam(name = "liveChannelName") String liveChannelName, String playListName, String start, String end) {
            LiveChannelUtils.postVodPlaylist(liveChannelName,playListName, start, end);
            return ResponseEntityT.ok("生成成功");
        }
    
        @ResponseBody
        @GetMapping("/getVodPlaylist")
        @ApiOperation(value=" 查看 LiveChannel 播放列表")
        public ResponseEntityT<?> getVodPlaylist(@RequestParam(name = "liveChannelName") String liveChannelName, String start, String end) {
            LiveChannelUtils.getVodPlaylist(liveChannelName, start, end);
            return ResponseEntityT.ok("生成成功");
        }
    
        @ResponseBody
        @GetMapping("/getLiveChannelHistory")
        @ApiOperation(value=" 获取 LiveChannel 推流记录")
        public ResponseEntityT<List<LiveRecord>> getLiveChannelHistory(@RequestParam(name = "liveChannelName") String liveChannelName) {
            return ResponseEntityT.ok(LiveChannelUtils.getLiveChannelHistory(liveChannelName));
        }
    
    }

## ##

package org.jeecg.modules.exam.utils;
    
    import com.alibaba.fastjson.JSON;
    import com.aliyun.oss.ClientException;
    import com.aliyun.oss.OSS;
    import com.aliyun.oss.OSSClientBuilder;
    import com.aliyun.oss.OSSException;
    import com.aliyun.oss.model.*;
    import org.jeecg.common.util.tzf.BadRequestException;
    
    import java.text.DateFormat;
    import java.text.ParseException;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.List;
    
    /**
     * @author ：admin
     * @date ：Created in 2020/9/10 15:48
     * @Time: 15:48
     * @description：
     * @modified By：
     * @version: $
     */
    public class LiveChannelUtils {
    
    
        private static String endpoint = "oss-cn-shanghai.aliyuncs.com";//用shanghai的
        private static String accessKeyId = "XXXXXXXXXXXXXXXXXXXX";
        private static String accessKeySecret = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";
        private static String bucketName = "XXXXX-video";
    
    
        /**
         * 创建 LiveChannel
         */
        public static LiveChannelAdd createLiveChannel(String liveChannelName) {
    
            LiveChannelAdd liveChannelAdds = new LiveChannelAdd();
    
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            CreateLiveChannelRequest request = new CreateLiveChannelRequest(bucketName,
                    liveChannelName, "desc", LiveChannelStatus.Enabled, new LiveChannelTarget());
            CreateLiveChannelResult result = oss.createLiveChannel(request);
    
    //        //获取推流地址
    //        List<String> publishUrls = result.getPublishUrls();
    //        for (String item : publishUrls) {
    //            publishUrl.add(item);
                System.out.println("获取推流地址------------------------------");
                System.out.println(item);
    //        }
    //        //获取播放地址。
    //        List<String> playUrls = result.getPlayUrls();
    //        for (String item : playUrls) {
    //            playUrl.add(item);
                System.out.println("获取播放地址------------------------------");
                System.out.println(item);
    //        }
            liveChannelAdds.setPublishUrls(result.getPublishUrls());
            liveChannelAdds.setPlayUrls(result.getPlayUrls());
            oss.shutdown();
            return liveChannelAdds;
        }
    
        /**
         * 列举 LiveChannel
         */
        public static LiveChannelListing listLiveChannels() {
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            ListLiveChannelsRequest request = new ListLiveChannelsRequest(bucketName);
            LiveChannelListing liveChannelListing = oss.listLiveChannels(request);
            System.out.println("列举 LiveChannel------------------------------");
            System.out.println(JSON.toJSONString(liveChannelListing));
            oss.shutdown();
            return liveChannelListing;
        }
    
    //    /**
    //     * 删除 LiveChannel
    //     */
    //    public static void deleteLiveChannel(String liveChannelName) {
    //        // 创建 OSSClient 实例。
    //        OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    //        LiveChannelGenericRequest request = new LiveChannelGenericRequest(bucketName, liveChannelName);
    //        try {
    //            oss.deleteLiveChannel(request);
    //        } catch (OSSException ex) {
    //            ex.printStackTrace();
    //            throw new BadRequestException("推流通道关闭失败，" + ex.getMessage());
    //        } catch (ClientException ex) {
    //            ex.printStackTrace();
    //            throw new BadRequestException("推流通道关闭失败，" + ex.getMessage());
    //        } finally {
    //            oss.shutdown();
    //        }
    //    }
    
        /**
         * 设置 LiveChannel 状态
         */
        public static void setLiveChannelStatus(String liveChannelName,String stu) {
            //String liveChannelName = "<yourLiveChannelName>";
            // 创建OSSClient实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            try {
                if("enabled".equals(stu)){
                    oss.setLiveChannelStatus(bucketName, liveChannelName, LiveChannelStatus.Enabled );
                }
                if("disabled".equals(stu)){
                    oss.setLiveChannelStatus(bucketName, liveChannelName, LiveChannelStatus.Disabled );
                }
    
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
    
        /**
         * 获取 LiveChannel 配置信息
         */
        public static LiveChannelInfo getLiveChannelInfo(String liveChannelName) {
            //String liveChannelName = "<yourLiveChannelName>";
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            LiveChannelInfo liveChannelInfo = oss.getLiveChannelInfo(bucketName, liveChannelName);
            System.out.println(JSON.toJSONString(liveChannelInfo));
            oss.shutdown();
            return liveChannelInfo;
        }
    
        /**
         * 生成 LiveChannel 播放列表
         * @param liveChannelName
         * @param playListName
         * @param start
         * @param end
         */
        public static void postVodPlaylist(String liveChannelName,String playListName,String start,String end) {
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            long startTime = getUnixTimestamp(start);//"2019-06-27 23:00:00"
            long endTIme = getUnixTimestamp(end);//"2019-06-28 23:00:00"
            try {
                oss.generateVodPlaylist(bucketName, liveChannelName, playListName, startTime, endTIme);
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
        public static void postVodPlaylistT(String liveChannelName,String playListName,String start,String end) {
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            long startTime = getUnixTimestamp(start);//"2019-06-27 23:00:00"
            long endTIme = getUnixTimestamp(end);//"2019-06-28 23:00:00"
            try {
                oss.generateVodPlaylist(bucketName, liveChannelName, playListName, startTime, endTIme);
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
        /**
         * 生成 LiveChannel 播放列表
         * @param liveChannelName
         * @param playListName
         * @param startTime
         * @param endTIme
         */
        public static void postVodPlaylist(String liveChannelName,String playListName,long startTime,long endTIme) {
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            try {
                oss.generateVodPlaylist(bucketName, liveChannelName, playListName, startTime, endTIme);
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
    
        private static long getUnixTimestamp(String time) {
            DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            try {
                Date date = format.parse(time);
                return date.getTime() / 1000;
            } catch (ParseException e) {
                e.printStackTrace();
                return 0;
            }
        }
    
        /**
         * 查看 LiveChannel 播放列表
         * @param liveChannelName
         * @param start
         * @param end
         */
        public static void getVodPlaylist(String liveChannelName,String start,String end) {
    //        String endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
    //        // 阿里云主账号 AccessKey 拥有所有 API 的访问权限，风险很高。
    //        // 强烈建议您创建并使用 RAM 账号进行 API 访问或日常运维，请登录 https://ram.console.aliyun.com 创建 RAM 账号。
    //        String accessKeyId = "<yourAccessKeyId>";
    //        String accessKeySecret = "<yourAccessKeySecret>";
    //        String liveChannelName = "<yourLiveChannelName>";
    //        String bucketName = "<yourBucketName>";
    
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    
            long startTime = getUnixTimestamp(start);//"2019-06-27 23:00:00"
            long endTIme = getUnixTimestamp(end);//"2019-06-28 23:00:00"
    
            try {
                OSSObject ossObject = oss.getVodPlaylist(bucketName, liveChannelName, startTime, endTIme);
                System.out.println(ossObject.toString());
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
    
        /**
         * 获取 LiveChannel 推流记录
         */
        public static List<LiveRecord> getLiveChannelHistory(String liveChannelName) {
            try {
                OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
                List<LiveRecord> list = oss.getLiveChannelHistory(bucketName, liveChannelName);
                System.out.println("-----推流记录-----");
                System.out.println(JSON.toJSONString(list));
                System.out.println("-----推流记录-----");
                oss.shutdown();
                return list;
            }catch (Exception e){
                throw new BadRequestException("获取异常-" + e.getMessage());
            }
        }
    
        public static void main(String[] args) {
            //getLiveChannelHistory("online_examination");
            long s = Long.valueOf("1599793969310");
            long e = Long.valueOf("1599793986570");
            LiveChannelAdd liveChannelAdd = createLiveChannel("online-examination");
            System.out.println(liveChannelAdd.getPlayUrls());
            System.out.println(liveChannelAdd.getPublishUrls());
            //listLiveChannels();
    //        postVodPlaylist("online_examination","playlist.m3u8","2020-09-10 20:44:59","2020-09-11 15:45:17");
    
            //getLiveChannelHistory("online-examination");
    //        listLiveChannels();
        }
    
        /**
         * 生成 LiveChannel 播放列表
         * @param liveChannelName
         */
        public static void postVodPlaylist(String liveChannelName) {
            //String endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
            // 阿里云主账号 AccessKey 拥有所有 API 的访问权限，风险很高。
            // 强烈建议您创建并使用 RAM 账号进行 API 访问或日常运维，请登录 https://ram.console.aliyun.com 创建 RAM 账号。
    //        String accessKeyId = "<yourAccessKeyId>";
    //        String accessKeySecret = "<yourAccessKeySecret>";
    //        String liveChannelName = "<yourLiveChannelName>";
    //        String bucketName = "<yourBucketName>";
            String playListName = "playlist.m3u8";
            // 创建 OSSClient 实例。
            OSS oss = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            long startTime = getUnixTimestamp("2020-09-10 23:00:00");//
            long endTIme = getUnixTimestamp("2020-09-11 23:00:00");//
            try {
                oss.generateVodPlaylist(bucketName, liveChannelName, playListName, startTime, endTIme);
            } catch (OSSException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } catch (ClientException ex) {
                System.out.println(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
                throw new BadRequestException(ex.getErrorCode().concat(",").concat(ex.getErrorMessage()));
            } finally {
                oss.shutdown();
            }
        }
    }

### 前端uni-app推流调用 ###

略

[https_www.alibabacloud.com_help_zh_doc-detail_44297.htm]: https://www.alibabacloud.com/help/zh/doc-detail/44297.htm