推流过程

1. 首先为了将来可以扩展多种协议（TRSP、RTMP）的视频推流功能，我们创建BStreamer基类。

/**
 1. 基础视频流
 */
public class BStreamer {
    private int width = 640;
    private int height = 480;
    private String url;

    public BStreamer(String url) {
        this.url = url;
    }

    public BStreamer(String url, int w, int h) {
        this.url = url;
        if (w > 0 && h > 0) {
            this.width = w;
            this.height = h;
        }
    }
    public int getWidth() {
        return width;
    }

    public void setWidth(int width) {
        this.width = width;
    }

    public int getHeight() {
        return height;
    }

    public void setHeight(int height) {
        this.height = height;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }}12345678910111213141516171819202122232425262728293031323334353637383940414243

1. 根据上面BStreamer基类，我们扩展实现RTSP协议的视频推流器，由于本实例是采用FFMPEG为推流手段，所以我们下面创建FFmpegPusher实体类。

public class FFmpegPusher extends BStreamer {
    public FFmpegPusher(String url) {
        super(url);
    }

    public FFmpegPusher(String url, int w, int h) {
        super(url, w, h);
    }
    private Process process;

    public void push(){
        String basePath="F:\\ffmpeg-4.2.1-win64-shared\\bin";
        String videoPath=String.format("%s\\test.mp4",basePath);
        String ffmpegPath=String.format("%s\\ffmpeg",basePath);
       try {
            // 视频切换时，先销毁进程，全局变量Process process，方便进程销毁重启，即切换推流视频
            if(process != null){
                process.destroy();
                System.out.println(">>>>>>>>>>推流视频切换<<<<<<<<<<");
            }
           // ffmpeg开头，-re代表按照帧率发送，在推流时必须有
           // 指定要推送的视频
           // 指定推送服务器，-f：指定格式
           String command =String.format("%s -re -i %s -f rtsp %s",
                   ffmpegPath,videoPath,getUrl());
            System.out.println("ffmpeg推流命令：" + command);
            // 运行cmd命令，获取其进程
            process = Runtime.getRuntime().exec(command);
            // 输出ffmpeg推流日志
            BufferedReader br= new BufferedReader(new InputStreamReader(process.getErrorStream()));
            String line = "";
            while ((line = br.readLine()) != null) {
                System.out.println("视频推流信息[" + line + "]");
            }
            process.waitFor();
        }catch (Exception e){
            e.printStackTrace();
        }
    }}12345678910111213141516171819202122232425262728293031323334353637383940

1. 创建单元测试

public class TestRTSPFFmpegPusher {
    public static void main(String[] args) throws Exception {
        String url="rtsp://192.168.56.1/test";
        FFmpegPusher pusher=new FFmpegPusher(url);
        pusher.push();
    }}1234567

1. 运行以上测试程序得到如下结果
   

2. 在服务端查看推流结果（服务下载地址：http://www.easydarwin.org/）
   

3. 客户端测试拉取上面的视频流进行直播显示