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

remove unused code

Browse source
This commit is contained in:
leon.li 2016-08-30 15:31:35 +08:00
parent 025bcd1705
commit 9d01966476
4 changed files with 12 additions and 114 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
camel-agent/src/main/java/com/dianping/platform/slb/agent/constant/Constants.java Normal file
View file

@ -0,0 +1,12 @@
package com.dianping.platform.slb.agent.constant;
/**
* dianping.com @2015
* slb - soft load balance
* <p/>
* Created by leon.li(Li Yang)
*/
public class Constants {
public static final String CHAREST_UTF8 = "utf-8";
}

42
camel-agent/src/main/java/com/dianping/platform/slb/agent/core/script/DefaultScriptExecutor.java
View file

@ -1,42 +0,0 @@
package com.dianping.platform.slb.agent.core.script;
import org.apache.commons.exec.CommandLine;
import org.apache.commons.exec.DefaultExecutor;
import org.apache.commons.exec.ExecuteWatchdog;
import org.apache.commons.exec.PumpStreamHandler;
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 DefaultExecutor m_executor = new DefaultExecutor();
private ExecuteWatchdog m_watchdog = new ExecuteWatchdog(300000);
{
m_executor.setWatchdog(m_watchdog);
}
@Override
public int exec(String scriptPath, OutputStream normalOutput, OutputStream errorOutput) throws IOException {
CommandLine commandLine = CommandLine.parse(scriptPath);
PumpStreamHandler m_handler = new PumpStreamHandler(normalOutput, errorOutput);
m_executor.setStreamHandler(m_handler);
m_executor.setExitValues(null);
return m_executor.execute(commandLine);
}
@Override
public void kill() {
m_watchdog.destroyProcess();
}
}

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

@ -1,18 +0,0 @@
package com.dianping.platform.slb.agent.core.script;
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 exec(String scriptPath, OutputStream normalOutput, OutputStream errorOutput) throws IOException;
void kill();
}

54
camel-agent/src/main/java/com/dianping/platform/slb/agent/core/script/ScriptFileManager.java
View file

@ -1,54 +0,0 @@
package com.dianping.platform.slb.agent.core.script;
import com.dianping.platform.slb.agent.core.constant.MessageID;
import com.dianping.platform.slb.agent.core.exception.BizException;
import org.springframework.stereotype.Service;
import java.io.File;
import java.net.URL;
/**
* dianping.com @2015
* slb - soft load balance
* <p/>
* Created by leon.li(Li Yang)
*/
@Service
public class ScriptFileManager {
private static final String SCRIPT_FOLDER = "script/";
private static final String TENGINE_RELOAD = "tengine_reload.sh";
private static final String TENGINE_SCRIPT = "tengine.sh";
private static final String SCRIPT_LIST_VS = "ls -l /usr/local/nginx/conf/phoenix-slb/";
private static final String SCRIPT_DEL_VS = "rm -rf /usr/local/nginx/conf/phoenix-slb/%s/";
private File getScriptFile(String fileName) {
URL url = this.getClass().getClassLoader().getResource(SCRIPT_FOLDER + fileName);
if (url == null) {
throw new BizException(MessageID.FILE_NOT_EXIST, SCRIPT_FOLDER + fileName);
}
return new File(url.getPath());
}
public String getTengineReloadPath() {
return getScriptFile(TENGINE_RELOAD).getAbsolutePath();
}
public String getTengineScript() {
return getScriptFile(TENGINE_SCRIPT).getAbsolutePath();
}
public String getListVsScript() {
return SCRIPT_LIST_VS;
}
public String getDelVsScript(String vs) {
return String.format(SCRIPT_DEL_VS, vs);
}
}