DB에 저장된 IP를 가져와서 주기적으로 핑날려서 alive유무 확인

아침에 아기 기저귀 갈고, 이것 저것 둘러보다가

시간이 약간 있길래 JAVA로 작성해 보았습니다. 어떤 언어를 이용하든

실행하는 방법은 비슷하리라 생각합니다.

다만 JAVA보다는 C언어가 더 편할지도. :-)

먼저 Ping하는 부분은 외부의 ping프로그램을 이용했고요.

아직은 완전한 Ping을 순수 100% 자바로는 구현할 수가 없기때문입니다.

그 이유는 PING을 구현하기 위해서는 ICMP packet을 필요로

하는데요.

해당 Packet을 전송하기 위하여는 SOCK_RAW type 의 Socket이

필요한데, JAVA에서는 지원하지 않기 때문입니다

여하튼 예제는 3개의 도메인(sunny.sarang.net과 kldp.org는
존재하는 도메인, 나머지 한개는 존재하지 않는 도메인)으로 ping
을 한 후 결과를 가지고 오는 내용입니다.

일단 실행하기 위하여는 java가 당연히 설치가 되어있어야 겠지요.
실행방법 : java PingProcessTest

import java.io.*;
public class PingProcessTest{
	public static void main(String args[]){
		String[] ips = { "sunny.sarang.net", "kldp.org", "adfaf.com" };
		PingProcess[] pps = new PingProcess[ips.length];

		// thread를 이용하여 ips배열의 domain으로 Ping을 실행

                               // 이부분에서 database로 부터 select하여 5분마다 실행할 수 있도록 무한반복.
/*
                               try{
                                     // 5분 sleep. select하는 시간도 있으니깐 알아서 쉬도록!
                                      Thread.sleep(50000);
                              }catch(Exception ex2){}
*/
		for(int i = 0; i < pps.length; i++){
			pps[i] = new PingProcess(ips[i]);
			pps[i].start();
		}

		// 실행된 결과를 가지고 오는 부분 getMsg()부분에서 시간이 지연될 수도 있기 때문에
		// 해당 부분도 thread로 실행할 수 있도록 하는 것이 좋을듯. :-)
		for(int i = 0; i < pps.length; i++){
			System.out.println(ips[i] + " : " + pps[i].getMsg());
		}
	}
};

class PingProcess extends Thread{
	private String msg;
	private String ip;

	public PingProcess(String ip){
		this.ip = ip;
	}
	public void run(){
		InputStream is = null;
		BufferedReader br = null;
		try{
			Runtime run = Runtime.getRuntime();
			Process p = run.exec("c:\\winnt\\system32\\ping.exe " + ip);
			is = p.getInputStream();
			br = new BufferedReader(new InputStreamReader(is));
			String line = null;
			while((line = br.readLine()) != null){
				//System.out.println(line); // line을 임시 출력해본다.
				if(line.indexOf("Reply") >= 0){
					break;
				}
			}
			if(line != null){
				msg = line.substring(line.indexOf("time=")+5, line.indexOf("TTL=")-1);
			}// if
		}catch(Exception e){

		}finally{
			try{
				if(br != null) br.close();
			}catch(Exception ex2){}
			try{
				if(is != null) is.close();
			}catch(Exception ex2){}
		}
	}
	public String getMsg(){
		try{
			join(); // 해당 thread가 종료될때까지 대기.
		}catch(InterruptedException ie){
			return null;
		}

		return msg;
	}

	public static void main(String args[]){
		PingProcess pp = new PingProcess("sunny.sarang.net");
		pp.start(); // thread 시작
	
		String msg = pp.getMsg();
		if(msg == null){
			System.out.println("sunny.sarang.net die");
		}else{
			System.out.println("time : " + msg);
		}
	} // end main
} // end class