添加宕机监控相关代码。

+package com.sitech.ismp.check.downtime;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  宕机表对应的bean。
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeBean
+ * @date 2017年04月16日 13:30
+ */
+public class DowntimeBean implements Serializable{
+
+    //    设备ID
+    private String DEVICE_ID;
+    //    设备IP地址
+    private String DEVICE_IP;
+    //    设备别名
+    private String DEVICE_ALIAS;
+    //    kbp_class 设备的分类
+    private String KBP_CLASS;
+    //  连接协议（ssh/telnet）
+    private String PROTOCOL;
+    //  协议端口
+    private int PROTOCOL_PORT;
+    //  用户名
+    private String USER_NAME;
+    //  密码
+    private String PASSWORD;
+    //  创建日期
+    private Date CREATE_DATE;
+    //  ping IP 后的结果
+    private boolean pingState;
+    //  ping后进行ssh连接后的状态。
+    private boolean sshState;
+    //  告警级别 1 严重告警;2 重要告警
+    private int warningLevel;
+    //  ping后进行ssh连接后的结果，即重要告警还是严重告警。
+    private String warningResult;
+
+    private String unitId;
+
+    public String getDEVICE_ID() {
+        return DEVICE_ID;
+    }
+
+    public void setDEVICE_ID(String DEVICE_ID) {
+        this.DEVICE_ID = DEVICE_ID;
+    }
+
+    public String getDEVICE_IP() {
+        return DEVICE_IP;
+    }
+
+    public void setDEVICE_IP(String DEVICE_IP) {
+        this.DEVICE_IP = DEVICE_IP;
+    }
+
+    public String getDEVICE_ALIAS() {
+        return DEVICE_ALIAS;
+    }
+
+    public void setDEVICE_ALIAS(String DEVICE_ALIAS) {
+        this.DEVICE_ALIAS = DEVICE_ALIAS;
+    }
+
+    public String getKBP_CLASS() {
+        return KBP_CLASS;
+    }
+
+    public void setKBP_CLASS(String KBP_CLASS) {
+        this.KBP_CLASS = KBP_CLASS;
+    }
+
+    public String getPROTOCOL() {
+        return PROTOCOL;
+    }
+
+    public void setPROTOCOL(String PROTOCOL) {
+        this.PROTOCOL = PROTOCOL;
+    }
+
+    public int getPROTOCOL_PORT() {
+        return PROTOCOL_PORT;
+    }
+
+    public void setPROTOCOL_PORT(int PROTOCOL_PORT) {
+        this.PROTOCOL_PORT = PROTOCOL_PORT;
+    }
+
+    public String getUSER_NAME() {
+        return USER_NAME;
+    }
+
+    public void setUSER_NAME(String USER_NAME) {
+        this.USER_NAME = USER_NAME;
+    }
+
+    public String getPASSWORD() {
+        return PASSWORD;
+    }
+
+    public void setPASSWORD(String PASSWORD) {
+        this.PASSWORD = PASSWORD;
+    }
+
+    public Date getCREATE_DATE() {
+        return CREATE_DATE;
+    }
+
+    public void setCREATE_DATE(Date CREATE_DATE) {
+        this.CREATE_DATE = CREATE_DATE;
+    }
+
+    public boolean isPingState() {
+        return pingState;
+    }
+
+    public void setPingState(boolean pingState) {
+        this.pingState = pingState;
+    }
+
+    public boolean isSshState() {
+        return sshState;
+    }
+
+    public void setSshState(boolean sshState) {
+        this.sshState = sshState;
+    }
+
+    public String getWarningResult() {
+        return warningResult;
+    }
+
+    public void setWarningResult(String warningResult) {
+        this.warningResult = warningResult;
+    }
+
+    public int getWarningLevel() {
+        return warningLevel;
+    }
+
+    public void setWarningLevel(int warningLevel) {
+        this.warningLevel = warningLevel;
+    }
+
+    public String getUnitId() {
+        return unitId;
+    }
+
+    public void setUnitId(String unitId) {
+        this.unitId = unitId;
+    }
+
+    @Override
+    public String toString() {
+        return "DowntimeBean{" +
+                "  DEVICE_IP='" + DEVICE_IP + '\'' +
+                ", pingState=" + pingState +
+                ", sshState=" + sshState +
+                ", warningResult='" + warningResult + '\'' +
+                ", DEVICE_ALIAS='" + DEVICE_ALIAS + '\'' +
+                ", USER_NAME='" + USER_NAME + '\'' +
+                ", warningLevel=" + warningLevel +
+                '}';
+    }
+
+}

+package com.sitech.ismp.check.downtime;
+
+import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
+import org.apache.log4j.Logger;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  宕机检测MBean实现类
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.Downtime
+ * @date 2017年04月15日 13:43
+ */
+public class Downtime implements DowntimeMBean {
+
+    private static Logger log= Logger.getLogger(Downtime.class);
+
+
+    DowntimeDao dao=new DowntimeDao();
+    DowntimeHistoryDao historyDao=new DowntimeHistoryDao();
+    SimpleDateFormat formaF=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+    /**
+     * 检查主机的连接状态。如果连接异常，需要每隔30秒连续连接3次，如果3次连接都异常，则视为主机宕机，发送严重告警。
+     * 1 将需要监控的设备添加到内存数据库中。
+     * 2 对表中的主机进行ping操作。
+     * 3 对表中的主机进行SSH登录认证
+     * 4 发送告警信息
+     * @param params
+     * @return
+     */
+    @Override
+    public Vector<TblATO_KPIDETAIL> checkConnectState(HashMap<String,String> params){
+        dao.addDowntimeHost(params);
+        String ipAddr=params.get("DEVICE_IP");
+        boolean flag=isNeedExecuteCheckMethod(ipAddr);
+        if(flag){
+            log.info("*************"+ formaF.format(new Date()) +" execute method checkConnectState .................");
+            // 将需要监控的设备添加到内存数据库中。
+            DowntimeBean bean=dao.map2DowntimeBean(params);
+            DowntimeServer server=new DowntimeServer(bean);
+            // 包括 2-4 需要执行的内容。 如果监控的设备很多的时候，使用单线程可能一个监控周期都不能ping完所有的主机。
+            server.run();
+            log.info("@@@@@@@@@@@@@@@@@@@@@@***** finish run method *****@@@@@@@@@@@@@@@@@@@@@@@@@@@");
+            log.info(bean.toString());
+        }
+        Vector<TblATO_KPIDETAIL> bean = new Vector<TblATO_KPIDETAIL>();
+        return bean;
+    }
+
+
+
+    /**
+     * 是否执行checkConnectState 方法。
+     * 判断当前IP是否发送过告警信息。每天一个主机只发送1条告警信息。
+     * @return
+     */
+    private boolean isNeedExecuteCheckMethod(String ipAddr){
+        boolean flag=true; // 是否该ipAddr已经发送过消息。
+        SimpleDateFormat formaF=new SimpleDateFormat("yyyy-MM-dd");
+        String currentDay=formaF.format(new Date());
+        List<DowntimeHistoryBean> list=historyDao.getDowntimeHistoryByIp(ipAddr,currentDay);
+        if(null !=list && list.size()>0){
+            flag=false;
+        }
+        return flag;
+    }
+
+
+}

+package com.sitech.ismp.check.downtime;
+
+import com.sitech.database.dao.BaseDao;
+import org.apache.log4j.Logger;
+
+import java.sql.SQLException;
+import java.util.*;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  宕机检测MBean对应dao类
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeDao
+ * @date 2017年04月16日 14:15
+ */
+public class DowntimeDao extends BaseDao {
+
+    private static Logger log=Logger.getLogger(DowntimeDao.class);
+
+    /**
+     * 添加需要监控宕机情况的设备,如果该设备已经存在，则修改。
+     */
+    public void addDowntimeHost(HashMap<String,String> params){
+        DowntimeBean downtimeBean=map2DowntimeBean(params);
+        addDowntimeHost(downtimeBean);
+    }
+
+    public void addDowntimeHost(DowntimeBean downtimeBean){
+        try {
+            int updateSum = sqlmapClient.update("updateDowntimeHostByIp",downtimeBean);
+            if(updateSum == 0){
+                sqlmapClient.insert("addDowntimeHost", downtimeBean);
+            }
+        } catch (Exception e) {
+            error.error("Exception while addDowntimeHost.", e);
+        }
+    }
+
+
+    /**
+     * 根据IP删除对应的记录。
+     * @param ip
+     * @return
+     */
+    public int deleteDowntimeHostByIp(String ip){
+        try {
+            return sqlmapClient.delete("deleteDowntimeHostByIp", ip);
+        } catch (Exception e) {
+            error.error("Exception while deleteDowntimeHostByIp.", e);
+        }
+        return -1;
+    }
+
+    /**
+     * 根据IP查询对应的记录。
+     * @param deviceIp
+     * @return
+     */
+    public List<DowntimeBean> getDowntimeByIp(String deviceIp){
+        HashMap<String,String> param=new HashMap<String, String>();
+        param.put("DEVICE_IP",deviceIp);
+        List<DowntimeBean> beanList=new ArrayList<DowntimeBean>();
+        try {
+            beanList=sqlmapClient.queryForList("getDowntimeByIp", param);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return beanList;
+    }
+
+    public DowntimeBean map2DowntimeBean(HashMap<String,String> params){
+        DowntimeBean bean=new DowntimeBean();
+        try {
+            bean.setDEVICE_ID(UUID.randomUUID().toString());
+            bean.setDEVICE_IP(params.get("DEVICE_IP"));
+            bean.setDEVICE_ALIAS(params.get("DEVICE_ALIAS"));
+            bean.setKBP_CLASS(params.get("KBP_CLASS") + "-99");
+            bean.setPROTOCOL(params.get("PROTOCOL"));
+            bean.setPROTOCOL_PORT(Integer.parseInt(params.get("PROTOCOL_PORT")));
+            bean.setUSER_NAME(params.get("USER_NAME"));
+            bean.setPASSWORD(params.get("PASSWORD"));
+            bean.setCREATE_DATE(new Date());
+        }catch (Exception e){
+            log.error("addDowntimeHost, write values to DowntimeBean has error！",e);
+        }
+        return bean;
+    }
+
+}

+package com.sitech.ismp.check.downtime;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  发送告警的历史记录bean。
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeHistoryBean
+ * @date 2017年04月19日 14:04
+ */
+public class DowntimeHistoryBean {
+    //    设备ID
+    private String DEVICE_ID;
+    //    设备IP地址
+    private String DEVICE_IP;
+    //    创建日期
+    private String CREATE_DATE;
+
+    public String getDEVICE_ID() {
+        return DEVICE_ID;
+    }
+
+    public void setDEVICE_ID(String DEVICE_ID) {
+        this.DEVICE_ID = DEVICE_ID;
+    }
+
+    public String getDEVICE_IP() {
+        return DEVICE_IP;
+    }
+
+    public void setDEVICE_IP(String DEVICE_IP) {
+        this.DEVICE_IP = DEVICE_IP;
+    }
+
+    public String getCREATE_DATE() {
+        return CREATE_DATE;
+    }
+
+    public void setCREATE_DATE(String CREATE_DATE) {
+        this.CREATE_DATE = CREATE_DATE;
+    }
+
+    @Override
+    public String toString() {
+        return "DowntimeHistoryBean{" +
+                "DEVICE_ID='" + DEVICE_ID + '\'' +
+                ", DEVICE_IP='" + DEVICE_IP + '\'' +
+                ", CREATE_DATE='" + CREATE_DATE + '\'' +
+                '}';
+    }
+}

+package com.sitech.ismp.check.downtime;
+
+import com.sitech.database.dao.BaseDao;
+import org.apache.log4j.Logger;
+
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  告警历史dao
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeHistoryDao
+ * @date 2017年04月19日 14:06
+ */
+public class DowntimeHistoryDao extends BaseDao {
+    private static Logger log=Logger.getLogger(DowntimeHistoryDao.class);
+
+    /**
+     * 添加告警信息
+     * @param bean
+     */
+    public void addDowntimeHistory(DowntimeHistoryBean bean){
+        try {
+            sqlmapClient.insert("addDowntimeHistory", bean);
+        } catch (SQLException e) {
+            log.error("Exception while addDowntimeHistory.",e);
+        }
+    }
+
+    /**
+     *
+     * @param deviceIp
+     * @param createDate
+     * @return
+     */
+    public List<DowntimeHistoryBean> getDowntimeHistoryByIp(String deviceIp,String createDate){
+        HashMap<String,String> param=new HashMap<String, String>();
+        param.put("DEVICE_IP",deviceIp);
+        param.put("CREATE_DATE",createDate);
+        List<DowntimeHistoryBean> beanList=new ArrayList<DowntimeHistoryBean>();
+        try {
+            beanList=sqlmapClient.queryForList("getDowntimeHistoryByIp", param);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return beanList;
+    }
+
+    /**
+     * 删除表中的所有数据。
+     * @return
+     */
+    public int deleteDowntimeHistory(){
+        try {
+            return sqlmapClient.delete("deleteDowntimeHistory", null);
+        } catch (Exception e) {
+            error.error("Exception while deleteDowntimeHistory.", e);
+        }
+        return -1;
+    }
+
+}

+package com.sitech.ismp.check.downtime;
+
+import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
+
+import java.util.HashMap;
+import java.util.Vector;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  宕机检测MBean接口
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeMBean
+ * @date 2017年04月15日 13:42
+ */
+public interface DowntimeMBean {
+    /**
+     * 检查主机的连接状态。如果连接异常，需要每隔30秒连续连接3次，如果3次连接都异常，则视为主机宕机，发送严重告警。
+     * @param params
+     * @return
+     */
+    public Vector<TblATO_KPIDETAIL> checkConnectState(HashMap<String,String> params);
+
+
+}

+package com.sitech.ismp.check.downtime;
+
+import com.sitech.ismp.app.event.KPI2Event;
+import com.sitech.ismp.coll.basic.TblATO_EVENT;
+import com.sitech.util.Base62Util;
+import com.sitech.util.RandomGUID;
+import com.sitech.util.upload.RomoteController;
+import com.sitech.util.upload.SSHThread;
+import com.sitech.util.upload.TelnetThread;
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Random;
+
+/**
+ * @author frank  zmm@honggroup.com.cn
+ * @Description:  宕机检测MBean对应Server类。
+ *                ping的布尔结果 true:能ping通, false:ping不通
+ *                ssh连接的布尔结果 true:能ssh连接, false:ssh连接异常
+ * @Package com.sitech.ismp.check.downtime
+ * @ClassName: com.sitech.ismp.check.downtime.DowntimeServer
+ * @date 2017年04月12日 16:22
+ */
+public class DowntimeServer implements Runnable{
+
+    private static Logger log=Logger.getLogger(DowntimeServer.class);
+    private DowntimeBean bean;
+    DowntimeHistoryDao historyDao=new DowntimeHistoryDao();
+
+    public DowntimeServer(DowntimeBean bean){
+        this.bean=bean;
+    }
+
+    /**
+     * 1 对表中的主机进行ping操作。
+     * 2 对表中的主机进行SSH登录认证。
+     * 3 发送告警信息。
+     */
+    @Override
+    public void run(){
+        getPingResult(bean);
+        getSshResult(bean);
+        sendEvent2Workstation(bean);
+    }
+
+    /**
+     * 将每个IP ping后的结果设置到pingState属性上。
+     * @param bean
+     * @return
+     */
+    public void getPingResult(DowntimeBean bean){
+        String ipAddr=null;
+        log.info("============================== ping all parames ======================");
+        log.info(bean.toString());
+        ipAddr=bean.getDEVICE_IP();
+        boolean temp=pingIpAddress(ipAddr);
+        bean.setPingState(temp);
+
+    }
+
+    /**
+     * 进行SSH连接，并设置对应告警的内容。
+     * @param bean
+     * @return
+     */
+    public void getSshResult(DowntimeBean bean){
+        boolean pingState=bean.isPingState(); // true:能ping通, false:ping不通
+        log.info("========== pingState=== "+pingState+"==========");
+        boolean sshState=contentWithSsh(bean);
+        log.info("========== sshState=== "+sshState+"==========");
+        if(!pingState){ // ping 不通 false
+            if(!sshState){ // ssh 不能连接 严重告警
+                bean.setWarningLevel(1);
+                bean.setWarningResult(bean.getDEVICE_IP()+" 的主机连接异常，请检查网络是否正常或主机宕机!");
+                log.info("========== bean.setWarningResult sshState ="+sshState+",=ip is ["+bean.getDEVICE_IP()+"] host connect error");
+            }
+        }else{ //能ping 通
+            if(!sshState){ // ssh 不能连接 重要告警
+                bean.setWarningLevel(2);
+                bean.setWarningResult(bean.getDEVICE_IP()+" 的主机不能进行登录，请检查用户名或密码!!");
+                log.info("========== bean.setWarningResult sshState ="+sshState+",=ip is["+bean.getDEVICE_IP()+"] host login error");
+            }
+        }
+    }
+
+    /**
+     * 将告警信息发送到Workstation。
+     * 当ping的结果为false的时候才发送。
+     * @param bean
+     */
+    private void sendEvent2Workstation(DowntimeBean bean){
+        log.info("******************************************************");
+        log.info("*************** sendEvent2Workstation ****************");
+        log.info("******************************************************");
+        log.info(bean.toString());
+        if(!bean.isSshState()){
+            KPI2Event event=new KPI2Event();
+            TblATO_EVENT tblato_event = new TblATO_EVENT();
+            String eventId= RandomGUID.getRandomGUID();
+            try {
+                tblato_event.setEVENT_ID(eventId); // 随即生成一个GUID作为唯一键
+                tblato_event.setUNIT_ID(bean.getUnitId());  // UNIT_ID在页面显示的为平台类型。
+                tblato_event.setKPI_ID("FM-00-01-001-999");
+                tblato_event.setKPI_VALUE(bean.getWarningResult());
+                tblato_event.setEVENT_TITLE(bean.getWarningResult());
+                tblato_event.setEVENT_CLASS(bean.getWarningLevel()); // 告警级别
+                tblato_event.setCLL_TIME(new java.util.Date());
+                tblato_event.setGENERANT_TIME(new java.util.Date());
+                tblato_event.setCFG_GUID(RandomGUID.getRandomGUID());
+                log.info("hava finish set values to TblATO_EVENT!");
+            } catch (ParseException e) {
+                log.error("set values to TblATO_EVENT hava error!",e);
+            }
+            try {
+                event.sendEvent2Workstation(tblato_event);
+                addDowntimeHistory(bean);
+                log.info("have write object(TblATO_EVENT) to Workstation!");
+            } catch (Exception e) {
+                log.error("have write object(TblATO_EVENT) to Workstation have error!",e);
+            }
+        }
+    }
+
+
+    private void addDowntimeHistory(DowntimeBean bean){
+        DowntimeHistoryBean historyBean=new DowntimeHistoryBean();
+        historyBean.setDEVICE_ID(bean.getDEVICE_ID());
+        historyBean.setDEVICE_IP(bean.getDEVICE_IP());
+        SimpleDateFormat formaF=new SimpleDateFormat("yyyy-MM-dd");
+        String date=formaF.format(new Date())+"";
+        date=date.substring(0,10);
+        historyBean.setCREATE_DATE(date);
+        historyDao.addDowntimeHistory(historyBean);
+    }
+
+
+    /**
+     * 获取ping 后的结果，是否可以平通指定的IP。
+     * @param ipAddr
+     * @return
+     */
+    private boolean pingIpAddress(String ipAddr){
+        int pingErrorCount=0; // ping 不通的次数，ping3次。
+        int interval=8; // 时间间隔8秒。
+        boolean flag=false;
+        boolean temp=false;
+        for(int i=0;i<3;i++){
+            temp=executeCommand(ipAddr); // ping不通返回false。
+            log.info("["+ipAddr+"]ping result is ["+temp+"],(true:can connect;false:can't connect)");
+            if(!temp){
+                pingErrorCount++;
+            }
+            try {
+                Thread.sleep(interval*1000);
+                log.info("ping ["+ipAddr+"] trread sleep "+interval+" secound........");
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+        if(pingErrorCount == 3){
+            log.info("["+ipAddr+"] can't connect 3 times.");
+        }else{
+            flag=true;
+            log.info("["+ipAddr+"] can connect.");
+        }
+        return flag;
+    }
+
+
+    /**
+     * 进行ssh连接，判断是否可以连接成功。
+     * windows操作系统使用 TelnetThread类连接。 Windows的客户端需要配置并开启Telnet相关的服务。
+     * @return
+     */
+    private boolean contentWithSsh(DowntimeBean bean){
+        String protocol=bean.getPROTOCOL();
+        String ipAddr=bean.getDEVICE_IP();
+        String deviceAlias=bean.getDEVICE_ALIAS();
+        int protocolPort=bean.getPROTOCOL_PORT();
+        String userName=bean.getUSER_NAME();
+        String password=bean.getPASSWORD();
+        bean.setUnitId(getUnitId(deviceAlias));
+        log.info("execute contentWithSsh method ......");
+        boolean temp=false;
+        RomoteController tt = null;
+        log.info("host params is: ipAddr="+ipAddr+",protocol="+protocol+",protocolPort="+protocolPort+",userName="+userName);
+        if(loginParamterIsOk(protocol,ipAddr,protocolPort,userName,password,deviceAlias)){
+            try {
+                if (protocol != null && protocol.equalsIgnoreCase("telnet")) {
+                    tt = new TelnetThread(ipAddr, protocolPort, userName, password);
+                } else if (protocol != null && protocol.equalsIgnoreCase("ssh")) {
+                    tt = new SSHThread(ipAddr, protocolPort, userName, password);
+                }else{
+                    log.error("===================== unknown protocol =====================");
+                }
+            }catch (Exception e){
+                log.error(protocol+"connect have exception!");
+            }
+            tt.initial();
+            boolean flag=tt.isAuthorized();
+            log.info("******************* tt.isAuthorized() result is "+flag);
+            if (flag){ // 认证通过
+                log.info(ipAddr+" SSH connect,Authorized result is true authorized success!");
+                temp=true;
+                bean.setSshState(true);
+            }else{
+                log.info(ipAddr+" SSH connect,Authorized result is false authorized fail!!");
+                bean.setSshState(false);
+            }
+        }
+        return temp;
+    }
+
+
+    /**
+     * 判断所有的参数是否为空。
+     * @param protocol 协议类型
+     * @param ipAddr IP地址
+     * @param protocolPort 协议端口
+     * @param userName 用户名
+     * @param password 密码
+     * @param deviceAlias 主机别名
+     * @return
+     */
+    private boolean loginParamterIsOk(String protocol,String ipAddr,int protocolPort,String userName,
+                                      String password,String deviceAlias){
+        boolean flag=true;
+        if(StringUtils.isEmpty(protocol)){
+            flag=false;
+        }
+        if(StringUtils.isEmpty(ipAddr)){
+            flag=false;
+        }
+        if(StringUtils.isEmpty(protocolPort+"")){
+            flag=false;
+        }
+        if(StringUtils.isEmpty(userName)){
+            flag=false;
+        }
+        if(StringUtils.isEmpty(password)){
+            flag=false;
+        }
+        if(StringUtils.isEmpty(deviceAlias)){
+            flag=false;
+        }
+        return flag;
+    }
+
+
+    private String getUnitId(String deviceAlias){
+        StringBuffer bf=new StringBuffer("10-10-99-98:");
+        bf.append(deviceAlias).append("_").append(getEncryptStr());
+        return bf.toString();
+    }
+
+    /**
+     * 返回加密后的一个唯一字符串。
+     * @return
+     */
+    private String getEncryptStr(){
+        SimpleDateFormat forma=new SimpleDateFormat("yyMMddHHmmss");
+        Random rr= new Random();
+        String str=rr.nextInt(999)+forma.format(new Date())+rr.nextInt(999);
+        return Base62Util.encode(Long.parseLong(str));
+    }
+
+
+    /**
+     * 返回ping后的结果。
+     * @param ipAddr ip 地址。
+     * @return
+     */
+    private boolean executeCommand(String ipAddr){
+        String command = "/bin/ping -c 3 -w 3 " + ipAddr;;
+        // 执行command 命令。
+        boolean flag=false;
+        String line = null;
+        StringBuilder sb = new StringBuilder();
+        Runtime runtime = Runtime.getRuntime();
+        Process process = null;
+        long startTime = new Date().getTime();
+        try {
+            process = runtime.exec(command);
+        } catch (IOException e) {
+            log.error("execute command ["+command+"] has some error!");
+        }
+        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
+        try {
+            while ((line = bufferedReader.readLine()) != null) {
+                sb.append(line + "\n");
+            }
+        } catch (IOException e) {
+            log.error("======== bufferedReader.readLine() has some error!");
+        }
+
+        String pingResult=sb.toString();
+        /**
+         *  当执行结果出现下面字符说明已经执行完成。
+         *  ping 通的时候 结果包含【min/avg/max/mdev】
+         *  ping 不通的时候 结果包含【100% packet loss】
+         */
+        if(pingResult.contains("100% packet loss") || (pingResult.contains("min/avg/max/mdev"))){
+            process.destroy();
+            log.info("execute command ["+command+"] finish!");
+        }
+
+
+        String os = System.getProperty("os.name").toLowerCase();
+        log.info("------------ operator system is :" + os);
+
+        // 解析command命令结果，包含【100% packet loss】 意味着ping不通,返回 false。
+        if(os.indexOf("linux") >= 0){
+            if (!StringUtils.isEmpty(pingResult)) {
+                if(!pingResult.contains("100% packet loss")){
+                    flag = true;
+                }
+            }
+        }
+        return flag;
+    }
+
+
+    /**
+     * 添加已经发送的告警信息。
+     * @param bean，取出对象中的ID与IP，外加时间(年月日)
+     */
+    public void addSendedEvent(DowntimeBean bean){
+
+    }
+
+}