百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

socket网络编程中,阻塞和非阻塞是什么?它们区别是什么?附代码

bigegpt 2024-09-09 01:25 6 浏览

在TCP Socket网络编程中,接收和发送的阻塞和非阻塞是指调用相应的接收和发送函数时,该函数在什么条件下会立即返回。

  • 阻塞:

当调用阻塞式接收函数时,如果当前没有数据可用,函数会一直等待,直到有数据可用为止。类似地,当调用阻塞式发送函数时,如果发送缓冲区已满,函数会一直等待,直到缓冲区中有足够的空间来存储要发送的数据。

  • 非阻塞:

当调用非阻塞式接收函数时,如果当前没有数据可用,函数会立即返回,返回值为0或错误码,应用程序需要不断调用该函数来检查是否有新数据到达。类似地,当调用非阻塞式发送函数时,如果发送缓冲区已满,函数会立即返回,返回值为0或错误码,应用程序需要不断调用该函数来检查缓冲区是否有足够的空间来存储要发送的数据。

阻塞和非阻塞的主要区别在于函数的调用方式和返回值,阻塞函数会一直等待,直到满足条件才会返回,而非阻塞函数会立即返回,无论条件是否满足。阻塞函数通常会使应用程序挂起,等待数据可用或缓冲区可用,而非阻塞函数则允许应用程序在等待数据到达的同时继续执行其他任务。

下面是使用阻塞和非阻塞方式发送和接收数据的代码示例:

阻塞模式:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
  
int main() {
  int sockfd;
  char buf[1024];
  struct sockaddr_in server_addr;
  // 创建socket
  sockfd = socket(AF_INET, SOCK_STREAM, 0);
  if (sockfd == -1) {
    perror("socket");
    exit(EXIT_FAILURE);
  }
  
  // 设置server地址
  memset(&server_addr, 0, sizeof(server_addr));
  server_addr.sin_family = AF_INET;
  server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
  server_addr.sin_port = htons(8080);
  
  // 连接server
  if (connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
    perror("connect");
    exit(EXIT_FAILURE);
  }
  
  // 阻塞接收数据
  int ret = recv(sockfd, buf, sizeof(buf), 0);
  if (ret == -1) {
    perror("recv");
    exit(EXIT_FAILURE);
  }
  printf("Received: %s\n", buf);
  char *msg = "Hello, Server!";
  int len = strlen(msg);
  
  // 阻塞发送数据
  ret = send(sockfd, msg, len, 0);
  if (ret == -1) {
    perror("send");
    exit(EXIT_FAILURE);
  }
close(sockfd);
return 0;
}

非阻塞模式:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int main() {
    int sockfd;
    char buf[1024];
    struct sockaddr_in server_addr;

    // 创建socket
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }

    // 设置为非阻塞模式
    int flags = fcntl(sockfd, F_GETFL, 0);
    fcntl(sockfd, F_SETFL, flags | O_NONBLOCK);

    // 设置server地址
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    server_addr.sin_port = htons(8080);

    // 连接server
    int ret = connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));
    if (ret == -1 && errno != EINPROGRESS) {
        perror("connect");
        exit(EXIT_FAILURE);
    }

    // 等待连接完成
    fd_set write_set;
    FD_ZERO(&write_set);
    FD_SET(sockfd, &write_set);
    ret = select(sockfd + 1, NULL, &write_set, NULL, NULL);
    if (ret == -1) {
        perror("select");
        exit(EXIT_FAILURE);
    } else if (ret == 0) {
        printf("Connection timed out.\n");
        exit(EXIT_FAILURE);
    }

    // 非阻塞接收数据
    while (1) {
        ret = recv(sockfd, buf, sizeof(buf), 0);
		if (ret == -1) {
			if (errno == EAGAIN || errno == EWOULDBLOCK) {
				// 没有数据可读,等待一段时间再重试
				usleep(1000);
				continue;
			} else {
				perror("recv");
				exit(EXIT_FAILURE);
			}
		} else if (ret == 0) {
			printf("Server closed.\n");
			break;
		} else {
			buf[ret] = '\0';
			printf("Received: %s\n", buf);
			break;
		}
	}

	char *msg = "Hello, Server!";
	int len = strlen(msg);

	// 非阻塞发送数据
	int sent = 0;
	while (sent < len) {
		ret = send(sockfd, msg + sent, len - sent, 0);
		if (ret == -1) {
			if (errno == EAGAIN || errno == EWOULDBLOCK) {
				// 发送缓冲区已满,等待一段时间再重试
				usleep(1000);
				continue;
			} else {
				perror("send");
				exit(EXIT_FAILURE);
			}
		} else {
			sent += ret;
		}
	}

close(sockfd);
return 0;
}

上面的代码中,首先通过`fcntl`函数将socket设置为非阻塞模式。在非阻塞模式下,当调用`connect`函数时,连接操作会立即返回,无论连接是否成功。此时需要使用`select`函数来等待连接完成,然后才能进行数据通信。

在非阻塞模式下,当调用`recv`函数时,如果没有数据可读,该函数会立即返回,返回值为-1,同时设置`errno`为`EAGAIN`或`EWOULDBLOCK`。此时需要等待一段时间再重试。同样,当调用`send`函数时,如果发送缓冲区已满,该函数会立即返回,返回值为-1,同时设置`errno`为`EAGAIN`或`EWOULDBLOCK`。此时需要等待一段时间再重试,直到所有数据发送完毕。

注意:根据自己的需求进行略作修改。

相关推荐

Java 泛型大揭秘:类型参数、通配符与最佳实践

引言在编程世界中,代码的可重用性和可维护性是至关重要的。为了实现这些目标,Java5引入了一种名为泛型(Generics)的强大功能。本文将详细介绍Java泛型的概念、优势和局限性,以及如何在...

K8s 的标签与选择器:流畅运维的秘诀

在Kubernetes的世界里,**标签(Label)和选择器(Selector)**并不是最炫酷的技术,但却是贯穿整个集群管理与运维流程的核心机制。正是它们让复杂的资源调度、查询、自动化运维变得...

哈希Hash算法:原理、应用(哈希算法 知乎)

原作者:Linux教程,原文地址:「链接」什么是哈希算法?哈希算法(HashAlgorithm),又称为散列算法或杂凑算法,是一种将任意长度的数据输入转换为固定长度输出值的数学函数。其输出结果通常被...

C#学习:基于LLM的简历评估程序(c# 简历)

前言在pocketflow的例子中看到了一个基于LLM的简历评估程序的例子,感觉还挺好玩的,为了练习一下C#,我最近使用C#重写了一个。准备不同的简历:image-20250528183949844查...

55顺位,砍41+14+3!季后赛也成得分王,难道他也是一名球星?

雷霆队最不可思议的新星:一个55号秀的疯狂逆袭!你是不是也觉得NBA最底层的55号秀,就只能当饮水机管理员?今年的55号秀阿龙·威金斯恐怕要打破你的认知了!常规赛阶段,这位二轮秀就像开了窍的天才,直接...

5分钟读懂C#字典对象(c# 字典获取值)

什么是字典对象在C#中,使用Dictionary类来管理由键值对组成的集合,这类集合被称为字典。字典最大的特点就是能够根据键来快速查找集合中的值,其键的定义不能重复,具有唯一性,相当于数组索引值,字典...

c#窗体传值(c# 跨窗体传递数据)

在WinForm编程中我们经常需要进行俩个窗体间的传值。下面我给出了两种方法,来实现传值一、在输入数据的界面中定义一个属性,供接受数据的窗体使用1、子窗体usingSystem;usingSyst...

C#入门篇章—委托(c#委托的理解)

C#委托1.委托的定义和使用委托的作用:如果要把方法作为函数来进行传递的话,就要用到委托。委托是一个类型,这个类型可以赋值一个方法的引用。C#的委托通过delegate关键字来声明。声明委托的...

C#.NET in、out、ref详解(c#.net framework)

简介在C#中,in、ref和out是用于修改方法参数传递方式的关键字,它们决定了参数是按值传递还是按引用传递,以及参数是否必须在传递前初始化。基本语义对比修饰符传递方式可读写性必须初始化调用...

C#广义表(广义表headtail)

在C#中,广义表(GeneralizedList)是一种特殊的数据结构,它是线性表的推广。广义表可以包含单个元素(称为原子),也可以包含另一个广义表(称为子表)。以下是一个简单的C#广义表示例代...

「C#.NET 拾遗补漏」04:你必须知道的反射

阅读本文大概需要3分钟。通常,反射用于动态获取对象的类型、属性和方法等信息。今天带你玩转反射,来汇总一下反射的各种常见操作,捡漏看看有没有你不知道的。获取类型的成员Type类的GetMembe...

C#启动外部程序的问题(c#怎么启动)

IT&OT的深度融合是智能制造的基石。本公众号将聚焦于PLC编程与上位机开发。除理论知识外,也会结合我们团队在开发过程中遇到的具体问题介绍一些项目经验。在使用C#开发上位机时,有时会需要启动外部的一些...

全网最狠C#面试拷问:这20道题没答出来,别说你懂.NET!

在竞争激烈的C#开发岗位求职过程中,面试是必经的一道关卡。而一场高质量的面试,不仅能筛选出真正掌握C#和.NET技术精髓的人才,也能让求职者对自身技术水平有更清晰的认知。今天,就为大家精心准备了20道...

C#匿名方法(c#匿名方法与匿名类)

C#中的匿名方法是一种没有名称只有主体的方法,它提供了一种传递代码块作为委托参数的技术。以下是关于C#匿名方法的一些重要特点和用法:特点省略参数列表:使用匿名方法可省略参数列表,这意味着匿名方法...

C# Windows窗体(.Net Framework)知识总结

Windows窗体可大致分为Form窗体和MDI窗体,Form窗体没什么好细说的,知识点总结都在思维导图里面了,下文将围绕MDI窗体来讲述。MDI(MultipleDocumentInterfac...