C++使用Poco库指定网卡去接收组播数据

2024-06-20 07:04

本文主要是介绍C++使用Poco库指定网卡去接收组播数据,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  • 0x00

    1、以下代码封装了一个UDP接收组播数据的类,第一个构造函数 Poco::Net::DatagramSocket 类可以实现UDP单播数据的接收、发送以及往组播发送数据,第二个构造函数使用Poco::Net::MulticastSocket类去接收组播数据,UdpUnit类中成员函数Recv仅仅实现了组播数据的接收,可以改成使用 Poco::Net::DatagramSocket 去接收单播数据。

  • 0x01

    2、Poco::Net::MulticastSocket在使用 joinGroup 函数加入组播时,可以只填写第一个参数"组播地址",Poco中Net库可以为你选择默认网卡加入组播,如果需要指定网卡加入组播时则使用 Poco::Net::NetworkInterface 类去选择需要的网卡。

  • 0x02

#ifndef UDP_UNIT_H
#define UDP_UNIT_H#include <string>
#include <Poco/Net/Socket.h>
#include <Poco/Net/SocketAddress.h>
#include <Poco/Net/DatagramSocket.h>
#include <Poco/Net/MulticastSocket.h>
#include <Poco/Net/NetException.h>
#include <Poco/Net/NetworkInterface.h>#define RECV_BUFFER_SIZE 1024 * 1024 * 1class UdpUnit
{
public:UdpUnit(std::string const local_addr, int const local_port);UdpUnit(std::string const local_addr, std::string const multicast_addr, int const multicast_port);int Recv(std::string &recvMsg);int Recv(char *buffer, int bufferSize);int Send(const char *buffer, int bufferSize, const std::string remote_addr, const int remote_port);private:Poco::Net::SocketAddress m_localAddress;Poco::Net::DatagramSocket m_datagramSocket;Poco::Net::MulticastSocket m_multicastSocket;
};#endif

#include "udpUnit.h"UdpUnit::UdpUnit(std::string const local_addr, int const local_port) : m_localAddress(local_addr, local_port)
{// 单播数据try{m_datagramSocket.bind(m_localAddress, true);}catch (const Poco::Exception &ex){printf("Error: %s\n", ex.displayText().c_str());}
}UdpUnit::UdpUnit(std::string const local_addr, std::string const multicast_addr, int const multicast_port)
{// 组播数据try{m_multicastSocket.bind(Poco::Net::SocketAddress(multicast_port), true);// 指定网卡加入组播Poco::Net::IPAddress localAddr(local_addr);Poco::Net::NetworkInterface iInterface;iInterface.addAddress(localAddr);Poco::Net::IPAddress multicastAddr(multicast_addr);m_multicastSocket.joinGroup(multicastAddr, iInterface);}catch (const Poco::Exception &ex){printf("Error: %s\n", ex.displayText().c_str());}
}int UdpUnit::Recv(std::string &recvMsg)
{int bytesReceived = -1;try{char recvBuffer[RECV_BUFFER_SIZE];Poco::Net::SocketAddress otherAddr;bytesReceived = m_multicastSocket.receiveFrom(recvBuffer, RECV_BUFFER_SIZE, otherAddr);printf("Received from <%s:%d>\n", otherAddr.host().toString().c_str(), otherAddr.port());recvMsg.assign(recvBuffer, bytesReceived);}catch (const Poco::Exception &ex){printf("Exception: %s\n", ex.displayText().c_str());}return bytesReceived;
}int UdpUnit::Recv(char *buffer, int bufferSize)
{int bytesReceived = -1;try{Poco::Net::SocketAddress otherAddr;bytesReceived = m_multicastSocket.receiveFrom(buffer, bufferSize, otherAddr);printf("Received from <%s:%d>\n", otherAddr.host().toString().c_str(), otherAddr.port());}catch (const Poco::Exception &ex){printf("Exception: %s\n", ex.displayText().c_str());}return bytesReceived;
}int UdpUnit::Send(const char *buffer, int bufferSize, const std::string remote_addr, const int remote_port)
{Poco::Net::SocketAddress m_remoteAddress(remote_addr, remote_port);int bytesSend = m_datagramSocket.sendTo(buffer, bufferSize, m_remoteAddress);return bytesSend;
}

这篇关于C++使用Poco库指定网卡去接收组播数据的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/1077430

相关文章

SQL Server修改数据库名及物理数据文件名操作步骤

《SQLServer修改数据库名及物理数据文件名操作步骤》在SQLServer中重命名数据库是一个常见的操作,但需要确保用户具有足够的权限来执行此操作,:本文主要介绍SQLServer修改数据... 目录一、背景介绍二、操作步骤2.1 设置为单用户模式(断开连接)2.2 修改数据库名称2.3 查找逻辑文件名

C++中RAII资源获取即初始化

《C++中RAII资源获取即初始化》RAII通过构造/析构自动管理资源生命周期,确保安全释放,本文就来介绍一下C++中的RAII技术及其应用,具有一定的参考价值,感兴趣的可以了解一下... 目录一、核心原理与机制二、标准库中的RAII实现三、自定义RAII类设计原则四、常见应用场景1. 内存管理2. 文件操

C++中零拷贝的多种实现方式

《C++中零拷贝的多种实现方式》本文主要介绍了C++中零拷贝的实现示例,旨在在减少数据在内存中的不必要复制,从而提高程序性能、降低内存使用并减少CPU消耗,零拷贝技术通过多种方式实现,下面就来了解一下... 目录一、C++中零拷贝技术的核心概念二、std::string_view 简介三、std::stri

Python常用命令提示符使用方法详解

《Python常用命令提示符使用方法详解》在学习python的过程中,我们需要用到命令提示符(CMD)进行环境的配置,:本文主要介绍Python常用命令提示符使用方法的相关资料,文中通过代码介绍的... 目录一、python环境基础命令【Windows】1、检查Python是否安装2、 查看Python的安

C++高效内存池实现减少动态分配开销的解决方案

《C++高效内存池实现减少动态分配开销的解决方案》C++动态内存分配存在系统调用开销、碎片化和锁竞争等性能问题,内存池通过预分配、分块管理和缓存复用解决这些问题,下面就来了解一下... 目录一、C++内存分配的性能挑战二、内存池技术的核心原理三、主流内存池实现:TCMalloc与Jemalloc1. TCM

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象(如模块、类、函数等)的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(

Linux脚本(shell)的使用方式

《Linux脚本(shell)的使用方式》:本文主要介绍Linux脚本(shell)的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述语法详解数学运算表达式Shell变量变量分类环境变量Shell内部变量自定义变量:定义、赋值自定义变量:引用、修改、删

Python pip下载包及所有依赖到指定文件夹的步骤说明

《Pythonpip下载包及所有依赖到指定文件夹的步骤说明》为了方便开发和部署,我们常常需要将Python项目所依赖的第三方包导出到本地文件夹中,:本文主要介绍Pythonpip下载包及所有依... 目录步骤说明命令格式示例参数说明离线安装方法注意事项总结要使用pip下载包及其所有依赖到指定文件夹,请按照以

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.