欢送拜访我的GitHub
https://github.com/zq2599/blog_demos
内容：所有原创文章分类汇总及配套源码，波及Java、Docker、Kubernetes、DevOPS等；
欢送拜访我的GitHub
这里分类和汇总了欣宸的全副原创(含配套源码)：https://github.com/zq2599/blog_demos
本篇概览
- 本人的mp4文件，如何让更多的人近程播放？如下图所示：
- 这里简略解释一下上图的性能：
- 部署开源流媒体服务器<font color="blue">SRS</font>
- 开发名为<font color="blue">PushMp4</font>的java利用，该利用会读取本机磁盘上的Mp4文件，读取每一帧，推送到SRS上
- 每个想看视频的人，就在本人电脑上用流媒体播放软件（例如VLC）连贯SRS，播放PushMp4推上来的视频
- 明天咱们就来实现上图中的实战，整个过程分为以下步骤：
- 环境信息
- 筹备MP4文件
- 用docker部署SRS
- java利用开发和运行
- VLC播放
环境信息
- 本次实战，我这边波及的环境信息如下，供您参考：
- 操作系统：macOS Monterey
- JDK：1.8.0_211
- JavaCV：1.5.6
- SRS：3
筹备MP4文件
- 筹备一个一般的MP4视频文件即可，我是在线下载了视频开发罕用的大熊兔视频，地址是：
https://www.learningcontainer...
用docker部署SRS
SRS是驰名的开源的媒体服务器，推到这里的流，都能够用媒体播放器在线播放，为了简略起见，我在docker环境下一行命令实现部署：
docker run -p 1935:1935 -p 1985:1985 -p 8080:8080 ossrs/srs:3- 此刻SRS服务正在运行中，能够推流上去了
开发JavaCV利用
- 接下来进入最重要的编码阶段，新建名为<font color="blue">simple-grab-push</font>的maven工程，pom.xml如下（那个名为<font color="blue">javacv-tutorials</font>的父工程其实没有什么作用，我这里只是为了方便管理多个工程的代码而已，您能够删除这个父工程节点）：
<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>javacv-tutorials</artifactId> <groupId>com.bolingcavalry</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <groupId>com.bolingcavalry</groupId> <version>1.0-SNAPSHOT</version> <artifactId>simple-grab-push</artifactId> <packaging>jar</packaging> <properties> <!-- javacpp以后版本 --> <javacpp.version>1.5.6</javacpp.version> </properties> <dependencies> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>1.2.3</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-to-slf4j</artifactId> <version>2.13.3</version> </dependency> <!-- javacv相干依赖，一个就够了 --> <dependency> <groupId>org.bytedeco</groupId> <artifactId>javacv-platform</artifactId> <version>${javacpp.version}</version> </dependency> </dependencies></project>- 从上述文件可见，JavaCV的依赖只有一个<font color="blue">javacv-platform</font>，挺简洁
- 接下来开始编码，在编码前，先把整个流程画进去，这样写代码就清晰多了：
- 从上图可见流程很简略，这里将所有代码写在一个java类中：
package com.bolingcavalry.grabpush;import lombok.extern.slf4j.Slf4j;import org.bytedeco.ffmpeg.avcodec.AVCodecParameters;import org.bytedeco.ffmpeg.avformat.AVFormatContext;import org.bytedeco.ffmpeg.avformat.AVStream;import org.bytedeco.ffmpeg.global.avcodec;import org.bytedeco.ffmpeg.global.avutil;import org.bytedeco.javacv.FFmpegFrameGrabber;import org.bytedeco.javacv.FFmpegFrameRecorder;import org.bytedeco.javacv.FFmpegLogCallback;import org.bytedeco.javacv.Frame;/** * @author willzhao * @version 1.0 * @description 读取指定的mp4文件，推送到SRS服务器 * @date 2021/11/19 8:49 */@Slf4jpublic class PushMp4 { /** * 本地MP4文件的残缺门路(两分零五秒的视频) */ private static final String MP4_FILE_PATH = "/Users/zhaoqin/temp/202111/20/sample-mp4-file.mp4"; /** * SRS的推流地址 */ private static final String SRS_PUSH_ADDRESS = "rtmp://192.168.50.43:11935/live/livestream"; /** * 读取指定的mp4文件，推送到SRS服务器 * @param sourceFilePath 视频文件的绝对路径 * @param PUSH_ADDRESS 推流地址 * @throws Exception */ private static void grabAndPush(String sourceFilePath, String PUSH_ADDRESS) throws Exception { // ffmepg日志级别 avutil.av_log_set_level(avutil.AV_LOG_ERROR); FFmpegLogCallback.set(); // 实例化帧抓取器对象，将文件门路传入 FFmpegFrameGrabber grabber = new FFmpegFrameGrabber(MP4_FILE_PATH); long startTime = System.currentTimeMillis(); log.info("开始初始化帧抓取器"); // 初始化帧抓取器，例如数据结构（工夫戳、编码器上下文、帧对象等）， // 如果入参等于true，还会调用avformat_find_stream_info办法获取流的信息，放入AVFormatContext类型的成员变量oc中 grabber.start(true); log.info("帧抓取器初始化实现，耗时[{}]毫秒", System.currentTimeMillis()-startTime); // grabber.start办法中，初始化的解码器信息存在放在grabber的成员变量oc中 AVFormatContext avFormatContext = grabber.getFormatContext(); // 文件内有几个媒体流（个别是视频流+音频流） int streamNum = avFormatContext.nb_streams(); // 没有媒体流就不必持续了 if (streamNum<1) { log.error("文件内不存在媒体流"); return; } // 获得视频的帧率 int frameRate = (int)grabber.getVideoFrameRate(); log.info("视频帧率[{}]，视频时长[{}]秒，媒体流数量[{}]", frameRate, avFormatContext.duration()/1000000, avFormatContext.nb_streams()); // 遍历每一个流，查看其类型 for (int i=0; i< streamNum; i++) { AVStream avStream = avFormatContext.streams(i); AVCodecParameters avCodecParameters = avStream.codecpar(); log.info("流的索引[{}]，编码器类型[{}]，编码器ID[{}]", i, avCodecParameters.codec_type(), avCodecParameters.codec_id()); } // 视频宽度 int frameWidth = grabber.getImageWidth(); // 视频高度 int frameHeight = grabber.getImageHeight(); // 音频通道数量 int audioChannels = grabber.getAudioChannels(); log.info("视频宽度[{}]，视频高度[{}]，音频通道数[{}]", frameWidth, frameHeight, audioChannels); // 实例化FFmpegFrameRecorder，将SRS的推送地址传入 FFmpegFrameRecorder recorder = new FFmpegFrameRecorder(SRS_PUSH_ADDRESS, frameWidth, frameHeight, audioChannels); // 设置编码格局 recorder.setVideoCodec(avcodec.AV_CODEC_ID_H264); // 设置封装格局 recorder.setFormat("flv"); // 一秒内的帧数 recorder.setFrameRate(frameRate); // 两个关键帧之间的帧数 recorder.setGopSize(frameRate); // 设置音频通道数，与视频源的通道数相等 recorder.setAudioChannels(grabber.getAudioChannels()); startTime = System.currentTimeMillis(); log.info("开始初始化帧抓取器"); // 初始化帧录制器，例如数据结构（音频流、视频流指针，编码器）， // 调用av_guess_format办法，确定视频输入时的封装形式， // 媒体上下文对象的内存调配， // 编码器的各项参数设置 recorder.start(); log.info("帧录制初始化实现，耗时[{}]毫秒", System.currentTimeMillis()-startTime); Frame frame; startTime = System.currentTimeMillis(); log.info("开始推流"); long videoTS = 0; int videoFrameNum = 0; int audioFrameNum = 0; int dataFrameNum = 0; // 假如一秒钟15帧，那么两帧距离就是(1000/15)毫秒 int interVal = 1000/frameRate; // 发送完一帧后sleep的工夫，不能齐全等于(1000/frameRate)，不然会卡顿， // 要更小一些，这里取八分之一 interVal/=8; // 继续从视频源取帧 while (null!=(frame=grabber.grab())) { videoTS = 1000 * (System.currentTimeMillis() - startTime); // 工夫戳 recorder.setTimestamp(videoTS); // 有图像，就把视频帧加一 if (null!=frame.image) { videoFrameNum++; } // 有声音，就把音频帧加一 if (null!=frame.samples) { audioFrameNum++; } // 有数据，就把数据帧加一 if (null!=frame.data) { dataFrameNum++; } // 取出的每一帧，都推送到SRS recorder.record(frame); // 进展一下再推送 Thread.sleep(interVal); } log.info("推送实现，视频帧[{}]，音频帧[{}]，数据帧[{}]，耗时[{}]秒", videoFrameNum, audioFrameNum, dataFrameNum, (System.currentTimeMillis()-startTime)/1000); // 敞开帧录制器 recorder.close(); // 敞开帧抓取器 grabber.close(); } public static void main(String[] args) throws Exception { grabAndPush(MP4_FILE_PATH, SRS_PUSH_ADDRESS); }}- 上述代码中每一行都有具体正文，就不多赘述了，只有上面这到处要害须要留神：
- <font color="blue">MP4_FILE_PATH</font>是本地MP4文件寄存的中央，请改为本人电脑上MP4文件寄存的地位
- <font color="blue">SRS_PUSH_ADDRESS</font>是SRS服务的推流地址，请改为本人的SRS服务部署的地址
- <font color="blue">grabber.start(true)</font>办法执行的时候，外部是帧抓取器的初始化流程，会获得MP4文件的相干信息
- <font color="blue">recorder.record(frame)</font>办法执行的时候，会将帧推送到SRS服务器
- 编码实现后运行此类，控制台日志如下所示，可见胜利的取到了MP4文件的帧率、时长、解码器、媒体流等信息，而后开始推流了：
23:21:48.107 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 开始初始化帧抓取器23:21:48.267 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 帧抓取器初始化实现，耗时[163]毫秒23:21:48.277 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 视频帧率[15]，视频时长[125]秒，媒体流数量[2]23:21:48.277 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 流的索引[0]，编码器类型[0]，编码器ID[27]23:21:48.277 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 流的索引[1]，编码器类型[1]，编码器ID[86018]23:21:48.279 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 视频宽度[320]，视频高度[240]，音频通道数[6]23:21:48.294 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 开始初始化帧抓取器23:21:48.727 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 帧录制初始化实现，耗时[433]毫秒23:21:48.727 [main] INFO com.bolingcavalry.grabpush.PushMp4 - 开始推流- 接下来试试能不能拉流播放
用VLC播放
- 请装置VLC软件，并关上
- 如下图红框，点击菜单中的<font color="blue">Open Network...</font>，而后输出后面代码中写的推流地址（我这里是<font color="red">rtmp://192.168.50.43:11935/live/livestream</font>）：
- 如下图，胜利播放，而且声音也失常：
附加知识点
- 通过下面的实战，咱们相熟了播放和推流的基本操作，把握了惯例信息的获取以及参数设置，除了代码中的常识，还有以下几个暗藏的知识点也值得关注
- 设置ffmpeg日志级别的代码是<font color="blue">avutil.av_log_set_level(avutil.AV_LOG_ERROR)</font>，把参数改为<font color="red">avutil.AV_LOG_INFO</font>后，能够在控制台看到更丰盛的日志，如下图红色区域，外面显示了MP4文件的详细信息，例如两个媒体流（音频流和视频流）：
- 第二个知识点是对于编码器类型和编码器ID的，如下图，两个媒体流(AVStream)的编码器类型别离是<font color="red">0</font>和<font color="red">1</font>，两个编码器ID别离是<font color="red">27</font>和<font color="red">86018</font>，这四个数字别离代表什么呢？
- 先看编码器类型，用IDEA的反编译性能关上<font color="blue">avutil.class</font>，如下图，编码器类型等于0示意视频(VIDEO)，类型等于1示意音频（AUDIO）：
- 再看编码器ID，关上<font color="blue">avcodec.java</font>，看到编码器ID为<font color="red">27</font>示意H264：
- 编码器ID值<font color="red">86018</font>的十六进制是<font color="red">0x15002</font>，对应的编码器如下图红框：
- 至此，JavaCV推流实战(MP4文件)曾经全副实现，心愿通过本文咱们能够一起相熟JavaCV解决推拉流的惯例操作；
https://github.com/zq2599/blog_demos