TCP（TCP客户端、服务器如何通信）

一、TCP介绍

TCP的特点：

  1. 面向连接的协议：TCP是一种可靠的、面向连接的协议，在通信之前需要建立连接，以确保数据的可靠传输。这意味着在传输数据之前，发送方和接收方之间需要建立一条可靠的连接通道。
  2. 流式协议：TCP将数据看作是一连串的字节流，而不是独立的数据包。这意味着在传输过程中，数据可以被分割成多个数据包进行传输，并在接收端进行重新组装。
  3. 可靠传输：TCP通过使用校验和、序列号和确认应答等机制，确保数据的可靠传输。如果在传输过程中发生错误或丢失，TCP会进行重传，以确保数据的完整性和准确性。
  4. 出错重传：当TCP接收到错误的数据包时，它会要求发送方重新发送该数据包，以确保数据的正确性。
  5. 确认应答：TCP使用确认应答机制来确保数据的可靠传输。当接收方收到一个数据包时，它会向发送方发送一个确认应答，表示已经收到了该数据包。
  6. 服务器被动连接，客户端主动连接：在TCP连接中，服务器通常处于被动状态，等待客户端的连接请求。而客户端则处于主动状态，负责发起连接请求。一旦连接建立成功，双方就可以进行数据传输。  

TCP与UDP的差异

TCP与UDP流程对比 

TCP编程流程 

服务器端流程：

  1. 创建套接字（socket）：使用socket()函数创建一个套接字，指定使用的协议族（如IPv4或IPv6）和socket类型（如流式socket）。
  2. 绑定套接字（bind）：使用bind()函数将套接字与服务器的网络信息（如IP地址和端口号）进行绑定。
  3. 监听套接字（listen）：使用listen()函数将套接字设置为监听状态，准备接收客户端的连接请求。
  4. 接受连接（accept）：使用accept()函数阻塞等待客户端的连接请求，并返回一个新的套接字用于与该客户端进行通信。
  5. 进行通信（recv/send）：使用recv()和send()函数与客户端进行数据的接收和发送。
  6. 关闭套接字（close）：通信完成后，使用close()函数关闭套接字，释放资源。

客户端流程：

  1. 创建套接字（socket）：与服务器端相同，使用socket()函数创建一个套接字。
  2. 连接服务器（connect）：使用connect()函数向服务器发起连接请求，指定服务器的IP地址和端口号。
  3. 进行通信（send/recv）：连接建立后，使用send()和recv()函数与服务器进行数据的发送和接收。
  4. 关闭套接字（close）：通信完成后，使用close()函数关闭套接字，释放资源。

 二、TCP编程-socket

#include <sys/types.h>
#include <sys/socket.h>
int socket(int domain, int type, int protocol);

功能：
    创建一个套接字，返回一个文件描述符
参数：
    domain：通信域，协议族
      AF_UNIX 本地通信
      AF_INET ipv4网络协议
      AF_INET6 ipv6网络协议
      AF_PACKET 底层接口
    type：套接字的类型
      SOCK_STREAM 流式套接字（tcp）
      SOCK_DGRAM 数据报套接字（udp）
      SOCK_RAW 原始套接字（用于链路层）
    protocol：附加协议，如果不需要，则设置为0

返回值：
    成功：文件描述符
    失败：‐1

 案例

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>

int main(int argc, char const *argv[])
{
    //通过socket函数创建一个TCP套接字
    int sockfd;
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        perror("fail to socket");
        exit(1);
    }

    printf("sockfd = %d\n", sockfd);

    return 0;
}

这段代码演示了如何使用C语言创建一个TCP套接字。在代码中，首先通过socket()函数创建了一个套接字，指定了协议族为AF_INET（IPv4），套接字类型为SOCK_STREAM（TCP）。如果创建失败，则会输出错误信息并退出程序。如果创建成功，则会输出套接字的文件描述符。最后，程序返回0表示正常退出。

 执行结果

 三、TCP客户端-connect、send、recv

3.1 connect函数

#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
功能：
    给服务器发送客户端的连接请求
参数：
    sockfd：文件描述符，socket函数的返回值
    addr：要连接的服务器的网络信息结构体（需要自己设置）
    addrlen：add的长度
返回值：
    成功：0
    失败：-1

注意：

  1. connect建立连接之后不会产生新的套接字
  2. 连接成功后才可以开始传输TCP数据
  3. 头文件：#include 

3.2 send函数

#include <sys/types.h>
#include <sys/socket.h>
ssize_t send(int sockfd, const void *buf, size_t len, int flags);

功能：
    发送数据
参数：
    sockfd：文件描述符

客户端：
    socket函数的返回值
服务器：
    accept函数的返回值

     buf：发送的数据
     len：buf的长度
     flags：标志位
       0 阻塞
       MSG_DONTWAIT 非阻塞
 
返回值：
    成功：发送的字节数
    失败：-1

注意： 不能用TCP协议发送0长度的数据包

3.3 recv函数

#include <sys/types.h>

#include <sys/socket.h>
ssize_t recv(int sockfd, void *buf, size_t len, int flags);
功能：
    接收数据
参数：
    sockfd：文件描述符
客户端：socket函数的返回值
服务器：accept函数的返回值
    buf：保存接收到的数据
    len：buf的长度
    flags：标志位
      0 阻塞
      MSG_DONTWAIT 非阻塞
返回值：
    成功：接收的字节数
    失败：-1
如果发送端关闭文件描述符或者关闭进程，则recv函数会返回0

3.4 客户端code

使用windows下的网络调试助手作为服务器

客户端的程序 

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

#define N 128

int main(int argc, char const *argv[])
{
    if(argc < 3)
    {
        fprintf(stderr, "Usage: %s [ip] [port]\n", argv[0]);
        exit(1);
    }

    //第一步：创建套接字
    int sockfd;
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        perror("fail to socket");
        exit(1);
    }

    //printf("sockfd = %d\n", sockfd);

    //第二步：发送客户端连接请求
    struct sockaddr_in serveraddr;
    socklen_t addrlen = sizeof(serveraddr);

    serveraddr.sin_family = AF_INET;
    serveraddr.sin_addr.s_addr = inet_addr(argv[1]);
    serveraddr.sin_port = htons(atoi(argv[2]));

    if(connect(sockfd, (struct sockaddr *)&serveraddr, addrlen) == -1)
    {
        perror("fail to connect");
        exit(1);
    }

    //第三步：进行通信
    //发送数据
    char buf[N] = "";
    fgets(buf, N, stdin);
    buf[strlen(buf) - 1] = '\0';
    if(send(sockfd, buf, N, 0) == -1)
    {
        perror("fail to send");
        exit(1);
    }

    //接收数据
    char text[N] = "";
    if(recv(sockfd, text, N, 0) == -1)
    {
        perror("fail to recv");
        exit(1);
    }

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

    //第四步：关闭套接字文件描述符
    close(sockfd);

    return 0;
}

这段代码是一个简单的TCP客户端程序。它接收两个命令行参数：服务器的IP地址和端口号。然后，程序会执行以下步骤：

  1. 创建一个TCP套接字。
  2. 使用connect()函数向服务器发送连接请求。
  3. 从标准输入读取一行数据，并将其发送给服务器。
  4. 接收服务器返回的数据，并将其打印到标准输出。
  5. 关闭套接字文件描述符。

 执行结果

 

四、TCP服务器-bind、listen、accept 

4.1 做为TCP服务器需要具备的条件

1、具备一个可以确知的地址

2、让操作系统知道是一个服务器，而不是客户端

3、等待连接的到来 对于面向连接的TCP协议来说，连接的建立才真正意味着数据通信的开始

4.2 bind函数

#include <sys/types.h>

#include <sys/socket.h>
int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
功能：
    将套接字与网络信息结构体绑定
参数：
    sockfd：文件描述符，socket的返回值
    addr：网络信息结构体
      通用结构体（一般不用）
      struct sockaddr
      网络信息结构体 sockaddr_in
#include <netinet/in.h>
struct sockaddr_in
addrlen：
    addr的长度
返回值：
    成功：0
    失败：-1

 简单写个例子

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>

int main() {
    // 创建一个流式套接字
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd == -1) {
        perror("socket");
        return -1;
    }

    // 初始化网络信息结构体
    struct sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(8080); // 绑定到8080端口
    addr.sin_addr.s_addr = htonl(INADDR_ANY); // 绑定到任意IP地址

    // 将套接字与网络信息结构体绑定
    socklen_t addrlen = sizeof(addr);
    if (bind(sockfd, (struct sockaddr *)&addr, addrlen) == -1) {
        perror("bind");
        return -1;
    }

    printf("Bind successful\n");

    // 关闭套接字
    close(sockfd);

    return 0;
}

 在这个实例中，我们首先使用socket()函数

#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
功能：
    阻塞等待客户端的连接请求
参数：
    sockfd：文件描述符，socket函数的返回值
    addr：接收到的客户端的信息结构体（自动填充，定义变量即可）
    addrlen：addr的长度
返回值：
    成功：新的文件描述符（只要有客户端连接，就会产生新的文件描述符，这个新的文件描述符专门与指定的客户端进行通信的）
    失败：-1

创建了一个流式套接字，然后初始化了一个sockaddr_in结构体，将套接字绑定到8080端口和任意IP地址。最后，我们使用bind()函数将套接字与网络信息结构体绑定，如果绑定成功，则会输出"Bind successful"。

 4.3 listen函数

#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
int listen(int sockfd, int backlog);
功能：
    将套接字设置为被动监听状态，这样做之后就可以接收到连接请求
参数：
    sockfd：文件描述符，socket函数返回值
    backlog：允许通信连接的主机个数，一般设置为5、10
返回值：
    成功：0
    失败：-1

4.4 accept函数

#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
功能：
    阻塞等待客户端的连接请求
参数：
    sockfd：文件描述符，socket函数的返回值
    addr：接收到的客户端的信息结构体（自动填充，定义变量即可）
    addrlen：addr的长度
返回值：
    成功：新的文件描述符（只要有客户端连接，就会产生新的文件描述符，这个新的文件描述符专门与指定的客户端进行通信的）
    失败：-1

 4.5 TCP服务器例子

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

#define N 128

int main(int argc, char const *argv[])
{
    if(argc < 3)
    {
        fprintf(stderr, "Usage: %s [ip] [port]\n", argv[0]);
        exit(1);
    }

    //第一步：创建套接字
    int sockfd;
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        perror("fail to socket");
        exit(1);
    }

    //第二步：将套接字与服务器网络信息结构体绑定
    struct sockaddr_in serveraddr;
    socklen_t addrlen = sizeof(serveraddr);

    serveraddr.sin_family = AF_INET;
    serveraddr.sin_addr.s_addr = inet_addr(argv[1]);
    serveraddr.sin_port = htons(atoi(argv[2]));

    if(bind(sockfd, (struct sockaddr *)&serveraddr, addrlen) == -1)
    {
        perror("fail to bind");
        exit(1);
    }

    //第三步：将套接字设置为被动监听状态
    if(listen(sockfd, 10) == -1)
    {
        perror("fail to listen");
        exit(1);
    }

    //第四步：阻塞等待客户端的链接请求
    int acceptfd;
    struct sockaddr_in clientaddr;
    if((acceptfd = accept(sockfd, (struct sockaddr *)&clientaddr, &addrlen)) == -1)
    {
        perror("fail to accept");
        exit(1);
    }

    //打印连接的客户端的信息
    printf("ip:%s, port:%d\n", inet_ntoa(clientaddr.sin_addr), ntohs(clientaddr.sin_port));

    //第五步：进行通信
    //tcp服务器与客户端通信时，需要使用accept函数的返回值
    char buf[N] = "";
    if(recv(acceptfd, buf, N, 0) == -1)
    {
        perror("fail to recv");
    }

    printf("from client: %s\n", buf);

    strcat(buf, " *_*");
    if(send(acceptfd, buf, N, 0) == -1)
    {
        perror("fail to send");
        exit(1);
    }

    //关闭套接字文件描述符
    close(acceptfd);
    close(sockfd);

    return 0;
}

 

  1. 创建一个TCP套接字。
  2. 将套接字与服务器的IP地址和端口号绑定。
  3. 将套接字设置为被动监听状态，等待客户端的连接请求。
  4. 阻塞等待客户端的连接请求，并接受连接。
  5. 打印连接的客户端的IP地址和端口号。
  6. 接收客户端发送的数据，并将其打印出来。
  7. 向客户端发送数据。
  8. 关闭与客户端的连接，并关闭套接字。

 执行结果

4.6  close关闭套接字

  1. 使用close函数即可关闭套接字 关闭一个代表已连接套接字将导致另一端接收到一个0长度的数据包
  2. 做服务器时 1>关闭监听套接字将导致服务器无法接收新的连接，但不会影响已经建立的连接 2>关闭accept返回的已连接套接字将导致它所代表的连接被关闭，但不会影响服务器 的监听
  3. 做客户端时 关闭连接就是关闭连接，不意味着其他

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/594210.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Spring Cloud架构进化实操：Eureka、Apollo、OpenFeign、Ribbon、Zuul组件

Spring Cloud架构进化实操：Eureka、Apollo、OpenFeign、Ribbon、Zuul组件

文章目录 前言一、引出二、服务注册与发现2.1 创建Eureka注册中心2.1.1 引入pom依赖2.1.2 配置yaml2.1.3 启动服务21.4 测试访问 2.2 创建服务提供者2.2.1 配置yaml2.2.2 启动服务2.2.3 测试访问 2.3 创建服务消费者2.3.1 服务提供者接口2.3.2 服务消费者调用接口 三、负载均衡…
阅读更多...
Docker的私有仓库部署-Harbor

Docker的私有仓库部署-Harbor

目录 一. Docker原生私有仓库 Registry 1. Registry 的介绍 2. Registry 的部署过程 二. Registry 的升级——Habor 1. Harbor 简介 2. Harbor 特性 3. Harbor 的构成 4. Harbor 部署 4.1 部署 Docker-Compose 服务 4.2 部署 Harbor 服务 4.2.1 下载或上传 Harbor…
阅读更多...
18_Scala面向对象编程trait

18_Scala面向对象编程trait

文章目录 trait1.定义trait2.向类中混入特质2.1没有父类2.2有父类 3.动态混入3.1动态混入查询功能到公司业务中 4.父类&#xff0c;子类&#xff0c;特质初始化优先级5.Scala功能执行顺序6.常用API trait –特质的学习需要类比Java中的接口&#xff0c;源码编译之后就是interf…
阅读更多...
三种方法解决：检测到在集成的托管管道模式下不适用的 ASP.NET 设置

三种方法解决：检测到在集成的托管管道模式下不适用的 ASP.NET 设置

几天前配置一个IIS环境的网站时，出现500错误。根据错误提示，很快把问题解决了，现记录一下，希望能帮到遇到同样问题的网友。 问题描述 （点击图片放大） 应用程序“DEFAULT WEB SITE”中的服务器错误Internet Information Services 7.5错误摘要 HTTP 错误 500.24 - Interna…
阅读更多...
抓包证书安装到安卓7.0+手机

抓包证书安装到安卓7.0+手机

前言： 首先理解一下，这个不只是证书到浏览器，而是抓包证书到安卓7.0+手机上的文章； 还有一点区分，在浏览器上装的证书，只是让抓包工具可以抓取手机浏览器的包，而不是抓取手机app上的包； 如果你的证书只是简单的在浏览器下进行安装，那么你的手机app是走不了代理网络的…
阅读更多...
视频教程下载：为 GPTs 商店构建 10 个 GPTs获得被动收入

视频教程下载：为 GPTs 商店构建 10 个 GPTs获得被动收入

欢迎来到 AI 驱动的内容创作新时代 - GPT 商店。这门综合课程是您成为定制和利用 GPT 模型解决多样化应用的专家的路线图。无论你是错过了应用商店革命的初始浪潮还是乘着它取得了成功&#xff0c;这都是你站在下一个重大数字飞跃前沿的机会。 课程模块&#xff1a; - 介绍 Ch…
阅读更多...
Dragonfly 拓扑的路由算法

Dragonfly 拓扑的路由算法

Dragonfly 拓扑的路由算法 1. Dragonfly 上的路由 (1)最小路由(2)非最小路由 2. 评估 Dragonfly 拓扑的路由算法 John Kim, William J. Dally 等人在 2008 年的 ISCA 中提出技术驱动、高度可扩展的 Dragonfly 拓扑。而文章中也提到了 针对 Dragonfly 拓扑的路由算法。本文对…
阅读更多...
java-函数式编程-语法

java-函数式编程-语法

目录 1、函数表现形式 分类 lambda表达式 参数类型可以全写&#xff0c;也可以全不写&#xff0c;但不能一部分写&#xff0c;一部分不写lambda 的省略策略&#xff1a;凡是可推导&#xff0c;都可以省略
阅读更多...
【c++算法篇】双指针（上）

【c++算法篇】双指针（上）

&#x1f525;个人主页&#xff1a;Quitecoder &#x1f525;专栏&#xff1a;算法笔记仓 朋友们大家好啊&#xff0c;本篇文章我们来到算法的双指针部分 目录 1.移动零2.复写零3.快乐数4.盛水最多的容器 1.移动零 题目链接&#xff1a;283.移动零 题目描述&#xff1a; 算法…
阅读更多...
Python量化炒股的数据信息获取—获取上市公司分红送股数据信息

Python量化炒股的数据信息获取—获取上市公司分红送股数据信息

Python量化炒股的数据信息获取—获取上市公司分红送股数据信息 上市公司分红送股数据&#xff0c;都存放在STK_XR_XD表中&#xff0c;该表保存在finance包中。要查看表中的数据信息&#xff0c;需要使用query()函数。 单击聚宽JoinQuant量化炒股平台中的“策略研究/研究环境”…
阅读更多...
微服务---gateway网关

微服务---gateway网关

目录 gateway作用 gateway使用 添加依赖 配置yml文件 自定义过滤器 nacos上的gateway的配置文件 我们现在知道了通过nacos注册服务&#xff0c;通过feign实现服务间接口的调用&#xff0c;那对于不同权限的用户访问同一个接口&#xff0c;我们怎么知道他是否具有访问的权…
阅读更多...
Grafana：云原生时代的数据可视化与监控王者

Grafana：云原生时代的数据可视化与监控王者

&#x1f407;明明跟你说过&#xff1a;个人主页 &#x1f3c5;个人专栏&#xff1a;《Grafana&#xff1a;让数据说话的魔术师》 &#x1f3c5; &#x1f516;行路有良友&#xff0c;便是天堂&#x1f516; 目录 一、引言 1、Grafana简介 2、Grafana的重要性与影响力 …
阅读更多...
开发体育赛事直播平台，研发技术选型与架构设计实现方案

开发体育赛事直播平台，研发技术选型与架构设计实现方案

本文将深入探讨“东莞梦幻网络科技”现成体育直播源码的技术实现方案&#xff0c;如何为用户提供流畅、互动、个性化的观赛体验。 一、技术栈选择&#xff1a;强强联合的基石1、后端开发&#xff1a;采用Java与PHP作为主要开发语言。Java以其强大的企业级应用支持&#xff0c;保…
阅读更多...
双向冒泡法，可以只求最大最小值

双向冒泡法，可以只求最大最小值

int BiBubbleSort(int Arr[],int n,int maxnum){int left0,rightn-1;int i;bool notDone true;int temp;if(n<2)return -1;while(left<right&&notDone){ notDone false; //设置未发生交换标志 for(ileft;i<right;i){if(Arr[i]>Arr[i1]){//swap(Arr[…
阅读更多...
初识指针（1）＜C语言＞

初识指针（1）＜C语言＞

前言 指针是C语言中比较难的一部分&#xff0c;大部分同学对于此部分容易产生“畏难情结”&#xff0c;但是学习好这部分对C语言的深入很大的帮助&#xff0c;所以此篇主要以讲解指针基础为主。 指针概念 变量创建的本质就是在内存中申请空间&#xff0c;找到这个变量就需要地址…
阅读更多...
tiny-Tcmalloc（高并发内存池）

tiny-Tcmalloc（高并发内存池）

项目地址&#xff08;绝对可运行&#xff09; 一. 初识高并发内存池 1、项目介绍 当前项目是实现一个高并发的内存池&#xff0c;它的原型是google的一个开源项目tcmalloc&#xff0c;tcmalloc全称Thread-Caching Malloc&#xff0c;即线程缓存的malloc&#xff0c;实现了高…
阅读更多...
Pytorch 实现 GAN 对抗网络

Pytorch 实现 GAN 对抗网络

GAN 对抗网络 GAN&#xff08;Generative Adversarial Network&#xff09;对抗网络指的是神经网络中包括两个子网络&#xff0c;一个用于生成信息&#xff0c;一个用于验证信息。下面的例子是生成图片的对抗网络&#xff0c;一个网络用于生成图片&#xff0c;另一个网络用于验…
阅读更多...
Bookends for Mac：文献管理工具

Bookends for Mac：文献管理工具

Bookends for Mac&#xff0c;一款专为学术、研究和写作领域设计的文献管理工具&#xff0c;以其强大而高效的功能深受用户喜爱。这款软件支持多种文件格式&#xff0c;如PDF、DOC、RTF等&#xff0c;能够自动提取文献的关键信息&#xff0c;如作者、标题、出版社等&#xff0c…
阅读更多...
Unity 性能优化之静态批处理（三）

Unity 性能优化之静态批处理（三）

提示&#xff1a;仅供参考&#xff0c;有误之处&#xff0c;麻烦大佬指出&#xff0c;不胜感激&#xff01; 文章目录 前言一、静态批处理是什么&#xff1f;二、使用步骤1.勾选Static Batching2.测试静态合批效果 三、静态合批得限制1、游戏对象处于激活状态。2、游戏对象有一…
阅读更多...
Kannala-Brandt 鱼眼相机模型

Kannala-Brandt 鱼眼相机模型

最近在学习 ORB-SLAM3 的源代码&#xff0c;并模仿、重构了相机模型的实现 在学习的过程中发现针孔相机 (Pinhole) 与鱼眼相机 (Fisheye) 都有畸变参数&#xff0c;但是鱼眼相机无法使用 cv::undistort 函数去畸变 在对鱼眼相机的深度归一化平面进行可视化后&#xff0c;发现…
阅读更多...
最新文章

Copyright @ 2022~2023