Unix 网络编程_阅读笔记 三 (Socket高级篇之广播、多播、UDP套接字、信号驱动式I/O)
--Unix Network Programming
由 王宇 原创并发布
本文代码,在以下环境下编译通过
- CentOS 6.4
- Kernal version: 2.6.32
- GCC version: 4.4.7
一、广播
1、用途和寻址方式
广播的用途之一是在本地子网定位一个服务器主机,前提是已知或认定这个服务器主机位于本地子网,但是不知道它的单播IP地址。这种操作也称为资源发现。另一个用途是在有多个客户主机与单个服务器主机通信的局域网环境中尽量减少分组流通。
图 20-1
- TCP 只支持单播
- IPv6 不支持广播
- IPv4 是可选的
- 广播和多播要求用于UDP或原始IP
2、单播和广播的比较
图 20-3
图 20-4
单播IP数据报仅由通过目的IP地址指定的单个主机接收,子网上的其他主机都不受任何影响。 广播存在的根本问题,子网上未参加相应广播应用的所有主机也不得不沿协议栈一路向上完整地处理收取的UDP广播数据报,直到该数据报历经UDP层时被丢弃为止。另外,子网上所有非IP的主机也不得不在数据链路层接收完整的帧,然后再丢弃它,这有可能严重影响子网上这些其他主机的工作。
3、使用广播的dg_cli函数
void dg_cli( FILE *fp, int socket_fd, const SA *server_addr, socklen_t server_len) { int n; const int on = 1; char send_line[MAXLINE], recv_line[MAXLINE + 1]; struct sockaddr *preply_addr; socklen_t len; preply_addr = (struct sockaddr*)malloc(server_len); if(preply_addr == NULL) { perror("Error: malloc.\n"); return; } if(setsockopt(socket_fd, SOL_SOCKET, SO_BROADCAST, &on, sizeof(on)) == -1)/*广播标识:SO_BROADCAST*/ { perror("Error: setsockopt\n"); return; } if(signal(SIGALRM, recvfrom_alarm) == SIG_ERR) { perror("Error: signal\n"); return; } while(fgets(send_line, MAXLINE, fp) != NULL) { if(sendto(socket_fd, send_line, strlen(send_line), 0, server_addr, server_len) == -1) { perror("Error: sendto\n"); return; } alarm(5); for(;;) { len = server_len; n = recvfrom(socket_fd, recv_line, MAXLINE, 0, preply_addr, &len); if(n < 0) { if(errno == EINTR) { break; } else { perror("Error: recvfrom\n"); } } else { recv_line[n] = 0; printf("from %s: %s\n", sock_ntop_host(preply_addr, len), recv_line ); } } } free(preply_addr); }
二、 多播
单播地址标识单个IP接口,广播地址标识某个子网的所有IP接口,多播地址标识一组IP接口。
1、IPv4 的D类地址
IPv4的D类地址(从224.0.0.0到239.255.255.255)是IPv4多播地址。D类地址的低序28位构成多播组ID,整个32位地址则称为组地址
图A-3
图21-1
2、局域网上多播和广播的比较
图21-4
3、使用多播的dg_cli函数
通过简单地去掉setsockopt调用来修改广播的dg_cli函数,则发送多播数据报无需设置任何多播套接字选项。
三、高级UDP套接字编程
1、何时用UDP代替TCP
UDP的优势:
- UDP支持广播和多播。事实上如果应用程序使用广播或多播,那就必须使用UDP
- UDP没有连接建立和拆除,减小资源开销
UDP无法提供的TCP特性,需注意的是,不是所有应用程序都需要TCP的所有这些特性:
- 正面确认,丢失分组重传,重复分组检测,给被网络打乱次序的分组排序。TCP确认所有数据,以便检测出丢失的分组。这些特性的实现要求每个TCP数据分节都包含一个能被对端确认的序列号。这些特性还要求TCP为每个连接估算重传超时值,该值应随着两个端系统之间分组流通的变化持续更新。
- 窗口式流量控制
- 慢启动和拥塞避免
- 对于简单的请求-应答应用程序可以使用UDP,不过错误检测功能必须加到应用程序内部。
- 对于海量数据传输(例如文件传输)不应该使用UDP
2、给UDP应用增加可靠性
在客户程序中增加两个特性:
- 超时和重传:用于处理丢失的数据报
处理超时和重传的老式方法是先发送一个请求并等待N秒钟。如果期间没有收到应答,那就重新发送同一个请求并再等待N秒钟。如此发生一定次数后放弃发送。- 序列号:供客户验证一个应答是否匹配相应的请求
客户为每个请求冠以一个序列号,服务器必须在返送给客户的应答中回射这个序列号。
图:22-5
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<fcntl.h> #include<sys/socket.h> #include<sys/types.h> #include<sys/select.h> #include<sys/time.h> #include<netinet/in.h> #include<setjmp.h> #include<errno.h> #include<signal.h> #define SERV_PORT 51001 #define MAXLINE 4096 #define SA struct sockaddr char* Ip_address = "192.168.153.130"; struct rtt_info { float rtt_rtt; /* most recent measured RTT, in seconds */ float rtt_srtt; /* smoothed RTT estimator, in seconds */ float rtt_rttvar; /* smoothed mean deviation, in seconds */ float rtt_rto; /* current RTO to use, in seconds */ int rtt_nrexmt; /* times retransmitted: 0, 1, 2, ... */ uint32_t rtt_base; /* sec since 1/1/1970 at start */ }; #define RTT_RXTMIN 2 /* min retransmit timeout value, in seconds */ #define RTT_RXTMAX 60 /* max retransmit timeout value, in seconds */ #define RTT_MAXNREXMT 3 /* max times to retransmit */ /* * Calculate the RTO value based on current estimators: * smoothed RTT plus four times the deviation */ #define RTT_RTOCALC(ptr) ((ptr)->rtt_srtt + (4.0 * (ptr)->rtt_rttvar)) static struct rtt_info rttinfo; static int rttinit =0; static struct msghdr msgsend, msgrecv; static struct hdr { uint32_t seq; /* sequence */ uint32_t ts; /* timestamp when sent */ }sendhdr, recvhdr; static sigjmp_buf jmpbuf; int rtt_d_flag = 0; static float rtt_minmax(float rto) { if(rto < RTT_RXTMIN) { rto = RTT_RXTMIN; } else if(rto > RTT_RXTMAX) { rto = RTT_RXTMAX; } return(rto); } void rtt_init(struct rtt_info *ptr) { struct timeval tv; if(gettimeofday(&tv, NULL) == -1) { perror("Error: gettimeofday in rtt_init!\n"); } ptr->rtt_base = tv.tv_sec; ptr->rtt_rtt = 0; ptr->rtt_srtt = 0; ptr->rtt_rttvar = 0.75; ptr->rtt_rto = rtt_minmax(RTT_RTOCALC(ptr)); /* first RTO at (srtt + (4 * rttvar)) = 3 secounds */ } uint32_t rtt_ts(struct rtt_info *ptr) { uint32_t ts; struct timeval tv; if(gettimeofday(&tv, NULL) == -1) { perror("Error: gettimeofday in rtt_ts!\n"); } ts = ((tv.tv_sec - ptr->rtt_base) * 1000) + (tv.tv_usec /1000); return(ts); } void rtt_newpack(struct rtt_info *ptr) { ptr->rtt_nrexmt = 0; } int rtt_start(struct rtt_info *ptr) { return((int)(ptr->rtt_rto + 0.5)); /* round float ot int*/ /* return value can be used as: alarm(rtt_start(&foo)) */ } void rtt_stop(struct rtt_info *ptr, uint32_t ms) { double delta; ptr->rtt_rtt = ms / 1000.0; /* measured RTT in seconds*/ delta = ptr->rtt_rtt - ptr->rtt_srtt; ptr->rtt_srtt += delta / 8; /* g = 1/8*/ if(delta < 0.0) { delta = -delta; } ptr->rtt_rttvar += (delta - ptr->rtt_rttvar) /4; /* h = 1/4 */ ptr->rtt_rto = rtt_minmax(RTT_RTOCALC(ptr)); } int rtt_timeout(struct rtt_info *ptr) { ptr->rtt_rto *=2; /* next RTO */ if(++ptr->rtt_nrexmt > RTT_MAXNREXMT) { return -1; /* time to give up for this packet */ } return 0; } static void sig_alarm(int signo) { siglongjmp(jmpbuf, 1); } ssize_t dg_send_recv(int fd, const void *outbuff, size_t outbytes, void *inbuff, size_t inbytes, const SA *destaddr, socklen_t destlen) { ssize_t n; struct iovec iovsend[2], iovrecv[2]; if(rttinit == 0) { rtt_init(&rttinfo); rttinit = 1; rtt_d_flag = 1; } sendhdr.seq++; msgsend.msg_name = destaddr; msgsend.msg_namelen = destlen; msgsend.msg_iov = iovsend; msgsend.msg_iovlen = 2; iovsend[0].iov_base = &sendhdr; iovsend[0].iov_len = sizeof(struct hdr); iovsend[1].iov_base = outbuff; iovsend[1].iov_len = outbytes; msgrecv.msg_name = NULL; msgrecv.msg_namelen = 0; msgrecv.msg_iov = iovrecv; msgrecv.msg_iovlen = 2; iovrecv[0].iov_base = &recvhdr; iovrecv[0].iov_len = sizeof(struct hdr); iovrecv[1].iov_base = inbuff; iovrecv[1].iov_len = inbytes; if(signal(SIGALRM, sig_alarm) == SIG_ERR) { perror("Error: signal\n"); return; } rtt_newpack(&rttinfo); /* iinitialize for this packet */ sendagain: sendhdr.ts = rtt_ts(&rttinfo); sendmsg(fd, &msgsend, 0); alarm(rtt_start(&rttinfo)); /* calc timeout value & start timer */ if (sigsetjmp(jmpbuf, 1) !=0 ) { if ( rtt_timeout(&rttinfo) < 0 ) { printf("dg_send_recv: no response from server, giving up"); rttinit = 0; /* reinit in case we're called again */ errno = ETIMEDOUT; return(-1); } goto sendagain; } do { n = recvmsg(fd, &msgrecv, 0); } while (n < sizeof(struct hdr) || recvhdr.seq != sendhdr.seq ); alarm(0); /* calculate & store new RTT estimator values */ rtt_stop(&rttinfo, rtt_ts(&rttinfo) - recvhdr.ts); return(n -sizeof(struct hdr)); /* return size of received datagram */ } void dg_cli( FILE *fp, int socket_fd, const SA *server_addr, socklen_t server_len) { int n; char send_line[MAXLINE], recv_line[MAXLINE + 1]; while(fgets(send_line, MAXLINE, fp) != NULL) { n = dg_send_recv(socket_fd, send_line, strlen(send_line), recv_line, MAXLINE, server_addr, server_len); recv_line[n] = 0; fputs(recv_line, stdout); } } int main() { int socket_fd, connect_rt; struct sockaddr_in server_addr; bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(SERV_PORT); inet_pton(AF_INET, Ip_address, &server_addr.sin_addr); socket_fd = socket(AF_INET, SOCK_DGRAM, 0); if(socket_fd == -1) { perror("Error: created socket!\n"); exit(1); } dg_cli(stdin, socket_fd, (SA *)&server_addr, sizeof(server_addr)); exit(0); }
3、并发UDP服务器
对于UDP, 我们必须应对两种不同类型的服务器:
(1) 读入一个客户请求并发送一个应答后,与这个客户就不再相关了。这种情况下,读入客户请求的服务器可以fork一个子进程并让子进程去处理该请求。
(2) UDP服务器与客户交互多个数据报。问题是客户知道的服务器端口号只有服务器的一个荣所周知端口。一个客户发送其请求的第一个数据报到这个端口,但是服务器如何区分这是来自该客户同一个请求的后续数据报还是来自其他客户请求的数据报呢?这个问题典型的解决办法是让服务器为每个客户创建一个新的套接字,在其上bind一个临时端口,然后使用该套接字发送对该客户的所有应答。这个办法要求客户查看服务器第一个应答中的源端口号,并把本请求的后续数据报发送到该端口。
图22-19
四、 信号驱动式I/O
信号驱动式I/O是指进程预先告之内核,使得当某个描述符上发生某事时,内和使用信号通知相关进程。信号驱动式I/O不是真正的异步I/O, 非阻塞式I/O同样不是异步I/O
1、针对一个套接字使用信号驱动式I/O要求进程执行以下3个步骤:
- 建立SIGIO信号的信号处理函数。
- 设置该套接字的属主,通常使用fcntl的F_SETOWN命令设置
- 开启改套接字的信号驱动式I/O, 通常通过使用fcntl的F_SETFL命令打开O_ASYNC标志完成。
2、对于UDP套接字的SIGIO信号
SIGIO信号在发生以下事件时产生:
- 数据报到达套接字;
- 套接字上发生异步错误;
因此当捕获对于某个UDP套接字的SIGIO信号时,我们调用recvfrom或者读入到达的数据报,或者获取发生的异步错误
3、对于TCP套接字的SIGIO信号
不幸的是,信号驱动式I/O对于TCP套接字近乎无用。问题在于该信号产生得过于频繁,并且它的出现并没有告诉我们发生了什么事件。
4、使用SIGIO的UDP回射服务器程序
相关推荐
### 带有ENC28J60驱动的BSD套接字API的Microchip TCP/IP栈 #### 引言 带有伯克利套接字版(BSD)套接字API的Microchip TCP/IP栈为互联网TCP/IP通信提供了一个强大的套接字库。这种通用的套接字编程接口最初由位于...
内容概要:本文详细阐述了C++类的构造与析构机制,解释了这两种特殊成员函数的工作原理和应用场景,涵盖构造函数的特点、分类与调用方式、构造函数初始化列表、以及析构函数的作用、调用时机和注意事项。文中还探讨了在C++编程中如何运用这些机制实现高效的资源管理和内存安全,特别是遵循RAII原则、避免常见错误(如资源未释放、重复析构、异常安全问题)、并在多线程环境中合理处理同步操作。 适合人群:具有基础C++编程技能的程序员,尤其是希望深入了解对象生命周期管理和高级资源管理技术的人群。 使用场景及目标:①理解和应用C++类的构造与析构机制来编写高效的代码;②预防和修复由于资源管理不当引发的各种错误和性能问题;③提高对面向对象编程的理解,掌握在多线程环境下的资源管理技巧。 其他说明:通过实际案例深入分析C++中构造函数和析构函数的应用,强调RAII(Resource Acquisition Is Initialization)原则的重要性。同时也提及了未来学习方向如智能指针和移动语义等内容,帮助开发者更好地掌握C++编程技巧。
本文为抛砖引玉:简单描述,如需根据自身业务详细设计,请随时联系
百合检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx
最新PHP盲盒商城系统源码ThinkPHP框架
奇异值分解(Singular Value Decomposition,简称SVD)是线性代数中的一种重要矩阵分解方法,广泛应用于数据处理和信号分析。在本场景中,我们关注的是如何利用SVD来确定VMD(Variable Modulation Decomposition,可变调制分解)的K值。VMD是一种信号分解技术,它能够将复杂信号分解为一系列调制频率成分,对于非平稳信号的分析和处理非常有用。 理解SVD的基本概念:任何m×n的实数或复数矩阵A都可以表示为三个矩阵的乘积,即A=UΣV^T,其中U是m×m的正交矩阵,Σ是一个m×n的对角矩阵,其对角线元素是奇异值,V是n×n的正交矩阵。奇异值σ_i按照非降序排列,它们反映了矩阵A的信息量和重要性。 在VMD中,奇异值分解的作用在于识别信号的不同频率成分。当对信号进行VMD时,目标是找到最佳的K值,以使分解后的子带信号尽可能独立且无交叉。K值代表了分解得到的调制模式数量,每个模式对应一个特定的频率范围。 为了确定K值,我们需要分析SVD的结果,即奇异值的分布。奇异值的大小反映了原始信号的结构信息。通常,信号中的主要成分对应较大的奇异值,而噪声或不重要的成分对应较小的奇异值。因此,奇异值的下降趋势可以作为判断信号成分变化的一个指标。 通过绘制奇异值的累积贡献率曲线,我们可以观察到奇异值的显著下降点,这个点通常对应着信号主要成分的结束,后续的奇异值可以视为噪声或次要成分。这个显著下降点即为选择K值的依据。一般来说,选择奇异值曲线出现“转折”或者“平台”的位置作为K值,可以确保主要信号成分被保留,同时尽可能减少噪声的影响。 具体实现步骤如下: 1. 对信号进行SVD,得到奇异值序列。 2. 计算奇异值的累积贡献率,即将奇异值按降序排列后,每个奇异值除以所有奇异值的和,然后累加。 3. 绘制累积贡献率曲线,并寻找曲线的转折点或者平台区。 4. 将转折点对应的奇异值个数作为VMD的K值。 在实际应用中,确定K值还可以结合其他准则,如信息熵、能量集中度等,以确保分解的合理性和稳定性。此外,不同的信号和应用场景可能需要调整K值的选择策略,这需要根据具体问题进行细致的研究和实验验证。 总结来说,利用SVD确定VMD的K值是通过对奇异值分布的分析,找出信号主要成分与噪声之间的界限,从而选择一个合适的分解模式数量。这种方法有助于提取信号的关键特征,提高VMD分解的效率和准确性。。内容来源于网络分享,如有侵权请联系我删除。
常用护理技术操作规程49项.docx
局部阴影遮挡,灰狼MPPT,灰狼算法 灰狼算法实现部分遮阴的MPPT跟踪,包括光照突变情况,包括灰狼算法程序和matlab simulink模型的搭建,功率,电压,电流波形图和占空比波形图入如下。 ,局部阴影遮挡; 灰狼MPPT; 灰狼算法; 光照突变; 波形图; 程序搭建; matlab simulink模型,灰狼算法MPPT跟踪,局部遮阴及突变情况研究
XCP或者CCP标定,A2L标定文件,基于map文件自动更新A2L的地址和结构体变量的地址 源码基于C#需要开发,编译器为VS2022 ,XCP/CCP标定; A2L标定文件; 地图文件自动更新; C#开发; VS2022编译器,基于C#开发的XCP/CCP标定系统,自动更新A2L文件地址与结构体变量
给那些修改kof的玩家用的工具,简单快捷方便,需要自取
s10207-024-00818-y.pdf
Screenshot_20250314_152955.jpg
内容概要:本文档详细介绍了 FactSet 公司推出的 Truvalue V3 平台的内容采集与处理流程及其评分方法。FactSet 利用人工智能技术和语义大数据处理能力收集并解析每日超过4000万份来自20多万信源的全球ESG相关信息。通过对这些非结构化文本数据的深度剖析,Truvalue平台能够识别关键ESG主题并量化情绪倾向度。它不仅提供单篇文章层面的情绪打分(从最消极0到最积极100),而且还综合评估公司长期发展趋势以及短期市场表现。此外,还讨论了动态重要性和重点事件检测等特征,使分析师更容易捕捉到企业活动背后的潜在机会与风险。 适用人群:金融行业从业者如投资顾问、基金经理以及其他关注企业可持续发展和社会责任的专业人士。 使用场景及目标:为投资者提供精准的数据支持以进行资产配置决策;辅助研究员对特定企业或行业的深度调研工作。 其他说明:本方法论特别强调采用SASB标准作为评价基准之一,并解释了几种重要的得分计算公式,如脉搏分数、洞察力分数及时势动量指标等的具体运作机制。同时概述了一些质量控制措施以确保所提供数据的有效性和准确性。
毕业设计&课程设计 基于STM32单片机的物联网智能家庭安防系统(软件源码+硬件资料+部署教程+设计任务书+演示视频),高分项目,开箱即用 随着公众安全意识的提高,人们对家庭安全防控的需求愈发迫切,如何合理应用控制、通信及监控等自动化技术手段,打造智能化家庭安防系统成为研究重点。因此提出了基于物联网的家庭安防系统,实现监测燃气泄漏并报警、监测火灾烟雾并报警、检测非法入室并报警等功能,极大保障家庭居住场所的安全性。 用STM32单片机开发: 1、监测燃气泄漏(MQ-5)、监测火灾烟雾(DS18B20、MO-7)、检测非法入室(红外对管) 2、液晶显示燃气浓度、烟雾浓度、温度、是否有人闯入、布防状态 3、按键可以设置燃气、烟雾、温度的报警值,大于时候开启蜂鸣器报警以及对应的报警指示灯 4、当系统开启布防,有人闯入,开启蜂鸣器报警以及对应指示灯,撤防时,不检测非法闯入 5、数据通过wIFI上传到手机端 6、当报警时候发送报警短信,短信包含触发报警的情况:如燃气报警发送:gas leakage 温度或者烟雾报警发送:fire smoke alarm 非法入室发送:Illegal Entry
白胡椒检验表格(食品香辛料质量验收记录表)检验表格(食品香辛料质量验收记录表).docx
矢量边界,行政区域边界,精确到乡镇街道,可直接导入arcgis使用
c++多媒体音视频播放器
Adobe After Effects 全套插件安装包
Flac3d函数形式的应力边界施加编程 flac3d应力边界编程处理 本为本人做的简单案例:针对立方体模型,同时考虑重力和一侧应力边界对模型应力分布进行分析。 特色:应力函数可以任意改变,调节简单快捷 代码请前咨询了解清楚,不支持 款 针对地应力反演、走滑断层等分析中的应力边界位移边界问题如有需求定制 ,Flac3d;应力边界施加;编程处理;立方体模型;重力影响;应力分布分析;函数形式应力边界;地应力反演;走滑断层;位移边界问题。,Flac3d编程:应力边界施加的简易案例分析
基于matlab的凝土随机球形骨料球体蒙特卡洛随机分布模型 三种粒径不同的骨料随机分布 模拟混凝土材料的过程,粒径可自行定义,可设置孔隙率 动画显示建模过程 程序已调通,可直接运行 ,基于Matlab; 凝土随机球形骨料; 球体蒙特卡洛随机分布模型; 不同粒径骨料随机分布; 模拟混凝土材料; 粒径可定义; 孔隙率可设置; 动画显示建模过程; 程序已调通。,基于Matlab的混凝土骨料随机分布模拟程序