快捷導(dǎo)航

JavaCV?本地視頻推流實(shí)現(xiàn)依賴示例

更新時(shí)間：2023年08月03日 08:51:54 作者：JinYx

這篇文章主要為大家介紹了JavaCV?本地視頻推流實(shí)現(xiàn)的依賴示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

引言

<dependency>
    <groupId>org.bytedeco</groupId>
    <artifactId>javacv-platform</artifactId>
    <version>1.5.6</version>
</dependency>

導(dǎo)入 JavaCV 依賴

編寫(xiě)推流代碼如下：

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();
        /*
         * 測(cè)試時(shí)推了一個(gè)剪映重新生成的高分辨率視頻，其分辨率達(dá)到了 3840x2160；
         * 導(dǎo)致下面的推送速度跟不上實(shí)際消耗的速度；將會(huì)造成直播卡頓; 因此，可以重置其分辨率
         */
        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("本地視頻中沒(méi)有流數(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ù)之間的時(shí)間間隔就是 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("推流測(cè)試 >>>>>>>> " + 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);
        }
    }
}

使用播放器驗(yàn)證推流效果

問(wèn)題總結(jié)

推流時(shí)，主要解決兩個(gè)問(wèn)題：直播流卡頓 和 音畫(huà)不同步。

卡頓的問(wèn)題主要是采集本地視頻流和推流消耗的時(shí)間大于當(dāng)前采集到的視頻的時(shí)長(zhǎng)，通俗描述是 1 分鐘時(shí)長(zhǎng)的音視頻數(shù)據(jù)，使用 FFmpegFrameGrabber 采集 + FFmpegFrameRecorder 推流錄制，需要消耗的時(shí)間超過(guò) 1 分鐘。

因此可以適當(dāng)?shù)恼{(diào)用 setImageWidth 和 setImageHeight 降低視頻的分辨率；或者是調(diào)用 setVideoBitrate 或 setVideoQuality 降低視頻比特率或質(zhì)量等；當(dāng)然，網(wǎng)絡(luò)也會(huì)造成卡頓。

而對(duì)于音畫(huà)不同步，主要在于錄制器的幀率要保持和采集器的幀率一致，即 recorder.setFrameRate(grabber.getFrameRate()) 。

另外，說(shuō)到卡頓是推流消耗時(shí)間比音視頻時(shí)長(zhǎng)要長(zhǎng)，而如果 10 分鐘長(zhǎng)的視頻。只需要 5 分鐘就可以推送完成又會(huì)怎么樣？測(cè)試過(guò)程使用 ffplay 進(jìn)行播放，發(fā)現(xiàn)其會(huì)跳進(jìn)度，即每次中間提前推送了的時(shí)長(zhǎng)的數(shù)據(jù)直接被跳過(guò)，還有就是推流進(jìn)程結(jié)束之后，還能夠繼續(xù)播放幾十秒鐘；因此，需要使用線程休眠盡量的保持推送時(shí)間和視頻時(shí)間的同步和一致；

以上就是JavaCV 本地視頻推流的詳細(xì)內(nèi)容，更多關(guān)于JavaCV 本地視頻推流的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: