libwebsocket建立服务器需要编写LWS_CALLBACK_ADD_HEADERS事件处理

最近在使用libwebsocket,感觉它搭建Http与websocket服务器比较简单,不像poco库那么庞大,但当我使用它建立websocket服务器后,发现websocket客户端连接一直没有连接成功,不知道什么原因,经过一天的调试,终于搞通,因此记录一下被坑的一天,以下是调通的完整DEMO:

#include <libwebsockets.h>
#include <stdio.h>
#include <string.h>/* 定义支持的协议 */
enum protocols {PROTOCOL_HTTP = 0,PROTOCOL_CHAT,PROTOCOL_JSON,PROTOCOL_COUNT
};/* WebSocket 协议回调函数 */
static int callback_chat(struct lws* wsi, enum lws_callback_reasons reason, void* user, void* in, size_t len) {printf("callback_chat %d\n", reason);switch (reason) {case LWS_CALLBACK_ESTABLISHED:printf("[Chat] 客户端连接成功 (协议: %s)\n", lws_get_protocol(wsi)->name);break;case LWS_CALLBACK_RECEIVE:printf("[Chat] 收到消息: %.*s\n", (int)len, (char*)in);// 回声lws_write(wsi, (unsigned char*) in, len, LWS_WRITE_TEXT);break;default:break;}return 0;
}static int callback_json(struct lws* wsi, enum lws_callback_reasons reason, void* user, void* in, size_t len) {printf("callback_json %d\n", reason);switch (reason) {case LWS_CALLBACK_ESTABLISHED:printf("[JSON] 客户端连接成功 (协议: %s)\n", lws_get_protocol(wsi)->name);break;case LWS_CALLBACK_RECEIVE:printf("[JSON] 收到消息: %.*s\n", (int)len, (char*)in);// 返回 JSON 响应const char* response = "{\"status\":\"ok\",\"data\":\"received\"}";lws_write(wsi, (unsigned char*)response, strlen(response), LWS_WRITE_TEXT);break;}return 0;
}/* HTTP 回调函数(处理非 WebSocket 请求) */
static int callback_http(struct lws* wsi, enum lws_callback_reasons reason, void* user, void* in, size_t len) {printf("callback_http %d\n", reason);switch (reason) {case LWS_CALLBACK_HTTP: {printf("收到 HTTP 请求: %s\n", (char*)in);}case LWS_CALLBACK_ESTABLISHED:printf("收到 websocket连接成功\n");lws_callback_on_writable(wsi);break;case LWS_CALLBACK_SERVER_WRITEABLE:printf("收到 LWS_CALLBACK_SERVER_WRITEABLE len:%u user:%d in:%d\n", len, user, in);if (len > 0){printf("收到 LWS_CALLBACK_SERVER_WRITEABLE data:%s\n", (char*)in);lws_write(wsi, (unsigned char*)in, len, LWS_WRITE_TEXT);}break;case LWS_CALLBACK_ADD_HEADERS: {struct lws_process_html_args* args =(struct lws_process_html_args*)in;printf("收到 LWS_CALLBACK_ADD_HEADERS data:%s\n", (char*)&args->p);if (lws_add_http_header_by_name(wsi,NULL,NULL, 0,(unsigned char**)&args->p,(unsigned char*)args->p + args->max_len))//必须要调用此函数后libwebsocket才会发出数据,也就是说如果要发送HTTP 101状态数据时,要调用这个才会发出return 1;break;}default:break;}return 0;
}static int callback_text(struct lws* wsi, enum lws_callback_reasons reason, void* user, void* in, size_t len) {printf("callback_text %d\n", reason);//switch (reason) {//default://    break;//}return 0;
}
static int callback_websocket(struct lws* wsi, enum lws_callback_reasons reason, void* user, void* in, size_t len) {printf("callback_websocket %d\n", reason);//switch (reason) {//default://    break;//}return 0;
}/* 协议列表 */
static struct lws_protocols protocols[] = {/* 第一个协议必须用于 HTTP */{"http",callback_http,0,0},/* WebSocket 协议 */{"chat",callback_chat,0,1024},{"json",callback_json,0,1024},{"text",callback_text,0,1024},{"websocket",callback_websocket,0,1024},{ NULL, NULL, 0, 0 } // 结束标记
};int main() {struct lws_context_creation_info info;memset(&info, 0, sizeof(info));/* 基本配置 */info.port = 9002;                           // 监听端口info.protocols = protocols;                 // 协议列表info.gid = -1;info.uid = -1;info.options = LWS_SERVER_OPTION_DO_SSL_GLOBAL_INIT; // 启用 SSL(可选)info.options |= LWS_SERVER_OPTION_ALLOW_NON_SSL_ON_SSL_PORT;//info.options |= LWS_SERVER_OPTION_LOG_ALL;/* 创建上下文 */struct lws_context* context = lws_create_context(&info);if (!context) {fprintf(stderr, "libwebsockets 初始化失败\n");return -1;}printf("服务器启动,监听端口 9002...\n");printf("测试命令:\n");printf("  - WebSocket (Chat): wscat -c ws://localhost:9002 -p chat\n");printf("  - WebSocket (JSON): wscat -c ws://localhost:9002 -p json\n");printf("  - HTTP: curl http://localhost:9002\n");/* 事件循环 */while (1) {lws_service(context, 0);}lws_context_destroy(context);return 0;
}

需要值得注意的是,必须要写LWS_CALLBACK_ADD_HEADERS事件的代码,libwesocket才会发送“HTTP/1.1 101 Switching Protocols\r\n”协议,让客户端连接成功,否则客户端认为一直不能连接成功。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/77069.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

从 PyTorch 到 ONNX:深度学习模型导出全解析

在模型训练完毕后&#xff0c;我们通常希望将其部署到推理平台中&#xff0c;比如 TensorRT、ONNX Runtime 或移动端框架。而 ONNX&#xff08;Open Neural Network Exchange&#xff09;正是 PyTorch 与这些平台之间的桥梁。 本文将以一个图像去噪模型 SimpleDenoiser 为例&a…

Hadoop集群部署教程-P6

Hadoop集群部署教程-P6 Hadoop集群部署教程&#xff08;续&#xff09; 第二十一章&#xff1a;监控与告警系统集成 21.1 Prometheus监控体系搭建 Exporter部署&#xff1a; # 部署HDFS Exporter wget https://github.com/prometheus/hdfs_exporter/releases/download/v1.1.…

【Altium】AD-生成PDF文件图纸包含太多的空白怎么解决

1、 文档目标 AD设计文件导出PDF时&#xff0c;图纸模板方向设置问题 2、 问题场景 AD使用Smart PDF导出PDF时&#xff0c;不管你怎么设置页面尺寸&#xff0c;只要从横向转为纵向输出&#xff0c;输出的始终是横向纸张&#xff08;中间保留纵向图纸&#xff0c;两边大量留白…

大厂面试:六大排序

前言 本篇博客集中了冒泡&#xff0c;选择&#xff0c;二分插入&#xff0c;快排&#xff0c;归并&#xff0c;堆排&#xff0c;六大排序算法 如果觉得对你有帮助&#xff0c;可以点点关注&#xff0c;点点赞&#xff0c;谢谢你&#xff01; 1.冒泡排序 //冒泡排序&#xff…

大模型开发:源码分析 Qwen 2.5-VL 视频抽帧模块(附加FFmpeg 性能对比测试)

目录 qwen 视频理解能力 messages 构建 demo qwen 抽帧代码分析 验证两个实际 case 官网介绍图 性能对比&#xff1a;ffmpeg 抽帧、decord 库抽帧 介绍 联系 对比 测试结果 测试明细 ffmpeg 100 qps 测试&#xff08;CPU&#xff09; decord 100 qps 测试&#x…

git的上传流程

好久没使用git 命令上传远程仓库了。。。。。温习了一遍&#xff1b; 几个注意点--单个文件大小不能超过100M~~~ 一步步运行下面的命令&#xff1a; 进入要上传的文件夹内&#xff0c;点击git bash 最终 hbu的小伙伴~有需要nndl实验的可以自形下载哦

驱动学习专栏--字符设备驱动篇--2_字符设备注册与注销

对于字符设备驱动而言&#xff0c;当驱动模块加载成功以后需要注册字符设备&#xff0c;同样&#xff0c;卸载驱动模 块的时候也需要注销掉字符设备。字符设备的注册和注销函数原型如下所示 : static inline int register_chrdev(unsigned int major, const char *name, const…

redis 放置序列化的对象,如果修改对象,需要修改版本号吗?

在 Redis 中存储序列化对象时,如果修改了对象的类结构(例如增删字段、修改字段类型或顺序),是否需要修改版本号取决于序列化协议的兼容性策略和业务场景的容错需求。以下是详细分析: 1. 为什么需要考虑版本号? 序列化兼容性问题: 当对象的类结构发生变化时,旧版本的序列…

WPF ObjectDataProvider

在 WPF(Windows Presentation Foundation)中,ObjectDataProvider 是一个非常有用的类,用于将非 UI 数据对象(如业务逻辑类或服务类)与 XAML 绑定集成。它允许在 XAML 中直接调用方法、访问属性或实例化对象,而无需编写额外的代码。以下是关于 ObjectDataProvider 的详细…

深度学习-损失函数 python opencv源码(史上最全)

目录 定义 种类 如何选择损失函数&#xff1f; 平方&#xff08;均方&#xff09;损失函数&#xff08;Mean Squared Error, MSE&#xff09; 均方根误差 交叉熵 对数损失 笔记回馈 逻辑回归中一些注意事项&#xff1a; 定义 损失函数又叫误差函数、成本函数、代价函数…

poll为什么使用poll_list链表结构而不是数组 - 深入内核源码分析

一&#xff1a;引言 在Linux内核中,poll机制是一个非常重要的I/O多路复用机制。它允许进程监视多个文件描述符,等待其中任何一个进入就绪状态。poll的内部实现使用了poll_list链表结构而不是数组,这个设计选择背后有其深层的技术考量。本文将从内核源码层面深入分析这个设计决…

使用 Azure AKS 保护 Kubernetes 部署的综合指南

企业不断寻求增强其软件开发和部署流程的方法。DevOps 一直是这一转型的基石,弥合了开发与运营之间的差距。然而,随着安全威胁日益复杂,将安全性集成到 DevOps 流水线(通常称为 DevSecOps)已变得势在必行。本指南深入探讨了如何使用 Azure Kubernetes 服务 (AKS) 来利用 D…

2025年常见渗透测试面试题-webshell免杀思路(题目+回答)

网络安全领域各种资源&#xff0c;学习文档&#xff0c;以及工具分享、前沿信息分享、POC、EXP分享。不定期分享各种好玩的项目及好用的工具&#xff0c;欢迎关注。 目录 webshell免杀思路 PHP免杀原理 webshell免杀测试&#xff1a; webshell免杀绕过方法&#xff1a; 编…

访问不到服务器上启动的llamafactory-cli webui

采用SSH端口转发有效&#xff0c;在Windows上面进行访问 在服务器上启动 llamafactory-cli webui 后&#xff0c;访问方式需根据服务器类型和网络环境选择以下方案&#xff1a; 一、本地服务器&#xff08;物理机/虚拟机&#xff09; 1. 直接访问 若服务器与操作设备处于同一…

基于 LSTM 的多特征序列预测-SHAP可视化!

往期精彩内容&#xff1a; 单步预测-风速预测模型代码全家桶-CSDN博客 半天入门&#xff01;锂电池剩余寿命预测&#xff08;Python&#xff09;-CSDN博客 超强预测模型&#xff1a;二次分解-组合预测-CSDN博客 VMD CEEMDAN 二次分解&#xff0c;BiLSTM-Attention预测模型…

C++ 编程指南35 - 为保持ABI稳定,应避免模板接口

一&#xff1a;概述 模板在 C 中是编译期展开的&#xff0c;不同模板参数会生成不同的代码&#xff0c;这使得模板类/函数天然不具备 ABI 稳定性。为了保持ABI稳定&#xff0c;接口不要直接用模板&#xff0c;先用普通类打个底&#xff0c;模板只是“外壳”&#xff0c;这样 AB…

【iOS】OC高级编程 iOS多线程与内存管理阅读笔记——自动引用计数(二)

自动引用计数 前言ARC规则所有权修饰符**__strong修饰符**__weak修饰符__unsafe_unretained修饰符__autoreleasing修饰符 规则属性数组 前言 上一篇我们主要学习了一些引用计数方法的内部实现&#xff0c;现在我们学习ARC规则。 ARC规则 所有权修饰符 OC中&#xff0c;为了处…

可信空间数据要素解决方案

可信空间数据要素解决方案 一、引言 随着数字经济的蓬勃发展&#xff0c;数据已成为重要的生产要素。可信空间数据要素解决方案旨在构建一个安全、可靠、高效的数据流通与应用环境&#xff0c;促进数据要素的合理配置和价值释放&#xff0c;推动各行业的数字化转型和创新发展…

mysql删除表后重建表报错Tablespace exists

版本 mysql:8.0.23 复现步骤 1、删除表 DROP TABLE IF EXISTS xxx_demo; 2、新建表 CREATE TABLE xxx_demo (id bigint NOT NULL AUTO_INCREMENT COMMENT 主键id,creator varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT COMMENT 创建者,c…

【Leetcode-Hot100】缺失的第一个正数

题目 解答 有一处需要注意&#xff0c;我使用注释部分进行交换值&#xff0c;报错&#xff1a;超出时间限制。有人知道是为什么吗&#xff1f;难道是先给nums[i]赋值后&#xff0c;从而改变了后一项的索引&#xff1f; class Solution(object):def firstMissingPositive(sel…