UDP组播通信(解决端口复用的问题)

2024-06-12 23:18

本文主要是介绍UDP组播通信(解决端口复用的问题),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

最近在写一个组播通信的功能,结果发现接受同一台电脑上只能运行一个接收端,如果运行两个时,第二个运行的程序不能收到数据。查找原因是因为没有设置端口数据复用的功能(setsockpot),setsockpot的调用见代码。

//发送端
// Send.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。
//
#include<WinSock2.h>
#include <iostream>
#include <Ws2tcpip.h>
#pragma comment(lib,"ws2_32.lib")using namespace std;int main()
{WSADATA wsaData = { 0 };WSAStartup(MAKEWORD(2, 2), &wsaData);SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);SOCKADDR_IN sa;sa.sin_family = AF_INET;sa.sin_addr.S_un.S_addr = inet_addr("239.255.88.8");sa.sin_port = htons(6868);int count = 0;char serr[1024] = { 0 };int a = 0;while (1){sprintf_s(serr, "Setsock falied !   %d", count);a = sendto(sock, serr, sizeof(serr), 0, (sockaddr*)&sa, sizeof(sa));if (a > 0){count++;//cout << "send hello lvzai sucessful   " << count << endl;cout << serr << endl;}Sleep(20);}return 0;
}

//接收端

// Recv.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。
//
#include<WinSock2.h>
#include <iostream>
#include <Ws2tcpip.h>
#pragma comment(lib,"ws2_32.lib")using namespace std;int main()
{WSADATA wsaData = { 0 };WSAStartup(MAKEWORD(2, 2), &wsaData);SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);SOCKADDR_IN addr_rec;addr_rec.sin_family = AF_INET;addr_rec.sin_addr.S_un.S_addr = htonl(INADDR_ANY);  addr_rec.sin_port = htons(6868);bool bOptval = true;int iret = 0;iret = setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)&bOptval, sizeof(bOptval));if (iret != 0)cout << "setsockopt fail: " << WSAGetLastError() << endl;iret = bind(sock, (SOCKADDR*)&addr_rec, sizeof(addr_rec));if (iret != 0){char serr[1024] = { 0 };sprintf_s(serr, "kbind falied !   %d", WSAGetLastError());cout << "bind fail" << endl;return -1;}struct ip_mreq mreq;mreq.imr_interface.s_addr = htonl(INADDR_ANY);; //inet_addr("169.254.4.119");mreq.imr_multiaddr.s_addr = inet_addr("239.255.88.8");if (setsockopt(sock,IPPROTO_IP, IP_ADD_MEMBERSHIP, (const char*)&mreq, sizeof(mreq)) !=0){char serr[1024] = { 0 };sprintf_s(serr, "Setsock falied !   %d", WSAGetLastError());cout << "加入组播失败!" <<serr << endl;}int len = sizeof(SOCKADDR);int res = 0;char strRecv[1024] = { 0 };int coutt = 0;while (1){res = recvfrom(sock, strRecv, sizeof(strRecv), 0, (SOCKADDR*)&addr_rec, &len);if (res > 0){coutt++;cout << "recv Data :  " << strRecv << "   coutt:  " << coutt << endl;}}return 0;
}

其中最关键的是setsockopt函数的使用。

这篇关于UDP组播通信(解决端口复用的问题)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1055620

相关文章

springboot3.x使用@NacosValue无法获取配置信息的解决过程

《springboot3.x使用@NacosValue无法获取配置信息的解决过程》在SpringBoot3.x中升级Nacos依赖后,使用@NacosValue无法动态获取配置,通过引入SpringC... 目录一、python问题描述二、解决方案总结一、问题描述springboot从2android.x

Python实现快速扫描目标主机的开放端口和服务

《Python实现快速扫描目标主机的开放端口和服务》这篇文章主要为大家详细介绍了如何使用Python编写一个功能强大的端口扫描器脚本,实现快速扫描目标主机的开放端口和服务,感兴趣的小伙伴可以了解下... 目录功能介绍场景应用1. 网络安全审计2. 系统管理维护3. 网络故障排查4. 合规性检查报错处理1.

Springboot3统一返回类设计全过程(从问题到实现)

《Springboot3统一返回类设计全过程(从问题到实现)》文章介绍了如何在SpringBoot3中设计一个统一返回类,以实现前后端接口返回格式的一致性,该类包含状态码、描述信息、业务数据和时间戳,... 目录Spring Boot 3 统一返回类设计:从问题到实现一、核心需求:统一返回类要解决什么问题?

解决idea启动项目报错java: OutOfMemoryError: insufficient memory

《解决idea启动项目报错java:OutOfMemoryError:insufficientmemory》:本文主要介绍解决idea启动项目报错java:OutOfMemoryError... 目录原因:解决:总结 原因:在Java中遇到OutOfMemoryError: insufficient me

maven异常Invalid bound statement(not found)的问题解决

《maven异常Invalidboundstatement(notfound)的问题解决》本文详细介绍了Maven项目中常见的Invalidboundstatement异常及其解决方案,文中通过... 目录Maven异常:Invalid bound statement (not found) 详解问题描述可

idea粘贴空格时显示NBSP的问题及解决方案

《idea粘贴空格时显示NBSP的问题及解决方案》在IDEA中粘贴代码时出现大量空格占位符NBSP,可以通过取消勾选AdvancedSettings中的相应选项来解决... 目录1、背景介绍2、解决办法3、处理完成总结1、背景介绍python在idehttp://www.chinasem.cna粘贴代码,出

SpringBoot整合Kafka启动失败的常见错误问题总结(推荐)

《SpringBoot整合Kafka启动失败的常见错误问题总结(推荐)》本文总结了SpringBoot项目整合Kafka启动失败的常见错误,包括Kafka服务器连接问题、序列化配置错误、依赖配置问题、... 目录一、Kafka服务器连接问题1. Kafka服务器无法连接2. 开发环境与生产环境网络不通二、序

SpringSecurity中的跨域问题处理方案

《SpringSecurity中的跨域问题处理方案》本文介绍了跨域资源共享(CORS)技术在JavaEE开发中的应用,详细讲解了CORS的工作原理,包括简单请求和非简单请求的处理方式,本文结合实例代码... 目录1.什么是CORS2.简单请求3.非简单请求4.Spring跨域解决方案4.1.@CrossOr

nacos服务无法注册到nacos服务中心问题及解决

《nacos服务无法注册到nacos服务中心问题及解决》本文详细描述了在Linux服务器上使用Tomcat启动Java程序时,服务无法注册到Nacos的排查过程,通过一系列排查步骤,发现问题出在Tom... 目录简介依赖异常情况排查断点调试原因解决NacosRegisterOnWar结果总结简介1、程序在

Java通过ServerSocket与Socket实现通信过程

《Java通过ServerSocket与Socket实现通信过程》本文介绍了Java中的ServerSocket和Socket类,详细讲解了它们的构造方法和使用场景,并通过一个简单的通信示例展示了如何... 目录1 ServerSocket2 Socket3 服务器端4 客户端5 运行结果6 设置超时总结1