C语言网络编程入门:socket编程、TCP/IP协议、客户端与服务器通信的实现

C语言网络编程入门:socket编程、TCP/IP协议、客户端与服务器通信的实现

第11篇 《C语言网络编程入门:socket编程、TCP/IP协议、客户端与服务器通信的实现》

在这里插入图片描述

一、前言:为什么网络编程是C语言开发的重要方向?

学习目标

  • 理解网络编程的本质:通过网络实现程序之间的通信
  • 理解TCP/IP协议的基本概念:传输层和网络层的协议
  • 明确网络编程的重要性:实现程序的远程通信、处理大量数据
  • 掌握本章学习重点:socket编程的基本概念、TCP/IP协议的基本概念、客户端与服务器通信的实现、网络编程的避坑指南、实战案例分析
  • 学会使用socket编程编写客户端与服务器通信的程序

重点提示

💡 网络编程是C语言开发的重要方向!通过网络编程,你可以实现程序的远程通信,处理大量数据,解决复杂问题。


二、模块1:socket编程的基本概念——网络通信的基础

2.1 学习目标

  • 理解socket的本质:网络通信的接口
  • 掌握socket的类型:流套接字(SOCK_STREAM)、数据报套接字(SOCK_DGRAM)
  • 掌握socket的创建方法:使用socket函数创建套接字
  • 避开socket编程使用的3大常见坑

2.2 socket的类型

流套接字(SOCK_STREAM)

  • 基于TCP协议
  • 可靠的、面向连接的通信
  • 保证数据的顺序和完整性

数据报套接字(SOCK_DGRAM)

  • 基于UDP协议
  • 不可靠的、无连接的通信
  • 不保证数据的顺序和完整性

代码示例1:创建socket

#include<stdio.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<netinet/in.h>#include<arpa/inet.h>intmain(){int sockfd;structsockaddr_in server_addr;// 创建socket sockfd =socket(AF_INET, SOCK_STREAM,0);if(sockfd <0){perror("socket() error");return0;}// 初始化服务器地址结构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(12345);// 连接服务器if(connect(sockfd,(structsockaddr*)&server_addr,sizeof(server_addr))<0){perror("connect() error");return0;}// 发送数据char buffer[1024]="Hello, Server!";if(send(sockfd, buffer,strlen(buffer),0)<0){perror("send() error");return0;}// 接收数据if(recv(sockfd, buffer,sizeof(buffer),0)<0){perror("recv() error");return0;}printf("服务器返回:%s\n", buffer);// 关闭socketclose(sockfd);return0;}

三、模块2:TCP/IP协议的基本概念——网络通信的核心

3.1 学习目标

  • 理解TCP的本质:传输层的协议,可靠的、面向连接的通信
  • 理解IP的本质:网络层的协议,负责数据的路由和寻址
  • 掌握TCP/IP协议的分层结构:应用层、传输层、网络层、数据链路层
  • 避开TCP/IP协议使用的3大常见坑

3.2 TCP/IP协议的分层结构

应用层:处理应用程序的请求和响应,如HTTP、FTP、SMTP
传输层:负责数据的传输,如TCP、UDP
网络层:负责数据的路由和寻址,如IP、ICMP
数据链路层:负责数据的物理传输,如Ethernet、WiFi


四、模块3:客户端与服务器通信的实现——流套接字通信

4.1 学习目标

  • 理解流套接字通信的本质:基于TCP协议的可靠的、面向连接的通信
  • 掌握服务器端的实现方法:创建socket、绑定地址、监听连接、接受连接、发送数据、接收数据、关闭socket
  • 掌握客户端的实现方法:创建socket、连接服务器、发送数据、接收数据、关闭socket
  • 避开客户端与服务器通信使用的3大常见坑

4.2 服务器端的实现方法

代码示例2:服务器端程序

#include<stdio.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<netinet/in.h>#include<arpa/inet.h>#include<unistd.h>intmain(){int sockfd, newsockfd;socklen_t clilen;char buffer[1024];structsockaddr_in serv_addr, cli_addr;// 创建socket sockfd =socket(AF_INET, SOCK_STREAM,0);if(sockfd <0){perror("socket() error");return0;}// 初始化服务器地址结构memset(&serv_addr,0,sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = INADDR_ANY; serv_addr.sin_port =htons(12345);// 绑定地址if(bind(sockfd,(structsockaddr*)&serv_addr,sizeof(serv_addr))<0){perror("bind() error");return0;}// 监听连接listen(sockfd,5); clilen =sizeof(cli_addr);// 接受连接printf("等待客户端连接...\n"); newsockfd =accept(sockfd,(structsockaddr*)&cli_addr,&clilen);if(newsockfd <0){perror("accept() error");return0;}printf("客户端连接成功!地址:%s,端口:%d\n",inet_ntoa(cli_addr.sin_addr),ntohs(cli_addr.sin_port));// 接收数据memset(buffer,0,sizeof(buffer));if(recv(newsockfd, buffer,sizeof(buffer),0)<0){perror("recv() error");return0;}printf("客户端发送:%s\n", buffer);// 发送数据strcpy(buffer,"Hello, Client!");if(send(newsockfd, buffer,strlen(buffer),0)<0){perror("send() error");return0;}// 关闭socketclose(newsockfd);close(sockfd);return0;}

五、模块4:数据报套接字通信的实现——基于UDP协议的通信

5.1 学习目标

  • 理解数据报套接字通信的本质:基于UDP协议的不可靠的、无连接的通信
  • 掌握服务器端的实现方法:创建socket、绑定地址、接收数据、发送数据、关闭socket
  • 掌握客户端的实现方法:创建socket、发送数据、接收数据、关闭socket
  • 避开数据报套接字通信使用的3大常见坑

5.2 服务器端的实现方法

代码示例3:UDP服务器端程序

#include<stdio.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<netinet/in.h>#include<arpa/inet.h>#include<unistd.h>intmain(){int sockfd;socklen_t clilen;char buffer[1024];structsockaddr_in serv_addr, cli_addr;// 创建socket sockfd =socket(AF_INET, SOCK_DGRAM,0);if(sockfd <0){perror("socket() error");return0;}// 初始化服务器地址结构memset(&serv_addr,0,sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = INADDR_ANY; serv_addr.sin_port =htons(12345);// 绑定地址if(bind(sockfd,(structsockaddr*)&serv_addr,sizeof(serv_addr))<0){perror("bind() error");return0;}// 接收数据 clilen =sizeof(cli_addr);memset(buffer,0,sizeof(buffer));if(recvfrom(sockfd, buffer,sizeof(buffer),0,(structsockaddr*)&cli_addr,&clilen)<0){perror("recvfrom() error");return0;}printf("客户端发送:%s\n", buffer);// 发送数据strcpy(buffer,"Hello, Client!");if(sendto(sockfd, buffer,strlen(buffer),0,(structsockaddr*)&cli_addr, clilen)<0){perror("sendto() error");return0;}// 关闭socketclose(sockfd);return0;}

六、模块5:网络编程的避坑指南——避免常见问题

6.1 学习目标

  • 理解网络编程的常见问题:语法错误、逻辑错误、连接失败、发送失败、接收失败、内存泄漏
  • 掌握避免语法错误的方法:使用编译器检查代码
  • 掌握避免逻辑错误的方法:使用调试工具定位和修复问题
  • 掌握避免连接失败的方法:检查服务器地址和端口是否正确、检查防火墙是否开启
  • 掌握避免发送失败的方法:检查socket是否有效、检查发送的数据是否为空
  • 掌握避免接收失败的方法:检查socket是否有效、检查接收的数据是否为空
  • 掌握避免内存泄漏的方法:在使用完内存后,使用free()函数释放内存
  • 避开网络编程使用的3大常见坑

6.2 常见问题

6.2.1 连接失败

问题:无法连接到服务器,导致程序崩溃

解决方法

  • 检查服务器地址和端口是否正确
  • 检查服务器是否正在运行
  • 检查防火墙是否开启
  • 使用telnet命令测试服务器是否可连接
6.2.2 发送失败

问题:无法发送数据到服务器,导致程序崩溃

解决方法

  • 检查socket是否有效
  • 检查发送的数据是否为空
  • 检查网络连接是否正常
  • 使用调试工具定位和修复问题
6.2.3 接收失败

问题:无法接收服务器返回的数据,导致程序崩溃

解决方法

  • 检查socket是否有效
  • 检查接收的数据是否为空
  • 检查网络连接是否正常
  • 使用调试工具定位和修复问题

七、模块6:实战案例分析——使用网络编程实现聊天程序

7.1 学习目标

  • 掌握使用网络编程实现聊天程序:使用流套接字通信实现客户端与服务器的聊天功能
  • 学会使用网络编程解决实际问题
  • 避开实战案例使用的3大常见坑

7.2 使用网络编程实现聊天程序

代码示例4:服务器端程序

#include<stdio.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<netinet/in.h>#include<arpa/inet.h>#include<unistd.h>#include<pthread.h>#defineMAX_CLIENTS5structClient{int sockfd;structsockaddr_in addr;};structClient clients[MAX_CLIENTS];int num_clients =0;pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;void*handle_client(void*arg){structClient*client =(structClient*)arg;char buffer[1024];int read_size;while((read_size =recv(client->sockfd, buffer,sizeof(buffer),0))>0){ buffer[read_size]='\0';printf("客户端 %s:%d 发送:%s\n",inet_ntoa(client->addr.sin_addr),ntohs(client->addr.sin_port), buffer);// 广播消息给所有客户端pthread_mutex_lock(&mutex);for(int i =0; i < num_clients; i++){if(clients[i].sockfd != client->sockfd){send(clients[i].sockfd, buffer,strlen(buffer),0);}}pthread_mutex_unlock(&mutex);}// 客户端断开连接printf("客户端 %s:%d 断开连接\n",inet_ntoa(client->addr.sin_addr),ntohs(client->addr.sin_port));pthread_mutex_lock(&mutex);for(int i =0; i < num_clients; i++){if(clients[i].sockfd == client->sockfd){for(int j = i; j < num_clients -1; j++){ clients[j]= clients[j +1];} num_clients--;break;}}pthread_mutex_unlock(&mutex);close(client->sockfd);free(client);returnNULL;}intmain(){int sockfd, newsockfd;socklen_t clilen;structsockaddr_in serv_addr, cli_addr;pthread_t tid;// 创建socket sockfd =socket(AF_INET, SOCK_STREAM,0);if(sockfd <0){perror("socket() error");return0;}// 初始化服务器地址结构memset(&serv_addr,0,sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = INADDR_ANY; serv_addr.sin_port =htons(12345);// 绑定地址if(bind(sockfd,(structsockaddr*)&serv_addr,sizeof(serv_addr))<0){perror("bind() error");return0;}// 监听连接listen(sockfd,5); clilen =sizeof(cli_addr);printf("等待客户端连接...\n");while(1){// 接受连接 newsockfd =accept(sockfd,(structsockaddr*)&cli_addr,&clilen);if(newsockfd <0){perror("accept() error");return0;}// 添加客户端到客户端列表pthread_mutex_lock(&mutex);if(num_clients >= MAX_CLIENTS){printf("客户端数量已达到上限!\n");close(newsockfd);pthread_mutex_unlock(&mutex);continue;}structClient*client =(structClient*)malloc(sizeof(structClient)); client->sockfd = newsockfd; client->addr = cli_addr; clients[num_clients++]=*client;pthread_mutex_unlock(&mutex);printf("客户端 %s:%d 连接成功!\n",inet_ntoa(cli_addr.sin_addr),ntohs(cli_addr.sin_port));// 创建线程处理客户端pthread_create(&tid,NULL, handle_client, client);pthread_detach(tid);}// 关闭socketclose(sockfd);return0;}

代码示例5:客户端程序

#include<stdio.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<netinet/in.h>#include<arpa/inet.h>#include<unistd.h>#include<pthread.h>void*receive_messages(void*arg){int sockfd =*(int*)arg;char buffer[1024];int read_size;while((read_size =recv(sockfd, buffer,sizeof(buffer),0))>0){ buffer[read_size]='\0';printf("收到消息:%s\n", buffer);}if(read_size ==0){printf("服务器断开连接!\n");}elseif(read_size <0){perror("recv() error");}close(sockfd);exit(0);returnNULL;}intmain(){int sockfd;structsockaddr_in server_addr;char buffer[1024];pthread_t tid;// 创建socket sockfd =socket(AF_INET, SOCK_STREAM,0);if(sockfd <0){perror("socket() error");return0;}// 初始化服务器地址结构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(12345);// 连接服务器if(connect(sockfd,(structsockaddr*)&server_addr,sizeof(server_addr))<0){perror("connect() error");return0;}printf("连接服务器成功!\n");// 创建线程接收消息pthread_create(&tid,NULL, receive_messages,&sockfd);pthread_detach(tid);// 发送消息while(1){printf("请输入消息:");fgets(buffer,sizeof(buffer),stdin); buffer[strcspn(buffer,"\n")]='\0';if(send(sockfd, buffer,strlen(buffer),0)<0){perror("send() error");return0;}if(strcmp(buffer,"exit")==0){close(sockfd);return0;}}return0;}

八、本章总结与课后练习

8.1 总结

socket编程的基本概念:网络通信的接口,分为流套接字和数据报套接字
TCP/IP协议的基本概念:网络通信的核心,分为应用层、传输层、网络层、数据链路层
客户端与服务器通信的实现:使用流套接字通信实现可靠的、面向连接的通信
数据报套接字通信的实现:使用数据报套接字通信实现不可靠的、无连接的通信
网络编程的避坑指南:避免语法错误、逻辑错误、连接失败、发送失败、接收失败、内存泄漏
实战案例分析:使用网络编程实现聊天程序,支持多个客户端同时连接

8.2 课后练习

  1. 编写程序:使用数据报套接字通信实现简单的网络聊天程序
  2. 编写程序:使用流套接字通信实现文件传输功能
  3. 编写程序:使用网络编程实现简单的HTTP服务器
  4. 编写程序:使用网络编程实现简单的FTP客户端
  5. 编写程序:使用网络编程实现简单的SMTP客户端

Read more

Apache IoTDB 数据管理全攻略:保留、查询与删除操作详解

Apache IoTDB 数据管理全攻略:保留、查询与删除操作详解

Apache IoTDB 数据管理全攻略:保留、查询与删除操作详解 本文围绕 Apache IoTDB 的数据管理核心功能展开,详细解读数据保留、查询与删除操作。在数据保留方面,阐述 TTL 以设备为单位、按数据时间戳判断过期的规则,介绍合法路径模式及设置、取消、查看 TTL 的方法。数据查询部分,说明基本语法,展示基础查询示例,详解最新点查询、分组聚合、空值填充等高级功能及两种结果对齐模式。数据删除部分,介绍单传感器、多传感器时间序列删除方法,提及实验性的时间分区删除功能。整体结合丰富代码示例与场景说明,助力用户掌握 IoTDB 数据管理技巧,应对时序数据存储与分析挑战。 在物联网(IoT)场景中,时序数据的高效管理是核心需求之一。Apache IoTDB 作为一款专为时序数据设计的数据库,提供了强大的数据保留、查询和删除功能,能够帮助用户轻松应对海量时序数据的存储与分析挑战。本文将基于官方文档,详细解读 IoTDB 中数据保留时间(

By Ne0inhk
【Linux】进程概念(三):从 R/S/D/T 到僵尸 / 孤儿进程

【Linux】进程概念(三):从 R/S/D/T 到僵尸 / 孤儿进程

摘要 Linux进程状态是进程在其生命周期中所处的不同状况,主要包括运行(R)、睡眠(S)、磁盘休眠(D)、停止(T)、僵尸(Z)和死亡(X)。这些状态反映了进程是正在执行、等待资源还是已经终止。其中,僵尸状态是一个关键概念,指子进程已退出但其退出信息未被父进程回收,导致其进程控制块无法释放,从而占用系统资源。若父进程先退出,子进程则会成为“孤儿进程”,并由1号init进程接管,以确保其最终能被正确回收,避免资源泄漏。 * 摘要 * 目录 * 一、Linux进程状态 * 1. R(runing)— 运行状态 * 2. S(sleeping)— 睡眠状态 * 3. D(disk sleep)— 磁盘休眠状态 * 4. T(stopped)— 停止状态 * 6. X(

By Ne0inhk
U-Boot 和 Linux 内核的关系及设备树详解

U-Boot 和 Linux 内核的关系及设备树详解

🔥作者简介: 一个平凡而乐于分享的小比特,中南民族大学通信工程专业研究生,研究方向无线联邦学习 🎬擅长领域:驱动开发,嵌入式软件开发,BSP开发 ❄️作者主页:一个平凡而乐于分享的小比特的个人主页 ✨收录专栏:操作系统,本专栏为讲解各操作系统的历史脉络,以及各性能对比,以及内部工作机制,方便开发选择 欢迎大家点赞 👍 收藏 ⭐ 加关注哦!💖💖 U-Boot 和 Linux 内核的关系及设备树详解 一、U-Boot 和 Linux 内核的关系 系统启动流程全景图 ┌─────────────────────────────────────────────────────┐ │ 嵌入式系统启动流程 │ ├─────────────────────────────────────────────────────┤ │ 阶段 1:硬件复位 → BootROM(固化在芯片中) │ │ ↓ │ │ 阶段 2:U-Boot(第一阶段:SPL) │ │ ↓ │ │ 阶段 3:U-Boot(第二阶段:主程序) │ │ ↓ │ │ 阶段 4:Linux 内核(内核初始化)

By Ne0inhk
【Milvus】安装 Milvus:Docker、Docker Compose、Kubernetes

【Milvus】安装 Milvus:Docker、Docker Compose、Kubernetes

Milvus 提供了多种部署方式,包括 Docker(单机部署)、Docker Compose(单机多容器部署)以及 Kubernetes(分布式集群部署)。以下是对这三种安装方式的详细介绍,包括先决条件、步骤、配置文件和注意事项,帮助完成安装。 1. 先决条件 在安装 Milvus 之前,确保满足以下条件: 通用要求: * 操作系统:Linux(推荐 Ubuntu 20.04 或 CentOS 7+)、macOS 或 Windows(需要 WSL2 支持)。 * 硬件要求: * 单机模式(Docker 或 Docker Compose):至少 8GB 内存、4 核 CPU、

By Ne0inhk