linux send与recv函数详解------内附代码

2024-02-06 12:32

本文主要是介绍linux send与recv函数详解------内附代码,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

        转载地址: http://blog.csdn.net/sjin_1314/article/details/9565743

      

 

[csharp]  view plain  copy
  print ?
  1. 1 #include <sys/socket.h>  
  2. 2 ssize_t recv(int sockfd, void *buff, size_t nbytes, int flags);  
  3. 3 ssize_t send(int sockfd, const void *buff, size_t nbytes, int flags);  

 

 

recv 和send的前3个参数等同于read和write。

flags参数值为0或:

flags说明recvsend
 MSG_DONTROUTE绕过路由表查找    •
 MSG_DONTWAIT仅本操作非阻塞   •      •
 MSG_OOB    发送或接收带外数据  •  •
 MSG_PEEK  窥看外来消息  • 
 MSG_WAITALL  等待所有数据   • 

 1. send解析

 sockfd:指定发送端套接字描述符。

 buff:    存放要发送数据的缓冲区

 nbytes:  实际要改善的数据的字节数

 flags:   一般设置为0

 1) send先比较发送数据的长度nbytes和套接字sockfd的发送缓冲区的长度,如果nbytes > 套接字sockfd的发送缓冲区的长度, 该函数返回SOCKET_ERROR;

 2) 如果nbtyes <= 套接字sockfd的发送缓冲区的长度,那么send先检查协议是否正在发送sockfd的发送缓冲区中的数据,如果是就等待协议把数据发送完,如果协议还没有开始发送sockfd的发送缓冲区中的数据或者sockfd的发送缓冲区中没有数据,那么send就比较sockfd的发送缓冲区的剩余空间和nbytes

 3) 如果 nbytes > 套接字sockfd的发送缓冲区剩余空间的长度,send就一起等待协议把套接字sockfd的发送缓冲区中的数据发送完

 4) 如果 nbytes < 套接字sockfd的发送缓冲区剩余空间大小,send就仅仅把buf中的数据copy到剩余空间里(注意并不是send把套接字sockfd的发送缓冲区中的数据传到连接的另一端的,而是协议传送的,send仅仅是把buf中的数据copy到套接字sockfd的发送缓冲区的剩余空间里)。

 5) 如果send函数copy成功,就返回实际copy的字节数,如果send在copy数据时出现错误,那么send就返回SOCKET_ERROR; 如果在等待协议传送数据时网络断开,send函数也返回SOCKET_ERROR。

 6) send函数把buff中的数据成功copy到sockfd的改善缓冲区的剩余空间后它就返回了,但是此时这些数据并不一定马上被传到连接的另一端。如果协议在后续的传送过程中出现网络错误的话,那么下一个socket函数就会返回SOCKET_ERROR。(每一个除send的socket函数在执行的最开始总要先等待套接字的发送缓冲区中的数据被协议传递完毕才能继续,如果在等待时出现网络错误那么该socket函数就返回SOCKET_ERROR)

 7) 在unix系统下,如果send在等待协议传送数据时网络断开,调用send的进程会接收到一个SIGPIPE信号,进程对该信号的处理是进程终止。

2.recv函数

sockfd: 接收端套接字描述符

buff:   用来存放recv函数接收到的数据的缓冲区

nbytes: 指明buff的长度

flags:   一般置为0

 1) recv先等待s的发送缓冲区的数据被协议传送完毕,如果协议在传送sock的发送缓冲区中的数据时出现网络错误,那么recv函数返回SOCKET_ERROR

 2) 如果套接字sockfd的发送缓冲区中没有数据或者数据被协议成功发送完毕后,recv先检查套接字sockfd的接收缓冲区,如果sockfd的接收缓冲区中没有数据或者协议正在接收数据,那么recv就一起等待,直到把数据接收完毕。当协议把数据接收完毕,recv函数就把s的接收缓冲区中的数据copy到buff中(注意协议接收到的数据可能大于buff的长度,所以在这种情况下要调用几次recv函数才能把sockfd的接收缓冲区中的数据copy完。recv函数仅仅是copy数据,真正的接收数据是协议来完成的)

 3) recv函数返回其实际copy的字节数,如果recv在copy时出错,那么它返回SOCKET_ERROR。如果recv函数在等待协议接收数据时网络中断了,那么它返回0。

 4) 在unix系统下,如果recv函数在等待协议接收数据时网络断开了,那么调用 recv的进程会接收到一个SIGPIPE信号,进程对该信号的默认处理是进程终止。

 

下面是非阻塞模式下的安全读写

[csharp]  view plain  copy
  print ?
  1. static int tcpSockRead(int fd, void *buf, int nSize)  
  2. {  
  3.     int rleft = nSize;  
  4.     int rlen;  
  5.     char *ptr = (char *)buf;  
  6.     time_t start,end;  
  7.     time(&start);  
  8.   
  9.     while (rleft > 0) {   
  10.         if ((rlen = read(fd,ptr,rleft)) < 0) {  
  11.             if (errno == EINTR || errno == EWOULDBLOCK || errno == EAGAIN ) {  
  12.                 rlen = 0;  
  13.             }else{  
  14.                 //LogEvent(ANT_EVENT_INFO, "RTP Read error: %s\n", strerror(errno));  
  15.                 return -1;  
  16.             }  
  17.         } else if (rlen == 0){   
  18.             break;  
  19.         }  
  20.   
  21.         rleft -= rlen;  
  22.         ptr += rlen;  
  23.         time(&end);  
  24.         if(end-start >= 30){  
  25.             LogTcpRtp("###%s(),time is too long!\n",__FUNCTION__);  
  26.             return -1;  
  27.         }  
  28.     }  
  29.       
  30.     if (rleft > 0){  
  31.         return -1;  
  32.     }else{  
  33.         return 0;  
  34.     }   
  35. }  
  36.   
  37. static int tcpSockWrite(int fd, void *buf, int nSize)  
  38. {  
  39.     int wleft = nSize;  
  40.     int wlen;  
  41.     char *ptr = (char *)buf;  
  42.   
  43.     while (wleft > 0) {  
  44.         if ((wlen = write(fd, ptr, wleft)) <= 0) {  
  45.             if (wlen < 0 && (errno == EINTR || errno == EWOULDBLOCK || errno == EAGAIN)){  
  46.                 wlen = 0;  
  47.             }else{  
  48.                 //LogEvent(ANT_EVENT_INFO, "RTP write error: %s\n", strerror(errno));  
  49.                 return -1;  
  50.             }  
  51.         }   
  52.         wleft -= wlen;  
  53.         ptr += wlen;  
  54.     }  
  55.   
  56.     if (wleft > 0){  
  57.         return -1;         
  58.     }else{   
  59.         return 0;  
  60.     }  
  61. }  

errno  EINTR 、EWOULDBLOCK 、EAGAIN在errno.h文件中有详细的宏定义,可以参考百度百科。
EAGAIN 11    /* Try again */
EWOULDBLOCK  用于非阻塞模式,不需要重新读或者写(如何设置成非阻塞模式,这个必须要加,在测试中,经常会出现这个错误码!)
EINTR        表示由于信号中断,没写成功任何数据!

 

 

这篇关于linux send与recv函数详解------内附代码的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中,括号匹配是一个常见问题,尤其是在

Linux使用nload监控网络流量的方法

《Linux使用nload监控网络流量的方法》Linux中的nload命令是一个用于实时监控网络流量的工具,它提供了传入和传出流量的可视化表示,帮助用户一目了然地了解网络活动,本文给大家介绍了Linu... 目录简介安装示例用法基础用法指定网络接口限制显示特定流量类型指定刷新率设置流量速率的显示单位监控多个

Debezium 与 Apache Kafka 的集成方式步骤详解

《Debezium与ApacheKafka的集成方式步骤详解》本文详细介绍了如何将Debezium与ApacheKafka集成,包括集成概述、步骤、注意事项等,通过KafkaConnect,D... 目录一、集成概述二、集成步骤1. 准备 Kafka 环境2. 配置 Kafka Connect3. 安装 D

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》:本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程

ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法

《ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法》本文介绍了Elasticsearch的基本概念,包括文档和字段、索引和映射,还详细描述了如何通过Docker... 目录1、ElasticSearch概念2、ElasticSearch、Kibana和IK分词器部署

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

Linux流媒体服务器部署流程

《Linux流媒体服务器部署流程》文章详细介绍了流媒体服务器的部署步骤,包括更新系统、安装依赖组件、编译安装Nginx和RTMP模块、配置Nginx和FFmpeg,以及测试流媒体服务器的搭建... 目录流媒体服务器部署部署安装1.更新系统2.安装依赖组件3.解压4.编译安装(添加RTMP和openssl模块

Spring Cloud LoadBalancer 负载均衡详解

《SpringCloudLoadBalancer负载均衡详解》本文介绍了如何在SpringCloud中使用SpringCloudLoadBalancer实现客户端负载均衡,并详细讲解了轮询策略和... 目录1. 在 idea 上运行多个服务2. 问题引入3. 负载均衡4. Spring Cloud Load

linux下多个硬盘划分到同一挂载点问题

《linux下多个硬盘划分到同一挂载点问题》在Linux系统中,将多个硬盘划分到同一挂载点需要通过逻辑卷管理(LVM)来实现,首先,需要将物理存储设备(如硬盘分区)创建为物理卷,然后,将这些物理卷组成... 目录linux下多个硬盘划分到同一挂载点需要明确的几个概念硬盘插上默认的是非lvm总结Linux下多

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式:MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录