C语言网络编程：Socket、TCP/IP与客户端服务器通信实现

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

学习目标

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

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

学习目标

理解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>

int main() {
    int sockfd;
    struct sockaddr_in server_addr;

    
    sockfd = socket(AF_INET, SOCK_STREAM, );
     (sockfd < ) {
        perror();
         ;
    }

    
    (&server_addr, , (server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr();
    server_addr.sin_port = htons();

    
     (connect(sockfd, ( sockaddr*)&server_addr, (server_addr)) < ) {
        perror();
         ;
    }

    
     buffer[] = ;
     (send(sockfd, buffer, (buffer), ) < ) {
        perror();
         ;
    }

    
     (recv(sockfd, buffer, (buffer), ) < ) {
        perror();
         ;
    }
    (, buffer);

    
    close(sockfd);
     ;
}

#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> #define MAX_CLIENTS 5 struct Client { int sockfd; struct sockaddr_in addr; }; struct Client clients[MAX_CLIENTS]; int num_clients = 0; pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; void* handle_client(void* arg) { struct Client* client = (struct Client*)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); return NULL; } int main() { int sockfd, newsockfd; socklen_t clilen; struct sockaddr_in serv_addr, cli_addr; pthread_t tid; // 创建 socket sockfd = socket(AF_INET, SOCK_STREAM, 0); if (sockfd < 0) { perror("socket() error"); return 0; } // 初始化服务器地址结构 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, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) < 0) { perror("bind() error"); return 0; } // 监听连接 listen(sockfd, 5); clilen = sizeof(cli_addr); printf("等待客户端连接...\n"); while (1) { // 接受连接 newsockfd = accept(sockfd, (struct sockaddr*)&cli_addr, &clilen); if (newsockfd < 0) { perror("accept() error"); return 0; } // 添加客户端到客户端列表 pthread_mutex_lock(&mutex); if (num_clients >= MAX_CLIENTS) { printf("客户端数量已达到上限！\n"); close(newsockfd); pthread_mutex_unlock(&mutex); continue; } struct Client* client = (struct Client*)malloc(sizeof(struct Client)); 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); } // 关闭 socket close(sockfd); return 0; }

C语言网络编程：Socket、TCP/IP与客户端服务器通信实现