[关闭]
@liruiyi962464 2024-09-22T18:20:14.000000Z 字数 4458 阅读 77

ping

代码

自己写的ping

  1. public void monitorUseState() {
  2.         List<ZcMonitor> zcMonitorList = zcMonitorService.list();
  3.         Integer flag = 0;
  4.         if(zcMonitorList.size() > 0 && zcMonitorList != null) {
  5.             for (int i = 0; i < zcMonitorList.size(); i++) {
  6.                 String ip = zcMonitorList.get(i).getIp();
  7.                 String name = zcMonitorList.get(i).getName();
  8.                 String position = zcMonitorList.get(i).getPosition();
  9.                 // 当返回值是true时，说明监控IP是可用的，false则不可。
  10.                 int timeOut = 3000;   // 超时应该在3钞以上
  11.                 boolean status = false;
  12.                 try {
  13.                     // status = InetAddress.getByName(ip).isReachable(timeOut);
  15.                     InetAddress address = InetAddress.getByName(ip);
  16.                     System.out.println("开始检查 IP 地址 " + ip + " 是否可达...");
  18.                     long startTime = System.currentTimeMillis();
  19.                     status = address.isReachable(timeOut);
  20.                     long endTime = System.currentTimeMillis();
  22.                     System.out.println("检查完成，耗时：" + (endTime - startTime) + " 毫秒");
  23.                     if (status) {
  24.                         System.out .println("IP 地址 " + ip + " 是可达的");
  25.                     } else {
  26.                         System.out.println("IP 地址 " + ip + " 不可达");
  27.                     }
  29.                 } catch (IOException e) {
  30.                     e.printStackTrace();
  31.                 }
  32.                 //System.err.println("监控ip"+ip+"状态"+status);
  33.                 //onlineOrNot lineOrNot = new onlineOrNot();
  34.                 //String userAndPwd = onlineOrNot.userAndPwd(ip, username, password);
  35.                 if (!status) {
  36.                     // 状态更新到数据库
  37.                     zcMonitorList.get(i).setUseState("1");
  38.                     zcMonitorService.updateById(zcMonitorList.get(i));
  39.                     // 离线（在线状态不用推送）
  40.                     System.err.println("监控IP：【"+ip+"】监控名称：【"+name+"】监控位置：【"+position+"】【已离线】");
  41.                     zcWarningInformationService.warnXiaoxi(3,"监控IP：【"+ip+"】监控名称：【"+name+"】监控位置：【"+position+"】【已离线】",zcMonitorList.get(i));
  42.                 }else {
  43.                     // 状态更新到数据库
  44.                     zcMonitorList.get(i).setUseState("2");
  45.                     zcMonitorService.updateById(zcMonitorList.get(i));
  47.                 }
  48.             }
  49.         }
  50.     }

使用工具类

  1.      public Result<?> pingDevice(@RequestParam(name="ip") String ip) throws Exception {
  2.          List<String> pingContent = new ArrayList<>();
  3.          boolean b = Ping.ping(ip);
  4.          if (b){
  5.             pingContent = Ping.pingA(ip);
  6.          } else {
  7.             String message = "目标主机"+ip+"无法访问，请检查！";
  8.              pingContent.add(message);
  9.          }
  10.          return Result.OK(pingContent);
  11.      }
  1. package org.jeecg.modules.demo.ping;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.net.InetAddress;
  7. import java.util.ArrayList;
  8. import java.util.List;
  9. import java.util.regex.Matcher;
  10. import java.util.regex.Pattern;
  12. public class Ping {
  15.      public  static  boolean ping(String ipAddress)  throws Exception {
  16.          int  timeOut =  3000 ;   // 超时应该在3钞以上        
  17.          boolean status = InetAddress.getByName(ipAddress).isReachable(timeOut);      //  当返回值是true时，说明host是可用的，false则不可。
  18.          return status;
  19.     }
  23.      public  static  List<String> ping02(String ipAddress)  throws Exception {
  24.          List<String> outputLines = new ArrayList<>(); // 用于保存输出的集合
  25.          try {
  26.             Process pro = Runtime.getRuntime().exec("ping " + ipAddress);
  27.             BufferedReader buf =  new BufferedReader( new InputStreamReader(
  28.                     pro.getInputStream(),"GBK"));
  29.             int i =1;
  30.              String line =  null;
  31.              while ((line = buf.readLine()) !=  null)
  32.                 System.out.println(line);
  33.              outputLines.add(line);
  34.         }  catch (Exception ex) {
  35.             System.out.println(ex.getMessage());
  36.         }
  37.          return outputLines;
  38.     }
  41.      public  static  boolean ping(String ipAddress,  int pingTimes,  int timeOut) {  
  42.         BufferedReader in =  null;  
  43.         Runtime r = Runtime.getRuntime();   //  将要执行的ping命令,此命令是windows格式的命令
  44.         String pingCommand = "ping " + ipAddress + " -n " + pingTimes    + " -w " + timeOut;
  45.          try {    //  执行命令并获取输出  
  46.             System.out.println(pingCommand);
  47.             Process p = r.exec(pingCommand);
  48.              if (p ==  null) {
  49.                  return  false;
  50.             }
  51.             in =  new BufferedReader( new InputStreamReader(p.getInputStream()));    //  逐行检查输出,计算类似出现=23ms TTL=62字样的次数  
  52.              int connectedCount = 0;   
  53.             String line =  null;   
  54.              while ((line = in.readLine()) !=  null) {    
  55.                 connectedCount += getCheckResult(line);   
  56.             }    //  如果出现类似=23ms TTL=62这样的字样,出现的次数=测试次数则返回真  
  57.              return connectedCount == pingTimes;  
  58.         }  catch (Exception ex) {   
  59.             ex.printStackTrace();    //  出现异常则返回假  
  60.              return  false;  
  61.         }  finally {   
  62.              try {
  63.                 in.close();   
  64.             }  catch (IOException e) {    
  65.                 e.printStackTrace();   
  66.             }  
  67.         }
  68.     }
  71.      // 若line含有=18ms TTL=16字样,说明已经ping通,返回1,否則返回0.
  72.      private  static  int getCheckResult(String line) {   //  System.out.println("控制台输出的结果为:"+line);  
  73.         Pattern pattern = Pattern.compile("(\\d+ms)(\\s+)(TTL=\\d+)",    Pattern.CASE_INSENSITIVE);  
  74.         Matcher matcher = pattern.matcher(line);  
  75.          while (matcher.find()) {
  76.              return 1;
  77.         }
  78.          return 0; 
  79.     }
  82.     public static List<String> pingA(String ipAddress){
  83.         List<String> outputLines = new ArrayList<>(); // 用于保存输出的集合
  84.         try {
  85.             // 创建一个Process实例执行ping命令
  86.             Process process = Runtime.getRuntime().exec("ping " + ipAddress);
  87.             // 读取ping命令的输出
  88.             BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream(),"GBK"));
  89.             String line;
  90.             while ((line = reader.readLine()) != null) {
  91.                 outputLines.add(line); // 将每行输出添加到集合中
  92.             }
  93.             // 等待ping命令执行完成
  94.             int exitCode = process.waitFor();
  95.             System.out.println("Ping命令执行完成，退出码: " + exitCode);
  96.         } catch (IOException | InterruptedException e) {
  97.             e.printStackTrace();
  98.         }
  99.         return outputLines;
  100.     }
  103.      public static void main(String[] args)  throws Exception {
  104.         String ipAddress = "192.168.10.92";
  105. //        System.out.println(ping(ipAddress));
  106. //         List<String> strings = pingA(ipAddress);
  107. //         for (String string : strings) {
  108. //             System.out.println(string);
  109. //         }
  110. //         System.out.println(strings);
  111.         System.out.println(ping02(ipAddress));
  112.     }
  113. }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注