javaCV系列文章：

補充篇：

• 歡迎大家積極開心的加入討論群

javacpp-ffmpeg:

前言：

本章基於javaCV實現轉流器和收流器功能，測試採用監控rtsp地址轉發至rtmp伺服器地址

新增openCV儲存圖片功能。

補充：

作為轉流器可以輕鬆實現rtsp/rtmp/本地檔案/本地攝像頭推送到rtmp流媒體伺服器；

作為收流器可以用來把流媒體伺服器視訊流錄製到本地檔案。

關於預設接收/推送rtsp流丟幀問題，由於ffmpeg預設採用udp方式，所以可以通過更改為tcp的方式來實現丟幀補償，解決方式如下：

1、FFmpeg命令方式：增加一個配置命令 -rtsp_transport tcp

2、javacv方式：FFmpegFrameGrabber.java中533行 AVDictionary options= new AVDictionary(null);後面增加一個配置av_dict_set(options, "rtsp_transport", "tcp", 0); 即可

3、ffmpeg原生方式：同上

一、開發所依賴的包（具體依賴包請檢視javacv開發詳解之1）

本章使用windows環境開發，基於javaCV的基礎支撐包以及ffmpeg-3.1.2-1.2.jar、ffmpeg-3.1.2-1.2-windows-x86.jar、ffmpeg-3.1.2-1.2-windows-x86_64.jar；

補充：

如果想要給視訊新增水印，需要從視訊中取出影象幀，給影象幀新增文字、圖片水印即可

在此之前我們需要取到BufferedImage，通過這個我們就可以用java的方式新增水印

如何從grabber中獲取BufferedImage：

//獲取BufferedImage可以給影象幀新增水印
		Java2DFrameConverter javaconverter=new Java2DFrameConverter();
		BufferedImage buffImg=javaconverter.convert(grabber.grab());

獲取到了BufferedImage我們就可以給視訊幀新增文字或者圖片水印了

二、程式碼實現

本功能實現按幀取流和轉發服務

/**
	 * 轉流器
	 * @param inputFile
	 * @param outputFile
	 * @throws Exception
	 * @throws org.bytedeco.javacv.FrameRecorder.Exception
	 * @throws InterruptedException
	 */
	public static void recordPush(String inputFile,String outputFile,int v_rs) throws Exception, org.bytedeco.javacv.FrameRecorder.Exception, InterruptedException{
		Loader.load(opencv_objdetect.class);
		long startTime=0;
		FrameGrabber grabber =FFmpegFrameGrabber.createDefault(inputFile);
		try {
			grabber.start();
		} catch (Exception e) {
			try {
				grabber.restart();
			} catch (Exception e1) {
				throw e;
			}
		}
		
		OpenCVFrameConverter.ToIplImage converter = new OpenCVFrameConverter.ToIplImage();
		Frame grabframe =grabber.grab();
		IplImage grabbedImage =null;
		if(grabframe!=null){
			System.out.println("取到第一幀");
			grabbedImage = converter.convert(grabframe);
		}else{
			System.out.println("沒有取到第一幀");
		}
		//如果想要儲存圖片,可以使用 opencv_imgcodecs.cvSaveImage("hello.jpg", grabbedImage);來儲存圖片
		FrameRecorder recorder;
		try {
			recorder = FrameRecorder.createDefault(outputFile, 1280, 720);
		} catch (org.bytedeco.javacv.FrameRecorder.Exception e) {
			throw e;
		}
		recorder.setVideoCodec(avcodec.AV_CODEC_ID_H264); // avcodec.AV_CODEC_ID_H264
		recorder.setFormat("flv");
		recorder.setFrameRate(v_rs);
		recorder.setGopSize(v_rs);
		System.out.println("準備開始推流...");
		try {
			recorder.start();
		} catch (org.bytedeco.javacv.FrameRecorder.Exception e) {
			try {
				System.out.println("錄製器啟動失敗，正在重新啟動...");
				if(recorder!=null)
				{
					System.out.println("嘗試關閉錄製器");
					recorder.stop();
					System.out.println("嘗試重新開啟錄製器");
					recorder.start();
				}
				
			} catch (org.bytedeco.javacv.FrameRecorder.Exception e1) {
				throw e;
			}
		}
		System.out.println("開始推流");
		CanvasFrame frame = new CanvasFrame("camera", CanvasFrame.getDefaultGamma() / grabber.getGamma());
		frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		frame.setAlwaysOnTop(true);
		while (frame.isVisible() && (grabframe=grabber.grab()) != null) {
			System.out.println("推流...");
			frame.showImage(grabframe);
			grabbedImage = converter.convert(grabframe);
			Frame rotatedFrame = converter.convert(grabbedImage);
			
			if (startTime == 0) {
				startTime = System.currentTimeMillis();
			}
			recorder.setTimestamp(1000 * (System.currentTimeMillis() - startTime));//時間戳
			if(rotatedFrame!=null){
			recorder.record(rotatedFrame);
			}
			
			Thread.sleep(40);
		}
		frame.dispose();
		recorder.stop();
		recorder.release();
		grabber.stop();
		System.exit(2);
	}

三、測試轉流服務

public static void main(String[] args)
			throws FrameRecorder.Exception, FrameGrabber.Exception, InterruptedException {

		 String inputFile = "rtsp://admin:[email protected]:37779/cam/realmonitor?channel=1&subtype=0";

		String outputFile="rtmp://192.168.30.21/live/pushFlow";

		recordPush(inputFile, outputFile,25);

支援eguid原創