Java + Jpcap實現監控 IP包流量

来源:https://www.cnblogs.com/fwdba/archive/2023/04/14/17320187.html
-Advertisement-
Play Games

Java + Jpcap實現監控 IP包流量 說明:本設計是電腦網路課程的課設,因為代碼是提前實現的,本博客於後期補上,又因為代碼沒寫註釋自己也看不懂了,所以,僅供參考,就當提供一種實現方式。 文中提供的《Jpcap中文API文檔》來源於網路,本文僅用於學習交流,如有侵權,可聯繫我進行刪除。 效果 ...


Java + Jpcap實現監控 IP包流量

說明:本設計是電腦網路課程的課設,因為代碼是提前實現的,本博客於後期補上,又因為代碼沒寫註釋自己也看不懂了,所以,僅供參考,就當提供一種實現方式。

文中提供的《Jpcap中文API文檔》來源於網路,本文僅用於學習交流,如有侵權,可聯繫我進行刪除。

效果圖:

1)課程設計要求

1.1 課程設計目的

通過本實課程設計,有助於理解 IP包的格式和加深對 IP 協議的理解。

1.2 課程設計要求

編製程式,監控網路,捕獲一段時間內網路上的 IP 數據包,按 IP 數據包的源地址統計出該源地址在該時間段內發出的 IP 包的個數,將其寫人日誌文件中或用圖形表示出來(建議用圖形表示出統計結果)。

1.3 程式的具體要求如下

用命令行運行: IPStatistic time logfile

其中, IPStatistic 是程式名; time 是設定的統計時間間隔(單位為分鐘,比如,2表示2分鐘); logfile 表示統計結果寫人的日誌文件名(若用圖形表示統計結果則可以不選這個參數)。

2)編碼前的準備

2.1 技術點

後端:springboot,Jpcap

前端:vue2,ECharts

說明:Jpcap是一個能夠捕獲、發送網路數據包的java類庫包。

2.2 環境搭建

2.2.1 事先說明和下載鏈接

ps:網上大部分都是Jpcap+winpcap,但是winpcap太老了,大概率在Windows10和Windows11上會出問題,當時也踩了不少坑,這裡推薦使用npcap

winocap網址:https://www.winpcap.org/

Npcap網址:https://npcap.com/

從圖中可以看出,winocap已經不再支持,推薦使用npcap

進入Npcap官網下載即可

2.2.2 資源下載

鏈接:https://pan.baidu.com/s/1y6u-V-FPwOgIxC9ZoAD7yg
提取碼:1111

內容:

  • Jpcap中文API文檔
  • npcap-1.72.exe
  • Jpcap.dll
  • jpcap.jar
  • network_vue(前端代碼,需要自己裝包:npm install
  • network_course_design(Java代碼)

2.2.3安裝

重點1、3、4步

  1. Npcap.exe正常進行安裝即可

  2. 創建一個普通springboot項目

  3. 在項目中導入Jpcap.jar

  1. Jpcap.dll放到JDK安裝路徑下的 /jre/bin 目錄下(我這裡好像沒有放也可以運行,可以試一下)

  2. 前端就是一個普普通通的VUE+ECharts項目

3)編碼

重要提示:當時為了趕工,其中的邏輯很有問題,現在的評價就一個字,爛,非常爛!!!看看關鍵實現就行。

這裡推薦看這篇博客,寫的很好,裡面對重要欄位進行了說明:https://www.cnblogs.com/shy-huiying/p/5636274.html

3.1 後端實現

3.1.1 獲得本機所有網卡介面信息

Jpcap提供了方法JpcapCaptor.getDeviceList()完成這個任務,該方法返回一組NetworkInterface對象。

NetworkInterface[] devices = JpcapCaptor.getDeviceList();

/**
*  這裡是controller層
 * 獲得所有網卡介面
 * @return List<String>
 */
@RequestMapping("/info")
public Object getNetworkCard(){
    // 獲取網路介面列表,返回所有的網路設備數組;
    NetworkInterface[] devices = JpcapCaptor.getDeviceList();
    if (devices.length == 0) {
        return "無網卡信息";
    }else{
        List<NetworkCardPojo> netList = new ArrayList<>();
        int index = 0;
        for (NetworkInterface n : devices) {
            //NetworkCardPojo是自己編寫的實體類,包含網卡介面索引和網卡介面名兩個屬性
            NetworkCardPojo networkCardPojo = new NetworkCardPojo();
            networkCardPojo.setIndex(index++);
            networkCardPojo.setDescription(n.description);
            //networkCardPojo.setNetworkInterface(n);
            netList.add(networkCardPojo);
        }
        return netList;
    }
}
public class NetworkCardPojo {
    private Integer index;
    private String description;
    //private NetworkInterface NetworkInterface;
}

返回到前端的數據:

3.1.2 得到指定網卡的具體信息

  • NetworkInterface[] devices = JpcapCaptor.getDeviceList();得到多有網卡信息
  • devices[index].addresses;根據前端傳入的網卡介面索引得到指定網卡介面的信息。
   /**
   	 *  這裡是controller層
     *  列印選擇網卡的IP地址和子網掩碼;
     * @param index
     * @return
     */
    @RequestMapping("/local")
    public LocalParameterPojo getLocalParameter(@ProbeParam("index") Integer index){	
        NetworkInterface[] devices = JpcapCaptor.getDeviceList();
        //根據傳入的網卡索引獲取該網卡介面所屬的IP地址
        NetworkInterfaceAddress[] device = devices[index].addresses;
        //LocalParameterPojo是自己編寫的實體類,包含本機IP地址、子網掩碼、網路連接類型
        LocalParameterPojo local = new LocalParameterPojo();
        if (device.length>0){
            local.setIpv4(device[0].address);
            local.setSubnetMask(device[0].subnet);
            local.setNetType(devices[0].datalink_description);
        }else {
            local.setNetType("該網卡介面不可用,請嘗試切換其他網卡介面!");
        }
        return local;
    }

LocalParameterPojo實體類,註意部分欄位是InetAddress類型

public class LocalParameterPojo {
    private InetAddress ipv4;            //本機IP地址
    private InetAddress SubnetMask;      //子網掩碼
    private String netType;         //網路連接類型
}

3.1.3 監控ip包數據

因為一個ip地址會發送多個ip包,這裡主要是將ip包進行分組統計:

IP地址--累計IP包數量--累計IP包大小

這裡寫的不好,有些問題,甚至問題很大,後面想到有更好的解決方法,但是沒有嘗試過,就不寫了

    /**
     * 這裡是controller層
     * 開啟監控ip包流量監控
     * @param index
     * @return
     */
    @RequestMapping("/start")
    public List<TargetParameterPojo> startGetPacket(@ProbeParam("index") Integer index){
        targetParameter.startThread(index);
        //根據Ip地址分組
        Map<InetAddress, IpGroup> mapAll = new HashMap<>();
        System.out.println("ip count:"+targetParameter.getTargetMap().size());
        for (int i=0;i<targetParameter.getTargetMap().size();i++){
            IpGroup ipGroup = new IpGroup();
            for (InetAddress key:targetParameter.getTargetMap().get(i).keySet()){
                Integer size = targetParameter.getTargetMap().get(i).get(key);
                int count=1;
                //檢查 hashMap 中是否存在指定的 key 對應的映射關係。
                if(mapAll.containsKey(key)){
                    Integer tempSize = mapAll.get(key).getSize();
                    size += tempSize;
                    Integer tempCount = mapAll.get(key).getCount();
                    count += tempCount;
                }
                ipGroup.setCount(count);
                ipGroup.setSize(size);
                mapAll.put(key,ipGroup);
            }
        }
        // 將數據裝到TargetParameterPojo
        List<TargetParameterPojo> targetList = new ArrayList<>();
        for (Map.Entry<InetAddress,IpGroup> map:mapAll.entrySet()){
            TargetParameterPojo targetPojo = new TargetParameterPojo();
            targetPojo.setSourceIp(map.getKey());
            targetPojo.setSize(map.getValue().getSize());
            targetPojo.setCount(map.getValue().getCount());
            targetList.add(targetPojo);
        }
        return targetList;
    }

    /**
     * 關閉監控ip包流量
     * @return
     */
    @RequestMapping("/stop")
    public int stopsGetPacket(){
        int flag = targetParameter.getTargetMap().size();
        if(flag>1){
            targetParameter.stopThread();
            return 1;
        }else {
            return 0;
        }
    }

service層

@Service
public class TargetParameter implements Runnable{
    //數據統計要用到的list
    private static List<Map<InetAddress,Integer>> targetMap = new ArrayList<>();
    private boolean flag = true;
    private TargetParameter tp;
    private Thread thread;
    private Integer isOff=0;

    public TargetParameter(JpcapCaptor jpcap) {
        this.jpcap = jpcap;
    }

    private JpcapCaptor jpcap = null;

    public TargetParameter() {
    }

    public List<Map<InetAddress, Integer>> getTargetMap() {
        return targetMap;
    }

    @Override
    public void run() {
        //只要不停止就一直進行抓包
        while (flag){
            IPPacket ipPacket = (IPPacket) jpcap.getPacket();
            if (ipPacket!=null){
                Map<InetAddress,Integer> map = new HashMap<>();
                map.put(ipPacket.src_ip,ipPacket.len);
                targetMap.add(map);
            }
            // 回調方法
            //jpcap.processPacket(-1, new CallbackService());
        }
    }
    /**
     * 開啟線程方法
     */
    public void startThread(Integer index){
        if (isOff==0){
            try {
                NetworkInterface[] devices = JpcapCaptor.getDeviceList();
                //獲得了JpcapCaptor實例就可以用來捕獲來自網路介面的數據包。
                //網卡索引,捕獲數據包大小,是否開啟混雜模式(混雜模式會捕獲到數據表),超時
                jpcap = JpcapCaptor.openDevice(devices[index], 1024, true, 1000);
                // 在捕獲前先設置過濾;
                jpcap.setFilter("ip", true);
            } catch (IOException e) {
                e.printStackTrace();
                System.out.println("抓取數據包時出現異常!!");
            }
            tp = new TargetParameter(jpcap);
            //創建一個抓抓包線程,保證一直進行抓包
            thread = new Thread(tp);
            thread.start();
            System.out.println("thread.getName():"+thread.getName());
            isOff++;
        }
    }

    /**
     * 關閉線程並清空List
     */
    public void stopThread(){
        isOff=0;
        tp.flag=false;
        targetMap.clear();
        System.out.println(targetMap);
    }
}

Pojo:

public class TargetParameterPojo {
    private InetAddress sourceIp;
    private Integer count;
    private Integer size;
}
public class IpGroup {
    private Integer size;
    private Integer count;
}

3.1.4 目錄結構

3.2 前端實現

前端實現很簡單,主要是數據渲染,這裡說一下我的思路:

  1. 設定一個計時器,每隔1秒鐘就請求一次數據,從而進行數據更新(axios實現)
  2. 可根據需要對數據進行排序和截取,比如截取前20條數據進行排序(數據條數太多會造成圖形不美觀)
  3. 優化:對開啟和關閉按鈕進行控制,防止重覆請求和重覆關閉

4)END

資源下載

鏈接:https://pan.baidu.com/s/1y6u-V-FPwOgIxC9ZoAD7yg
提取碼:1111

內容:

  • Jpcap中文API文檔
  • npcap-1.72.exe
  • Jpcap.dll
  • jpcap.jar
  • network_vue(前端代碼,需要自己裝包:npm install
  • network_course_design(Java代碼)

重要:請勿學習如上代碼的寫法,那時候vue正在學,還行學完,代碼冗餘嚴重。

本博客僅僅提供解決方法!歡迎討論,感謝批評指正。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 這裡給大家分享我在網上總結出來的一些知識,希望對大家有所幫助 Vue.js是一個基於組件化和響應式數據流的前端框架。當我們在Vue中編寫模板代碼時,它會被Vue編譯器處理並轉換為可被瀏覽器解析的JavaScript代碼。Vue中的模板實際上是HTML標記和Vue指令的組合,它們會被Vue編譯器處理並 ...
  • <!-- 封裝的模板下載和導入按鈕和功能組件--> <template> <span style="margin-left: 10px"> <el-button size="mini" class="el-icon-download" @click="downFiles"> 下載模板</el-but ...
  • 前言 前端開發者若要進行後端開發,大多都會選擇node.js,在node生態下是有大量框架的,其中最受新手喜愛的便是老牌的express.js,接下來我們就從零創建一個express項目。 安裝node 在這裡:https://nodejs.org/dist/v16.14.0/node-v16.14 ...
  • 作者羅錦華,API7.ai 技術專家/技術工程師,開源項目 pgcat,lua-resty-ffi,lua-resty-inspect 的作者。 原文鏈接 為什麼需要 Lua 動態調試插件? Apache APISIX 有很多 Lua 代碼,如何在運行時不觸碰源代碼的情況下,檢查代碼裡面的變數值? ...
  • 和女朋友坐一塊的時候,突然想到了,哈哈哈哈哈 不會很難!!! import java.util.*; import java.lang.Math; // 註意類名必須為 Main, 不要有任何 package xxx 信息 public class Main { public static void ...
  • Flask-SQLAlchemy MySQL是免費開源軟體,大家可以自行搜索其官網(https://www.MySQL.com/downloads/) 測試MySQL是否安裝成功 在所有程式中,找到MySQL→MySQL Server 5.6下麵的命令行工具,然後單擊輸入密碼後回車,就可以知道MyS ...
  • 前言 在上一篇文章中,我們介紹了~運算符的高級用法,本篇文章,我們將介紹<< 運算符的一些高級用法。 一、人物簡介 第一位閃亮登場,有請今後會一直教我們C語言的老師 —— 自在。 第二位上場的是和我們一起學習的小白程式猿 —— 逍遙。 二、計算2的整數次冪 代碼示例 #include <stdio. ...
  • 布隆過濾器是一個精巧而且經典的數據結構。 你可能沒想到: RocketMQ、 Hbase 、Cassandra 、LevelDB 、RocksDB 這些知名項目中都有布隆過濾器的身影。 對於後端程式員來講,學習和理解布隆過濾器有很大的必要性。來吧,我們一起品味布隆過濾器的設計之美。 1 緩存穿透 我 ...
一周排行
    -Advertisement-
    Play Games
  • 前言 本文介紹一款使用 C# 與 WPF 開發的音頻播放器,其界面簡潔大方,操作體驗流暢。該播放器支持多種音頻格式(如 MP4、WMA、OGG、FLAC 等),並具備標記、實時歌詞顯示等功能。 另外,還支持換膚及多語言(中英文)切換。核心音頻處理採用 FFmpeg 組件,獲得了廣泛認可,目前 Git ...
  • OAuth2.0授權驗證-gitee授權碼模式 本文主要介紹如何筆者自己是如何使用gitee提供的OAuth2.0協議完成授權驗證並登錄到自己的系統,完整模式如圖 1、創建應用 打開gitee個人中心->第三方應用->創建應用 創建應用後在我的應用界面,查看已創建應用的Client ID和Clien ...
  • 解決了這個問題:《winForm下,fastReport.net 從.net framework 升級到.net5遇到的錯誤“Operation is not supported on this platform.”》 本文內容轉載自:https://www.fcnsoft.com/Home/Sho ...
  • 國內文章 WPF 從裸 Win 32 的 WM_Pointer 消息獲取觸摸點繪製筆跡 https://www.cnblogs.com/lindexi/p/18390983 本文將告訴大家如何在 WPF 裡面,接收裸 Win 32 的 WM_Pointer 消息,從消息裡面獲取觸摸點信息,使用觸摸點 ...
  • 前言 給大家推薦一個專為新零售快消行業打造了一套高效的進銷存管理系統。 系統不僅具備強大的庫存管理功能,還集成了高性能的輕量級 POS 解決方案,確保頁面載入速度極快,提供良好的用戶體驗。 項目介紹 Dorisoy.POS 是一款基於 .NET 7 和 Angular 4 開發的新零售快消進銷存管理 ...
  • ABP CLI常用的代碼分享 一、確保環境配置正確 安裝.NET CLI: ABP CLI是基於.NET Core或.NET 5/6/7等更高版本構建的,因此首先需要在你的開發環境中安裝.NET CLI。這可以通過訪問Microsoft官網下載並安裝相應版本的.NET SDK來實現。 安裝ABP ...
  • 問題 問題是這樣的:第三方的webapi,需要先調用登陸介面獲取Cookie,訪問其它介面時攜帶Cookie信息。 但使用HttpClient類調用登陸介面,返回的Headers中沒有找到Cookie信息。 分析 首先,使用Postman測試該登陸介面,正常返回Cookie信息,說明是HttpCli ...
  • 國內文章 關於.NET在中國為什麼工資低的分析 https://www.cnblogs.com/thinkingmore/p/18406244 .NET在中國開發者的薪資偏低,主要因市場需求、技術棧選擇和企業文化等因素所致。歷史上,.NET曾因微軟的閉源策略發展受限,儘管後來推出了跨平臺的.NET ...
  • 在WPF開發應用中,動畫不僅可以引起用戶的註意與興趣,而且還使軟體更加便於使用。前面幾篇文章講解了畫筆(Brush),形狀(Shape),幾何圖形(Geometry),變換(Transform)等相關內容,今天繼續講解動畫相關內容和知識點,僅供學習分享使用,如有不足之處,還請指正。 ...
  • 什麼是委托? 委托可以說是把一個方法代入另一個方法執行,相當於指向函數的指針;事件就相當於保存委托的數組; 1.實例化委托的方式: 方式1:通過new創建實例: public delegate void ShowDelegate(); 或者 public delegate string ShowDe ...