Hadoop运维记录系列(二十一)
static HashSet blockedCodeString = new HashSet();static {
blockedCodeString.add(new String[]{"import", "os"});
blockedCodeString.add(new String[]{"import", "sys"});
blockedCodeString.add(new String[]{"import", "subprocess"});
blockedCodeString.add(new String[]{"import", "pty"});
blockedCodeString.add(new String[]{"import", "socket"});
blockedCodeString.add(new String[]{"import", "commands"});
blockedCodeString.add(new String[]{"import", "paramiko"});
blockedCodeString.add(new String[]{"import", "pexpect"});
blockedCodeString.add(new String[]{"import", "BaseHTTPServer"});
blockedCodeString.add(new String[]{"import", "ConfigParser"});
blockedCodeString.add(new String[]{"import", "platform"});
blockedCodeString.add(new String[]{"import", "popen2"});
blockedCodeString.add(new String[]{"import", "copy"});
blockedCodeString.add(new String[]{"import", "SocketServer"});
blockedCodeString.add(new String[]{"import", "sysconfig"});
blockedCodeString.add(new String[]{"import", "tty"});
blockedCodeString.add(new String[]{"import", "xmlrpmlib"});
blockedCodeString.add(new String[]{"etc"});
blockedCodeString.add(new String[]{"boot"});
blockedCodeString.add(new String[]{"dev"});
blockedCodeString.add(new String[]{"lib"});
blockedCodeString.add(new String[]{"lib64"});
blockedCodeString.add(new String[]{"lost+found"});
blockedCodeString.add(new String[]{"mnt"});
blockedCodeString.add(new String[]{"proc"});
blockedCodeString.add(new String[]{"root"});
blockedCodeString.add(new String[]{"sbin"});
blockedCodeString.add(new String[]{"selinux"});
blockedCodeString.add(new String[]{"usr"});
blockedCodeString.add(new String[]{"passwd"});
blockedCodeString.add(new String[]{"useradd"});
blockedCodeString.add(new String[]{"userdel"});
blockedCodeString.add(new String[]{"rm"});
blockedCodeString.add(new String[]{"akka "});
blockedCodeString.add(new String[]{"groupadd"});
blockedCodeString.add(new String[]{"groupdel"});
blockedCodeString.add(new String[]{"mkdir"});
blockedCodeString.add(new String[]{"rmdir"});
blockedCodeString.add(new String[]{"ping"});
blockedCodeString.add(new String[]{"nc"});
blockedCodeString.add(new String[]{"telnet"});
blockedCodeString.add(new String[]{"ftp"});
blockedCodeString.add(new String[]{"scp"});
blockedCodeString.add(new String[]{"ssh"});
blockedCodeString.add(new String[]{"ps"});
blockedCodeString.add(new String[]{"hostname"});
blockedCodeString.add(new String[]{"uname"});
blockedCodeString.add(new String[]{"vim"});
blockedCodeString.add(new String[]{"nano"});
blockedCodeString.add(new String[]{"top"});
blockedCodeString.add(new String[]{"cat"});
blockedCodeString.add(new String[]{"more"});
blockedCodeString.add(new String[]{"less"});
blockedCodeString.add(new String[]{"chkconfig"});
blockedCodeString.add(new String[]{"service"});
blockedCodeString.add(new String[]{"netstat"});
blockedCodeString.add(new String[]{"iptables"});
blockedCodeString.add(new String[]{"ip"});
blockedCodeString.add(new String[]{"route "});
blockedCodeString.add(new String[]{"curl"});
blockedCodeString.add(new String[]{"wget"});
blockedCodeString.add(new String[]{"sysctl"});
blockedCodeString.add(new String[]{"touch"});
blockedCodeString.add(new String[]{"scala.sys.process"});
blockedCodeString.add(new String[]{"0.0.0.0"});
blockedCodeString.add(new String[]{"git"});
blockedCodeString.add(new String[]{"svn"});
blockedCodeString.add(new String[]{"hg"});
blockedCodeString.add(new String[]{"cvs"});
blockedCodeString.add(new String[]{"exec"});
blockedCodeString.add(new String[]{"ln"});
blockedCodeString.add(new String[]{"kill"});
blockedCodeString.add(new String[]{"rsync"});
blockedCodeString.add(new String[]{"lsof"});
blockedCodeString.add(new String[]{"crontab"});
blockedCodeString.add(new String[]{"libtool"});
blockedCodeString.add(new String[]{"automake"});
blockedCodeString.add(new String[]{"autoconf"});
blockedCodeString.add(new String[]{"make"});
blockedCodeString.add(new String[]{"gcc"});
blockedCodeString.add(new String[]{"cc"});
}
static boolean allMatch(String aim, String[] checker){
if(checker == null || checker.length < 1){
return false;
}else {
// by default, treat as match, every not match change it
for (String i : checker) {
if (!aim.matches(".*\\b" + i + "\\b.*")){
return false;
}
}
return true;
}
}
static String anyMatch(String aim, HashSet all) throws Exception{
if(aim.contains("FUCK P&G")){
thrownew Exception("How do you know this ????");
} else {
for (String[] one : all) {
if (allMatch(aim, one)) {
StringBuilder sb = new StringBuilder();
for (String s : one) {
sb.append(s + " ");
}
return sb.toString();
}
}
throw new Exception("No one match");
}
}
//......此处是个public类
try{
String matchesStrings = anyMatch(st, blockedCodeString);
result = new InterpreterResult(Code.ERROR, "Contains dangerous code : " + matchesStrings);
}catch (Exception me){ // no match any
scheduler.submit(job);
while (!job.isTerminated()) {
synchronized (jobListener) {
try {
jobListener.wait(1000);
} catch (InterruptedException e) {
logger.info("Exception in RemoteInterpreterServer while interpret, jobListener.wait", e);
}
}
}
if (job.getStatus() == Status.ERROR) {
result = new InterpreterResult(Code.ERROR, Job.getStack(job.getException()));
} else {
result = (InterpreterResult) job.getReturn();
// in case of job abort in PENDING status, result can be null
if (result == null) {
result = new InterpreterResult(Code.KEEP_PREVIOUS_RESULT);
}
}
}
//......直到该public类结束
页:
[1]