1、服务器程序
服务器的任务是等待客户端的连接请求,接受连接并进行数据通信。使用 socket()
创建一个 TCP 套接字。协议族选择 AF_INET
,传输类型选择 SOCK_STREAM
。使用 bind()
将套接字绑定到指定的端口和 IP 地址。通过 listen()
函数,让服务器开始监听客户端的连接请求。使用 accept()
函数接受客户端的连接请求,这会返回一个新的套接字用于与该客户端通信。:使用 read()
从客户端接收消息,然后通过 send()
将响应发送回客户端。通信完成后,关闭套接字。
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#define PORT 8080 // 服务器端口
#define BUFFER_SIZE 1024
int main() {
int server_fd, new_socket;
struct sockaddr_in address;
int addrlen = sizeof(address);
char buffer[BUFFER_SIZE] = {0};
// 创建套接字文件描述符
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
perror("socket failed");
exit(EXIT_FAILURE);
}
// 绑定IP和端口
address.sin_family = AF_INET;
address.sin_addr.s_addr = INADDR_ANY; // 允许来自任意地址的连接
address.sin_port = htons(PORT); // 将端口号转换为网络字节序
// 绑定套接字到端口
if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
perror("bind failed");
exit(EXIT_FAILURE);
}
// 开始监听连接请求
if (listen(server_fd, 3) < 0) {
perror("listen");
exit(EXIT_FAILURE);
}
printf("服务器正在监听端口 %d...\n", PORT);
// 等待客户端连接
if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
perror("accept");
exit(EXIT_FAILURE);
}
// 读取客户端发送的消息
int valread = read(new_socket, buffer, BUFFER_SIZE);
printf("接收到的消息: %s\n", buffer);
// 发送响应回客户端
send(new_socket, buffer, strlen(buffer), 0);
printf("消息已发送回客户端\n");
// 关闭套接字
close(new_socket);
close(server_fd);
return 0;
}
2、客户端程序
客户端的任务是向服务器发起连接,发送数据,并接收来自服务器的响应。使用 socket()
创建一个 TCP 套接字。通过 serv_addr
结构体设置服务器的 IP 地址和端口号。使用 connect()
连接到服务器。使用 send()
发送消息到服务器,使用 read()
接收来自服务器的响应。通信完成后,关闭套接字。
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#define PORT 8080
#define BUFFER_SIZE 1024
int main() {
int sock = 0;
struct sockaddr_in serv_addr;
char *message = "Hello, Server!";
char buffer[BUFFER_SIZE] = {0};
// 创建套接字
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
printf("套接字创建失败\n");
return -1;
}
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(PORT);
// 将IP地址转换为二进制形式
if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0) {
printf("无效的地址/地址不支持\n");
return -1;
}
// 连接到服务器
if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
printf("连接失败\n");
return -1;
}
// 发送消息到服务器
send(sock, message, strlen(message), 0);
printf("消息已发送: %s\n", message);
// 接收服务器的响应
int valread = read(sock, buffer, BUFFER_SIZE);
printf("从服务器接收到的消息: %s\n", buffer);
// 关闭套接字
close(sock);
return 0;
}
3、在 Linux 或 macOS 上编译运行
可以使用 GCC 编译器编译 C 语言代码。确保已经安装了 GCC 编译器,如果没有安装,可以通过命令安装。安装方法可以参考下面文档。
参考文档:GCC编译器安装
1)编译服务器和客户端程序
gcc server.c -o server
gcc client.c -o client
2)运行服务器
先启动服务器,它会监听指定的端口等待客户端连接。
./server
3)运行客户端
启动客户端,它会向服务器发送消息并接收响应。
./client
4、在 Windows 上编译运行
如在 Windows 上编写并运行套接字程序,需要包含 Winsock 库并调用 WSAStartup() 来初始化 Winsock。
1)使用 Visual Studio 或 CodeBlocks 编译程序,需要在程序中添加代码
#include <winsock2.h>
WSADATA wsa;
WSAStartup(MAKEWORD(2,2),&wsa);
2)在完成工作后记得调用 WSACleanup() 清理 Winsock 资源
WSACleanup();