import org.bytedeco.ffmpeg.global.avcodec;
import org.bytedeco.javacv.*;
public class LivePuller {
    public void pull(String rtmp, String outputVideoPath) {
        FFmpegFrameGrabber grabber = null;
        FFmpegFrameRecorder recorder = null;
        try {
            FFmpegLogCallback.set();
            boolean hasStream = false;
            grabber = new FFmpegFrameGrabber(rtmp);
            grabber.setOption("nobuffer", "1");
            // 采集流超時時間，停止推流后，grab() 大致會在 20 秒左右超時停止；值也不宜太小，否則可能有些音視頻幀采集不到影響推流
            grabber.setOption("rw_timeout", "1000000");
            grabber.setVideoCodec(avcodec.AV_CODEC_ID_MPEG4);
            // setPixelFormat，可能會導(dǎo)致圖片幀保存的是黑白照
//            grabber.setPixelFormat(avutil.AV_PIX_FMT_YUV420P);
            grabber.setFormat("flv");
            grabber.setAudioCodec(avcodec.AV_CODEC_ID_AAC);
            // 先執(zhí)行代碼后有直播流的情況下，grabber.start() 會拋出異常；因此循環(huán)start()，直到有流數(shù)據(jù)時成功
            while (!hasStream) {
                try {
                    grabber.start();
                    hasStream = true;
                } catch (Exception ignored) {
                } finally {
                    try {
                        Thread.sleep(100);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
            // 重置分辨率
            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));
            }
            recorder = new FFmpegFrameRecorder(outputVideoPath, grabber.getImageWidth(), grabber.getImageHeight());
            recorder.setOption("nobuffer", "1");
            recorder.setAudioChannels(grabber.getAudioChannels());
            recorder.setFrameRate(grabber.getFrameRate());  // 保持和采集一樣的幀率，避免音畫不同步；
            recorder.setVideoQuality(0);    // 視頻質(zhì)量（清晰度）
            recorder.setAudioQuality(0);    // 音頻質(zhì)量
            // --------------------------- 非必須 ------------------------------
            // 當(dāng)設(shè)置了下方的錄制器的視頻編碼，需要再加上 setVideoBitrate 保證視頻質(zhì)量
            recorder.setVideoBitrate(grabber.getVideoBitrate());
            recorder.setVideoCodec(grabber.getVideoCodec());    // 指定為 mp4 錄制時需要 avcodec.AV_CODEC_ID_MPEG4
//            // 當(dāng)上面 grabber 沒有設(shè)置 setPixelFormat，recorder.setPixelFormat 最好不要使用 grabber.getPixelFormat()；可能異常
//            recorder.setPixelFormat(grabber.getPixelFormat());
//            recorder.setFormat(grabber.getFormat());
//            recorder.setAudioCodec(grabber.getAudioCodec());
//            recorder.setSampleRate(grabber.getSampleRate());
            recorder.start();
            Frame frame;
            while ((frame = grabber.grab()) != null) {
                // 此處不能判斷 frame.streamIndex 為 avutil.AVMEDIA_TYPE_VIDEO 或 avutil.AVMEDIA_TYPE_DATA；遇到過采集流時兩個類型是反著的
                if (frame.image != null || frame.samples != null) {
                    // frame.image 是圖像數(shù)據(jù)，frame.samples 是聲音數(shù)據(jù)
                    recorder.record(frame);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (grabber != null) {
                try {
                    grabber.close();
                } catch (FrameGrabber.Exception e) {
                    e.printStackTrace();
                }
            }
            if (recorder != null) {
                try {
                    recorder.close();
                } catch (FrameRecorder.Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}