java如何測試網(wǎng)絡(luò)連通性
本文實例為大家分享了Java測試網(wǎng)絡(luò)連通性的方法,供大家參考,具體內(nèi)容如下
第一種方式:利用java運行時:
Java代碼
/**
* test network
* @param ip
*/
private void getNetworkState(String ip) {
Runtime runtime = Runtime.getRuntime();
try {
log.info("=================正在測試網(wǎng)絡(luò)連通性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("網(wǎng)絡(luò)正常,時間: " + TimeUtil.getCurDate("yyyy-mm-dd hh:mm:ss"));
} else {
log.info("網(wǎng)絡(luò)斷開,時間 :" + TimeUtil.getCurDate("yyyy-mm-dd hh:mm:ss"));
}
}
} catch (Exception e) {
log.error("網(wǎng)絡(luò)異常:"+e.getMessage());
e.printStackTrace();
}
}
在windows平臺上,上面代碼沒有為,ping ip 會結(jié)束,而在linux環(huán)境中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;
/**
* 測試網(wǎng)絡(luò)連通性
*
* @author donald
*
*/
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;
}
/**
* 測試本地能否ping ip
*
* @param ip
* @return
*/
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;
}
/**
* 測試本地所有的網(wǎng)卡地址都能ping通 ip
*
* @param ip
* @return
*/
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<NetworkInterface> 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<InetAddress> 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;
}
/**
* 獲取能與遠(yuǎn)程主機指定端口建立連接的本機ip地址
* @param remoteAddr
* @param port
* @return
*/
public String getReachableIP(InetAddress remoteAddr, int port) {
String retIP = null;
Enumeration<NetworkInterface> netInterfaces;
try {
netInterfaces = NetworkInterface.getNetworkInterfaces();
while (netInterfaces.hasMoreElements()) {
NetworkInterface ni = netInterfaces.nextElement();
Enumeration<InetAddress> 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;
}
/**
* 獲取能與遠(yuǎn)程主機指定端口建立連接的本機ip地址
* @param remoteIp
* @param port
* @return
*/
public String getReachableIP(String remoteIp, int port) {
String retIP = null;
InetAddress remoteAddr = null;
Enumeration<NetworkInterface> netInterfaces;
try {
remoteAddr = InetAddress.getByName(remoteIp);
netInterfaces = NetworkInterface.getNetworkInterfaces();
while (netInterfaces.hasMoreElements()) {
NetworkInterface ni = netInterfaces.nextElement();
Enumeration<InetAddress> 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;
}
/**
* 測試localInetAddr能否與遠(yuǎn)程的主機指定端口建立連接相連
*
* @param localInetAddr
* @param remoteInetAddr
* @param port
* @param timeout
* @return
*/
public boolean isReachable(InetAddress localInetAddr,
InetAddress remoteInetAddr, int port, int timeout) {
boolean isReachable = false;
Socket socket = null;
try {
socket = new Socket();
// 端口號設(shè)置為 0 表示在本地挑選一個可用端口進(jìn)行連接
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;
}
/**
* 測試localIp能否與遠(yuǎn)程的主機指定端口建立連接相連
*
* @param localIp
* @param remoteIp
* @param port
* @param timeout
* @return
*/
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();
// 端口號設(shè)置為 0 表示在本地挑選一個可用端口進(jìn)行連接
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("=======本機所有網(wǎng)卡可以ping通ip:"+"192.168.126.128");
}
else{
log.info("=======本機所有網(wǎng)卡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");
}
}
}
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- Powershell實現(xiàn)監(jiān)測服務(wù)器連通狀態(tài)
- java網(wǎng)絡(luò)編程之socket網(wǎng)絡(luò)編程示例(服務(wù)器端/客戶端)
- Java用文件流下載網(wǎng)絡(luò)文件示例代碼
- java網(wǎng)絡(luò)編程中向指定URL發(fā)送GET POST請求示例
- 簡單介紹Java網(wǎng)絡(luò)編程中的HTTP請求
- java網(wǎng)絡(luò)編程學(xué)習(xí)java聊天程序代碼分享
- java使用TimerTask定時器獲取指定網(wǎng)絡(luò)數(shù)據(jù)
- Java實現(xiàn)爬蟲給App提供數(shù)據(jù)(Jsoup 網(wǎng)絡(luò)爬蟲)
- Java獲取網(wǎng)絡(luò)文件并插入數(shù)據(jù)庫的代碼
- Java網(wǎng)絡(luò)編程基礎(chǔ)教程之Socket入門實例
相關(guān)文章
springBoot 打war包 程序包com.sun.istack.internal不存在的問題及解決方案
這篇文章主要介紹了springBoot 打war包 程序包com.sun.istack.internal不存在的問題及解決方案,親測試過可以,需要的朋友可以參考下2018-07-07
spring Boot查詢數(shù)據(jù)分頁顯示的方法實例
這篇文章主要給大家介紹了關(guān)于spring Boot查詢數(shù)據(jù)分頁顯示的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家學(xué)習(xí)或者使用spring Boot具有一定的參考學(xué)習(xí)價值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
Mybatis學(xué)習(xí)總結(jié)之mybatis使用建議
這篇文章主要介紹了Mybatis學(xué)習(xí)總結(jié)之mybatis使用建議的相關(guān)資料,非常具有參考借鑒價值,需要的朋友可以參考下2016-05-05
Java實現(xiàn)斷點下載服務(wù)端與客戶端的示例代碼
這篇文章主要為大家介紹了如何實現(xiàn)服務(wù)端(Spring Boot)與客戶端(Android)的斷點下載與下載續(xù)傳功能,文中的示例代碼講解詳細(xì),需要的可以參考一下2022-08-08
Java8的DateTimeFormatter與SimpleDateFormat的區(qū)別詳解
這篇文章主要介紹了Java8的DateTimeFormatter與SimpleDateFormat的區(qū)別詳解,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03

