栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java如何测试网络连通性

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java如何测试网络连通性

本文实例为大家分享了Java测试网络连通性的方法,供大家参考,具体内容如下

第一种方式:利用java运行时:
Java代码

 
private void getNetworkState(String ip) {
  Runtime runtime = Runtime.getRuntime();
  try {
    log.info("=================正在测试网络连通性ip:"+ip);
    Process process = runtime.exec("ping " +ip);
    InputStream iStream = process.getInputStream();
    InputStreamReader iSReader = new InputStreamReader(iStream,"UTF-8");
    BufferedReader bReader = new BufferedReader(iSReader);
    String line = null;
    StringBuffer sb = new StringBuffer();
    while ((line = bReader.readLine()) != null) {
      sb.append(line);
    }
    iStream.close();
    iSReader.close();
    bReader.close();
    String result = new String(sb.toString().getBytes("UTF-8"));
    log.info("ping result:"+result);
    if (!StringUtils.isBlank(result)) {
      if (result.indexOf("TTL") > 0 || result.indexOf("ttl") > 0) {
 log.info("网络正常,时间: " + TimeUtil.getCurDate("yyyy-mm-dd hh:mm:ss"));     
      } else {
 log.info("网络断开,时间 :" + TimeUtil.getCurDate("yyyy-mm-dd hh:mm:ss"));

      }
    }
  } catch (Exception e) {
    log.error("网络异常:"+e.getMessage());
    e.printStackTrace();
  }
}

在windows平台上,上面代码没有为,ping ip 会结束,而在linux环境中ping命令,ping不通时,
会卡住,ping通,会不定的输出信息,考虑用另一种方式socket。

第二种方式socket:
Java代码

package com.util.network;

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.NetworkInterface;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Enumeration;

import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class NetworkHelper {
  private static Logger log = LoggerFactory.getLogger(NetworkHelper.class);
  private static NetworkHelper instance = null;
  public static synchronized NetworkHelper getInstance(){
    if(instance == null){
      instance = new NetworkHelper();
    }
    return instance;

  }

  
  public boolean isReachIp(String ip) {
    boolean isReach = false;
    try {
      InetAddress address = InetAddress.getByName(ip);// ping this IP

      if (address instanceof java.net.Inet4Address) {
 log.info(ip + " is ipv4 address");
      } else if (address instanceof java.net.Inet6Address) {
 log.info(ip + " is ipv6 address");
      } else {
 log.info(ip + " is unrecongized");
      }
      if (address.isReachable(5000)) {
 isReach = true;
 log.info("SUCCESS - ping " + ip
     + " with no interface specified");
      } else {
 isReach = false;
 log.info("FAILURE - ping " + ip
     + " with no interface specified");
      }
    } catch (Exception e) {
      log.error("error occurs:" + e.getMessage());
    }
    return isReach;
  }

  
  public boolean isReachNetworkInterfaces(String ip) {
    boolean isReach = false;
    try {
      InetAddress address = InetAddress.getByName(ip);// ping this IP

      if (address instanceof java.net.Inet4Address) {
 log.info(ip + " is ipv4 address");
      } else if (address instanceof java.net.Inet6Address) {
 log.info(ip + " is ipv6 address");
      } else {
 log.info(ip + " is unrecongized");
      }
      if (address.isReachable(5000)) {
 isReach = true;
 log.info("SUCCESS - ping " + ip
     + " with no interface specified");
      } else {
 isReach = false;
 log.info("FAILURE - ping " + ip
     + " with no interface specified");
      }
      if (isReach) {
 log.info("-------Trying different interfaces--------");
 Enumeration netInterfaces = NetworkInterface
     .getNetworkInterfaces();
 while (netInterfaces.hasMoreElements()) {
   NetworkInterface ni = netInterfaces.nextElement();
   log.info("Checking interface, DisplayName:"
+ ni.getDisplayName() + ", Name:" + ni.getName());
   if (address.isReachable(ni, 0, 5000)) {
     isReach = true;
     log.info("SUCCESS - ping " + ip);
   } else {
     isReach = false;
     log.info("FAILURE - ping " + ip);
   }
   Enumeration ips = ni.getInetAddresses();
   while (ips.hasMoreElements()) {
     log.info("IP: " + ips.nextElement().getHostAddress());
   }
   log.info("-----------------check now NetworkInterface is done--------------------------");
 }
      }
    } catch (Exception e) {
      log.error("error occurs:" + e.getMessage());
    }
    return isReach;
  }

  
  public String getReachableIP(InetAddress remoteAddr, int port) {
    String retIP = null;
    Enumeration netInterfaces;
    try {
      netInterfaces = NetworkInterface.getNetworkInterfaces();
      while (netInterfaces.hasMoreElements()) {
 NetworkInterface ni = netInterfaces.nextElement();
 Enumeration localAddrs = ni.getInetAddresses();
 while (localAddrs.hasMoreElements()) {
   InetAddress localAddr = localAddrs.nextElement();
   if (isReachable(localAddr, remoteAddr, port, 5000)) {
     retIP = localAddr.getHostAddress();
     break;
   }
 }
      }
    } catch (SocketException e) {
      log.error("Error occurred while listing all the local network addresses:"
   + e.getMessage());
    }
    if (retIP == null) {
      log.info("NULL reachable local IP is found!");
    } else {
      log.info("Reachable local IP is found, it is " + retIP);
    }
    return retIP;
  }
  
  public String getReachableIP(String remoteIp, int port) {

    String retIP = null;
    InetAddress remoteAddr = null;
    Enumeration netInterfaces;
    try {
      remoteAddr = InetAddress.getByName(remoteIp);
      netInterfaces = NetworkInterface.getNetworkInterfaces();
      while (netInterfaces.hasMoreElements()) {
 NetworkInterface ni = netInterfaces.nextElement();
 Enumeration localAddrs = ni.getInetAddresses();
 while (localAddrs.hasMoreElements()) {
   InetAddress localAddr = localAddrs.nextElement();
   if (isReachable(localAddr, remoteAddr, port, 5000)) {
     retIP = localAddr.getHostAddress();
     break;
   }
 }
      }
    } catch (UnknownHostException e) {
      log.error("Error occurred while listing all the local network addresses:"+ e.getMessage());
    }catch (SocketException e) {
      log.error("Error occurred while listing all the local network addresses:"+ e.getMessage());
    }
    if (retIP == null) {
      log.info("NULL reachable local IP is found!");
    } else {
      log.info("Reachable local IP is found, it is " + retIP);
    }
    return retIP;
  }
  
  public boolean isReachable(InetAddress localInetAddr,
      InetAddress remoteInetAddr, int port, int timeout) {
    boolean isReachable = false;
    Socket socket = null;
    try {
      socket = new Socket();
      // 端口号设置为 0 表示在本地挑选一个可用端口进行连接
      SocketAddress localSocketAddr = new InetSocketAddress(
   localInetAddr, 0);
      socket.bind(localSocketAddr);
      InetSocketAddress endpointSocketAddr = new InetSocketAddress(
   remoteInetAddr, port);
      socket.connect(endpointSocketAddr, timeout);
      log.info("SUCCESS - connection established! Local: "
   + localInetAddr.getHostAddress() + " remote: "
   + remoteInetAddr.getHostAddress() + " port" + port);
      isReachable = true;
    } catch (IOException e) {
      log.error("FAILRE - CAN not connect! Local: "
   + localInetAddr.getHostAddress() + " remote: "
   + remoteInetAddr.getHostAddress() + " port" + port);
    } finally {
      if (socket != null) {
 try {
   socket.close();
 } catch (IOException e) {
   log.error("Error occurred while closing socket:"
+ e.getMessage());
 }
      }
    }
    return isReachable;
  }

  
  public boolean isReachable(String localIp, String remoteIp,
      int port, int timeout) {
    boolean isReachable = false;
    Socket socket = null;
    InetAddress localInetAddr = null;
    InetAddress remoteInetAddr = null;
    try {
      localInetAddr = InetAddress.getByName(localIp);
      remoteInetAddr = InetAddress.getByName(remoteIp);
      socket = new Socket();
      // 端口号设置为 0 表示在本地挑选一个可用端口进行连接
      SocketAddress localSocketAddr = new InetSocketAddress(
   localInetAddr, 0);
      socket.bind(localSocketAddr);
      InetSocketAddress endpointSocketAddr = new InetSocketAddress(
   remoteInetAddr, port);
      socket.connect(endpointSocketAddr, timeout);
      log.info("SUCCESS - connection established! Local: "
   + localInetAddr.getHostAddress() + " remote: "
   + remoteInetAddr.getHostAddress() + " port" + port);
      isReachable = true;
    } catch (IOException e) {
      log.error("FAILRE - CAN not connect! Local: "
   + localInetAddr.getHostAddress() + " remote: "
   + remoteInetAddr.getHostAddress() + " port" + port);
    } finally {
      if (socket != null) {
 try {
   socket.close();
 } catch (IOException e) {
   log.error("Error occurred while closing socket:"
+ e.getMessage());
 }
      }
    }
    return isReachable;
  }

  public static void main(String[] args) {
     if(NetworkHelper.getInstance().isReachIp("192.168.126.128")){
log.info("=======本机可以ping通ip:"+"192.168.126.128");
     }
     else{
log.info("=======本机ping不通ip:"+"192.168.126.128");
     }
     if(NetworkHelper.getInstance().isReachNetworkInterfaces("192.168.126.128")){
log.info("=======本机所有网卡可以ping通ip:"+"192.168.126.128");
     }
     else{
log.info("=======本机所有网卡ping不通ip:"+"192.168.126.128");
     }
     String localIp = NetworkHelper.getInstance().getReachableIP("192.168.126.128",8081);
     if(!StringUtils.isBlank(localIp)){
log.info("=======本机可以与ip:"+"192.168.126.128"+",port:"+8081+"建立连接的IP:"+localIp);
     }
     else{
log.info("=======本机不能与ip:"+"192.168.126.128"+",port:"+8081+"建立连接的IP");
     }
  }

}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持考高分网。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/148871.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号