Javaでインターネット接続をテストするプログラム

Question

インターネットに接続しているかどうかをリアルタイムで教えてくれる簡単なプログラムを書こうとしています。それはwww.google.comに達した場合に必要なメッセージを出力

import java.net.Socket; 

public class InternetConnection { 
    public static void main(String[] args) { 
     String inetAddress = "www.google.com"; 
     int port = 80; 

     while (true) { 
      try { 
       Socket socket = new Socket(inetAddress, port); 
       System.out.println("Connected to the internet"); 
      } catch (Exception e) { 
       System.out.println("Not connected to the internet"); 
      } 
     } 
    } 
} 

：これは私がやっているものです。しかし、インターネットから切断して正常に機能しているかどうかを確認するには、「はインターネットに接続されていません。」と表示されたら、「」と表示されますが、 「インターネットに接続しました」というメッセージが表示されます。私は何が間違っているのかわからない...

P.S.私はこれがインターネット接続があるかどうかをチェックする最良の方法ではないことを知っています。

Answer 1

ソケットを作成して接続メッセージを印刷した後に遅延時間を設定します。

try { 
    Socket socket = new Socket(inetAddress,port); 
    System.out.println("Connected to the internet"); 
}catch(Exception e){  
    System.out.println("Not connected to the internet"); 
} 
TimeUnit.SECONDS.sleep(5); 

プログラムは意図した通りに動作するはずです。

Answer 2

プラグを接続してプルしようとすると、GoogleのDNSルックアップが失敗するため、UnknownHostExceptionが発生します。 「ホストするルートがない」場合は、直接スローされているはずです。あなたのコードでは、タイムアウト処理はありません。ソケットのコンストラクタ（https://docs.oracle.com/javase/6/docs/api/java/net/Socket.html#connect(java.net.SocketAddress,%20int)参照）に直接渡すことができる接続タイムアウトパラメータを使用してください。多くの問題が直接スローされます（詳細はこちらconnect() method ignoring its timeout valueなど）。また、あなたの1つのランタイムスレッドがトラブルの時にブロックされている、それだけでソケットとインターネット接続とトラブルがあり、あなたの

Socket socket = new Socket(inetAddress, port); 

、通常にハングアップします..あなたはで実行を終了することができるようにしたいです途中、おそらくあまりにも、あなたが制御された方法で停止することができ、おそらくあなたは「ただ眠っている」のではなく、テストのスケジュールを設定したいと思い、別のスレッドでも

private final static ScheduledExecutorService scheduler = 
Executors.newScheduledThreadPool(1); 
    .. 
     Runnable r =() -> { 
      try { 
       testConnections(); 
      } catch (InterruptedException | ExecutionException | TimeoutException e) { 
       // HANDLE IT 
      } 
     }; 
     scheduler.scheduleAtFixedRate(r, secondsInBetweenPolls, secondsInBetweenPolls, TimeUnit.SECONDS); 
     } 
    .. 

のようなものを、あなたのプログラムを実行制御、私が持っているでしょうCompletableFutureのために消えてしまいます。これは非ブロックであり、この種のものにはうってつけです。たとえば、ここにはhttp://www.deadcoderising.com/java8-writing-asynchronous-code-with-completablefutureという広告が表示されます。メインブロックは次のようになります

private void testConnections() throws InterruptedException, ExecutionException, TimeoutException { 
    for (URL u : urls) { 
     if (isRunning){ 
      try{ 
       CompletableFuture.supplyAsync(() -> testConnection(u)).acceptEither(timeoutAfter(millisConnectionTimeOut, TimeUnit.MILLISECONDS), result -> currentStatus = result).get(); 
      } catch (Exception e) { 
       if (e instanceof TimeoutException) { 
        currentStatus = Result.INTERNET_UNREACHABLE; 
       } 
      } 
      if (currentStatus.equals(Result.INTERNET_REACHED)) { 
       break; // first actual internet hit is enough, right? 
      } 
     } 
    } 
    notifyListener(); 
    lastStatus = currentStatus; 
} 

private void notifyListener() { 
    if (lastStatus == null || !currentStatus.equals(lastStatus)) { 
     if (currentStatus.equals(Result.INTERNET_REACHED)) { 
      listener.connectionIsUp(); 
     } else { 
      listener.connectionIsDown(); 
     } 
    } 
} 

private Result testConnection(URL url) { 
    if (isRunning) { 
     HttpURLConnection urlConnect = null; 
     try { 
      urlConnect = (HttpURLConnection) url.openConnection(); 
      urlConnect.setConnectTimeout(millisConnectionTimeOut); 
      int resultCode = urlConnect.getResponseCode(); 
      if (resultCode == 200) { 
       return Result.INTERNET_REACHED; 
      } 
     } catch (IOException ignore) {} 
    } finally { 
      if (urlConnect != null) { 
       urlConnect.disconnect(); 
      } 
     } 
    } 
    return Result.INTERNET_UNREACHABLE; 
}