以下是使用C语言实现一个简单的WebSocket服务器的基本示例代码:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#define MAX_CLIENTS 10
#define BUFFER_SIZE 1024
int main() {
int serverSocket, clientSockets[MAX_CLIENTS], maxClients = MAX_CLIENTS;
struct sockaddr_in serverAddress, clientAddress;
char buffer[BUFFER_SIZE];
// 创建服务器套接字
if ((serverSocket = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror("Failed to create socket");
exit(1);
}
// 设置服务器地址和端口
serverAddress.sin_family = AF_INET;
serverAddress.sin_addr.s_addr = INADDR_ANY;
serverAddress.sin_port = htons(8080);
// 绑定套接字到指定地址和端口
if (bind(serverSocket, (struct sockaddr *)&serverAddress, sizeof(serverAddress)) == -1) {
perror("Failed to bind socket");
exit(1);
}
// 开始监听连接请求
if (listen(serverSocket, maxClients) == -1) {
perror("Error in listen");
exit(1);
}
printf("WebSocket Server running on port 8080\n");
while (1) {
socklen_t clientLength = sizeof(clientAddress);
int newSocket;
// 等待客户端连接请求
if ((newSocket = accept(serverSocket, (struct sockaddr *)&clientAddress,
&clientLength)) == -1) {
perror("Error in accepting connection");
exit(1);
}
printf("New connection accepted\n");
// 接收和发送数据
while (1) {
memset(buffer, 0, BUFFER_SIZE);
// 接收客户端发送的消息
if (recv(newSocket, buffer, BUFFER_SIZE - 1, 0) == -1) {
perror("Error in receiving data");
exit(1);
}
printf("Received message: %s\n", buffer);
// 发送回复消息给客户端
const char *response = "Hello from WebSocket server!";
if (send(newSocket, response, strlen(response), 0) == -1) {
perror("Error in sending data");
exit(1);
}
}
}
// 关闭套接字
for (int i = 0; i < maxClients; i++) {
close(clientSockets[i]);
}
close(serverSocket);
return 0;
}
这只是一个简单示例,用于监听来自客户端的连接请求并发送回复消息。在实际应用中,您可能需要根据WebSocket协议规范处理更多细节,并实现WebSocket的握手过程、帧解析和数据处理等功能。
内容由零声教学AI助手提供,问题来源于学员提问