当前位置: 首页 > news >正文

探索PcapPlusPlus开源库:网络数据包处理与性能优化

文章目录

    • 0. 本文概要
    • 1. PcapPlusPlus介绍
      • 1.1 概述
      • 1.2主要特性和功能
      • 1.3 PcapPlusPlus 主要模块关系和依赖
      • 1.4 网络协议层处理过程
    • 2. 实例
      • 2.1 基于 PcapPlusPlus 的应用程序设计和封装流程:
      • 2.2 多线程示例代码
      • 2.3 代码说明:
    • 3. 程序性能进一步优化
      • 3.1 避免重复解析
      • 3.2 减少内存分配
      • 3.3 直接操作数据
      • 3.4 利用硬件加速的方法
    • 4. PcapPlusPlus 的优势与缺点

0. 本文概要

本文将详细探讨 PcapPlusPlus,介绍其功能特性、实际应用示例以及模块间的关系和依赖,以帮助 C++ 工程师更好地理解和利用该库进行网络应用程序开发。

1. PcapPlusPlus介绍

1.1 概述

PcapPlusPlus 是一个跨平台的 C++ 网络数据包处理库,提供高级抽象和易用的 API,使开发者能轻松进行网络数据包的捕获、解析和生成。

1.2主要特性和功能

  1. 数据包捕获和解析

    • 支持多种网络捕获引擎,包括 libpcap、WinPcap、Intel DPDK 等。
    • 提供简洁的 C++ 接口,实现快速捕获和实时数据包解析。
  2. 高级协议解析和构造

    • 支持 Ethernet、IPv4、IPv6、TCP、UDP 等协议。
  3. 文件读写和离线分析

    • 支持 PCAP 和 PCAPNG 格式的数据包文件读写,便于离线数据分析和处理。
  4. 跨平台支持

    • 完全支持 Linux、MacOS和Windows 等多个平台。
  5. 高级网络安全功能

    • 提供 TCP 重组、IP 碎片重组等高级功能,支持复杂的网络安全分析和流量监控需求。

1.3 PcapPlusPlus 主要模块关系和依赖

依赖
依赖
Packet++
Pcap++
Common++
libpcap/WinPcap
Npcap
Intel DPDK
PF_RING
eBPF AF_XDP
其他第三方库和工具

此图展示了 PcapPlusPlus 中各核心模块的依赖关系,以及它们与底层网络捕获引擎(如 libpcap、WinPcap、Npcap 等)及其他第三方库(如 Intel DPDK、PF_RING、eBPF AF_XDP 等)的关联。

1.4 网络协议层处理过程

Packet Parsing
Layer Identification
Layer Processing
Packet Crafting
Packet Capture
Data Link Layer
Network Layer
Transport Layer
Application Layer
User Space
Protocol Parsing
Identify Layer Type
Process Layer Information
Further Processing
Create or Edit Packets
Packet Transmission
Network Device
Physical Transmission Medium

此图详细描述了网络数据包在 PcapPlusPlus 中的捕获到处理的整个过程,包括各协议层的解析和处理步骤。

2. 实例

2.1 基于 PcapPlusPlus 的应用程序设计和封装流程:

  • 初始化网络捕获设备:使用 PcapLiveDevice 类初始化网络设备,准备开始捕获数据包。
  • 设置捕获过滤器:通过 PcapLiveDevice::setFilter 函数设置过滤器,以过滤出特定的数据包。
  • 开始捕获数据包:调用 PcapLiveDevice::startCapture 函数启动捕获过程,持续监听网络接口上的数据包到达。
  • 捕获数据包:当有新的数据包到达时,通过注册的 onPacketArrives 函数进行捕获并存储在缓冲区中。
  • 解析数据包:使用 Packet::Packet 类解析捕获到的数据包,提取数据包的各个协议层信息。
  • 分发数据包:使用 PacketDispatcher 类将解析后的数据包传递给处理模块。
  • 处理数据包:通过 PacketHandler 类对数据包进行进一步处理,如协议分析、安全检查等。
  • 应用逻辑处理:通过 ApplicationLogic 类执行特定的应用逻辑,如网络监控、流量分析或安全审计等。
  • 生成响应或记录:使用 ResponseGeneratorLogger 类根据处理结果生成响应或将数据记录到日志或数据库中。
  • 继续捕获或结束:通过 DecisionMaker 类根据应用需求决定是否继续捕获数据包或结束捕获过程。
  • 关闭捕获设备:通过 PcapLiveDevice::stopCapture 函数结束捕获过程,关闭网络捕获设备。

2.2 多线程示例代码

#include <iostream>
#include <thread>
#include <mutex>
#include <atomic>
#include "Packet.h"
#include "PcapLiveDeviceList.h"
#include "PcapLiveDevice.h"
#include "IPv4Layer.h"using namespace std;
using namespace pcpp;// 全局变量
mutex mtx;
atomic<bool> stopCapture(false);
IPv4Layer* cachedIpLayer = nullptr;// 回调函数处理捕获到的数据包
void onPacketArrives(RawPacket* packet, PcapLiveDevice* dev, void* cookie) {// 异步处理数据包thread packetHandlerThread([packet]() {// 解析数据包Packet parsedPacket(packet);// 缓存解析结果cachedIpLayer = parsedPacket.getLayerOfType<IPv4Layer>();// 在这里可以进行更多的数据包处理,例如协议解析和业务逻辑处理if (cachedIpLayer) {// 在锁的作用域内进行输出,保证线程安全lock_guard<mutex> lock(mtx);cout << "捕获到数据包,源IP地址: " << cachedIpLayer->getSrcIpAddress().toString() << ", 目的IP地址: " << cachedIpLayer->getDstIpAddress().toString() << endl;}});packetHandlerThread.detach(); // 分离线程,允许异步运行
}int main() {// 获取设备列表vector<PcapLiveDevice*> devList = PcapLiveDeviceList::getInstance().getPcapLiveDevicesList();// 选择设备进行初始化PcapLiveDevice* dev = devList[0];if (!dev->open()) {cerr << "无法打开设备: " << dev->getLastError() << endl;return 1;}// 设置过滤器string filter = "ip"; // 过滤所有IP流量if (!dev->setFilter(filter)) {cerr << "无法设置过滤器: " << dev->getLastError() << endl;dev->close();return 1;}// 开始捕获数据包dev->startCapture(onPacketArrives, nullptr);// 捕获数据包一段时间后停止this_thread::sleep_for(chrono::seconds(10)); // 捕获10秒钟// 停止捕获并关闭设备dev->stopCapture();dev->close();return 0;
}

2.3 代码说明:

  • 缓存解析结果:在 onPacketArrives 回调函数中,使用 cachedIpLayer 全局变量缓存解析后的 IPv4Layer 对象。这样可以避免对每个数据包重复解析,节省CPU时间和内存开销。
  • 采用多线程异步处理:使用C++的异步处理机制,在捕获到数据包后启动一个新的线程或任务来处理数据包。这样可以利用多核处理器的能力并行处理数据包,提高处理速度。
开始
初始化网络捕获设备
(PcapLiveDevice)
设置捕获过滤器
(PcapLiveDevice::setFilter)
开始捕获数据包
(PcapLiveDevice::startCapture)
捕获数据包
(onPacketArrives)
是否有新数据包
创建新线程处理数据包
解析数据包
(Packet::Packet)
缓存解析结果
输出处理结果
(线程安全)
继续捕获或结束
(决策)
停止捕获并关闭设备
(PcapLiveDevice::stopCapture)
结束

3. 程序性能进一步优化

合理使用缓存、内存池和零拷贝技术,可以有效地避免重复解析、减少内存分配并直接操作数据,从而提升程序的性能和效率

3.1 避免重复解析

重复解析数据包会消耗大量的CPU时间和内存资源。为了避免这种情况,可以使用以下方法:

  • 缓存解析结果:在解析数据包后,将解析得到的关键信息(如协议头部字段)缓存起来,而不是每次都重新解析。这样可以避免多次访问数据包和重复执行解析操作。

  • 延迟解析:仅在需要时才进行解析。例如,可以根据应用需求,只在收到特定类型的数据包或者需要处理特定协议信息时才执行解析操作。

3.2 减少内存分配

动态内存分配和释放操作是性能瓶颈之一,特别是在高频率的数据包处理中。以下是减少内存分配的方法:

  • 使用内存池:预先分配一定数量的内存块,并在需要时从内存池中获取和释放内存,而不是每次都进行动态分配和释放。这样可以避免频繁的内存管理开销。

  • 重复使用数据结构:对于固定大小的数据结构或缓冲区,可以重复使用,避免频繁地创建和销毁对象。

3.3 直接操作数据

直接在原始数据上操作可以显著降低内存和CPU消耗,特别是对于大型数据包的处理。以下是实现直接操作数据的方法:

  • 使用零拷贝技术:在网络数据包处理中,尽量避免将数据从内核空间复制到用户空间的应用程序缓冲区。可以直接在网络接收缓冲区中操作数据,减少数据复制的开销和内存带宽消耗。

  • 原地修改数据:尽可能在接收到数据时直接在原始数据上进行操作和修改,避免创建中间副本或额外的数据结构。

3.4 利用硬件加速的方法

  • 选择适合的捕获引擎

    • Intel DPDK(Data Plane Development Kit):DPDK 提供了一个用户空间的数据包处理框架,可以利用支持 DPDK 的网卡直接从网络接口接收数据包,避免了数据包在内核空间和用户空间之间的复制,减少了 CPU 的负担和延迟。通过 DPDK,可以实现高性能的数据包捕获和处理。
  • 启用 Offload 功能

    • TCP Offload Engine(TOE):TOE 是一种专用硬件或芯片,可以在网卡上执行 TCP 协议处理,包括连接管理、流量控制和数据包的发送和接收,从而减轻主机 CPU 的负担。

4. PcapPlusPlus 的优势与缺点

优势

  • 高级抽象接口:PcapPlusPlus 封装了底层的网络捕获接口,提供了更高层次的抽象。

  • 统一的API:不论是在 Windows 还是 Linux 等平台上,PcapPlusPlus 提供了统一的API,使得开发者可以编写跨平台的网络应用程序,而无需关心底层接口的细节。

  • 丰富的功能扩展:PcapPlusPlus 提供了多种扩展功能,包括对 PCAP 和 PCAPNG 文件的完整支持、远程数据包捕获等。

  • 协议解析能力:PcapPlusPlus 提供了强大的协议解析功能,支持解析多种网络协议(如 TCP/IP、UDP、ICMP 等),并且具有良好的扩展性。

缺点

  • 学习曲线较陡:对于初学者来说,学习和掌握 PcapPlusPlus 的高级功能和API可能需要一定的时间和精力投入。
  • 功能复杂性:对于简单的数据包捕获和处理需求,使用 PcapPlusPlus 可能显得有些“杀鸡用牛刀”,过于复杂。

相关文章:

探索PcapPlusPlus开源库:网络数据包处理与性能优化

文章目录 0. 本文概要1. PcapPlusPlus介绍1.1 概述1.2主要特性和功能1.3 PcapPlusPlus 主要模块关系和依赖1.4 网络协议层处理过程 2. 实例2.1 基于 PcapPlusPlus 的应用程序设计和封装流程&#xff1a;2.2 多线程示例代码2.3 代码说明&#xff1a; 3. 程序性能进一步优化3.1 避…...

深入理解SSH:网络安全的守护者

在当今数字化时代&#xff0c;网络安全已成为全球关注的焦点。随着网络攻击手段的不断升级&#xff0c;保护数据传输的安全性变得尤为重要。SSH&#xff08;Secure Shell&#xff09;作为一种安全的网络协议&#xff0c;为远程登录和网络服务提供了强大的安全保障&#xff0c;成…...

DDD学习笔记四

领域模型的构建 基础领域模型的基本组成有名称、属性、关联、职责、事件和异常 发掘领域概念3种策略&#xff1a; 1&#xff09;学习已有系统&#xff0c;重用已有模型 2&#xff09;使用分类标签。分类标签来源于领域&#xff0c;需要我们研究一些资料并做一些提炼。从采用5W…...

Head First设计模式中的典型设计模式解析与案例分析

Head First设计模式中的典型设计模式解析与案例分析 大家好&#xff0c;我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01; 《Head First设计模式》是一本广受欢迎的书籍&#xff0c…...

iptables 防火墙(一)

iptables 防火墙&#xff08;一&#xff09; 一、Linux 防火墙基础防火墙分类 二、iptables 的表、链结构规则表规则链数据包过滤的匹配流程 三、编写防火墙规则iptables 的安装iptables的基本语法规则的匹配条件通用匹配隐含匹配显式匹配 四、总结 在网络安全的世界里&#xf…...

数据库物理结构设计-定义数据库模式结构(概念模式、用户外模式、内模式)、定义数据库、物理结构设计策略

一、引言 如何基于具体的DBMS产品&#xff0c;为数据库逻辑结构设计的结果&#xff0c;即关系数据库模式&#xff0c;制定适合应用要求的物理结构 1、在设计数据库物理结构前&#xff0c;数据库设计人员首先 要充分了解所用的DBMS产品的功能、性能和特点&#xff0c;包括提供…...

QT加载安装外围依赖库的翻译文件后翻译失败的现象分析:依赖库以饿汉式的形式暴露单例接口导致该现象的产生

1、前提说明 VS2019 QtClassLibaryDll是动态库,QtWidgetsApplication4是应用程序。 首先明确:动态库以饿汉式的形式进行单例接口暴露; 然后,应用程序加载动态库的翻译文件并进行全局安装; // ...QTranslator* trans = new QTranslator();//qDebug() << trans->…...

13_旷视轻量化网络--ShuffleNet V2

回顾一下ShuffleNetV1:08_旷视轻量化网络--ShuffleNet V1-CSDN博客 1.1 简介 ShuffleNet V2是在2018年由旷视科技的研究团队提出的一种深度学习模型&#xff0c;主要用于图像分类和目标检测等计算机视觉任务。它是ShuffleNet V1的后续版本&#xff0c;重点在于提供更高效的模…...

Linux系统编程--进程间通信

目录 1. 介绍 1.1 进程间通信的目的 1.2 进程间通信的分类 2. 管道 2.1 什么是管道 2.2 匿名管道 2.2.1 接口 2.2.2 步骤--以父子进程通信为例 2.2.3 站在文件描述符角度-深度理解 2.2.4 管道代码 2.2.5 读写特征 2.2.6 管道特征 2.3 命名管道 2.3.1 接口 2.3.2…...

docker-本地部署-后端

前置条件 后端文件 这边是一个简单项目的后端文件目录 docker服务 镜像文件打包 #命令行 docker build -t author/chatgpt-ai-app:1.0 -f ./Dockerfile .红框是docker所在文件夹 author&#xff1a;docker用户名chatgpt-ai-app&#xff1a;打包的镜像文件名字:1.0 &#…...

TLS + OpenSSL + Engine + PKCS#11 + softhsm2 安全通信

引擎库路径只有在 /lib 下才能被 "LOAD" 识别到&#xff0c;OpenSSL的ReadMe给的示例在/lib&#xff0c;大概是在构建OpenSSL时默认的configure指定了lib路径 // #define PKCS11_ENGINE_PATH "/usr/lib/x86_64-linux-gnu/engines-1.1/pkcs11.so" #define …...

Unity实现简单的MVC架构

文章目录 前言MVC基本概念示例流程图效果预览后话 前言 在Unity中&#xff0c;MVC&#xff08;Model-View-Controller&#xff09;框架是一种架构模式&#xff0c;用于分离游戏的逻辑、数据和用户界面。MVC模式可以帮助开发者更好地管理代码结构&#xff0c;提高代码的可维护性…...

【简单讲解下OneFlow深度学习框架】

&#x1f3a5;博主&#xff1a;程序员不想YY啊 &#x1f4ab;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家 &#x1f917;点赞&#x1f388;收藏⭐再看&#x1f4ab;养成习惯 ✨希望本文对您有所裨益&#xff0c;如有不足之处&#xff0c;欢迎在评论区提出…...

FastGPT 调用Qwen 测试Hello world

Ubuntu 安装Qwen/FastGPT_fastgpt message: core.chat.chat api is error or u-CSDN博客 参考上面文档 安装FastGPT后 登录&#xff0c; 点击右上角的 新建 点击 这里&#xff0c;配置AI使用本地 ollama跑的qwen模型 问题&#xff1a;树上有3只鸟&#xff0c;开了一枪&#…...

Golang-GMP

GMP调度 golang-GMP语雀笔记整理 GMP调度设计目的&#xff0c;为何设计GMP?GMP的底层实现几个核心数据结构GMP调度流程 设计目的&#xff0c;为何设计GMP? 无论是多进程、多线程目的都是为了并发提高cpu的利用率&#xff0c;但多进程、多线程都存在局限性。比如多进程通过时…...

【PythonWeb开发】Flask自定义模板路径和静态资源路径

在大型的 Flask 项目中&#xff0c;确实可能会有多个子应用&#xff08;Blueprints&#xff09;&#xff0c;每个子应用可能都有自己的静态文件和模板。为了更好地管理和组织这些资源&#xff0c;可以使用static_folder 和template_folder 属性来统一管理。必须同时设置好主应用…...

Java对象创建过程

在日常开发中&#xff0c;我们常常需要创建对象&#xff0c;那么通过new关键字创建对象的执行中涉及到哪些流程呢&#xff1f;本文主要围绕这个问题来展开。 类的加载 创建对象时我们常常使用new关键字。如下 ObjectA o new ObjectA();对虚拟机来讲首先需要判断ObjectA类的…...

Does a vector database maintain pre-vector chunked data for RAG systems?

题意&#xff1a;一个向量数据库是否为RAG系统维护预向量化分块数据&#xff1f; 问题背景&#xff1a; I believe that when using an LLM with a Retrieval-Augmented Generation (RAG) approach, the results retrieved from a vector search must ultimately be presented…...

Rust-11-错误处理

Rust 将错误分为两大类&#xff1a;可恢复的&#xff08;recoverable&#xff09;和 不可恢复的&#xff08;unrecoverable&#xff09;错误。对于一个可恢复的错误&#xff0c;比如文件未找到的错误&#xff0c;我们很可能只想向用户报告问题并重试操作。不可恢复的错误总是 b…...

自动化测试:使用Postman进行接口测试与脚本编写

Postman 是一种流行的 API 测试工具&#xff0c;广泛应用于开发和测试过程中。它不仅可以用于手动测试&#xff0c;还支持自动化测试和脚本编写&#xff0c;以确保 API 的可靠性和性能。本文将详细介绍如何使用 Postman 进行接口测试与脚本编写&#xff0c;帮助你更高效地进行自…...

AI-调查研究-01-正念冥想有用吗?对健康的影响及科学指南

点一下关注吧&#xff01;&#xff01;&#xff01;非常感谢&#xff01;&#xff01;持续更新&#xff01;&#xff01;&#xff01; &#x1f680; AI篇持续更新中&#xff01;&#xff08;长期更新&#xff09; 目前2025年06月05日更新到&#xff1a; AI炼丹日志-28 - Aud…...

Appium+python自动化(十六)- ADB命令

简介 Android 调试桥(adb)是多种用途的工具&#xff0c;该工具可以帮助你你管理设备或模拟器 的状态。 adb ( Android Debug Bridge)是一个通用命令行工具&#xff0c;其允许您与模拟器实例或连接的 Android 设备进行通信。它可为各种设备操作提供便利&#xff0c;如安装和调试…...

Oracle查询表空间大小

1 查询数据库中所有的表空间以及表空间所占空间的大小 SELECTtablespace_name,sum( bytes ) / 1024 / 1024 FROMdba_data_files GROUP BYtablespace_name; 2 Oracle查询表空间大小及每个表所占空间的大小 SELECTtablespace_name,file_id,file_name,round( bytes / ( 1024 …...

遍历 Map 类型集合的方法汇总

1 方法一 先用方法 keySet() 获取集合中的所有键。再通过 gey(key) 方法用对应键获取值 import java.util.HashMap; import java.util.Set;public class Test {public static void main(String[] args) {HashMap hashMap new HashMap();hashMap.put("语文",99);has…...

Java如何权衡是使用无序的数组还是有序的数组

在 Java 中,选择有序数组还是无序数组取决于具体场景的性能需求与操作特点。以下是关键权衡因素及决策指南: ⚖️ 核心权衡维度 维度有序数组无序数组查询性能二分查找 O(log n) ✅线性扫描 O(n) ❌插入/删除需移位维护顺序 O(n) ❌直接操作尾部 O(1) ✅内存开销与无序数组相…...

聊聊 Pulsar:Producer 源码解析

一、前言 Apache Pulsar 是一个企业级的开源分布式消息传递平台&#xff0c;以其高性能、可扩展性和存储计算分离架构在消息队列和流处理领域独树一帜。在 Pulsar 的核心架构中&#xff0c;Producer&#xff08;生产者&#xff09; 是连接客户端应用与消息队列的第一步。生产者…...

【第二十一章 SDIO接口(SDIO)】

第二十一章 SDIO接口 目录 第二十一章 SDIO接口(SDIO) 1 SDIO 主要功能 2 SDIO 总线拓扑 3 SDIO 功能描述 3.1 SDIO 适配器 3.2 SDIOAHB 接口 4 卡功能描述 4.1 卡识别模式 4.2 卡复位 4.3 操作电压范围确认 4.4 卡识别过程 4.5 写数据块 4.6 读数据块 4.7 数据流…...

Cloudflare 从 Nginx 到 Pingora:性能、效率与安全的全面升级

在互联网的快速发展中&#xff0c;高性能、高效率和高安全性的网络服务成为了各大互联网基础设施提供商的核心追求。Cloudflare 作为全球领先的互联网安全和基础设施公司&#xff0c;近期做出了一个重大技术决策&#xff1a;弃用长期使用的 Nginx&#xff0c;转而采用其内部开发…...

HBuilderX安装(uni-app和小程序开发)

下载HBuilderX 访问官方网站&#xff1a;https://www.dcloud.io/hbuilderx.html 根据您的操作系统选择合适版本&#xff1a; Windows版&#xff08;推荐下载标准版&#xff09; Windows系统安装步骤 运行安装程序&#xff1a; 双击下载的.exe安装文件 如果出现安全提示&…...

反射获取方法和属性

Java反射获取方法 在Java中&#xff0c;反射&#xff08;Reflection&#xff09;是一种强大的机制&#xff0c;允许程序在运行时访问和操作类的内部属性和方法。通过反射&#xff0c;可以动态地创建对象、调用方法、改变属性值&#xff0c;这在很多Java框架中如Spring和Hiberna…...