dianping/camel
1
1
Fork 0
mirror of https://github.com/dianping/camel.git synced 2024-11-10 09:13:26 +08:00
Code Issues Projects Releases Packages Wiki Activity

add script executor

Browse source
This commit is contained in:
leon.li 2016-08-30 15:19:42 +08:00
parent aa516471f2
commit 826041b60e
2 changed files with 64 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
camel-agent/src/main/java/com/dianping/platform/slb/agent/shell/ScriptExecutor.java Normal file
View file

@ -0,0 +1,18 @@
package com.dianping.platform.slb.agent.shell;
import java.io.IOException;
import java.io.OutputStream;
/**
* dianping.com @2015
* slb - soft load balance
* <p/>
* Created by leon.li(Li Yang)
*/
public interface ScriptExecutor {
int execute(String command, OutputStream stdOutput, OutputStream errorOutput) throws IOException;
void kill();
}

46
camel-agent/src/main/java/com/dianping/platform/slb/agent/shell/impl/DefaultScriptExecutor.java Normal file
View file

@ -0,0 +1,46 @@
package com.dianping.platform.slb.agent.shell.impl;
import com.dianping.platform.slb.agent.shell.ScriptExecutor;
import org.apache.commons.exec.*;
import java.io.IOException;
import java.io.OutputStream;
/**
* dianping.com @2015
* slb - soft load balance
* <p/>
* Created by leon.li(Li Yang)
*/
public class DefaultScriptExecutor implements ScriptExecutor {
private Executor m_executor = new DefaultExecutor();
private ExecuteWatchdog m_executeWatchdog;
public DefaultScriptExecutor() {
this(300000);
}
public DefaultScriptExecutor(long watchDogMills) {
m_executeWatchdog = new ExecuteWatchdog(watchDogMills);
m_executor.setWatchdog(m_executeWatchdog);
}
@Override
public int execute(String command, OutputStream stdOutput, OutputStream errorOutput) throws IOException {
PumpStreamHandler streamHandler = new PumpStreamHandler(stdOutput, errorOutput);
m_executor.setExitValues(null);
m_executor.setStreamHandler(streamHandler);
CommandLine commandLine = CommandLine.parse(command);
return m_executor.execute(commandLine);
}
@Override
public void kill() {
m_executeWatchdog.killedProcess();
}
}