【网络编程】广播和组播

数据包发送方式只有一个接受方,称为单播。如果同时发给局域网中的所有主机,称为广播。只有用户数据报(使用UDP协议)套接字才能广播:

广播地址以192.168.1.0 (255.255.255.0) 网段为例,最大的主机地址192.168.1.255代表该网段的广播地址,发到该地址的数据包被所有的主机接收。255.255.255.255在所有网段中都代表广播地址。广播发送创建用户数据报套接字缺省创建的套接字不允许广播数据包,需要设置属性。(setsockopt可以设置套接字属性)接收方地址指定为广播地址指定端口信息发送数据包setsockoptint  setsockopt(int  s,  int level,  int  optname, const void *optval, socklen_t  optlen);头文件:<sys/socket.h>level : 选项级别(例如SOL_SOCKET)optname : 选项名(例如SO_BROADCAST)optval : 存放选项值的缓冲区的地址optlen : 缓冲区长度返回值:成功返回0   失败返回-1并设置errno广播发送示例sockfd = socket(,,);……int on = 1;setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &on, sizeof(on));……sendto(;;;;;);广播接收创建用户数据报套接字绑定IP地址(广播IP或0.0.0.0)和端口(绑定的端口必须和发送方指定的端口相同)等待接收数据

UDP 广播服务器与客户端(C 语言实现)

  • 广播(Broadcast):将数据发送到 整个局域网,所有主机都能接收。
  • UDP 支持广播,但 TCP 不支持 广播。
  • 广播地址示例
    • 192.168.1.255(局域网广播,子网掩码 255.255.255.0)。
    • 255.255.255.255(全网广播)。
      在这里插入图片描述
关键 API
函数功能
setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &on, sizeof(on));允许 UDP 广播
sendto(sockfd, message, len, 0, (struct sockaddr*)&addr, addr_len);发送广播消息
recvfrom(sockfd, buffer, len, 0, (struct sockaddr*)&addr, &addr_len);接收广播消息
UDP 广播服务器完整实现代码

服务端:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define BROADCAST_PORT 8080  // 广播端口
#define BROADCAST_ADDR "255.255.255.255" // 广播地址
#define BUFFER_SIZE 1024int main() {int sockfd;struct sockaddr_in broadcast_addr;char message[BUFFER_SIZE] = "这是来自服务器的广播消息!";int broadcast_permit = 1;// 1️⃣ 创建 UDP 套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("❌ 创建套接字失败");exit(EXIT_FAILURE);}// 2️⃣ 允许发送广播setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &broadcast_permit, sizeof(broadcast_permit));// 3️⃣ 设置广播地址memset(&broadcast_addr, 0, sizeof(broadcast_addr));broadcast_addr.sin_family = AF_INET;broadcast_addr.sin_port = htons(BROADCAST_PORT);broadcast_addr.sin_addr.s_addr = inet_addr(BROADCAST_ADDR);printf("服务器开始广播消息...\n");while (1) {// 4️⃣ 发送广播消息sendto(sockfd, message, strlen(message), 0,(struct sockaddr*)&broadcast_addr, sizeof(broadcast_addr));printf("发送广播消息: %s\n", message);sleep(3); // 每 3 秒广播一次}close(sockfd);return 0;
}

客户端:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define BROADCAST_PORT 8080  // 监听广播端口
#define BUFFER_SIZE 1024int main() {int sockfd;struct sockaddr_in listen_addr;char buffer[BUFFER_SIZE];socklen_t addr_len = sizeof(listen_addr);// 1️⃣ 创建 UDP 套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("❌ 创建套接字失败");exit(EXIT_FAILURE);}// 2️⃣ 允许端口重用(多个客户端可绑定相同端口)int reuse = 1;setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));// 3️⃣ 绑定监听端口memset(&listen_addr, 0, sizeof(listen_addr));listen_addr.sin_family = AF_INET;listen_addr.sin_port = htons(BROADCAST_PORT);listen_addr.sin_addr.s_addr = htonl(INADDR_ANY);if (bind(sockfd, (struct sockaddr*)&listen_addr, sizeof(listen_addr)) < 0) {perror("❌ 绑定失败");close(sockfd);exit(EXIT_FAILURE);}printf("客户端正在监听广播消息...\n");while (1) {// 4️⃣ 接收广播消息memset(buffer, 0, BUFFER_SIZE);recvfrom(sockfd, buffer, BUFFER_SIZE, 0,(struct sockaddr*)&listen_addr, &addr_len);printf("📩 收到广播消息: %s\n", buffer);}close(sockfd);return 0;
}

运行步骤:

  1. 编译
gcc udp_broadcast_server.c -o udp_broadcast_server
gcc udp_broadcast_client.c -o udp_broadcast_client
  1. 运行服务器(广播消息)
./udp_broadcast_server

输出示例:

⚡ 服务器开始广播消息...
📡 发送广播消息: 这是来自服务器的广播消息!
📡 发送广播消息: 这是来自服务器的广播消息!
  1. 运行客户端(监听广播)
./udp_broadcast_client

输出示例:

客户端正在监听广播消息...
📩 收到广播消息: 这是来自服务器的广播消息!
📩 收到广播消息: 这是来自服务器的广播消息!
广播流程思路解析(逐帧解释)流程上面的注释已经写了,但是这里是配合完整的代码实现和业务流程再过一遍

🔹 服务器

  1. 创建 UDP 套接字
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  1. 允许广播
int broadcast_permit = 1;
setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &broadcast_permit, sizeof(broadcast_permit));
  1. 设置广播地址
broadcast_addr.sin_addr.s_addr = inet_addr("255.255.255.255");
  1. 发送广播消息
sendto(sockfd, message, strlen(message), 0, (struct sockaddr*)&broadcast_addr, sizeof(broadcast_addr));

🔹 客户端

  1. 创建 UDP 套接字
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  1. 允许端口重用
int reuse = 1;
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));
  1. 绑定监听端口
listen_addr.sin_addr.s_addr = htonl(INADDR_ANY);
bind(sockfd, (struct sockaddr*)&listen_addr, sizeof(listen_addr));
  1. 接收广播消息
recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&listen_addr, &addr_len);
广播代码优化:
  1. 使用 SO_REUSEADDR
    • 允许多个客户端监听相同端口,防止端口占用问题:
int reuse = 1;
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));
  1. 限制广播频率:
sleep(3); // 控制广播间隔,避免网络拥塞。
  1. 支持多播:监听 指定的多播组,而不是整个局域网:
struct ip_mreq mreq;
mreq.imr_multiaddr.s_addr = inet_addr("224.0.0.1");
mreq.imr_interface.s_addr = INADDR_ANY;
setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq));

UDP 广播通信,适用于 局域网设备发现日志广播状态同步等应用。相比 TCP,UDP 广播更加轻量级,可用于 IoT、在线游戏等场景。

在编译过程中可能遇到的问题

🚨 1. Permission denied(权限错误)
如果 sendto() 失败,检查 SO_BROADCAST 是否设置:

int broadcast_permit = 1;
setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &broadcast_permit, sizeof(broadcast_permit));

若仍然失败,可以尝试 sudo 运行:

sudo ./udp_broadcast_server

🚨 2. Address already in use(端口占用)
如果 bind() 失败,尝试释放端口:

sudo fuser -k 8080/udp

然后重新运行程序。

🚨 3. recvfrom() 接收不到消息

  • 确保服务器和客户端在 同一局域网
  • 使用 ifconfig / ip a 检查本机 IP 地址并使用正确的广播地址:
ifconfig | grep "inet "
  • 确保防火墙没有阻止 UDP 广播:
sudo iptables -I INPUT -p udp --dport 8080 -j ACCEPT
sudo iptables -I OUTPUT -p udp --dport 8080 -j ACCEPT

组播(Multicast)编程指南(C 语言)

单播(Unicast):数据仅发送给一个特定的主机。
广播(Broadcast):广播方式发给所有的主机。过多的广播会大量占用网络带宽,造成广播风暴,影响正常的通信。
组播(Multicast):组播(又称为多播)是一种折中的方式。只有加入某个多播组的主机才能收到数据。多播方式既可以发给多个主机又能避免象广播那样带来过多的负载(每台主机要到传输层才能判断广播包是否要处理)

  • 仅发送给加入 特定组播组 的主机。
  • 减少网络负载,避免广播风暴。
  • 适用于 IPTV、视频流、在线游戏、股票行情推送等场景
    组播
📌 组播地址

组播范围:224.0.0.0 ~ 239.255.255.255
特殊组播地址:

  • 224.0.0.1:所有支持 IP 组播的主机。
  • 224.0.0.2:所有路由器。
关键 API
函数/结构体作用
setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq));加入组播组
setsockopt(sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP, &mreq, sizeof(mreq));退出组播组
sendto(sockfd, message, len, 0, (struct sockaddr*)&addr, addr_len);发送组播
recvfrom(sockfd, buffer, len, 0, (struct sockaddr*)&addr, &addr_len);接收组播
struct ip_mreq组播配置结构体
组播发送端(C 语言实现)
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define MULTICAST_GROUP "239.0.0.1"  // 组播地址
#define MULTICAST_PORT 8080          // 组播端口
#define MESSAGE "🌍 这是组播消息!"int main() {int sockfd;struct sockaddr_in multicast_addr;int ttl = 64;  // 组播生存时间(TTL)// 1️⃣ 创建 UDP 套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("❌ 创建套接字失败");exit(EXIT_FAILURE);}// 2️⃣ 设置组播 TTLsetsockopt(sockfd, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, sizeof(ttl));// 3️⃣ 设置组播地址memset(&multicast_addr, 0, sizeof(multicast_addr));multicast_addr.sin_family = AF_INET;multicast_addr.sin_port = htons(MULTICAST_PORT);multicast_addr.sin_addr.s_addr = inet_addr(MULTICAST_GROUP);printf("发送组播消息到 %s:%d\n", MULTICAST_GROUP, MULTICAST_PORT);while (1) {// 4️⃣ 发送组播消息sendto(sockfd, MESSAGE, strlen(MESSAGE), 0,(struct sockaddr*)&multicast_addr, sizeof(multicast_addr));printf("✅ 发送消息: %s\n", MESSAGE);sleep(3);  // 每 3 秒发送一次}close(sockfd);return 0;
}
组播接收端(C 语言实现)
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define MULTICAST_GROUP "239.0.0.1"  // 组播地址
#define MULTICAST_PORT 8080          // 组播端口
#define BUFFER_SIZE 1024int main() {int sockfd;struct sockaddr_in local_addr;struct ip_mreq mreq;char buffer[BUFFER_SIZE];socklen_t addr_len = sizeof(local_addr);// 1️⃣ 创建 UDP 套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("❌ 创建套接字失败");exit(EXIT_FAILURE);}// 2️⃣ 允许端口复用(多个进程/设备可接收同一组播)int reuse = 1;setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));// 3️⃣ 绑定本地地址memset(&local_addr, 0, sizeof(local_addr));local_addr.sin_family = AF_INET;local_addr.sin_port = htons(MULTICAST_PORT);local_addr.sin_addr.s_addr = htonl(INADDR_ANY);if (bind(sockfd, (struct sockaddr*)&local_addr, sizeof(local_addr)) < 0) {perror("❌ 绑定失败");close(sockfd);exit(EXIT_FAILURE);}// 4️⃣ 加入组播组mreq.imr_multiaddr.s_addr = inet_addr(MULTICAST_GROUP);mreq.imr_interface.s_addr = htonl(INADDR_ANY);setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq));printf("监听组播消息 (%s:%d)...\n", MULTICAST_GROUP, MULTICAST_PORT);while (1) {// 5️⃣ 接收组播消息memset(buffer, 0, BUFFER_SIZE);recvfrom(sockfd, buffer, BUFFER_SIZE, 0,(struct sockaddr*)&local_addr, &addr_len);printf("📩 收到消息: %s\n", buffer);}// 6️⃣ 退出组播setsockopt(sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP, &mreq, sizeof(mreq));close(sockfd);return 0;
}

运行步骤:

  1. 编译
gcc multicast_sender.c -o multicast_sender
gcc multicast_receiver.c -o multicast_receiver
  1. 运行组播接收端
./multicast_receiver

示例输出:

监听组播消息 (239.0.0.1:8080)...
收到消息: 🌍 这是组播消息!
收到消息: 🌍 这是组播消息!
  1. 运行组播发送端
./multicast_sender

示例输出:

发送组播消息到 239.0.0.1:8080
✅ 发送消息: 🌍 这是组播消息!
✅ 发送消息: 🌍 这是组播消息!

编译中可能遇到的问题:
🚨 1. recvfrom() 接收不到数据
✅ 解决方案

  • 确保接收端 加入了相同的组播地址(239.0.0.1)。
  • 使用 netstat -g 命令检查当前加入的组播组:
netstat -g
  • 确保 Linux 防火墙未阻止 UDP 组播:
sudo iptables -I INPUT -p udp --dport 8080 -j ACCEPT
sudo iptables -I OUTPUT -p udp --dport 8080 -j ACCEPT

组播是一种高效的网络通信方式,可用于 IPTV、在线游戏、股票行情推送等应用场景。以上 C 代码实现了 UDP 组播的发送和接收,支持多个设备同时接收组播消息。 相比广播,组播能够减少网络负载,提高数据传输效率

以上。仅供学习与分享交流,请勿用于商业用途!转载需提前说明。

我是一个十分热爱技术的程序员,希望这篇文章能够对您有帮助,也希望认识更多热爱程序开发的小伙伴。
感谢!

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

小程序如何实现跨页面通信

前言 最近有很多同学问&#xff0c;小程序里面如何进行跨页面通信。看了下之前的老代码&#xff0c;基本都是基于onShow或者localStorage。虽然可以实现&#xff0c;但是并不怎么优雅。 今天就来聊一聊&#xff0c;小程序的跨页面通信的几种实现方案。或许会有你想要的方案&a…

【工具】win-画图 保留图片信息并仅改变图片比例的工具

Windows 系统自带的“画图”工具 Windows 系统自带的“画图”&#xff08;Paint&#xff09;工具可以进行简单的图片编辑&#xff0c;包括调整图片大小和比例。 使用方法&#xff1a; 打开“画图”工具&#xff08;可以通过在开始菜单中搜索“画图”或“Paint”&#xff09;。…

如何编辑autodl中以.bashrc结尾的隐藏文件

在nnunet的运行过程中遇到了设置环境变量的问题。之前没有接触过linux系统&#xff0c;但是autodl里面默认是linux系统。.bashrc 是一个在 Bash shell 启动时执行的脚本文件&#xff0c;常用于设置环境变量、定义别名、加载函数等&#xff0c;用户可以通过编辑这个文件来定制自…

实验3 知识表示与推理

实验3 知识表示与推理 一、实验目的 &#xff08;1&#xff09;掌握知识和知识表示的基本概念&#xff0c;理解其在AI中的深刻含义与意义&#xff1b; &#xff08;2&#xff09;熟悉AI中常用的知识表示方法的优缺点及其应用场景&#xff1b; &#xff08;3&#xff09;掌握产…

在 M1 Mac 上解锁 TensorFlow GPU 加速:从环境搭建到实战验证

在 M1 Mac 上解锁 TensorFlow GPU 加速&#xff1a;从环境搭建到实战验证 前言&#xff1a;苹果芯片的深度学习新纪元 随着 Apple Silicon 芯片的普及&#xff0c;M1/M2/M3 系列 Mac 已成为移动端深度学习开发的新选择。本文将以 TensorFlow 2.x 为例&#xff0c;手把手教你如…

Python 数据分析概述 ①

一文读懂Python数据分析&#xff1a;从基础到实践全攻略 在当今数字化浪潮中&#xff0c;数据分析已然成为解锁海量数据价值的关键钥匙&#xff0c;而Python凭借其独特优势&#xff0c;在数据分析领域大放异彩。今天&#xff0c;咱们就结合教学PPT内容&#xff0c;深入探索Pyt…

【Gin-Web】Bluebell社区项目梳理6:限流策略-漏桶与令牌桶

本文目录 一、限流二、漏桶三、令牌桶算法四、Gin框架中实现令牌桶限流 一、限流 限流又称为流量控制&#xff0c;也就是流控&#xff0c;通常是指限制到达系统的并发请求数。 限流虽然会影响部分用户的使用体验&#xff0c;但是能一定程度上保证系统的稳定性&#xff0c;不至…

Linux高并发服务器开发 第十九天(线程 进程)

目录 1.进程组和会话 2.守护进程 2.1守护进程daemon概念 2.2创建守护进程 3.线程 3.1线程的概念 3.2线程内核三级映射 3.3线程共享 3.4线程优缺点 4.线程控制原语 4.1获取线程id 4.2创建线程 4.3循环创建N个子线 4.4子线程传参地址&#xff0c;错误示例 4.5线程…

软件工程和系统分析与设计

软件工程 1、软件危机 2、软件过程模型 2.1 瀑布模型 2.2原型模型 2.3螺旋模型 2.4敏捷模型 2.5软件统一过程 3、软件能力成熟度模型 CMM 4、软件能力成熟度模型集成 CMMI 系统分析与设计 1、结构化方法SASD 1.1结构化分析 DFD 1.2结构化设计 SD-是一种面向数据流的设计…

Qt/C++面试【速通笔记一】

Qt 信号与槽机制 什么是信号&#xff08;Signal&#xff09;和槽&#xff08;Slot&#xff09;&#xff1f; 在Qt中&#xff0c;信号&#xff08;Signal&#xff09;和槽&#xff08;Slot&#xff09;是实现对象之间通信的一种机制。信号是对象在某些事件发生时发出的通知&…

LangChain大模型应用开发:构建Agent智能体

介绍 大家好&#xff0c;博主又来给大家分享知识了。今天要给大家分享的内容是使用LangChain进行大模型应用开发中的构建Agent智能体。 在LangChain中&#xff0c;Agent智能体是一种能够根据输入的任务或问题&#xff0c;动态地决定使用哪些工具(如搜索引擎、数据库查询等)来…

微服务架构概述及创建父子项目

目录 一&#xff0c;什么是单体架构 二&#xff0c;什么是集群和分布式架构 三&#xff0c;什么是微服务架构 四&#xff0c;解决微服务难题的方案Spring-cloud Spring Cloud Alibaba是阿里巴实现的方案&#xff0c;基于SpringCloud的规范。如果说Spring Cloud Netflix 是…

C/C++跳动的爱心

系列文章 序号直达链接1C/C李峋同款跳动的爱心2C/C跳动的爱心3C/C经典爱心4C/C满屏飘字5C/C大雪纷飞6C/C炫酷烟花7C/C黑客帝国同款字母雨8C/C樱花树9C/C奥特曼10C/C精美圣诞树11C/C俄罗斯方块小游戏12C/C贪吃蛇小游戏13C/C孤单又灿烂的神14C/C闪烁的爱心15C/C哆啦A梦16C/C简单…

量子计算的威胁,以及企业可以采取的措施

当谷歌、IBM、Honeywell和微软等科技巨头纷纷投身量子计算领域时&#xff0c;一场技术军备竞赛已然拉开帷幕。 量子计算虽能为全球数字经济带来巨大价值&#xff0c;但也有可能对相互关联的系统、设备和数据造成损害。这一潜在影响在全球网络安全领域引起了强烈关注。也正因如…

Unity制作游戏——前期准备:Unity2023和VS2022下载和安装配置——附安装包

1.Unity2023的下载和安装配置 &#xff08;1&#xff09;Unity官网下载地址&#xff08;国际如果进不去&#xff0c;进国内的官网&#xff0c;下面以国内官网流程为例子&#xff09; unity中国官网&#xff1a;Unity中国官网 - 实时内容开发平台 | 3D、2D、VR & AR可视化 …

23贪心算法

分发饼干 class Solution { public:int findContentChildren(vector<int>& g, vector<int>& s) {int i0,j0;int count0;sort(s.begin(),s.end());sort(g.begin(),g.end());while(i<g.size()&&j<s.size()){if(g[i]<s[j]){i;j;count;}else…

Spark 和 Flink

Spark 和 Flink 都是目前流行的大数据处理引擎&#xff0c;但它们在架构设计、应用场景、性能和生态方面有较大区别。以下是详细对比&#xff1a; 1. 架构与核心概念 方面Apache SparkApache Flink计算模型微批&#xff08;Micro-Batch&#xff09;为主&#xff0c;但支持结构…

Android 串口通信

引言 在iot项目中&#xff0c;Android 端总会有和硬件通信。 通信这里&#xff1a;串口通信&#xff0c;蓝牙通信或者局域网通信。 这里讲一下串口通信。 什么是串口&#xff1f; “串口”&#xff08;Serial Port&#xff09;通常是指一种用于与外部设备进行串行通信的接口。…

【计算机网络】OSI模型、TCP/IP模型、路由器、集线器、交换机

一、计算机网络分层结构 计算机网络分层结构 指将计算机网络的功能划分为多个层次&#xff0c;每个层次都有其特定的功能和协议&#xff0c;并且层次之间通过接口进行通信。 分层设计的优势&#xff1a; 模块化&#xff1a;各层独立发展&#xff08;如IPv4→IPv6&#xff0c…

从人机环境系统智能角度看传统IP的全球化二次创作法则

从人机环境系统智能的视角看&#xff0c;传统IP的全球化二次创作法则需结合技术、文化、伦理与环境的复杂协同。这一过程不仅是内容的本土化改编&#xff0c;更是人、机器与环境在动态交互中实现价值共创的体现。 一、人机环境系统智能的底层逻辑与IP二次创作的融合 1、感知层&…