实现基于 TCP 的服务器端/客户端

2023-11-01

根据数据传输方式的不同,基于网络协议的套接字一般分为TCP套接字和UDP套接字。

因为TCP套接字是面向连接的,因此又称基于流(stream)的套接字。TCP 是 Transmission Control Protocol(传输控制协议)的简写,意为“对数据传输过程的控制”。

1.TCP服务器端的默认函数调用顺序

下图给出了TCP服务器端默认的函数调用顺序,绝大部分TCP服务器端都按照该顺序调用。

在这里插入图片描述

调用 socket 函数创建套接字,声明并初始化地址信息结构体变量;调用 bind 函数向套接字分配地址。这 2 2 2 个阶段之前都已讨论过,下面讲解之后的几个过程。

1.1 进入等待连接请求状态(listen 函数)

我们已调用 bind 函数给套接字分配了地址,接下来就要通过调用 listen 函数进入等待连接请求状态。只有调用了 listen 函数,客户端才能进入可发出连接请求的状态。换言之,这时客户端才能调用 connect 函数(若提前调用将发生错误)。

#include <sys/socket.h>

int listen(int sockfd, int backlog);

// 成功时返回0,失败时返回-1
// sockfd:希望进入等待连接请求状态的套接字文件描述符,传递的描述符套接字参数称为服务器端套接字(监听套接字)
// backlog:连接请求等待队列的长度,若为5,则队列长度为5,表示最多使5个连接请求进入队列

“服务器端处于等待连接请求状态”是指,客户端请求连接时,受理连接前一直使请求处于等待状态。下图给出了这个过程。

在这里插入图片描述

由上图可知作为 listen 函数的第一个参数传递的文件描述符套接字的用途。客户端连接请求本身也是从网络中接收到的一种数据,而要想接收就需要套接字。此任务就由服务器端套接字完成。服务器端套接字是接收连接请求的一名门卫或一扇门。

客户端如果向服务器端询问:“请问我是否可以发起连接?”服务器端套接字就会亲切应答:“您好!当然可以,但系统正忙,请到等候室排号等待,准备好后会立即受理您的连接。”同时将连接请求请到等候室。调用 listen 函数即可生成这种门卫(服务器端套接字),listen 函数的第二个参数决定了等候室的大小。等候室称为连接请求等待队列,准备好服务器端套接字和连接请求等待队列后,这种可接收连接请求的状态称为等待连接请求状态。

listen 函数的第二个参数值与服务器端的特性有关,像频繁接收请求的 Web 服务器端至少应为 15 15 15。另外,连接请求队列的大小始终根据实验结果而定。

1.2 受理客户端连接请求(accept 函数)

调用 listen 函数后,若有新的连接请求,则应按序受理。受理请求意味着进入可接受数据的状态。也许各位已经猜到进入这种状态所需部件,当然是套接字!大家可能认为可以使用服务器端套接字,但服务器端套接字是做门卫的。如果在与客户端的数据交换中使用门卫,那谁来守门呢?因此需要另外一个套接字,但没必要亲自创建。accept 函数将自动创建套接字,并连接到发起请求的客户端。

#include <sys/socket.h>

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

// 成功时返回创建的套接字文件描述符,失败时返回-1
// sockfd:服务器端套接字的文件描述符
// addr:保存发起连接请求的客户端地址信息的变量地址值,调用函数后向传递来的地址变量参数填充客户端地址信息
// addrlen:第二个参数addr结构体的长度,但是存有长度的变量地址。函数调用完成后,该变量即被填入客户端地址长度

accept 函数受理连接请求等待队列中待处理的客户端连接请求。函数调用成功时,accept 函数内部将产生用于数据 I/O 的套接字,并返回其文件描述符。需要强调的是,套接字是自动创建的,并自动与发起连接请求的客户端建立连接。下图展示了 accept 函数调用过程。

在这里插入图片描述

上图展示了“从等待队列中取出 1 1 1 个连接请求,创建套接字并完成连接请求”的过程。服务器端单独创建的套接字与客户端建立连接后进行数据交换。

1.3 回顾 HelloWorld 服务器端

下面分析之前未理解透的 HelloWorld 服务器端程序代码 hello_server.c。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

void error_handling(char *message);

int main(int argc, char *argv[])
{
	int serv_sock;
	int clnt_sock;

	struct sockaddr_in serv_addr;
	struct sockaddr_in clnt_addr;
	socklen_t clnt_addr_size;

	char message[] = "Hello World!";
	
	if (argc != 2)
	{
		printf("Usage : %s <port>\n", argv[0]);
		exit(1);
	}

	// 服务器端实现过程中先要创建套接字。第28行创建套接字,但此时的套接字尚非真正的服务器端套接字。
	serv_sock = socket(PF_INET, SOCK_STREAM, 0);
	
	if (serv_sock == -1)
	{
		error_handling("socket() error");
	}

	// 为了完成套接字地址分配,初始化结构体变量并调用bind函数。
	memset(&serv_addr, 0, sizeof(serv_addr));
	serv_addr.sin_family = AF_INET;
	serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
	serv_addr.sin_port = htons(atoi(argv[1]));

	if (bind(serv_sock, (struct sockaddr*) &serv_addr, sizeof(serv_addr)) == -1)
	{
		error_handling("bind() error");
	}

	// 调用listen函数进入等待连接请求状态。连接请求等待队列的长度设置为5。此时的套接字才是服务器端套接字。
	if (listen(serv_sock, 5) == -1)
	{
		error_handling("listen() error");
	}
	
	clnt_addr_size = sizeof(clnt_addr);
	
	// 调用accept函数从队头取1个连接请求与客户端建立连接,并返回创建的套接字文件描述符。
	// 另外,调用accept函数时若等待队列为空,则accept函数不会返回,直到队列中出现新的客户端连接。
	clnt_sock = accept(serv_sock, (struct sockaddr*) &clnt_addr, &clnt_addr_size);
	
	if (clnt_sock == -1)
	{
		error_handling("accept() error");
	}

	// 调用write函数向客户端传输数据,调用close函数关闭连接。
	write(clnt_sock, message, sizeof(message));

	close(clnt_sock);
	close(serv_sock);
	
	return 0;
}

void error_handling(char *message)
{
	fputs(message, stderr);
	fputc('\n', stderr);
	exit(1);
}

2.TCP客户端的默认函数调用顺序

接下来讲解客户端的实现顺序,这要比服务器端简单许多。因为创建套接字和请求连接就是客户端的全部内容,如下图所示。

在这里插入图片描述

2.1 发起连接请求(connect 函数)

与服务器端相比,区别就在于“请求连接”,它是创建客户端套接字后向服务器端发起的连接请求。服务器端调用 listen 函数后创建连接请求等待队列,之后客户端即可请求连接。那如何发起连接请求呢?通过调用 connect 函数完成。

#include <sys/socket.h>

int connect(int sockfd, struct sockaddr *servaddr, socklen_t addrlen);

// 成功时返回0,失败时返回-1
// sockfd:客户端套接字文件描述符
// servaddr:保存目标服务器端地址信息的变量地址值
// addrlen:以字节为单位传递已传递给第二个结构体参数servaddr的地址变量长度

客户端调用 connect 函数后,发生以下情况之一才会返回(完成函数调用):

  • 服务器端接收连接请求
  • 发生断网等异常情况而中断连接请求

需要注意,所谓的“接收连接”并不意味着服务器端调用 accept 函数,其实是服务器端把连接请求信息记录到等待队列。因此 connect 函数返回后并不立即进行数据交换。

问:客户端套接字地址信息在哪?

实现服务器端必经过程之一就是给套接字分配IP和端口号。但客户端实现过程中并未出现套接字地址分配,而是创建套接字后立即调用 connect 函数。难道客户端套接字无需分配IP和端口?

当然不是!网络数据交换必须分配IP和端口。

既然如此,那客户端套接字何时、何地、如何分配地址呢?

  • 何时?调用 connect 函数时。
  • 何地?操作系统,更准确地说是在内核中。
  • 如何?IP用计算机(主机)的IP,端口随机。

客户端的IP地址和端口在调用 connect 函数时自动分配,无需调用标记的 bind 函数进行分配。

2.2 回顾 HelloWorld 客户端

下面分析之前未理解透的 HelloWorld 客户端程序代码 hello_client.c。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

void error_handling(char *message);

int main(int argc, char* argv[])
{
	int sock;
	struct sockaddr_in serv_addr;
	char message[30];
	int str_len;
	
	if (argc != 3)
	{
		printf("Usage : %s <IP> <port>\n", argv[0]);
		exit(1);
	}
	
	// 创建准备连接服务器端的套接字,此时创建的是TCP套接字。
	sock = socket(PF_INET, SOCK_STREAM, 0);

	if (sock == -1)
	{
		error_handling("socket() error");
	}

	// 结构体变量serv_addr中初始化IP和端口信息。初始化值为目标服务器端套接字的IP和端口信息。
	memset(&serv_addr, 0, sizeof(serv_addr));
	serv_addr.sin_family = AF_INET;
	serv_addr.sin_addr.s_addr = inet_addr(argv[1]);
	serv_addr.sin_port = htons(atoi(argv[2]));

	// 调用connect函数向服务器端发送连接请求
	if (connect(sock, (struct sockaddr*) &serv_addr, sizeof(serv_addr)) == -1)
	{
		error_handling("connect() error!");
	}

	// 完成连接后,接收服务器端传输的数据
	str_len = read(sock, message, sizeof(message) - 1);
	
	if (str_len == -1)
	{
		error_handling("read() error!");
	}

	printf("Message from server: %s\n", message);

	// 接收数据后调用close函数关闭套接字,结束与服务器端的连接
	close(sock);

	return 0;
}

void error_handling(char *message)
{
	fputs(message, stderr);
	fputc('\n', stderr);
	exit(1);
}

3.基于TCP的服务器端和客户端函数调用关系

前面讲解了TCP服务器端和客户端的实现顺序,实际上二者并非相互独立,它们之间的交互过程如下图所示。

在这里插入图片描述

上图的总体流程整理如下:服务器端创建套接字后连续调用 bind、listen 函数进入等待状态,客户端通过调用 connect 函数发起连接请求。需要注意的是,客户端只能等到服务器端调用 listen 函数后才能调 connect 函数。同时要清楚,客户端调用 connect 函数前,服务器端有可能率先调用 accept 函数。当然,此时服务器端在调用 accept 函数时进入阻塞(blocking)状态,直到客户端调 connect 函数为止。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

实现基于 TCP 的服务器端/客户端 的相关文章

  • 访问 AWS 上的 Tensorboard

    我正在尝试访问 AWS 上的 Tensorboard 这是我的设置 张量板 tensorboard host 0 0 0 0 logdir train 在端口 6006 上启动 TensorBoard b 39 您可以导航到http 172
  • 当使用环回地址使用 TCP/IP 套接字进行 IPC 时,常见的网络堆栈是否会跳过将消息帧封装在较低级别的 PDU 中?

    在某些环境 例如 Java 中 很自然地使用 TCP IP 套接字通过 localhost 地址 IPv4 中的 127 0 0 1 或 IPv6 中的 1 在同一主机上的进程之间传递消息 因为Java倾向于不在其API中公开其他IPC机制
  • UWP 无法在两个应用程序之间创建本地主机连接

    我正在尝试在两个 UWP 应用程序之间设置 TCP 连接 当服务器和客户端在同一个应用程序中运行时 它可以正常工作 但是 当我将服务器部分移动到一个应用程序并将客户端部分移动到另一个应用程序时 ConnectAsync 会引发异常 服务器未
  • 如何抑制Windows防火墙的Windows安全警报?

    当我从这里找到的 ZeroMQ 指南中用 C 创建 Hello World 示例时 http zguide zeromq org page all Ask and Ye Shall Receive http zguide zeromq or
  • 谁在 Mac OS X 上监听给定的 TCP 端口?

    在Linux上 我可以使用netstat pntl grep PORT or fuser n tcp PORT找出哪个进程 PID 正在侦听指定的 TCP 端口 如何在 Mac OS X 上获得相同的信息 在 macOS 上Big Sur然
  • 了解 netty 通道缓冲区和水印

    我正在尝试了解网络缓冲区和水印 作为一个测试用例 我有一个 netty 服务器 它向客户端写入数据 客户端被阻止 基本上每次读取之间有 10 秒的睡眠时间 在正常 I O 下 如果接收方被阻塞 TCP 发送方将受到限制 由于流量控制 发送速
  • TCP打孔问题

    我尝试使用 Python 3 中概述的原则为防火墙编写一个基本的 TCP 打孔器本文 http www bford info pub net p2pnat index html 不过 我无法连接任何东西 这是代码 usr bin pytho
  • Java Servlet 中限制 HTTP 请求

    在 java servlet 中 如何根据客户端的 IP 地址限制来自用户的 http 请求 我不想每秒处理来自特定源 IP 地址的超过 X 个请求 其中 X 是可配置的并且具有 0 1 中的实际值 10 范围 从 10 秒内 1 个请求到
  • Docker 容器是否有自己的 TCP/IP 堆栈?

    我试图了解来自连接到主机的线路并定向到 Docker 容器内的应用程序的网络数据包在幕后发生了什么 如果它是一个经典的 VM 我知道到达主机的数据包将由虚拟机管理程序 例如 VMware VBox 等 传输到 VM 的虚拟 NIC 并从那里
  • 无法从亚马逊Windows实例的公共IP访问node.js服务器

    我正在 Windows 服务器的亚马逊微实例上运行 Node js 服务器 我无法使用亚马逊实例的公共IP访问node js服务器 我可以使用 localhost 12345 从实例访问 node js 服务器 但无法使用实例的公共 IP
  • 用 C 语言进行非阻塞 udp 套接字编程:我能得到什么?

    我在理解从非阻塞 UDP 套接字返回什么recv recvfrom 时遇到问题 与 TCP 相比更具体一点 如果我错了 请纠正我 阻塞套接字 TCP 或 UDP 在缓冲区中有一些数据之前不会从 recv 返回 这可以是一定数量的字节 TCP
  • Silverlight 套接字:模仿框架 Bind、Listen 和 Accept 方法?

    我有这个 NET Framework C 类 它实际上充当 TCP 连接的包装器Socket http msdn microsoft com en us library attbb8f5 aspxSystem Net Sockets 命名空
  • NodeJS:TCP套接字服务器仅在第一次返回数据

    我正在尝试在 node js 中编写一个小型中继脚本 用于侦听本地套接字上传入的 TCP 连接 当它收到连接时 将流量转发给第三方 它还必须从该第三方获取任何返回的数据并将其发送回原始本地套接字 我试过类似的代码http delog wor
  • 创建 ip 网络数据包 [关闭]

    很难说出这里问的是什么 这个问题是含糊的 模糊的 不完整的 过于宽泛的或修辞性的 无法以目前的形式得到合理的回答 如需帮助澄清此问题以便重新打开 访问帮助中心 help reopen questions 我必须使用任何协议手动创建自己的网络
  • python 中的原始套接字和 sendto

    我正在努力将 scapy 与twisted 集成 但我在 OSX 上遇到了这个非常奇怪的错误 我似乎无法弄清楚 基本上我无法通过原始套接字发送有效的 TCP 数据包 包括 IP 标头 这就是我正在做的 import socket from
  • 确定 TCP Listen() 队列中当前积压的连接数

    有没有办法找出currentLinux 上 TCP 套接字上等待 Accept 的连接尝试次数 我想我可以在每个事件循环上点击 EWOULDBLOCK 之前计算成功的 Accept 数量 但我使用的是隐藏这些细节的高级库 Python Tw
  • TCP 校验和可能无法检测到错误吗?如果是的话,这件事是如何处理的?

    如果 TCP 有效负载在传输过程中被损坏 则重新计算的校验和将与传输的校验和不匹配 太好了 到目前为止一切都很好 如果 TCP 校验和在传输过程中损坏 则重新计算的校验和将与现在损坏的校验和不匹配 太好了 到目前为止一切都很好 当有效负载和
  • 可以访问每个套接字的 TCP 统计数据/信息吗? (C/C++)

    我需要一些信息 例如我创建的特定 TCP 套接字发生的重新发送包 数据包丢失的数量 有人知道如何直接从我的 C C 程序访问或请求此类信息吗 也许是 Linux 特有的东西 或者我是否需要 作为解决方法 捕获和分析我自己的流量 提前致谢 通
  • PHP游戏服务器,多个TCP客户端?

    我正在制作一个基于网络浏览器的多人游戏 鉴于其实时性 我确定 Websocket 是处理通信的最佳方式 客户端使用 HTML5 画布来渲染游戏 并使用 Websocket 与主机进行通信 我选择使用 PHP 来托管游戏 因为托管提供商似乎更
  • Unix网络编程澄清

    我正在翻阅这本经典书籍Unix网络编程 https rads stackoverflow com amzn click com 0139498761 当我偶然发现这个程序时 第 6 8 节 第 179 180 页 include unp h

随机推荐

  • 9个用于本地存储的JavaScript库

    HTML5本地存储API Web存储的一部分 具有出色的浏览器支持 并且正在越来越多的应用程序中使用 它具有简单的API 当然也有其缺点 类似于cookie 在过去的一年左右的时间里 我遇到了许多使用localStorage API的工具和
  • Hadoop的一些问题

    关系数据库已经流行很多年 并且Hadoop已经有了HDFS和MapReduce 为什么需要HBase Hadoop可以很少地解决大规模数据的离线批量处理问题 但是 受限于hadoop MapReduce编程框架的高延迟数据处理机制 使得ha
  • https协议

    一 https的简介 HTTPS 全称 Hypertext Transfer Protocol Secure 是以安全为目标的 HTTP 通道 在HTTP的基础上通过传输加密和身份认证保证了传输过程的安全性 HTTPS 在HTTP 的基础下
  • Doris--基础--4.2--数据导入--Insert Into

    Doris 基础 4 2 数据导入 Insert Into 1 介绍 类似Mysql中的insert语句 方式 通过 insert into table select 的方式从Doris的表中读取数据并导入到另一张表中 通过 insert
  • Ubuntu 安装 .deb文件

    用法 dpkg 选项 lt 命令 gt 命令 i install deb 文件名 R recursive unpack deb 文件名 R recursive A record avail deb 文件名 R recursive confi
  • 游戏开发物理引擎PhysX研究系列:force值与mass值的关系

    参考 What is force mean in unity Unity Forum 结论 force mass gravity 由于精度问题 在unity中看到mass 100 constantforce的force的y 981 物体仍然
  • The endpoint reference (EPR) for the Operation not found 可能问题以及解决办法

    在调用webservice接口的时候一直报The endpoint reference EPR for the Operation not found这个错 最后在Stack Overflow上找到一个 说可能是content type的问
  • DCDC基础(10)-- BUCK电路的CCM和DCM模式

    欢迎关注我的微信公众号 射频工程师的日常 每天给你分享技术干货 以非同步BUCK为例 分享MPS关于开关电源CCM与DCM的培训内容 1 CCM模式 CCM Continuous Conduction Mode 连续导通模式 在一个开关周期
  • 最速曲线及应用

    一起来观赏一下数学之骚美 原文 https tieba baidu com p 3635683462 red tag 0223460281 这事儿和17世纪的一道谜题有关 直到后来微积分被建立起来以后才得正解 虽然问题不难 但结果惊艳 我先
  • 使用gcov和lcov测试代码覆盖率

    参考文章 gcov介绍 gcov是Linux下GCC自带的一个C C 代码覆盖率分析工具 因此只要安装了gcc 就不需要再次安装了 lcov介绍 gcov能够生成代码覆盖信息 但是不够直观 因此需要结合lcov gcovr等前端图形工具才能
  • 流氓ONU问题分析和处理

    1 流氓ONU问题分析和处理 1 1 故障现象描述 故障现象为 1 设备被判定为流氓ONU 2 同一PON口下其他设备都在反复掉线 只有这一台设备一直正常注册 3 设备下所有ONU都在反复上下线 上下线时间没有规律 4 只有几台设备能正常注
  • Windows系统提权姿势

    windows系统提权 权限提升简介 权限提升概述 什么是提权 提权分类 提权条件 Windows提权思路 Windows系统提权 Windows提权信息收集 WMIC信息收集 自动信息收集 提权工具脚本 环境搭建 提权 Windows内核
  • iOS11网络类型判断(iPhoneX获取网络类型闪退)

    简介 在之前的项目中 很多是使用导航栏中视图层 通过KVC来获取网络状态 感觉这个方法有些投机取巧 到了iOS11 iPhoneX的导航栏视图层也进行了修改 除了蛋疼的UI 在获取使用以前获取网络状态的方法时候 果然炸了 解决方案 可以使用
  • airpods固件更新方法_AirPods如何升级固件?AirPods更新固件方法教程

    AirPods如何升级固件呢 很多人对 AirPods 怎么升级固件这个问题都很困惑 在使用AirPods的过程中 有时候AirPods 自己突然就更新了最新固件 但当你想要它更新的时候 它却不能自己更新 对此 苹果也没有给出官方的说法 就
  • C语言简单编程题(素数,闰年,回文数)

    C语言简单编程 素数 闰年 回文数 习题 1 输入一个整数 判断这个数是否是素数 除1以外能只能被 1和它本身整除的自然数 include
  • java基础静态变量是什么?如何使用?

    1 定义 静态变量也叫做类变量 类属性 由static修饰的变量称为静态变量 其实质上就是一个全局变量 如果某个内容是被所有对象所共享 那么该内容就应该用静态修饰 没有被静态修饰的内容 其实是属于对象的特殊描述 2 访问语法 类名 静态方法
  • Android中pendingIntent的深入理解

    http blog csdn net yuzhiboyi article details 8484771
  • MySQL进阶——触发器

    1 触发器定义 同存储过程和函数类似 MySQL中的触发器也是存储在系统内部的一段程序代码 可以把它看作是一个特殊的存储过程 所不同的是 触发器无需人工调用 当程序满足定义条件时就会被MySQL自动调用 这些条件可以称为触发事件 包括INS
  • Uncaught ReferenceError: require is not defined

    在electron中 渲染进程与主进程交互时 引入ipcRenderer报错 Uncaught ReferenceError require is not defined 渲染进程是这么写的 h1 Hello World h1 We are
  • 实现基于 TCP 的服务器端/客户端

    文章目录 1 TCP服务器端的默认函数调用顺序 1 1 进入等待连接请求状态 listen 函数 1 2 受理客户端连接请求 accept 函数 1 3 回顾 HelloWorld 服务器端 2 TCP客户端的默认函数调用顺序 2 1 发起