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

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);
        }
    }
}