以下是使用libwebsockets库实现WebSocket的示例代码:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <libwebsockets.h>
#define MAX_MESSAGE_SIZE 4096
static int callback_echo(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len)
{
switch (reason) {
case LWS_CALLBACK_ESTABLISHED:
printf("Client connected\n");
break;
case LWS_CALLBACK_RECEIVE:
// 处理收到的消息
char message[MAX_MESSAGE_SIZE];
strncpy(message, (char *) in, sizeof(message)-1);
message[sizeof(message)-1] = '\0';
printf("Received message: %s\n", message);
// 发送回复消息
lws_write(wsi, (unsigned char *)message, strlen(message), LWS_WRITE_TEXT);
break;
default:
break;
}
return 0;
}
int main(void)
{
struct lws_context_creation_info info;
memset(&info, 0, sizeof(info));
info.port = CONTEXT_PORT_NO_LISTEN; // 不监听任何端口
info.protocols = NULL; // 使用默认协议列表
info.gid = -1;
info.uid = -1;
struct lws_context *context = lws_create_context(&info);
if (!context) {
printf("Failed to create libwebsocket context\n");
return 1;
}
struct lws_protocols protocols[] = {
{ "echo-protocol", callback_echo, 0 },
{ NULL, NULL, 0 }
};
struct lws_vhost *vhost = lws_create_vhost(context, &protocols[0]);
while (1) {
lws_service(context, 0);
}
lws_context_destroy(context);
return 0;
}
此示例创建了一个使用”echo-protocol”协议的WebSocket服务器,当有客户端连接时,会打印相关信息并处理收到的消息,并将相同的消息回复给客户端。您可以根据自己的需求进行修改和扩展。
请注意,此代码仅是一个简单的示例,并未包含完整的错误处理和异常情况处理,请在实际开发中进行适当调整和优化。另外,确保已正确安装libwebsockets库并添加必要的编译选项以链接该库。
内容由零声教学AI助手提供,问题来源于学员提问




