人脸识别（基于阿里云）

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.v1230.*;import com.aliyuncs.profile.DefaultProfile;import lombok.extern.slf4j.Slf4j;import mon.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 /7/7 17:54* @Time: 17:54* @description：人脸识别* @modified By：* @version: 1.0$*/@Slf4jpublic class FaceRecognition {@Value(value="${face.accessKeyId}")private static String accessKeyId;@Value(value="${face.secret}")private static String secret;/*** 人脸比对* CompareFace可以基于您输入的两张图片，检测两张图片中的人脸，并分别挑选两张图片中的最大人脸进行比较，判断是否为同一人。同时返回这两个人脸的矩形框坐标、比对的置信度，以及不同误识率的置信度阈值。* /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;}/*** 视频活体检测* 文档地址 /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;}/*** 照片活体检测* 文档地址 /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 = "/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 /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\\115814.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;}}

视频处理

依赖

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

/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 mon.system.api.ISysBaseAPI;import mon.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 /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 mon.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 /9/10 15:48* @Time: 15:48* @description：* @modified By：* @version: $*/public class LiveChannelUtils {private static String endpoint = "oss-cn-";//用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);//"-06-27 23:00:00"long endTIme = getUnixTimestamp(end);//"-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);//"-06-27 23:00:00"long endTIme = getUnixTimestamp(end);//"-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-";// // 阿里云主账号 AccessKey 拥有所有 API 的访问权限，风险很高。// // 强烈建议您创建并使用 RAM 账号进行 API 访问或日常运维，请登录 https://ram. 创建 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);//"-06-27 23:00:00"long endTIme = getUnixTimestamp(end);//"-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","-09-10 20:44:59","-09-11 15:45:17");//getLiveChannelHistory("online-examination");// listLiveChannels();}/*** 生成 LiveChannel 播放列表* @param liveChannelName*/public static void postVodPlaylist(String liveChannelName) {//String endpoint = "http://oss-cn-";// 阿里云主账号 AccessKey 拥有所有 API 的访问权限，风险很高。// 强烈建议您创建并使用 RAM 账号进行 API 访问或日常运维，请登录 https://ram. 创建 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("-09-10 23:00:00");//long endTIme = getUnixTimestamp("-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推流调用

略