java直播推流

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; public class CmdRunnable implements Runnable{ private String channel=""; private Boolean isRun=false; private Process process=null; @Override public void run() { Thread.currentThread().setName("ffmpeg"+channel); String command="ffmpeg -f rtsp -rtsp_transport tcp -i" + " \"rtsp://admin:abcd1234@192.168.10.11:554/Streaming/Channels/"+channel+"01\"" + " -vcodec libx264 -vprofile baseline" + " -acodec libmp3lame -ar 44100 -ac 1 -f flv" + " rtmp://172.18.1.229:1935/live/show"+channel; try { cmd(command); }catch (Exception ex){ if (ex instanceof InterruptedException){ System.out.println("关闭线程:"+Thread.currentThread().getName()); }else { ex.printStackTrace(); } }finally { isRun=false; process.destroy(); } } private void cmd(String command) throws IOException, InterruptedException { String line=null; Runtime runtime = Runtime.getRuntime(); process = runtime.exec(command); //用于存储执行命令的错误信息 Thread out = new Thread(new CmdReadRunnable(channel,new InputStreamReader(process.getErrorStream(),"GB2312"))); out.start(); process.waitFor();//会堵塞线程 } public CmdRunnable(String channel) { this.channel=channel; } }