C
C语言网络编程入门：Socket编程、TCP/IP协议与通信实现
C语言网络编程涉及 Socket 接口、TCP/IP 协议分层及客户端服务器通信。内容包括流套接字与数据报套接字区别，TCP 与 UDP 实现代码示例，常见连接发送接收问题排查，以及多线程聊天室实战案例。重点掌握 socket 创建、绑定、监听、连接等核心 API 使用。
C语言网络编程涉及 Socket 接口、TCP/IP 协议分层及客户端服务器通信。内容包括流套接字与数据报套接字区别，TCP 与 UDP 实现代码示例，常见连接发送接收问题排查，以及多线程聊天室实战案例。重点掌握 socket 创建、绑定、监听、连接等核心 API 使用。
流套接字（SOCK_STREAM）：
数据报套接字（SOCK_DGRAM）：
代码示例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;
// 创建 socket
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
perror("socket() error");
return 0;
}
// 初始化服务器地址结构
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, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
perror("connect() error");
return 0;
}
// 发送数据
char buffer[1024] = "Hello, Server!";
if (send(sockfd, buffer, strlen(buffer), 0) < 0) {
perror("send() error");
return 0;
}
// 接收数据
if (recv(sockfd, buffer, sizeof(buffer), 0) < 0) {
perror("recv() error");
return 0;
}
printf("服务器返回：%s\n", buffer);
// 关闭 socket
close(sockfd);
return 0;
}
应用层：处理应用程序的请求和响应，如 HTTP、FTP、SMTP
传输层：负责数据的传输，如 TCP、UDP
网络层：负责数据的路由和寻址，如 IP、ICMP
数据链路层：负责数据的物理传输，如 Ethernet、WiFi
代码示例 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>
int main() {
int sockfd, newsockfd;
socklen_t clilen;
char buffer[1024];
struct sockaddr_in serv_addr, cli_addr;
// 创建 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");
newsockfd = accept(sockfd, (struct sockaddr*)&cli_addr, &clilen);
if (newsockfd < 0) {
perror("accept() error");
return 0;
}
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");
return 0;
}
printf("客户端发送：%s\n", buffer);
// 发送数据
strcpy(buffer, "Hello, Client!");
if (send(newsockfd, buffer, strlen(buffer), 0) < 0) {
perror("send() error");
return 0;
}
// 关闭 socket
close(newsockfd);
close(sockfd);
return 0;
}
代码示例 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>
int main() {
int sockfd;
socklen_t clilen;
char buffer[1024];
struct sockaddr_in serv_addr, cli_addr;
// 创建 socket
sockfd = socket(AF_INET, SOCK_DGRAM, 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;
}
// 接收数据
clilen = sizeof(cli_addr);
memset(buffer, 0, sizeof(buffer));
if (recvfrom(sockfd, buffer, sizeof(buffer), 0, (struct sockaddr*)&cli_addr, &clilen) < 0) {
perror("recvfrom() error");
return 0;
}
printf("客户端发送：%s\n", buffer);
// 发送数据
strcpy(buffer, "Hello, Client!");
if (sendto(sockfd, buffer, strlen(buffer), 0, (struct sockaddr*)&cli_addr, clilen) < 0) {
perror("sendto() error");
return 0;
}
// 关闭 socket
close(sockfd);
return 0;
}
问题：无法连接到服务器，导致程序崩溃
解决方法：
问题：无法发送数据到服务器，导致程序崩溃
解决方法：
问题：无法接收服务器返回的数据，导致程序崩溃
解决方法：
代码示例 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>
#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;
}
代码示例 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");
} else if (read_size < 0) {
perror("recv() error");
}
close(sockfd);
exit(0);
return NULL;
}
int main() {
int sockfd;
struct sockaddr_in server_addr;
char buffer[1024];
pthread_t tid;
// 创建 socket
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
perror("socket() error");
return 0;
}
// 初始化服务器地址结构
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, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
perror("connect() error");
return 0;
}
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");
return 0;
}
if (strcmp(buffer, "exit") == 0) {
close(sockfd);
return 0;
}
}
return 0;
}
✅ socket编程的基本概念：网络通信的接口，分为流套接字和数据报套接字
✅ TCP/IP协议的基本概念：网络通信的核心，分为应用层、传输层、网络层、数据链路层
✅ 客户端与服务器通信的实现：使用流套接字通信实现可靠的、面向连接的通信
✅ 数据报套接字通信的实现：使用数据报套接字通信实现不可靠的、无连接的通信
✅ 网络编程的避坑指南：避免语法错误、逻辑错误、连接失败、发送失败、接收失败、内存泄漏
✅ 实战案例分析：使用网络编程实现聊天程序，支持多个客户端同时连接
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online
将 Markdown（GFM）转为 HTML 片段，浏览器内 marked 解析；与 HTML转Markdown 互为补充。 在线工具，Markdown转HTML在线工具，online
将 HTML 片段转为 GitHub Flavored Markdown，支持标题、列表、链接、代码块与表格等；浏览器内处理，可链接预填。 在线工具，HTML转Markdown在线工具，online
通过删除不必要的空白来缩小和压缩JSON。 在线工具，JSON 压缩在线工具，online
将JSON字符串修饰为友好的可读格式。 在线工具，JSON美化和格式化在线工具，online