package com.mandi.servlet.file.impl;
|
|
import java.io.File;
|
import java.io.InputStream;
|
import java.net.URL;
|
import java.nio.ByteBuffer;
|
import java.nio.channels.Channels;
|
import java.nio.channels.ReadableByteChannel;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.locks.Lock;
|
import java.util.concurrent.locks.ReentrantLock;
|
|
import org.apache.log4j.Logger;
|
import org.dom4j.Document;
|
import org.dom4j.DocumentException;
|
import org.dom4j.Element;
|
import org.dom4j.io.SAXReader;
|
import org.springframework.context.annotation.Scope;
|
import org.springframework.stereotype.Service;
|
|
|
|
|
@Service("flashpaper")
|
@Scope(value="singleton")
|
public class Flashpaper extends Thread{
|
private Logger log=Logger.getLogger(Flashpaper.class);
|
private List<File> list=null;
|
private Lock lock=null;
|
private Object obj=null;
|
private boolean executeflag=false;
|
private String flashpaperurl=null;
|
private String findflashpaper()
|
{
|
@SuppressWarnings("rawtypes")
|
Class tc=Flashpaper.class;
|
URL turl=tc.getResource("/");//get the root path of class ,like the location where struts.xml is
|
if(turl==null)
|
return null;
|
File file=new File(turl.getPath()+"flashpaper.xml");
|
if(!file.exists())
|
return null;
|
SAXReader reader=new SAXReader();
|
try {
|
Document doc=reader.read(file);
|
Element ele=doc.getRootElement();
|
if(ele==null)
|
return null;
|
Element ele1=ele.element("flashpaher");
|
if(ele1==null)
|
return null;
|
String path=ele1.getTextTrim();
|
if(path!=null&&!path.isEmpty())
|
return path;
|
} catch (DocumentException e) {
|
log.error("findflashpaper error");
|
}
|
return null;
|
}
|
public Flashpaper() {
|
flashpaperurl=this.findflashpaper();
|
log.info(flashpaperurl);
|
list=new ArrayList<File>();
|
lock=new ReentrantLock();
|
obj=new Object();
|
executeflag=true;
|
this.start();
|
}
|
public boolean printFile(File file)
|
{
|
if(!file.exists())
|
return false;
|
lock.lock();
|
this.list.add(file);
|
lock.unlock();
|
synchronized (obj) {
|
obj.notify();
|
}
|
return true;
|
}
|
@Override
|
public void run() {
|
// TODO Auto-generated method stub
|
log.info("flashpaper start thread!!");
|
// final Logger log1=this.log;
|
ProcessBuilder processbuilder=new ProcessBuilder();
|
Map<String, String> envmap=processbuilder.environment();
|
envmap.clear();
|
envmap.putAll(System.getenv());
|
while(executeflag)
|
{
|
File file=null;
|
lock.lock();
|
if(list.size()>0)
|
{
|
file=list.get(0);
|
list.remove(0);
|
}
|
lock.unlock();
|
if(file==null)
|
{
|
synchronized (obj) {
|
try {
|
log.info("start waiting ...");
|
obj.wait();
|
log.info("waking...");
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
continue;
|
}
|
String cmd=this.flashpaperurl;
|
List<String> command = new java.util.ArrayList<String>();
|
command.add(cmd);
|
command.add(file.getPath());
|
command.add("-o");
|
command.add(file.getPath()+".swf");
|
cmd=cmd+" "+file.getPath()+" -o "+file.getPath()+".swf";
|
Process process=null;
|
File fileparent=file.getParentFile();
|
try {
|
if(fileparent.exists()&& fileparent.isDirectory())
|
processbuilder.directory(fileparent);
|
process=processbuilder.command(command).start();
|
if(process==null)
|
log.warn("can not start flashpapper");
|
final InputStream is=process.getInputStream();
|
final InputStream error=process.getErrorStream();
|
final ByteBuffer bytebuffer=ByteBuffer.allocate(1024);
|
final ByteBuffer bytebuffer1=ByteBuffer.allocate(1024);
|
Thread th=new Thread(){
|
@Override
|
public void run() {
|
// TODO Auto-generated method stub
|
ReadableByteChannel channel=Channels.newChannel(is);
|
try {
|
while(channel.read(bytebuffer)!=-1)
|
{
|
bytebuffer.flip();
|
bytebuffer.clear();
|
}
|
} catch (Exception e) {
|
// TODO: handle exception
|
log.error("can't convert");
|
e.printStackTrace();
|
}
|
}
|
};
|
Thread th1=new Thread(){
|
|
@Override
|
public void run() {
|
// TODO Auto-generated method stub
|
ReadableByteChannel channel1=Channels.newChannel(error);
|
try {
|
while(channel1.read(bytebuffer)!=-1)
|
{
|
bytebuffer1.flip();
|
bytebuffer1.clear();
|
}
|
} catch (Exception e) {
|
// TODO: handle exception
|
log.error("can't convert");
|
e.printStackTrace();
|
}
|
}
|
};
|
th.setDaemon(true);
|
th.start();
|
th1.setDaemon(true);
|
th1.start();
|
try{
|
int value=process.waitFor();
|
log.info("process waitfor code is:"+value);
|
}catch (Exception e) {
|
// TODO: handle exception
|
log.error("waitfor error"+e.getMessage());
|
}
|
}catch (Exception e) {
|
// TODO: handle exception
|
log.error("flashpaper can't convert the file"+e.getMessage());
|
} finally{
|
if(process!=null)
|
process.destroy();
|
}
|
}
|
if(executeflag==false)
|
{
|
this.list.clear();
|
}
|
}
|
|
public void stopExecute()
|
{
|
this.executeflag=false;
|
}
|
public String getFlashpaperurl() {
|
return flashpaperurl;
|
}
|
public void setFlashpaperurl(String flashpaperurl) {
|
this.flashpaperurl = flashpaperurl;
|
}
|
}
|
