JavaCV?本地視頻推流實現(xiàn)依賴示例
引言
<dependency>
<groupId>org.bytedeco</groupId>
<artifactId>javacv-platform</artifactId>
<version>1.5.6</version>
</dependency>導(dǎo)入 JavaCV 依賴
編寫推流代碼如下:
import org.bytedeco.ffmpeg.global.avcodec;
import org.bytedeco.ffmpeg.global.avutil;
import org.bytedeco.javacv.*;
import java.nio.ByteBuffer;
public class LivePusher {
public void pushLocalVideo2Rtmp(String localVideoPath, String rtmpAddress) throws Exception {
FFmpegLogCallback.set();
FFmpegFrameGrabber grabber = new FFmpegFrameGrabber(localVideoPath);
grabber.setOption("nobuffer", "1");
grabber.start();
/*
* 測試時推了一個剪映重新生成的高分辨率視頻,其分辨率達(dá)到了 3840x2160;
* 導(dǎo)致下面的推送速度跟不上實際消耗的速度;將會造成直播卡頓; 因此,可以重置其分辨率
*/
int imageWidth = grabber.getImageWidth();
int imageHeight = grabber.getImageHeight();
if (imageWidth > 1920 || imageHeight > 1080) {
double wScale = imageWidth * 1.0 / 1920;
double hScale = imageHeight * 1.0 / 1080;
double scale = Math.max(wScale, hScale);
grabber.setImageWidth((int) (imageWidth / scale));
grabber.setImageHeight((int) (imageHeight / scale));
}
if (grabber.getFormatContext() == null || grabber.getFormatContext().nb_streams() < 1) {
throw new RuntimeException("本地視頻中沒有流數(shù)據(jù)");
}
FFmpegFrameRecorder recorder = new FFmpegFrameRecorder(
rtmpAddress, grabber.getImageWidth(), grabber.getImageHeight()
);
recorder.setFrameRate(grabber.getFrameRate()); // 設(shè)置幀率
recorder.setGopSize((int) (grabber.getFrameRate() * 2)); // 設(shè)置關(guān)鍵幀
recorder.setVideoBitrate(grabber.getVideoBitrate());
recorder.setVideoCodec(avcodec.AV_CODEC_ID_H264); // 視頻編碼格式
recorder.setPixelFormat(avutil.AV_PIX_FMT_YUV420P); // 視頻源數(shù)據(jù)yuv
recorder.setFormat("flv");
recorder.setAudioCodec(avcodec.AV_CODEC_ID_AAC); // 音頻編碼格式
// recorder.setAudioBitrate(grabber.getAudioBitrate());
recorder.setAudioChannels(grabber.getAudioChannels());
recorder.setSampleRate(grabber.getSampleRate());
recorder.start();
// 假設(shè) 1 秒中有 30 幀數(shù)據(jù),那么兩幀數(shù)據(jù)之間的時間間隔就是 1000 / 30;
long interval = 1_000 / (int) grabber.getFrameRate();
long startTime = System.currentTimeMillis();
Frame frame;
while ((frame = grabber.grab()) != null) {
recorder.record(frame);
long currentTime = 1_000 * (System.currentTimeMillis() - startTime);
long frameTime = frame.timestamp;
long sleepTime = (frameTime - currentTime) / 1_000;
System.out.println("推流測試 >>>>>>>> " + getFrameTime(currentTime) + " >>>>>>>> " + getFrameTime(frameTime));
try {
if (interval > 0 && sleepTime > 500 + interval) {
Thread.sleep(interval);
}
} catch (Exception e) {
e.printStackTrace();
}
}
recorder.close();
grabber.close();
}
private String getFrameTime(long frameTime) {
long mills = (frameTime / 1000) % 1000;
int sec = (int) (frameTime / 1_000 / 1_000);
int min = sec / 60;
sec %= 60;
if (min >= 60) {
int hour = min / 60;
min %= 60;
return String.format("%02d:%02d:%02d.%03d", hour, min, sec, mills);
} else {
return String.format("%02d:%02d.%03d", min, sec, mills);
}
}
}使用播放器驗證推流效果

問題總結(jié)
推流時,主要解決兩個問題:直播流卡頓 和 音畫不同步。
卡頓的問題主要是采集本地視頻流和推流消耗的時間大于當(dāng)前采集到的視頻的時長,通俗描述是 1 分鐘時長的音視頻數(shù)據(jù),使用 FFmpegFrameGrabber 采集 + FFmpegFrameRecorder 推流錄制,需要消耗的時間超過 1 分鐘。
因此可以適當(dāng)?shù)恼{(diào)用 setImageWidth 和 setImageHeight 降低視頻的分辨率;或者是調(diào)用 setVideoBitrate 或 setVideoQuality 降低視頻比特率或質(zhì)量等;當(dāng)然,網(wǎng)絡(luò)也會造成卡頓。
而對于音畫不同步,主要在于錄制器的幀率要保持和采集器的幀率一致,即 recorder.setFrameRate(grabber.getFrameRate()) 。
另外,說到卡頓是推流消耗時間比音視頻時長要長,而如果 10 分鐘長的視頻。只需要 5 分鐘就可以推送完成又會怎么樣?測試過程使用 ffplay 進(jìn)行播放,發(fā)現(xiàn)其會跳進(jìn)度,即每次中間提前推送了的時長的數(shù)據(jù)直接被跳過,還有就是推流進(jìn)程結(jié)束之后,還能夠繼續(xù)播放幾十秒鐘;因此,需要使用線程休眠盡量的保持推送時間和視頻時間的同步和一致;
以上就是JavaCV 本地視頻推流的詳細(xì)內(nèi)容,更多關(guān)于JavaCV 本地視頻推流的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
xxl-job在 Spring Boot 項目中的完整配置指南(最新整理)
本文詳細(xì)介紹了Spring Boot任務(wù)調(diào)度配置,包括依賴配置、多環(huán)境支持、任務(wù)處理器、高級配置、常見問題及解決方法,以及項目結(jié)構(gòu)和注意事項,感興趣的朋友跟隨小編一起看看吧2025-12-12
MybatisPlus 不修改全局策略和字段注解如何將字段更新為null
這篇文章主要介紹了MybatisPlus 不修改全局策略和字段注解如何將字段更新為null,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-04-04
Java基于面向?qū)ο髮崿F(xiàn)一個戰(zhàn)士小游戲
這篇文章主要為大家詳細(xì)介紹了Java如何基于面向?qū)ο髮崿F(xiàn)一個戰(zhàn)士小游戲,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以動手嘗試一下2022-07-07
Java JAR 啟動內(nèi)存參數(shù)配置指南(從基礎(chǔ)設(shè)置到性能優(yōu)化)
在啟動 Java 可執(zhí)行 JAR 文件時,合理配置 JVM 內(nèi)存參數(shù)是保障應(yīng)用穩(wěn)定性和性能的關(guān)鍵,本文將系統(tǒng)講解如何通過命令行參數(shù)、環(huán)境變量等方式指定內(nèi)存配置,并結(jié)合實際場景提供優(yōu)化建議,感興趣的朋友跟隨小編一起看看吧2025-11-11
Java適配器模式_動力節(jié)點Java學(xué)院整理
這篇文章主要介紹了Java適配器模式,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-07-07
Java請求流量合并和拆分提高系統(tǒng)的并發(fā)量示例
這篇文章主要為大家介紹了Java請求流量合并和拆分提高系統(tǒng)的并發(fā)量示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步早日升職加薪2022-04-04

