Created
June 4, 2020 13:56
-
-
Save zepinto/c7bbb10654a4c83ea213bd6c6f2265de to your computer and use it in GitHub Desktop.
Check if an host is reachable (Java)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.net.InetAddress; | |
import java.util.LinkedHashMap; | |
import java.util.Map; | |
import java.util.concurrent.*; | |
/** | |
* This class is used to check if a remote peer is reachable | |
*/ | |
public class ReachableCache { | |
static LinkedHashMap<String, HostReachability> reachabilityCache = new LinkedHashMap<>(); | |
static ExecutorService executorService = Executors.newCachedThreadPool(); | |
public static Future<Boolean> isReachable(String hostname) { | |
return executorService.submit(new Callable<Boolean>() { | |
@Override | |
public Boolean call() throws Exception { | |
return isReachableBlocking(hostname); | |
} | |
}); | |
} | |
public static boolean isReachableBlocking(String hostname) { | |
synchronized (reachabilityCache) { | |
HostReachability reachability = reachabilityCache.get(hostname); | |
if (reachability != null && reachability.getAge() < 60000) { | |
return reachability.isReachable(); | |
} | |
else { | |
try { | |
if (InetAddress.getByName(hostname).isReachable(2500)) | |
reachabilityCache.put(hostname, new HostReachability(true)); | |
else | |
reachabilityCache.put(hostname, new HostReachability(false)); | |
} | |
catch (Exception e) { | |
e.printStackTrace(); | |
reachabilityCache.put(hostname, new HostReachability(false)); | |
} | |
} | |
return reachabilityCache.get(hostname).isReachable(); | |
} | |
} | |
public static String firstReachable(long timeout, String... hostnames) { | |
long endTime = System.currentTimeMillis() + timeout; | |
LinkedHashMap<String, Future<Boolean>> pings = new LinkedHashMap<>(); | |
for (String host : hostnames) | |
pings.put(host, isReachable(host)); | |
while(System.currentTimeMillis() < endTime) { | |
try { | |
Thread.sleep(25); | |
for (Map.Entry<String, Future<Boolean>> ping : pings.entrySet()) { | |
try { | |
if (ping.getValue().isDone() && ping.getValue().get()) | |
return ping.getKey(); | |
} | |
catch (Exception e) { | |
// nothing | |
} | |
} | |
} | |
catch (Exception e) { | |
return null; | |
} | |
} | |
return null; | |
} | |
private static class HostReachability { | |
long lastTested; | |
boolean reachable; | |
public HostReachability(boolean reachable) { | |
this.reachable = reachable; | |
this.lastTested = System.currentTimeMillis(); | |
} | |
long getAge() { | |
return System.currentTimeMillis() - lastTested; | |
} | |
boolean isReachable() { | |
return reachable; | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment