一种libuv实现websockets服务的解决方案

方法是libuv用多事件循环来驱动。说起来容易，做起来还是比下面的方法更容易：

在这里插入图片描述

上图是某位网友的方法代表子大部分网络资料。此方法对部署不友好，因为软件仓库提供的libwebsockets是不能用了。如何简化部署，利用好现有的软件仓库呢？

libwebsockets版本历史

libwebsockets曾经是无缝支持libuv的。不过，随着版本号的增大，它对libuv的支持越来越差了。首先快速回顾下libwebsockets的版本历史：

  • v0.1.0 - 2011年9月：这是libwebsockets的第一个版本，它提供了基本的WebSocket协议支持，包括创建WebSocket连接、发送和接收消息等基本功能。
  • v0.2.0 - 2012年1月：这个版本添加了对HTTP协议的支持，使得libwebsockets可以处理HTTP请求和响应。此外，还添加了对多线程的支持，使得你可以在多个线程中安全地使用libwebsockets。
  • v0.3.0 - 2012年7月：这个版本添加了对SSL/TLS加密的支持，使得你可以使用安全连接来传输WebSocket消息。此外，还添加了一些新的API和功能，比如定时器和回调函数等。
  • v0.4.0 - 2013年1月：这个版本添加了对HyBi-17协议的支持，这是WebSocket协议的一个扩展版本，提供了更多的功能和更好的性能。此外，还修复了一些已知的漏洞和错误。
  • v0.5.0 - 2014年2月：这个版本添加了对多路复用和支持，这意味着你可以同时处理多个WebSocket连接。此外，还添加了一些新的API和功能，比如获取连接信息、处理文件上传等。
  • v1.0.0 - 2015年9月：这是libwebsockets的一个重要版本，它标志着libwebsockets已经成熟并稳定。这个版本添加了对HTTP/2协议的支持，同时优化了性能和内存使用。此外，还修复了一些已知的漏洞和错误。
  • v1.1.0 - 2016年3月：这个版本主要修复了一些已知的漏洞和错误，同时添加了一些新的功能和优化，比如更好的日志记录和内存管理。
  • v2.0.0 - 2018年8月：这是一个具有里程碑意义的版本，它引入了许多新的功能和改变。其中包括更好的多线程支持、对更多协议的支持（如Raw WebSocket、HyBi-17、HTTP等），以及对更多操作系统的支持。此外，它还改进了API设计，并修复了许多已知问题。
  • v2.1.0 - 2019年4月：这个版本主要修复了一些已知的漏洞和错误，同时添加了一些新的功能和优化，比如更好的SSL/TLS支持和对更多操作系统的支持。
  • v3.0.0 - 2020年5月：这个版本标志着libwebsockets进入了一个新的阶段。它引入了更多新的功能和改变，包括更好的多线程支持、对更多协议的支持（如Raw WebSocket、HyBi-17、HTTP等），以及对更多操作系统的支持。此外，它还改进了API设计，并修复了许多已知问题。从这个版本开始，事件循环对libuv的支持逐渐边缘化。

关键问题

  1. 从v3.0.0开始，lws_uv_initloop函数不存在。
  2. lws_context_create_info.options增加LWS_SERVER_OPTION_LIBUV导致lws_service函数崩溃。

复现问题的常规操作：

  1. 编译时开启LIBUV支持：在编译libwebsockets库时，需要开启LIBUV支持并指定LIBUV的目录位置。这可以通过修改CMakeLists.txt文件来实现。具体来说，需要在CMakeLists.txt文件中添加以下行：

    option(WITH_LIBUV "Enable libuv support" ON)  
find_package(libuv REQUIRED)  
include_directories(${LIBUV_INCLUDE_DIRS})  
link_directories(${LIBUV_LIBRARY_DIRS})  
add_definitions(-DLIBUV_SUPPORT=1)

    这将启用LIBUV支持，并自动搜索和链接LIBUV库。

  2. 修改线程模型：libwebsockets默认使用自己的线程模型，但可以使用libuv的线程模型替代。这需要在初始化libwebsockets时指定使用libuv线程模型。具体来说，需要在调用lws_create_context函数时，将thread_mode参数设置为LWS_THREAD_MODE_UV。例如：

    struct lws_context_creation_info info;  
memset(&info, 0, sizeof(info));  
info.port = 8000;  
info.protocols = protocols;  
info.thread_mode = LWS_THREAD_MODE_UV; // 使用libuv线程模型  
struct lws_context *context = lws_create_context(&info);

    这将告诉libwebsockets使用libuv的线程模型进行初始化。

  3. 使用libuv的API：在使用libwebsockets时，需要使用libuv提供的API来进行读写操作和事件处理。例如，可以使用uv_read_start和uv_write_t等函数来进行读写操作，使用uv_run函数来进行事件循环。这些函数将在libuv库中提供。例如：

    uv_stream_t *stream;  
uv_buf_t buf;  
uv_read_start(stream, on_read, &buf); // 开始读取操作  
uv_write(&req, stream, buf.base, nread, on_write); // 开始写入操作  
uv_run(uv_default_loop(), UV_RUN_DEFAULT); // 运行事件循环

解决思路

每个线程一个循环。可以在同一线程中使用多个事件循环。但这通常没有意义，因为一个循环的 uv_run() 调用将阻止并停止另一个循环的运行。通过仔细组合 uv_run(loop, UV_RUN_ONCE) 你可以做一些非常有趣的事情。您可以使用多个循环在程序中创建“模态”步骤，其中第二个事件循环“暂停”第一个事件循环，直到发生某些操作（用户按 Return 键或您收到新事件或其他事件）。

有一个非常具体的用例，可以使用两个事件循环作为同步机制来代替条件变量。当时 libuv 没有条件变量支持，现在我保持这种方式，以允许它与早期的节点版本一起使用。具体用例是：

  1. 主线程使用 uv_queue_work() 在工作线程中调用阻塞函数。
  2. 工作线程必须调用自定义函数。问题是自定义函数必须在主线程上运行。
  3. 工作线程必须等待该函数返回。

条件变量方法是：

  1. 工作线程不直接调用自定义函数。相反，它创建一个 uv_async_t 处理程序。此处理程序的回调调用自定义函数。
  2. 初始化条件变量。
  3. 它使用 uv_async_send() 来让主线程（事件循环运行的地方）代表它调用该函数。
  4. 等待条件变量。
  5. 回调调用自定义函数，然后向条件变量发出信号，让工作线程继续运行。

事件循环实现改为：

  1. 在工作线程中创建一个新的事件循环。
  2. 将 uv_async_t 与这个新循环关联起来。
  3. 通过原始 uv_async_t 处理程序的数据字段将此处理程序传递到主线程。
  4. uv_run() 新的事件循环，现在会阻塞，因为异步处理程序已经增加了它的 refcount 。
  5. 主线程中的回调调用自定义函数，然后使用 uv_async_send() 向新循环上的异步处理程序发出信号。
  6. 该异步处理程序的回调只是关闭处理程序本身，新循环的引用计数降至零，uv_run() 返回并且工作线程可以继续。

解决办法

下面的示例由TCP服务和websockets服务组成。TCP服务只是一个echo服务端，websockets则是静态文件服务，仅两个网页：index.html和404.html。

TCP线程

void tcp_thread_cb(void* args)
{uv_loop_t loop;uv_loop_init(&loop);struct sockaddr_in addr;uv_tcp_t server;int ierr = uv_tcp_init(&loop, &server);VOID_RETURN(ierr);ierr = uv_ip4_addr("0.0.0.0", IPORT, &addr);VOID_RETURN(ierr);ierr = uv_tcp_bind(&server, (const struct sockaddr*)&addr, 0);VOID_RETURN(ierr);ierr = uv_listen((uv_stream_t*)&server, 128, on_new_connection);VOID_RETURN(ierr);printf("server started.\n");ierr = uv_run(&loop, UV_RUN_DEFAULT);VOID_RETURN(ierr);uv_stop(&loop);uv_barrier_wait((uv_barrier_t*)args);
}

websockets线程

void websockets_thread_cb(void* args)
{static struct lws_context* context;static const struct lws_http_mount mounts[] = { {/* .mount_next */		NULL,		/* linked-list "next" *//* .mountpoint */		"/",		/* mountpoint URL *//* .origin */			".", /* serve from dir *//* .def */			"index.html",	/* default filename *//* .protocol */			NULL,/* .cgienv */			NULL,/* .extra_mimetypes */		NULL,/* .interpret */		NULL,/* .cgi_timeout */		0,/* .cache_max_age */		0,/* .auth_mask */		0,/* .cache_reusable */		0,/* .cache_revalidate */		0,/* .cache_intermediaries */	0,/* .origin_protocol */		LWSMPRO_FILE,	/* files in a dir *//* .mountpoint_len */		1,		/* char count *//* .basic_auth_login_file */	NULL,},{0,} };struct lws_context_creation_info info = { 0, };lws_set_log_level(LLL_USER | LLL_ERR | LLL_WARN | LLL_NOTICE, NULL);info.port = 20001;info.mounts = mounts;info.error_document_404 = "/404.html";info.options = LWS_SERVER_OPTION_HTTP_HEADERS_SECURITY_BEST_PRACTICES_ENFORCE;context = lws_create_context(&info);assert(context);lwsl_user("websockets started\n");while (1)lws_service(context, 0);lws_context_destroy(context);uv_barrier_wait((uv_barrier_t*)args);
}

主函数

int main(int argc, char** argv)
{uv_loop_t* loop = uv_default_loop();uv_thread_t t[2];uv_barrier_t b;uv_barrier_init(&b, 3);int ierr = uv_thread_create(&t[0], tcp_thread_cb, &b);RAISE_RETURN(ierr);ierr = uv_thread_create(&t[1], websockets_thread_cb, &b);RAISE_RETURN(ierr);ierr = uv_run(loop, UV_RUN_DEFAULT);RAISE_RETURN(ierr);uv_barrier_wait(&b);return 0;
}

通用部分

#include <uv.h>
#include <libwebsockets.h>
#include <stdio.h>
#include <malloc.h>
#include <assert.h>#define RAISE_RETURN(x) \if((x)) \{ \fprintf(stderr, "error {%s} code %ld %s\n", __func__, (long int)(x), uv_strerror(x)); \printf("error {%s} code %ld %s\n", __func__, (long int)(x), uv_strerror(x)); \raise(x); \return (x); \}
#define VOID_RETURN(x) \if((x)) \{ \fprintf(stderr, "error {%s} code %ld %s\n", __func__, (long int)(x), uv_strerror(x)); \printf("error {%s} code %ld %s\n", __func__, (long int)(x), uv_strerror(x)); \return; \}

验证

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

在这里插入图片描述

在这里插入图片描述

作者：岬淢箫声
日期：2023年11月7日
版本：1.0
链接：http://caowei.blog.csdn.net

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

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

相关文章

竞赛选题 深度学习手势识别算法实现 - opencv python

竞赛选题 深度学习手势识别算法实现 - opencv python

文章目录 1 前言2 项目背景3 任务描述4 环境搭配5 项目实现5.1 准备数据5.2 构建网络5.3 开始训练5.4 模型评估 6 识别效果7 最后 1 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 深度学习手势识别算法实现 - opencv python 该项目较为新颖…
阅读更多...
京东数据分析：2023年9月京东打印机行业品牌销售排行榜

京东数据分析：2023年9月京东打印机行业品牌销售排行榜

鲸参谋监测的京东平台9月份打印机市场销售数据已出炉&#xff01; 鲸参谋数据显示&#xff0c;今年9月&#xff0c;京东平台打印机的销量为60万&#xff0c;环比增长约32%&#xff0c;同比下滑约25%&#xff1b;销售额为5亿&#xff0c;环比增长约35%&#xff0c;同比下滑约29%…
阅读更多...
Microsoft Dynamics 365 CE 扩展定制 - 7. 安全

Microsoft Dynamics 365 CE 扩展定制 - 7. 安全

在本章中，我们将介绍以下内容： 构建累积安全角色配置业务单元层次结构基于分层位置配置访问配置和分配字段级安全组建团队并共享设置访问团队对静止数据进行加密以满足FIPS 140-2标准管理Dynamics 365在线SQLTDE加密密钥简介 Dynamics 365是一个强大的平台，具有超过10年的良…
阅读更多...
小程序如何设置自取模式下的服务方式

小程序如何设置自取模式下的服务方式

设置自取模式下的服务方式是非常重要的&#xff0c;尤其是对于到店自取和到店堂食这两种不同的服务模式。下面我们就来介绍一下如何在小程序中设置这两种服务方式。 在小程序管理员后台->配送设置处&#xff0c;在服务方式处&#xff0c;设置自取情况下的服务方式。默认是&…
阅读更多...
MSR015/MSR025低温漂、低功耗电压基准

MSR015/MSR025低温漂、低功耗电压基准

MSR015/MSR025 是低温漂、低功耗、高精度 CMOS 电压基准&#xff0c; 具有 0.05% 初始精度、低功耗特点。该器件的低输出电压迟滞和低长期输出电压 漂移特性&#xff0c;进一步提高稳定性和系统可靠性。 此外&#xff0c;器件的小尺寸和低运行 电流特性使其非常适合便携…
阅读更多...
微信小程序案例3-1 比较数字

微信小程序案例3-1 比较数字

文章目录 一、运行效果二、知识储备&#xff08;一&#xff09;Page()函数&#xff08;二&#xff09;数据绑定&#xff08;三&#xff09;事件绑定&#xff08;四&#xff09;事件对象&#xff08;五&#xff09;this关键字&#xff08;六&#xff09;setData()方法&#xff0…
阅读更多...
DocTemplateTool - 可根据模板生成word或pdf文件的工具

DocTemplateTool - 可根据模板生成word或pdf文件的工具

你是否经常遇到这样的场景&#xff1a;产品运营有着大量的报告需求&#xff0c;或者给客户领导展现每周的运营报告&#xff1f;这些文档类的任务可以交给运营同事&#xff0c;他们负责文档排版和样式&#xff0c;你作为开发人员你只需要提供数据源&#xff0c;和一个映射表&…
阅读更多...
数据结构(c语言版) 栈

数据结构(c语言版) 栈

顺序栈 要求&#xff1a;实现顺序栈的入栈&#xff0c;出栈&#xff0c;显示栈 代码 #include <stdio.h> #define MAXSIZE 100struct liststack{int data[MAXSIZE];int top; };//初始化栈 void init(struct liststack * LS){LS->top -1; }//入栈操作 void instack…
阅读更多...
Web3.0的测试题

Web3.0的测试题

任务&#xff1a; 在前端开发一个查询UI&#xff0c;查询当前用户账户的ETH余额和指定ERC20合约中的余额 目标&#xff1a; UI框架指定使用 MUI (https://mui.com)需要查询到当前账户的ETH余额并展示在UI界面上需要输入ERC20合约地址后&#xff0c;查询到到当前账户在此ERC20…
阅读更多...
简述SVM

简述SVM

概述 SVM&#xff0c;即支持向量机&#xff08;Support Vector Machine&#xff09;&#xff0c;是一种常见的监督学习算法&#xff0c;用于分类和回归问题。它是一种基于统计学习理论和结构风险最小化原则的机器学习方法。 SVM的主要思想是在特征空间中找到一个最优的超平面…
阅读更多...
怎么将pdf转换成word？

怎么将pdf转换成word？

怎么将pdf转换成word&#xff1f;将pdf文件转换成word是一件非常重要的转换技能&#xff0c;将pdf转换成word可以解决非常多的问题&#xff0c;总结起来主要有以下这些&#xff1a;编辑文本&#xff1a;① PDF文件通常是不可编辑的&#xff0c;而将其转换为Word格式后&#xff…
阅读更多...
微服务使用指南

微服务使用指南

微服务使用指南 1.初识微服务 微服务可以认为是一种分布式架构的解决方案&#xff0c;提供服务的独立性和完整性&#xff0c;做到服务的高内聚、低耦合。 目前服务架构主要包含&#xff1a;单体架构和分布式架构。 1.1 单体架构 单体架构&#xff1a;把所有业务功能模块都…
阅读更多...
小程序day04

小程序day04

目标 自定义组件 创建组件 引用组件 局部引用 全局引用 组件的函数定义到metods节点中&#xff0c;梦回vue2. 样式 数据&#xff0c;方法&#xff0c;属性 下划线开头的称为自定义方法&#xff0c;非下划线开头的都是事件处理函数。 神特么&#xff0c;this.datathis.pro…
阅读更多...
Databend 开源周报第 118 期

Databend 开源周报第 118 期

Databend 是一款现代云数仓。专为弹性和高效设计&#xff0c;为您的大规模分析需求保驾护航。自由且开源。即刻体验云服务&#xff1a;https://app.databend.cn 。 Whats On In Databend 探索 Databend 本周新进展&#xff0c;遇到更贴近你心意的 Databend 。 MERGE INTO 现已…
阅读更多...
Elasticsearch内存分析

Elasticsearch内存分析

文章目录 Elasticsearch JVM内存由哪些部分组成Indexing BufferNode Query CacheShard Request CacheField Data CacheSegments Cache查询 非堆内存内存压力mat分析es的jvm缓存监控 Elasticsearch JVM内存由哪些部分组成 官方建议Elasticsearch设置堆内存为32G&#xff0c;因为…
阅读更多...
Chrome 插件开发 V3版本 跨域处理

Chrome 插件开发 V3版本 跨域处理

插件构成 chrome 插件通常由以下几部分组成&#xff1a; manifest.json&#xff1a;相当于插件的 meta 信息&#xff0c;包含插件的名称、版本号、图标、脚本文件名称等&#xff0c;这个文件是每个插件都必须提供的&#xff0c;其他几部分都是可选的。 background script&…
阅读更多...
【大数据】NiFi 中的重要术语

【大数据】NiFi 中的重要术语

NiFi 中的重要术语 1.Flow Controller2.Processor3.Connection4.Controller Service5.Process Group6.FlowFile 那些一个个黑匣子称为 Processor&#xff0c;它们通过称为 Connection 的队列交换名为 FlowFile 的信息块。最后&#xff0c;FlowFile Controller 负责管理这些组件…
阅读更多...
服务器代码上云过程

服务器代码上云过程

一、前置要求 1.1 服务器端代码 需要有服务器端的代码&#xff0c;不然在云服务器&#xff08;云主机&#xff09;上运行啥嘞 1.2 云服务器&#xff08;云主机&#xff09; 需要有云服务器&#xff0c;因为云服务器会有公网IP&#xff0c;可以在任意地方进行访问。云服务器…
阅读更多...
Visual Studio Code将中文写入变量时，中文老是乱码问题

Visual Studio Code将中文写入变量时，中文老是乱码问题

对于这个问题&#xff0c;我也是弄了很久才知道&#xff0c;编码格式的问题 在此之前我们要先下载个插件 照这以上步骤&#xff0c;最后按F6运行即可&#xff0c;按F6是利用我们刚刚下载的插件进行编译&#xff0c;唯一有一点不好就是&#xff0c;用这种插件运行的话&#xff…
阅读更多...
App备案-iOS云管理式证书 Distribution Managed 公钥及证书SHA-1指纹的获取方法

App备案-iOS云管理式证书 Distribution Managed 公钥及证书SHA-1指纹的获取方法

根据近日工业和信息化部发布的《工业和信息化部关于开展移动互联网应用程序备案工作的通知》&#xff0c;相信不少要进行IOS平台App备案的朋友遇到了一个问题&#xff0c;就是apple不提供云管理式证书的下载&#xff0c;也就无法获取公钥及证书SHA-1指纹。 已经上架的应用不想重…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023