lv7 嵌入式开发-网络编程开发 07 TCP服务器实现

目录

1 函数介绍

1.1 socket函数 与 通信域

1.2 bind函数 与 通信结构体

1.3 listen函数 与 accept函数

2 TCP服务端代码实现

 3 TCP客户端代码实现

4 代码优化

5 练习

1 函数介绍

其中read、write、close在IO中已经介绍过，只需了解socket、bind、listen、accept等

1.1 socket函数 与 通信域

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

参数：

  • domain：指定套接字的协议域（protocol family），可以是 AF_INET（IPv4）或 AF_INET6（IPv6）等。
  • type：指定套接字的类型，可以是 SOCK_STREAM（流套接字，用于可靠的、面向连接的通信）或 SOCK_DGRAM（数据报套接字，用于无连接的通信）等。
  • protocol：指定使用的协议，可以是 IPPROTO_TCP（TCP）或 IPPROTO_UDP（UDP）等。所以无需要指定协议，设为0即可

返回值：

  • 成功创建套接字时，返回一个非负整数，代表新创建的套接字描述符。
  • 创建套接字失败时，返回 -1，并设置 errno 来表示具体的错误原因。

 示例：

#include <sys/types.h>
#include <sys/socket.h>int main() {int sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);  //最后一个参数也可以是0if (sockfd == -1) {// 处理创建套接字失败的情况return -1;}// 套接字创建成功，可以进行后续操作return 0;
}

1.2 bind函数 与 通信结构体

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

参数解释：

  • sockfd：要进行绑定的套接字描述符。
  • addr：指向sockaddr结构体的指针，其中包含了要绑定的地址信息。
  • addrlen：addr指向的结构体的大小。

返回值：

  • 成功时，返回0。
  • 失败时，返回-1，并且在错误码中设置相应的错误标志，可以通过errno全局变量获取具体错误信息。

ipv4结构体 

struct sockaddr_in {sa_family_t    sin_family; /* 地址族: AF_INET */in_port_t      sin_port;   /* 网络字节序的端口号 */struct in_addr sin_addr;   /*IP地址结构体 */
};/* IP地址结构体 */
struct in_addr {uint32_t       s_addr;     /* 网络字节序的IP地址 */
};/*通用地址族结构体*/
struct sockaddr {sa_family_t sa_family;char sa_data[14];
}

注意事项：

  • 调用bind()函数之前，需要先创建一个套接字，并确保该套接字是未绑定的。
  • bind()函数通常在服务器端使用，用于将服务器的套接字与指定的本地地址绑定，从而监听并接收该地址发来的连接请求。
  • 在调用bind()函数时，要根据实际情况提供正确的地址信息，如IP地址和端口号等。
  • 在IPv4中，地址信息存储在sockaddr_in结构体中；而在IPv6中，地址信息存储在sockaddr_in6结构体中。

示例：强制转换

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>int main() {int sockfd;struct sockaddr_in server_addr;// 创建套接字sockfd = socket(AF_INET, SOCK_STREAM, 0);// 设置服务器地址信息server_addr.sin_family = AF_INET;server_addr.sin_port = htons(8080);server_addr.sin_addr.s_addr = INADDR_ANY;// 绑定套接字和地址if (bind(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)) == -1) {perror("bind");return 1;}// 其他操作...return 0;
}

1.3 listen函数 与 accept函数

/*监听套接字*/
int listen(int sockfd, int backlog);

参数：

  • sockfd：要监听的套接字描述符。
  • backlog：定义允许排队等待的连接请求的最大数量。

返回值：

  • 成功调用 listen() 函数时，返回 0 表示成功。
  • 调用 listen() 函数失败时，返回 -1 并设置 errno 来表示具体的错误原因。

函数功能： listen() 函数被用于 TCP 服务器端，用于将指定的套接字标记为被动套接字（passive socket），开始监听传入的连接请求。在调用 listen() 之前，服务器需要使用 socket() 函数创建一个套接字，并使用 bind() 函数将套接字与特定的地址和端口绑定。

一旦套接字被标记为监听状态，它就可以开始接受传入的连接请求。这些连接请求会被放置在一个连接请求队列中，等待服务器进程使用 accept() 函数来接受这些请求并建立连接。

注意事项：

  • backlog 参数指定了连接请求队列的最大长度。如果队列已满，则新的连接请求将被拒绝。实际允许的队列长度可能会受到系统限制。
  • 在调用 listen() 之后，通常需要调用 accept() 函数来接受连接请求并建立连接。

示例：

#include <sys/types.h>
#include <sys/socket.h>int main() {int sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (sockfd == -1) {// 处理创建套接字失败的情况return -1;}// 套接字创建成功，可以进行后续操作if (bind(sockfd, (struct sockaddr*)&addr, sizeof(addr)) == -1) {// 处理绑定地址和端口失败的情况return -1;}if (listen(sockfd, 10) == -1) {// 处理监听套接字失败的情况return -1;}// 套接字处于监听状态，可以接受连接请求并建立连接return 0;
}

/*处理客户端发起的连接，生成新的套接字*/
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
-sockfd: 函数socket生成的套接字
-addr:客户端的地址族信息
-addrlen:地址族结构体的长度

参数：

  • sockfd：监听套接字描述符，即之前调用 listen() 函数返回的套接字描述符。
  • addr：指向用于存储客户端地址信息的结构体 sockaddr 的指针，可以为 NULL。
  • addrlen：指向存储客户端地址长度的变量的指针，如果 addr 不为 NULL，则需要将 addrlen 设置为 sizeof(struct sockaddr)。

返回值：

  • 成功调用 accept() 函数时，返回一个新的套接字描述符，用于处理与客户端的连接。
  • 调用 accept() 函数失败时，返回 -1 并设置 errno 来表示具体的错误原因。

函数功能： accept() 函数用于监听套接字上接受传入的连接请求，并创建一个新的套接字来处理与客户端的连接。该新的套接字用于与客户端进行通信。在调用 accept() 函数之前，需要先使用 socket()、bind() 和 listen() 函数来准备监听套接字。

当有一个连接请求到达监听套接字时，accept() 函数会从连接请求队列中取出一个请求，创建一个新的套接字来处理该连接，并返回新创建的套接字描述符。可以通过新创建的套接字描述符进行与客户端的通信。

如果传入的 addr 不为 NULL，则 accept() 函数会将客户端的地址信息存储在 addr 指向的结构体中。同时，addrlen 也需要传入一个指向存储客户端地址长度的变量的指针。

注意事项：

  • accept() 函数是一个阻塞调用，当没有连接请求时，它会一直等待，直到有连接请求到达或出现错误才返回。
  • 通常在多线程或多进程环境中使用 accept() 函数来实现并发处理多个连接请求的功能。

示例： 

#include <sys/types.h>
#include <sys/socket.h>int main() {int sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (sockfd == -1) {// 处理创建套接字失败的情况return -1;}// 套接字创建成功，可以进行后续操作if (bind(sockfd, (struct sockaddr*)&addr, sizeof(addr)) == -1) {// 处理绑定地址和端口失败的情况return -1;}if (listen(sockfd, 10) == -1) {// 处理监听套接字失败的情况return -1;}// 套接字处于监听状态，可以接受连接请求并建立连接struct sockaddr_in client_addr;socklen_t client_addrlen = sizeof(client_addr);int client_sockfd = accept(sockfd, (struct sockaddr*)&client_addr, &client_addrlen);if (client_sockfd == -1) {// 处理接受连接请求失败的情况return -1;}// 成功接受连接请求，可以使用 client_sockfd 进行与客户端的通信return 0;
}

2 TCP服务端代码实现

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>#define PORT 5001
#define BACKLOG 5int main(int argc, char *argv[])
{int fd, newfd;char buf[BUFSIZ] = {}; //BUFSIZ 8142struct sockaddr_in addr;/*创建套接字*/fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = 0;/*绑定通信结构体*/if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("bind");exit(0);}/*设置套接字为监听模式*/if(listen(fd, BACKLOG) == -1){perror("listen");exit(0);}/*接受客户端的连接请求，生成新的用于和客户端通信的套接字*/newfd = accept(fd, NULL, NULL);if(newfd < 0){perror("accept");exit(0);}printf("BUFSIZ = %d\n", BUFSIZ);read(newfd, buf, BUFSIZ);printf("buf = %s\n", buf);close(fd);return 0;
}

 3 TCP客户端代码实现

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>#define PORT 5001
#define BACKLOG 5
#define STR "Hello World!"int main(int argc, char *argv[])
{int fd;struct sockaddr_in addr;/*创建套接字*/fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = inet_addr("127.0.0.1");/*向服务端发起连接请求*/if(connect(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("connect");exit(0);}write(fd, STR, sizeof(STR) );printf("STR = %s\n", STR);close(fd);return 0;
}

4 代码优化

服务端

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>#define BACKLOG 5int main(int argc, char *argv[])
{int fd, newfd, ret;char buf[BUFSIZ] = {}; //BUFSIZ 8142struct sockaddr_in addr;if(argc < 3){fprintf(stderr, "%s<addr><port>\n", argv[0]);exit(0);}/*创建套接字*/fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons( atoi(argv[2]) );if ( inet_aton(argv[1], &addr.sin_addr) == 0) {fprintf(stderr, "Invalid address\n");exit(EXIT_FAILURE);}/*绑定通信结构体*/if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("bind");exit(0);}/*设置套接字为监听模式*/if(listen(fd, BACKLOG) == -1){perror("listen");exit(0);}/*接受客户端的连接请求，生成新的用于和客户端通信的套接字*/newfd = accept(fd, NULL, NULL);if(newfd < 0){perror("accept");exit(0);}while(1){memset(buf, 0, BUFSIZ);ret = read(newfd, buf, BUFSIZ);if(ret < 0){perror("read");exit(0);}else if(ret == 0)break;elseprintf("buf = %s\n", buf);}close(newfd);close(fd);return 0;
}

客户端

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>#define BACKLOG 5int main(int argc, char *argv[])
{int fd;struct sockaddr_in addr;char buf[BUFSIZ] = {};if(argc < 3){fprintf(stderr, "%s<addr><port>\n", argv[0]);exit(0);}/*创建套接字*/fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons( atoi(argv[2]) );if ( inet_aton(argv[1], &addr.sin_addr) == 0) {fprintf(stderr, "Invalid address\n");exit(EXIT_FAILURE);}/*向服务端发起连接请求*/if(connect(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("connect");exit(0);}while(1){printf("Input->");fgets(buf, BUFSIZ, stdin);write(fd, buf, strlen(buf) );}close(fd);return 0;
}

5 练习

实现TCP通信代码，并使用Makefile进行编译。提交代码和完成通信的截图

client

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>#define CLIENT_MAX_NUM 5int main(int argc, char * argv[])
{int clientfd;struct sockaddr_in server_addr;char buf[BUFSIZ];int ret;if( argc < 3){printf("%s <ip> <port>\n",argv[0]);return 0;}clientfd = socket(AF_INET, SOCK_STREAM,0);if(clientfd == -1){perror("socket");return 0;}server_addr.sin_family = AF_INET;server_addr.sin_port = htons( atoi(argv[2]) ) ;if( inet_aton(argv[1], &server_addr.sin_addr) == 0){printf("Invalid address:%s\n",argv[1]);return 0;}if(connect(clientfd, (struct sockaddr *)&server_addr,sizeof(server_addr)) == -1){perror("connect");return 0;}while(1){printf(">");fgets(buf, BUFSIZ, stdin);write(clientfd, buf, strlen(buf));}close(clientfd);return 0;
}

server

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>#define CLIENT_MAX_NUM 5int main(int argc, char * argv[])
{int sockfd, clientfd;struct sockaddr_in server_addr;char buf[BUFSIZ];int ret;if( argc < 3){printf("%s <ip> <port>\n",argv[0]);return 0;}sockfd = socket(AF_INET, SOCK_STREAM,0);if(sockfd == -1){perror("socket");return 0;}server_addr.sin_family = AF_INET;server_addr.sin_port = htons( atoi(argv[2]) ) ;if( inet_aton(argv[1], &server_addr.sin_addr) == 0){printf("Invalid address:%s\n",argv[1]);return 0;}if(bind(sockfd, (struct sockaddr *)&server_addr,sizeof(server_addr)) == -1){perror("bind");return 0;}if(listen(sockfd, CLIENT_MAX_NUM) == -1){perror("listen");return 0;}clientfd = accept(sockfd, NULL, NULL); if( clientfd == -1){perror("accept");return 0;}while(1){memset(buf, 0, BUFSIZ);ret = read(clientfd, buf, BUFSIZ);if(ret < 0){perror("read");return 0;}else if( ret == 0 ){break;}else{printf("buf = %s\n", buf);}	}close(clientfd);close(sockfd);return 0;
}

makefile

CC=gcc
CFLAGS=-Wall
all:tcp_client tcp_serverclean:rm tcp_server tcp_client

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

国庆假期day5

国庆假期day5

作业&#xff1a;请写出七层模型及每一层的功能&#xff0c;请绘制三次握手四次挥手的流程图 1.OSI七层模型&#xff1a; 应用层--------提供函 表示层--------表密缩 会话层--------会话 传输层--------进程的接收和发送 网络层--------寻主机 数据链路层----相邻节点的可靠传…
阅读更多...
【题解 动态规划】 Colored Rectangles

【题解 动态规划】 Colored Rectangles

题目描述&#xff1a; 分析&#xff1a; 乍一看我还以为是贪心&#xff01; 猫 想想感觉没问题 但是局部最优并不能保证全局最优 比如这组数据 19 19 19 19 20 20 20 20如果按照贪心的做法&#xff0c;答案是20*20*2 但是其实答案是19*20*4 因此这道题用贪心是不对的 于是我…
阅读更多...
Redis分页+多条件模糊查询组合实现思路

Redis分页+多条件模糊查询组合实现思路

Redis是一个高效的内存数据库&#xff0c;它支持包括String、List、Set、SortedSet和Hash等数据类型的存储&#xff0c;在Redis中通常根据数据的key查询其value值&#xff0c;Redis没有模糊条件查询&#xff0c;在面对一些需要分页、排序以及条件查询的场景时(如评论&#xff0…
阅读更多...
基于SSM的健身房管理系统

基于SSM的健身房管理系统

基于SSM的健身房管理系统的设计与实现 开发语言&#xff1a;Java数据库&#xff1a;MySQL技术&#xff1a;SpringSpringMVCMyBatis工具&#xff1a;IDEA/Ecilpse、Navicat、Maven 【主要功能】 角色&#xff1a;管理员、用户 查看健身课程列表、新闻公告查看、推荐课程、购买…
阅读更多...
《机器学习实战》学习记录-ch2

《机器学习实战》学习记录-ch2

PS: 个人笔记&#xff0c;建议不看 原书资料&#xff1a;https://github.com/ageron/handson-ml2 2.1数据获取 import pandas as pd data pd.read_csv(r"C:\Users\cyan\Desktop\AI\ML\handson-ml2\datasets\housing\housing.csv")data.head() data.info()<clas…
阅读更多...
【Leetcode】 131. 分割回文串

【Leetcode】 131. 分割回文串

给你一个字符串 s&#xff0c;请你将 s 分割成一些子串&#xff0c;使每个子串都是 回文串 。返回 s 所有可能的分割方案。 回文串 是正着读和反着读都一样的字符串。 示例 1&#xff1a; 输入&#xff1a;s "aab" 输出&#xff1a;[["a","a"…
阅读更多...
Spring Cloud Zuul 基本原理

Spring Cloud Zuul 基本原理

Spring Cloud Zuul 底层是基于Servlet实现的&#xff0c;核心是通过一系列的ZuulFilter来完成请求的转发。 1、核心组件注册 1.1. EnableZuulProxy注解 启用Zuul作为微服务网关&#xff0c;需要在Application应用类加上EnableZuulProxy注解&#xff0c;而该注解核心是利用Im…
阅读更多...
Web版Photoshop来了，用到了哪些前端技术？

Web版Photoshop来了，用到了哪些前端技术？

经过 Adobe 工程师多年来的努力&#xff0c;并与 Chrome 等浏览器供应商密切合作&#xff0c;通过 WebAssembly Emscripten、Web Components Lit、Service Workers Workbox 和新的 Web API 的支持&#xff0c;终于在近期推出了 Web 版 Photoshop&#xff08;photoshop.adobe…
阅读更多...
Qt+openCV学习笔记（十六）Qt6.6.0rc+openCV4.8.1+emsdk3.1.37编译静态库

Qt+openCV学习笔记（十六）Qt6.6.0rc+openCV4.8.1+emsdk3.1.37编译静态库

前言&#xff1a; 有段时间没来写文章了&#xff0c;趁编译库的空闲&#xff0c;再写一篇记录文档 WebAssembly的发展逐渐成熟&#xff0c;即便不了解相关技术&#xff0c;web前端也在不经意中使用了相关技术的库&#xff0c;本篇文档记录下如何编译WebAssembly版本的openCV&…
阅读更多...
区块链3.0时代 基于GoMars构建的新概念TravelFi能否注入新力量？

区块链3.0时代 基于GoMars构建的新概念TravelFi能否注入新力量？

区块链技术进入3.0时代 后疫情时代&#xff0c;全球数字化进程不断加快&#xff0c;世界范围内的移动通信、互联网技术及各类数字化应用的社会普及率也正在快速提升&#xff0c;疫情推动了互联网经济的增长&#xff0c;也让数字经济的价值开始显现。 数字经济一词的由来至今已经…
阅读更多...
网络协议--概述

网络协议--概述

1.2 分层 网络协议通常分不同层次进行开发&#xff0c;每一层分别负责不同的通信功能。一个协议族&#xff0c;比如TCP/IP&#xff0c;是一组不同层次上的多个协议的组合。TCP/IP通常被认为是一个四层协议系统&#xff0c;如图1-1所示。 每一层负责不同的功能&#xff1a; 1.…
阅读更多...
objective-c 基础学习

objective-c 基础学习

目录 第一节&#xff1a;OC 介绍 ​​第二节&#xff1a;Fundation 框架 ​第三节&#xff1a;NSLog 相对于print 的增强 ​第四节&#xff1a;NSString ​第五节&#xff1a;oc新增数据类型 第六节&#xff1a; 类和对象 ​类的方法的声明与实现 ​第七节&#xff1a;类…
阅读更多...
Linux信号解析

Linux信号解析

文章目录 Linux信号概念信号种类Linux信号产生异步 LInux信号阻塞递达、未决、阻塞、忽略信号集操作函数阻塞信号集操作函数未决信号集操作函数 Linux信号捕捉signal函数sigaction函数 总结 Linux信号概念 信号在我们的生活中无处不在&#xff0c;常见的如电话铃声&#xff0c…
阅读更多...
国庆10.4

国庆10.4

QT实现TCP服务器客户端 服务器 头文件 #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QTcpServer> //服务器头文件 #include <QTcpSocket> //客户端头文件 #include <QList> //链表容器 #include <QMe…
阅读更多...
【C 语言进阶（12）】动态内存管理笔试题

【C 语言进阶（12）】动态内存管理笔试题

文章目录 题目 1题目 2题目 3题目 4 题目 1 运行 Test 函数后的结果是什么&#xff1f; void GetMemory(char* p) {p (char*)malloc(100); }void Test(void) {char* str NULL;GetMemory(str);strcpy(str, "hello world");printf(str); }代码结果 程序崩溃。 代…
阅读更多...
C++ YAML使用

C++ YAML使用

C++工程如何使用YAML-cpp 一、前期准备工作 1、已安装minGW、cmake、make等本地工具。 2、下载YAML-cpp第三方开源代码（一定要下载最新的release版本，不然坑很多）。 3、生成YAML-cpp静态库 （1）在yaml-cpp-master下建立build文件夹； （2）在该文件夹下生成MakaFile文…
阅读更多...
C++入门-day01

C++入门-day01

一、认识C C融合了三种不同的编程方式 C代表的过程性语言在C基础上添加的类、结构体puls代表的面向对象语言C模板支持泛型编程 C完全兼容C的特性 Tips&#xff1a;侯捷老师提倡的Modren C是指C11、C14、C17和C20这些新标准所引入的一系列新特性和改进。在我们练习的时候也应当去…
阅读更多...
Blender 之创建一个简单的笔筒

Blender 之创建一个简单的笔筒

文章目录 成品图实现步骤 你是不是想创建一个笔筒捏&#xff1f; follow me! 成品图 实现步骤 先添加一个柱体 选中柱体&#xff0c;然后按tab 进入编辑模式 切换到面模式 &#xff08;可以按主键盘的 3 键&#xff09; 分别选中上下面&#xff0c;鼠标右键&#xff0c;选…
阅读更多...
BL808学习日志-2-LVGL for M0 and D0

BL808学习日志-2-LVGL for M0 and D0

一、lvgl测试环境 对拿到的M1S_DOCK开发板进行开发板测试&#xff0c;博流的官方SDK是支持M0和D0两个内核都进行测试的&#xff1b;但是目前只实现了M0的LVGLBenchmark&#xff0c;测试D0内核中发现很多莫名其妙的问题。一会详细记录。 使用的是开发板自带的SPI显示屏&#xff…
阅读更多...
【软考】4.2 关系代数/函数依赖/范式

【软考】4.2 关系代数/函数依赖/范式

《 关系代数 》 表和表之间的逻辑运算 笛卡尔积&#xff1a;S1 x S2 投影&#xff1a;π&#xff1b;选择某一列&#xff08;属性&#xff09;&#xff1b;一个关系R的投影操作结果也是一个关系&#xff0c;记作Πa&#xff0c;它由从关系R中选出的A列元素构成&#xff1b;选择…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023