简说TCP通信非阻塞接收(附代码例子)

嵌入式大杂烩 2022-06-28 21:30

大家好,我是LinuxZn。

上一篇文章TCP server如何与多个client通信?(附代码)的TCP通信的数据接收中,我们使用了我们封装的接口之一的:

int tcp_blocking_recv(int conn_sockfd, void *rx_buf, uint16_t buf_len);

这是一个数据接收函数,但其是 阻塞方式(block) 的。

阻塞就是进程或是线程执行到这些函数时必须等待某个事件的发生,如果事件没有发生,进程或线程就被阻塞,函数不能立即返回。

比如,在这个例子中,假如我们把tcp_blocking_recv函数在tcp_send函数之前调用的(这里只是为了举例子说明才这么改,实际并不会这么写):

从标准输入中输入数据时,是没办法发送出去的,因为这时候程序被阻塞在第21行了,只有收到数据之后,程序才会往下走。

下面我们调用 非阻塞方式(non-block) 的接收接口改写上一篇文章的代码:

非阻塞就是进程或线程执行此函数时不必非要等待事件的发生,一旦执行肯定返回,以返回值的不同来反映函数的执行情况,如果事件发生则与阻塞方式相同,若事件没有发生则返回一个代码来告知事件未发生,而进程或线程继续执行,所以效率较高。

我们先来简单看看tcp_nonblocking_recv函数的实现:

其中,用到了select函数。select函数位于头文件sys/select.h中 。该函数 用于监视文件描述符的变化情况 ——读写或是异常。

select函数简介

select函数原型:

int select(int maxfdp,
          fd_set *readfds,
          fd_set *writefds,
          fd_set *errorfds,
          struct timeval *timeout)
;

其中:

  • fd_set:为一个集合,这个集合中存放的是文件描述符,典型是一个整数数组数组),其中每个整数中的每一位对应一个描述字。假设使用32位整数,那么该数组的第一个元素对应于描述字0~31,第二个元素对应于描述字32~63。
  • maxfdp:一个整数值,是指集合中所有文件描述符的范围,即 所有文件描述符的最大值加1
  • readfds:指向fd_set结构的指针。监视这些文件描述符的读变化的, 即我们关心是否可以从这些文件中读取数据 。如果这个集合中有一个文件可读,select就会返回一个大于0的值,表示有文件可读,如果没有可读的文件,则根据timeout参数再判断是否超时,若超出timeout的时间,select返回0,若发生错误返回负值。可以传入NULL值,表示不关心任何文件的读变化。
  • writefds:指向fd_set结构的指针。监视这些文件描述符的写变化的, 即我们关心是否可以从这些文件中写入数据 。如果这个集合中有一个文件可写,select就会返回一个大于0的值,表示有文件可写,如果没有可写的文件,则根据timeout参数再判断是否超时,若超出timeout的时间,select返回0,若发生错误返回负值。可以传入NULL值,表示不关心任何文件的写变化。
  • errorfds:同上面两个参数的意图,用来监视文件错误异常。
  • timeout:select的超时时间。struct timeval结构:
struct timeval
{

    long tv_sec; // seconds
    long tv_usec; // microseconds
}

它可以使select处于三种状态:

第一,若将NULL以形参传入,即不传入时间结构,就是将select置于 阻塞状态 ,一定等到监视文件描述符集合中某个文件描述符发生变化为止;

第二,若将时间值设为0秒0毫秒,就变成一个纯粹的 非阻塞函数 ,不管文件描述符是否有变化,都立刻返回继续执行,文件无变化返回0,有变化返回一个正值;

第三,timeout的值大于0,这就是等待的超时时间,即 select在timeout时间内阻塞 ,超时时间之内有事件到来就返回了,否则在超时后不管怎样一定返回,返回值同上述。

  • 返回值:负值,select错误;正值,某些文件可读写或出错;0,等待超时,没有可读写或错误的文件。

操作fd_set的几个宏:

void FD_ZERO (fd_set *fdset)// 清除fdset中的所有位
void FD_SET (int fd,fd_set *fdset)// 设置fdset中的某一位
void FD_CLR (int fd,fd_set *fdset)// 清除fdset中的某一位
int FD_ISSET(int fd,fd_set *fdset)// 判断fdset中的某一位是否置位

在tcp_nonblocking_recv函数里,select监视当前正在连接的conn_sockfd是否发生变化,如果发生读变化,我们就可以从conn_sockfd中读取数据。

实例:non-block接收

我们把上一篇文章TCP server如何与多个client通信?(附代码)中的代码拿来修改,改为non-block的方式接收数据。

tcp_server.c:

左右滑动查看全部代码>>>

#include 
#include "tcp_socket.h"

static pthread_t cli_data_proce_thread_tid;

static void *process_client_data(void *arg)
{
    int client_fd = *(int*)arg;

    while (1)
    {
        char buf[128] = {0};
        
        int recv_len = tcp_nonblocking_recv(client_fd, 
                                            buf, 
                                            sizeof(buf), 
                                            1
                                            0);
        if (recv_len <= 0)
        {
            continue;
        }
        else
        {
            printf("client_fd = %d, recv : %s\n", client_fd, buf);
            int send_len = tcp_send(client_fd, buf, strlen(buf));
            if (send_len <= 0)
            {
                printf("send error!\n");
                tcp_close(client_fd);
                return NULL;
            }
            else
            {
                printf("send success! send: %s, send_len: %d\n", buf, send_len);
            }
        }
        
        usleep(10 * 1000);
    }
}

int main(int argc, char **argv)
{
    printf("==================tcp server==================\n");
    int server_fd = tcp_init(NULL4321);

    while (1)
    {
        int new_fd = tcp_accept(server_fd);

        // 创建客户端数据处理线程
        int ret = pthread_create(&cli_data_proce_thread_tid, NULL, process_client_data, (void*)&new_fd);
        if(ret != 0)
        {
            perror("pthread_create");
            exit(EXIT_FAILURE);
        }
    }

    tcp_close(server_fd);

    return 0;
}

tcp_client.c:

左右滑动查看全部代码>>>

#include "tcp_socket.h"

int main(int argc, char **argv)
{
    printf("==================tcp cient==================\n");

    int server_fd = tcp_connect("192.168.1.107"4321);
    if (server_fd < 0)
    {
        printf("tcp_connect error!\n");
        exit(EXIT_FAILURE);
    }

    while (1)
    {
        char send_buf[128] = {0};
        char recv_buf[128] = {0};
        if (scanf("%s", send_buf))
        {
            int send_len = tcp_send(server_fd, send_buf, strlen(send_buf));
            if (send_len <= 0)
            {
                printf("tcp_send error!\n");
                tcp_close(server_fd);
                exit(EXIT_FAILURE);  
            }
            else
            {
                printf("send success! send: %s, send_len: %d\n", send_buf, send_len);
            }

            bzero(recv_buf, sizeof(recv_buf));
            int recv_len = tcp_nonblocking_recv(server_fd, 
                                                recv_buf, 
                                                sizeof(recv_buf), 
                                                1
                                                0);
            if (recv_len > 0)
            {
                printf("recv : %s\n", recv_buf);
            } 
        } 
    }

    return 0;
}

运行:

本次的完整demo代码可在本公众号后台回复关键词:tcp_socket_nonblock ,进行获取。

如果觉得文章不错,麻烦帮忙点赞、转发,谢谢!

往期推荐:

Hello系列 | cmake简明基础知识

TCP server如何与多个client通信?(附代码)

TCP常用应用接口的使用封装

Linux命令行万能解压命令

分享几个工作中用到的shell脚本

分享一个轻量级跨平台构建工具!

分享一个程序员必备的知识库系统!

Hello系列 | Shell编程必备简明基础知识

Hello系列 | 静态、动态链接简明知识

在公众号聊天界面回复1024,可获取Linux资源

嵌入式大杂烩 专注于嵌入式技术,包括但不限于C/C++、嵌入式、物联网、Linux等编程学习笔记,同时,内包含大量的学习资源。欢迎关注,一同交流学习,共同进步!
评论
  • 应用环境与极具挑战性的测试需求在服务器制造领域里,系统整合测试(System Integration Test;SIT)是确保产品质量和性能的关键步骤。随着服务器系统的复杂性不断提升,包括:多种硬件组件、操作系统、虚拟化平台以及各种应用程序和服务的整合,服务器制造商面临着更有挑战性的测试需求。这些挑战主要体现在以下五个方面:1. 硬件和软件的高度整合:现代服务器通常包括多个处理器、内存模块、储存设备和网络接口。这些硬件组件必须与操作系统及应用软件无缝整合。SIT测试可以帮助制造商确保这些不同组件
    百佳泰测试实验室 2024-12-12 17:45 39浏览
  • 铁氧体芯片是一种基于铁氧体磁性材料制成的芯片,在通信、传感器、储能等领域有着广泛的应用。铁氧体磁性材料能够通过外加磁场调控其导电性质和反射性质,因此在信号处理和传感器技术方面有着独特的优势。以下是对半导体划片机在铁氧体划切领域应用的详细阐述: 一、半导体划片机的工作原理与特点半导体划片机是一种使用刀片或通过激光等方式高精度切割被加工物的装置,是半导体后道封测中晶圆切割和WLP切割环节的关键设备。它结合了水气电、空气静压高速主轴、精密机械传动、传感器及自动化控制等先进技术,具有高精度、高
    博捷芯划片机 2024-12-12 09:16 82浏览
  • 习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习笔记&记录学习习笔记&记学习学习笔记&记录学习学习笔记&记录学习习笔记&记录学习学习笔记&记录学习学习笔记记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记
    youyeye 2024-12-11 17:58 83浏览
  • 时源芯微——RE超标整机定位与解决详细流程一、 初步测量与问题确认使用专业的电磁辐射测量设备,对整机的辐射发射进行精确测量。确认是否存在RE超标问题,并记录超标频段和幅度。二、电缆检查与处理若存在信号电缆:步骤一:拔掉所有信号电缆,仅保留电源线,再次测量整机的辐射发射。若测量合格:判定问题出在信号电缆上,可能是电缆的共模电流导致。逐一连接信号电缆,每次连接后测量,定位具体哪根电缆或接口导致超标。对问题电缆进行处理,如加共模扼流圈、滤波器,或优化电缆布局和屏蔽。重新连接所有电缆,再次测量
    时源芯微 2024-12-11 17:11 109浏览
  • 习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习笔记&记录学习习笔记&记学习学习笔记&记录学习学习笔记&记录学习习笔记&记录学习学习笔记&记录学习学习笔记记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记录学习学习笔记&记
    youyeye 2024-12-12 10:13 31浏览
  • 一、SAE J1939协议概述SAE J1939协议是由美国汽车工程师协会(SAE,Society of Automotive Engineers)定义的一种用于重型车辆和工业设备中的通信协议,主要应用于车辆和设备之间的实时数据交换。J1939基于CAN(Controller Area Network)总线技术,使用29bit的扩展标识符和扩展数据帧,CAN通信速率为250Kbps,用于车载电子控制单元(ECU)之间的通信和控制。小北同学在之前也对J1939协议做过扫盲科普【科普系列】SAE J
    北汇信息 2024-12-11 15:45 110浏览
  • 全球智能电视时代来临这年头若是消费者想随意地从各个通路中选购电视时,不难发现目前市场上的产品都已是具有智能联网功能的智能电视了,可以宣告智能电视的普及时代已到临!Google从2021年开始大力推广Google TV(即原Android TV的升级版),其他各大品牌商也都跟进推出搭载Google TV操作系统的机种,除了Google TV外,LG、Samsung、Panasonic等大厂牌也开发出自家的智能电视平台,可以看出各家业者都一致地看好这块大饼。智能电视的Wi-Fi连线怎么消失了?智能电
    百佳泰测试实验室 2024-12-12 17:33 46浏览
  • 在智能化技术快速发展当下,图像数据的采集与处理逐渐成为自动驾驶、工业等领域的一项关键技术。高质量的图像数据采集与算法集成测试都是确保系统性能和可靠性的关键。随着技术的不断进步,对于图像数据的采集、处理和分析的需求日益增长,这不仅要求我们拥有高性能的相机硬件,还要求我们能够高效地集成和测试各种算法。我们探索了一种多源相机数据采集与算法集成测试方案,能够满足不同应用场景下对图像采集和算法测试的多样化需求,确保数据的准确性和算法的有效性。一、相机组成相机一般由镜头(Lens),图像传感器(Image
    康谋 2024-12-12 09:45 74浏览
  • 本文介绍瑞芯微RK3588主板/开发板Android12系统下,APK签名文件生成方法。触觉智能EVB3588开发板演示,搭载了瑞芯微RK3588芯片,该开发板是核心板加底板设计,音视频接口、通信接口等各类接口一应俱全,可帮助企业提高产品开发效率,缩短上市时间,降低成本和设计风险。工具准备下载Keytool-ImportKeyPair工具在源码:build/target/product/security/系统初始签名文件目录中,将以下三个文件拷贝出来:platform.pem;platform.
    Industio_触觉智能 2024-12-12 10:27 43浏览
  • 首先在gitee上打个广告:ad5d2f3b647444a88b6f7f9555fd681f.mp4 · 丙丁先生/香河英茂工作室中国 - Gitee.com丙丁先生 (mr-bingding) - Gitee.com2024年对我来说是充满挑战和机遇的一年。在这一年里,我不仅进行了多个开发板的测评,还尝试了多种不同的项目和技术。今天,我想分享一下这一年的故事,希望能给大家带来一些启发和乐趣。 年初的时候,我开始对各种开发板进行测评。从STM32WBA55CG到瑞萨、平头哥和平海的开发板,我都
    丙丁先生 2024-12-11 20:14 68浏览
我要评论
0
点击右上角,分享到朋友圈 我知道啦
请使用浏览器分享功能 我知道啦