查看hadoop 是否运行
执行工具类 ExecCMD：主要判断其进程：jps hadoop : NameNode DataNode hbase :HMasterhive : RunJar package com.winhong.test.util;<p>import java.io.BufferedReader;import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;</p><p>import org.json.JSONException;
import org.json.JSONObject;</p><p>/**
* @author kuanghj| 下午4:16:21 | 创建
*/
public class ExecCMD
{
/**
* 检查服务实例是否在运行
*
* @param param
* @return
* @throws JSONException
*/
public static boolean isCheckRun(String param, JSONObject temp) throws JSONException
{
List<String> strlst = new ArrayList<String>();
boolean isRun = false;
try {</p><p> Process process = null;</p><p> String[] cmdArray = new String[]{"/bin/sh", "-c", "ssh " + temp.getString("hostIP") + " \"ps -ef | grep " + param + "\""};
System.out.println(cmdArray);
process = Runtime.getRuntime().exec(cmdArray);</p><p> InputStream is = process.getInputStream();</p><p> InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null)
{
strlst.add(line);
if (line.contains(param + " start"))
{
isRun = true;
}
}
is.close();
isr.close();
return isRun;
} catch (IOException e)
{
e.printStackTrace();
}</p><p> return isRun;
}
/**
* 监控Hbase的数据，返回监控结果
*
* @param
* @return
*/
public static List<String> monitorHbase(JSONObject temp) throws JSONException
{
List<String> strList = new ArrayList<String>();</p><p> try {
boolean isStart = isCheckRun("HMaster", temp);
if (isStart)
{
// ssh 192.168.1.61 "echo \"status 'simple'\" | /home/hadmin/hbase/bin/hbase shell"
Process process = null;</p><p> String cmd = "echo <a>\\\"status</a> 'simple'\\\"";
String ip = temp.getString("hostIP");
String appPath = temp.getString("installPath");
String[] cmdArray = new String[]{"/bin/sh", "-c", "ssh " + ip + " \"" + cmd + " | " + appPath + "/bin/hbase shell\""};
process = Runtime.getRuntime().exec(cmdArray);</p><p> InputStream is = process.getInputStream();</p><p> InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null)
{
strList.add(line);
}
is.close();
isr.close();
}</p><p> return strList;
} catch (IOException e) {
e.printStackTrace();
}</p><p> return strList;
}
/**
*取得用户占用空间
* @param temp
* @return
* @author kuanghj |下午4:20:58
* @version 0.1
*/
public static String getStroageData(JSONObject temp) throws JSONException
{
List<String> strlst = new ArrayList<String>();
String home = temp.getString("home");
String value = "";
try {</p><p> Process process = null;</p><p> String[] cmdArray = new String[]{"/bin/sh", "-c", "hadoop fs -du " + home};
process = Runtime.getRuntime().exec(cmdArray);</p><p> InputStream is = process.getInputStream();</p><p> InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null)
{
strlst.add(line);
if (line.contains(home))
{
value = line;
break;
}
}
is.close();
isr.close();
}
catch (IOException e)
{
e.printStackTrace();
}</p><p> return value;</p><p> }
/**
* 取到当前时间 格试为yyyyMMddHHmmssSSS
*
* @return
*/
public static String getCurrtime()
{
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmssSSS");
String currTime = format.format(date);</p><p> return currTime;
}
}
</p>
版权声明：本文为博主原创文章，未经博主允许不得转载。
页:
[1]