/*** 功能：将任意格式的视频转化为flv格式，有利于在线视频播放

* ps: ffmpeg 能解析的格式：asx，asf，mpg，wmv，3gp，mp4，mov，avi，flv等

* mencoder 解析剩下的格式：wmv9，rm，rmvb

* time：2013.12.11*/

package softflag.core.util;

import java.io.BufferedReader;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.util.List;

import softflag.index.IndexService;

public class VideoConverter {

public synchronized void convert(String inputFile, String outputFile) {

process(inputFile, outputFile);

}

private static String getAviFilePath(String filePath) {

String path = filePath.substring(0, filePath.lastIndexOf(".")) + ".avi";

return path;

}

/**

* 转换过程 ：先检查文件类型，在决定调用 processFlv还是processAVI

*

* @param inputFile

* @param outputFile

* @return

*/

private void process(String inputFile, String outputFile) {

int type = checkContentType(inputFile);

if (type == 0) {

processFLV(inputFile, outputFile);// 直接将文件转为flv文件

} else if (type == 1) {

processAVI(type, inputFile,outputFile);

}

}

/**

* 检查视频类型

*

* @param inputFile

* @return ffmpeg 能解析返回0，不能解析返回1

*/

private static int checkContentType(String inputFile) {

String type = inputFile.substring(inputFile.lastIndexOf(".") + 1,

inputFile.length()).toLowerCase();

// ffmpeg能解析的格式：(asx，asf，mpg，wmv，3gp，mp4，mov，avi，flv等)

if (type.equals("avi")) {

return 0;

} else if (type.equals("mpg")) {

return 0;

} else if (type.equals("wmv")) {

return 0;

} else if (type.equals("3gp")) {

return 0;

} else if (type.equals("mov")) {

return 0;

} else if (type.equals("mp4")) {

return 0;

} else if (type.equals("asf")) {

return 0;

} else if (type.equals("asx")) {

return 0;

} else if (type.equals("flv")) {

return 0;

}

// 对ffmpeg无法解析的文件格式(wmv9，rm，rmvb等),

// 可以先用别的工具(mencoder)转换为avi(ffmpeg能解析的)格式.

else if (type.equals("wmv9")) {

return 1;

} else if (type.equals("rm")) {

return 1;

} else if (type.equals("rmvb")) {

return 1;

}

return 9;

}

/**

* ffmepg: 能解析的格式：(asx，asf，mpg，wmv，3gp，mp4，mov，avi，flv等)

*

* @param inputFile

* @param outputFile

* @return

*/

private void processFLV(String inputFile, String outputFile) {

try {

try {

List commend = new java.util.ArrayList();

// 低精度

commend.add(IndexService.getConfigValue("check_multi_ffmpegPath"));

commend.add("-i");

commend.add(inputFile);

commend.add("-ab");

commend.add("64");

commend.add("-acodec");

commend.add("mp3");

commend.add("-ac");

commend.add("2");

commend.add("-ar");

commend.add("22050");

commend.add("-b");

commend.add("230");

commend.add("-r");

commend.add("24");

commend.add("-y");

commend.add(outputFile);

StringBuffer test = new StringBuffer();

for (int i = 0; i < commend.size(); i++)

test.append(commend.get(i) + " ");

//                            System.out.println(test);

try {

ProcessBuilder builder = new ProcessBuilder();

builder.command(commend);

Process p = builder.start();

doWaitFor(p);

p.destroy();

} catch (Exception e) {

e.printStackTrace();

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

/**

* Mencoder: 对ffmpeg无法解析的文件格式(wmv9，rm，rmvb等),

* 可以先用别的工具(mencoder)转换为avi(ffmpeg能解析的)格式.

*

* @param type

* @param inputFile

* @return

*/

private void processAVI(int type, String inputFile,String outputFile) {

String aviPath = getAviFilePath(inputFile);

String outputFilePath = outputFile;

File file = new File(aviPath);

if (file.exists())

file.delete();

List commend = new java.util.ArrayList();

commend.add(IndexService.getConfigValue("check_multi_mencoderPath"));

commend.add(inputFile);

commend.add("-oac");

commend.add("mp3lame");

commend.add("-lameopts");

commend.add("preset=64");

commend.add("-ovc");

commend.add("xvid");

commend.add("-xvidencopts");

commend.add("bitrate=600");

commend.add("-of");

commend.add("avi");

commend.add("-o");

commend.add(aviPath);

StringBuffer test = new StringBuffer();

for (int i = 0; i < commend.size(); i++)

test.append(commend.get(i) + " ");

//            System.out.println(test);

try {

ProcessBuilder builder = new ProcessBuilder();

builder.command(commend);

Process p = builder.start();

/**

* 清空Mencoder进程 的输出流和错误流 因为有些本机平台仅针对标准输入和输出流提供有限的缓冲区大小，

* 如果读写子进程的输出流或输入流迅速出现失败，则可能导致子进程阻塞，甚至产生死锁。

*/

final InputStream is1 = p.getInputStream();

final InputStream is2 = p.getErrorStream();

new Thread() {

public void run() {

BufferedReader br = new BufferedReader(

new InputStreamReader(is1));

try {

String lineB = null;

while ((lineB = br.readLine()) != null) {

if (lineB != null)

System.out.println(lineB);

}

is1.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}.start();

new Thread() {

public void run() {

BufferedReader br2 = new BufferedReader(

new InputStreamReader(is2));

try {

String lineC = null;

while ((lineC = br2.readLine()) != null) {

if (lineC != null)

System.out.println(lineC);

}

br2.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}.start();

doWaitFor(p);

p.destroy();

processFLV(aviPath,outputFilePath);

} catch (Exception e) {

System.err.println(e);

}

}

public int doWaitFor(Process p) {

InputStream in = null;

InputStream err = null;

int exitValue = -1; // returned to caller when p is finished

try {

//            System.out.println("comeing");

in = p.getInputStream();

err = p.getErrorStream();

boolean finished = false; // Set to true when p is finished

while (!finished) {

try {

while (in.available() > 0) {

Character c = new Character((char) in.read());

System.out.print(c);

}

while (err.available() > 0) {

Character c = new Character((char) err.read());

System.out.print(c);

}

exitValue = p.exitValue();

finished = true;

} catch (IllegalThreadStateException e) {

Thread.currentThread().sleep(500);

}

}

} catch (Exception e) {

System.err.println("doWaitFor();: unexpected exception - "

+ e.getMessage());

} finally {

try {

if (in != null) {

in.close();

}

} catch (IOException e) {

System.out.println(e.getMessage());

}

if (err != null) {

try {

err.close();

} catch (IOException e) {

System.out.println(e.getMessage());

}

}

}

return exitValue;

}

}