devbox
Monodyee
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用iperf工具，用java的swing，编写网络带宽监测小工具_java 如何实现类似 宝塔面板的网络带宽监控

作者：Monodyee | 2024-06-14 01:21:56

赞

踩

java 如何实现类似 宝塔面板的网络带宽监控

接到一个需求，要写个简单的工具，测试本机的CPU、内存等信息，以及监测当前主机与连接的服务器之间的网速信息
获取CPU和内存的方法，此处省略，重点是监测网速这一块

先看下工具的目录结构：

jperf是需要用到测试网络带宽的工具包，jar包是需要运行的项目，run.bat是项目的启动文件，serverInfo文件是用来配置服务器IP和端口的

再看下效果图：

一、获取网络信息，需要利用iperf工具
    简要说明下iperf工具的使用
    1.下载工具包，有Linux和window版本
    2.在Linux中（作为服务端），解压tar包，编译并安装，使用如下命令运行：（详细命令网上搜）
        iperf -s
    此时服务端会开启5001端口
    3.在window系统中（作为服务端），解压压缩包，打开cmd命令，进入压缩包的bin目录，并执行以下命令：
        iperf -c 192.168.1.24 -p 5001 -i 5 -t 5
    回车即可看到结果

二、回到我们的任务，整体的思路和步骤：
    1.找个Linux服务器，安装iperf，并启动服务
    2.创建一个springboot项目，为了方便打包
    3.写一个工具类PropertiesFileUtil，用来读取properties配置文件的值
    4.写一个工具类IperfUtil，用来执行命令，从而获取检测到的网速的结果
    5.写一个工具类ComputerMonitorUtil，用来获取CPU、磁盘等信息
    6.写一个工具类FrameUI，用来构造窗口界面，并展示信息，信息从3、4的工具类中获取
    7.测试完成后，使用maven打包，xxx.jar
    8.编写一个bat文件，用来启动jar包文件
    9.最后创建一个文件夹，将xxx.jar、window版本的iperf文件夹、run.bat文件和serverInfo.peoperties文件放在同一个文件夹下
    10.点击run.bat文件，可以打开窗口界面，并显示相应信息

三、细节部分
    1.需要注意的就是，在用java执行命令的时候，需要获取正确的项目所在目录，否则会报错，找不到要执行的文件
    2.打包完成后，一定要把iperf文件夹放到相应的位置，具体位置和1中的命令所指向的目录有关
    3.run.bat文件内容如下：

  1. @echo off
  2. java -jar xxx.jar

   4.PropertiesFileUtil代码

  1. package com.net.netmonitor.util;
  2.  
  3. import java.io.BufferedInputStream;
  4. import java.io.FileInputStream;
  5. import java.io.IOException;
  6. import java.io.InputStream;
  7. import java.util.Properties;
  8.  
  9. public class PropertiesFileUtil {
  10.  
  11. 	public static String getValueByKey(String key, String filePath) {
  12. 		Properties pps = new Properties();
  13. 		try {
  14. 			InputStream in = new BufferedInputStream (new FileInputStream(filePath));
  15. 			pps.load(in);
  16. 			String value = pps.getProperty(key);
  17. 			return value;
  18.  
  19. 		}catch (IOException e) {
  20. 			e.printStackTrace();
  21. 			return null;
  22. 		}
  23. 	}
  24. }

    5.IperfUtil代码

  1. package com.net.netmonitor.util;
  2.  
  3. import org.springframework.util.ResourceUtils;
  4.  
  5. import java.io.BufferedReader;
  6. import java.io.File;
  7. import java.io.InputStream;
  8. import java.io.InputStreamReader;
  9.  
  10. //使用iperf工具，调用dmc命令，来检测客户端与服务器段的网速
  11. public class IperfUtil {
  12.  
  13.     private static String netSec="";//最终返回的结果
  14.     private static String ip = "";//服务器ip
  15.     private static String port = "";//服务器端监听的端口
  16.  
  17.     public static String getNetSpeed() throws Exception{
  18.         File path = new File(ResourceUtils.getURL("classpath:").getPath());
  19.         if(!path.exists()) path = new File("");
  20.  
  21.         //当前项目jar包所在目录
  22.         String ROOT = path.getAbsolutePath();
  23.         System.out.println("jar_path>>>"+ROOT);
  24.  
  25.         //从配置文件获取ip和port的值
  26.         String filePath = ROOT + "\\serverInfo.properties";
  27.         System.out.println("file_path>>>"+filePath);
  28.         ip = PropertiesFileUtil.getValueByKey("ip",filePath);
  29.         port = PropertiesFileUtil.getValueByKey("port",filePath);
  30.  
  31.         //构造出要执行的命令，检测10s，间隔2s，以MB作为单位
  32.         String cmd =  ROOT + "\\jperf-2.0.0\\bin\\iperf -c "+ip+" -p "+port+" -i 2 -t 10 -f M";
  33.         System.out.println("iperf_path>>>"+cmd);
  34.  
  35.         Process p = Runtime.getRuntime().exec(cmd);
  36.  
  37.         InputStream inputStream = p.getInputStream();
  38.         BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
  39.         String line;
  40.         int count = 0;//带宽总量
  41.         int second = 0;//查询带宽次数
  42.         while((line = reader.readLine())!= null){
  43.             //[312]  0.0-10.0 sec  2.46 GBytes  2.11 Gbits/sec
  44.             if(line.contains("/sec")){//获取到宽带信息，从“Bytes”开始截取，到“/sec”结束
  45.                 netSec = line.substring(line.indexOf("Bytes")+5,line.indexOf("MBytes/sec")).trim();
  46.                 count +=Integer.parseInt(netSec);
  47.                 second ++;
  48.  
  49.                 System.out.println(line);
  50.             }
  51.         }
  52.  
  53.         //求平均数
  54.         netSec = String.valueOf(count/second);
  55.         System.out.println("平均网速："+netSec);
  56.  
  57.         p.waitFor();
  58.         inputStream.close();
  59.         reader.close();
  60.         p.destroy();
  61.         return netSec;
  62.     }
  63. }

    6.FrameUI代码

  1. package com.net.netmonitor.util;
  2.  
  3. import javax.swing.*;
  4. import java.awt.*;
  5. import java.text.SimpleDateFormat;
  6. import java.util.Date;
  7.  
  8. public class FrameUI extends JPanel {
  9.     private static final int JFRAME_WIDTH = 350;
  10.     private static final int JFRAME_HEIGHT= 400;
  11.     private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  12.  
  13.     public  void createWindow() throws Exception{
  14.  
  15.             //窗口-顶层面板
  16.             JFrame jFrame = new JFrame("网速监测");
  17.             jFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  18.  
  19.             //网格布局,容器中的方法
  20.             GridBagLayout gridBagLayout = new GridBagLayout();
  21.             setLayout(gridBagLayout);
  22.             jFrame.add(this,BorderLayout.CENTER);
  23.             jFrame.setSize(JFRAME_WIDTH,JFRAME_HEIGHT);
  24.  
  25.             //弹框位置：居中
  26.             Dimension dimension = Toolkit.getDefaultToolkit().getScreenSize();
  27.             jFrame.setLocation((int)(dimension.getWidth() - JFRAME_WIDTH ) / 2,(int)(dimension.getHeight() - JFRAME_HEIGHT ) / 2);
  28.  
  29.             //初次打开面板，初始化信息时显示提示消息
  30.             JLabel tipLabel = new JLabel("正在获取本机CPU等信息，请稍等...");
  31.             add(tipLabel);
  32.  
  33.             //展示面板，并且不可编辑
  34.             jFrame.setVisible(true);
  35.             jFrame.setResizable(false);
  36.  
  37.             while (true){
  38.                 //当前网速
  39.                 JLabel lable_net_key = new JLabel("当前带宽:");
  40.                 String net_val = IperfUtil.getNetSpeed() + "MB/s";
  41.                 JLabel lable_net_val = new JLabel(net_val);
  42.  
  43.                 //当前cpu
  44.                 JLabel lable_cpu_key = new JLabel("CPU:");
  45.                 String cpu_val = Double.toString(ComputerMonitorUtil.getCpuUsage()) + "%";
  46.                 JLabel lable_cpu_val = new JLabel(cpu_val);
  47.  
  48.                 //当前内存
  49.                 JLabel lable_mem_key = new JLabel("内存:");
  50.                 String mem_val = Double.toString(ComputerMonitorUtil.getMemUsage()) + "%";
  51.                 JLabel lable_mem_val = new JLabel(mem_val);
  52.  
  53.                 //当前磁盘
  54. //                JLabel lable_disk_key = new JLabel("磁盘:");
  55. //                String disk_val = Double.toString(ComputerMonitorUtil.getDiskUsage()) + "%";
  56. //                JLabel lable_disk_val = new JLabel(disk_val);
  57.  
  58.                 //当前时间
  59.                 JLabel lable_time_key = new JLabel("获取时间:");
  60.                 String time_val = sdf.format(new Date());
  61.                 JLabel lable_time_val = new JLabel(time_val);
  62.  
  63.  
  64.                 System.out.println(cpu_val);
  65.                 System.out.println(mem_val);
  66. //                System.out.println(disk_val);
  67.  
  68.                 //移除所有组件，重新加载
  69.                 removeAll();
  70.  
  71.                 //网格布局
  72.                 GridBagConstraints gridBagConstraints = new GridBagConstraints();
  73.                 gridBagConstraints.fill = GridBagConstraints.NONE;
  74.                 gridBagConstraints.anchor = GridBagConstraints.CENTER;
  75.                 gridBagConstraints.weightx = 3;
  76.                 gridBagConstraints.weighty = 4;
  77.                 //添加组件并指定组件的位置
  78.                 addComponent(lable_net_key,gridBagConstraints,0,1,1,1);
  79.                 addComponent(lable_net_val,gridBagConstraints,1,1,1,1);
  80.                 addComponent(lable_cpu_key,gridBagConstraints,0,2,1,1);
  81.                 addComponent(lable_cpu_val,gridBagConstraints,1,2,1,1);
  82.                 addComponent(lable_mem_key,gridBagConstraints,0,3,1,1);
  83.                 addComponent(lable_mem_val,gridBagConstraints,1,3,1,1);
  84. //                addComponent(lable_disk_key,gridBagConstraints,0,4,1,1);
  85. //                addComponent(lable_disk_val,gridBagConstraints,1,4,1,1);
  86.                 addComponent(lable_time_key,gridBagConstraints,0,4,1,1);
  87.                 addComponent(lable_time_val,gridBagConstraints,1,4,1,1);
  88.  
  89.                 jFrame.validate();
  90.                 jFrame.repaint();
  91.             }
  92.  
  93.         }
  94.  
  95.     private void addComponent(Component component,GridBagConstraints gridBagConstraints,int x,int y,int w,int h){
  96.         gridBagConstraints.gridx = x;
  97.         gridBagConstraints.gridy = y;
  98.         gridBagConstraints.gridwidth = w;
  99.         gridBagConstraints.gridheight = h;
  100.         //Container中的方法
  101.         add(component,gridBagConstraints);
  102.     }
  103. }

四、完善功能，使体验更加友好

以上已经可以实现需求，现在在以上现有的功能，完善一下

   1.集成jdk环境，不需要在机器上额外配置jdk环境变量
        1）下载绿色版jdk，解压到run.bat同一级目录
        2）修改run.bat文件，添加path，如下：

  1. 	@echo off
  2. 	set path=.\jdk1.8\bin
  3. 	java -jar netmonitor-0.0.1-SNAPSHOT.jar

    2.直接点击run.bat，启动项目后，会有个cmd弹框，并显示打印的消息，给客户用的时候，体验不好
        1）在与run.bat同一级目录，新建一个run.vbs文件
        2）添加内容如下：

    createobject("wscript.shell").run ".\run.bat",0

       3）此时点击run.vbs，会调用run.bat文件，进而启动java程序，并且不会弹出cmd窗口

五、最终的工具的结构：

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Monodyee/article/detail/715692
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号