深入理解 Cowboy WebSocket：使用 Erlang/OTP 构建高效的即时通讯(IM)应用

深入理解 Cowboy WebSocket：使用 Erlang/OTP 构建高效的即时通讯(IM)应用

引言

实时通信技术在现代 Web 应用中扮演着核心角色，而 WebSocket 作为其中的关键技术，已成为即时通讯(IM)系统不可或缺的一部分。Cowboy，这个基于 Erlang/OTP 的轻量级 HTTP 服务器框架，以其强大且用户友好的 WebSocket 功能，为开发者提供了构建高效 IM 应用的利器。本文将深入分析如何利用 Cowboy WebSocket 来打造高性能的即时通讯解决方案。

Cowboy 高效的理由

构建在现代Web应用基础上的Cowboy，利用Erlang/OTP框架的强大功能，提供了一系列的高效特性，这些特性使其成为开发高性能即时通讯(IM)应用的理想选择：

  1. 轻量级架构：
    Cowboy建立在Ranch之上，采用每连接一个进程的模型，这不仅简化了并发处理，还降低了内存占用，因为进程可以在处理多个请求时被重用。

  2. 高效的二进制处理：
    与字符串相比，二进制数据处理在性能上更为高效和节省资源。Cowboy充分利用Erlang的二进制模式，优化了数据传输和处理。

  3. 智能连接管理：
    Cowboy默认配置了足够大的最大活动连接数，有效防止了大量进程处理繁重任务时对系统资源和内存的过度消耗。对于短连接请求，通过设置{max_connections, infinity}，可以极大提升性能。

  4. HTTP/2的透明支持：
    HTTP/2作为一种高效的Web服务协议，Cowboy为其提供了透明支持，包括保持连接打开、并发请求处理以及通过头部压缩减少请求大小等特性。

  5. WebSocket的完全控制：
    Cowboy的Websocket处理程序接口允许开发者完全控制Websocket连接，包括自定义协议实现和消息处理。

  6. 自动超时和连接关闭：
    通过设置超时，Cowboy能够自动关闭空闲连接，避免不必要的资源占用。同时，Cowboy在回调返回后使连接进程进入休眠状态，进一步减少了内存使用。

  7. 长轮询和服务器发送事件支持：
    Cowboy提供了接口支持长轮询和服务器发送事件，有助于实现高效的数据传输和实时通信。

  8. RESTful API简化实现：
    Cowboy提供的REST处理程序接口简化了在HTTP协议上REST API的实现，使开发者可以更专注于业务逻辑。

  9. 内存优化：
    通过在回调返回后使连接进程进入休眠状态，Cowboy显著降低了内存占用，同时在CPU使用或延迟上可能有所增加，但这对于大量并发连接的服务器来说是一个可接受的权衡。

  10. 动态超时设置：
    Cowboy允许开发者根据客户端网络状况动态设置WebSocket的idle timeout值，提供了更灵活的连接管理。

  11. Websocket协议的广泛支持：
    Cowboy支持Websocket协议的所有标准，包括通过Autobahn测试套件的验证，证明了其高性能和符合标准的实现。

  12. 压缩扩展：
    Cowboy的Websocket实现包括permessage-deflate和x-webkit-deflate-frame压缩扩展，进一步减少了传输数据的大小。

通过这些高效的特性，Cowboy WebSocket 成为了构建高性能、低延迟的即时通讯应用的强大工具。开发者可以利用这些特性，构建出既快速又可靠的实时通信系统。

Websocket Handler 架构

IMBoy 的 websocket_handler.erl 模块通过实现 cowboy_websocket 行为来管理 WebSocket 连接。以下是关键组件的概览：

  • init/2：初始化请求处理。
  • websocket_init/1：WebSocket 连接建立后的初始化操作。
  • websocket_handle/2：处理 WebSocket 接收到的消息。
  • websocket_info/2：处理从其他进程发送到 WebSocket 进程的消息。
  • terminate/3：关闭 WebSocket 连接时的资源清理。

websocket_handler.erl 代码解析

以下是对 websocket_handler.erl 代码片段的解析：

1. 模块定义与行为引入：

-module(websocket_handler).
-behavior(cowboy_websocket).

定义了名为 websocket_handler 的模块，并引入了名为 cowboy_websocket 的 behavior。

2. 导出函数：

-export([init/2]).
-export([websocket_init/1]).
-export([websocket_handle/2]).
-export([websocket_info/2]).
-export([terminate/3]).

这些函数分别对应 WebSocket 生命周期的不同阶段。

3. WebSocket 初始化握手 (init/2)：

在此阶段，我们从请求中提取关键信息（如设备 ID、版本号等），并根据这些信息配置 WebSocket。

3.1 客户端连接频率控制：

首先，检查客户端设备 ID 的连接频率。配置文件中设定了每秒 2 次、每分钟 20 次的限制。

case throttle:check(throttle_ws, DID) of{limit_exceeded, _, _} ->imboy_log:warning("DeviceID ~p exceeded api limit", [DID]),Req = cowboy_req:reply(429, Req0),{ok, Req, State0};_ ->% ... 代码省略
end.
3.2 WebSocket 子协议升级：

频率检查通过后，检查 sec-websocket-protocol 请求头，确保其为非空列表。IMBoy 采用列表中的第一个元素（例如 “text”），并设置响应头。

check_subprotocols([H | _Tail], Req0) ->Req = cowboy_req:set_resp_header(<<"sec-websocket-protocol">>, H, Req0),{cowboy_websocket, Req}.
3.3 校验 Authorization：

子协议检查通过后，校验 authorization 请求头中的 JWT 令牌。验证成功后，将当前用户 UID 写入状态参数 State，供后续使用。

auth_after(Uid, Req, State, Opt) ->Timeout = idle_timeout(Uid),{cowboy_websocket, Req, State#{current_uid => Uid}, Opt#{idle_timeout := Timeout}}.
3.4 动态设置 WebSocket 的 idle timeout 值：

设想根据客户端网络状况动态计算 idle timeout 值（该功能尚未实现，但值得期待）。

% 设置用户 WebSocket 超时时间，默认为 60 秒
% Cowboy 默认在 128 秒后关闭空闲连接，此处设置为 60000
idle_timeout(_Uid) ->60000.

4. 连接初始化 (websocket_init/1)：

一旦 WebSocket 连接建立，可以执行一些初始化操作，例如记录用户上线、获取离线消息等。

5. 消息处理 (websocket_handle/2)：

在此处理客户端发送的各种消息。例如，对于 ping 消息，回复 pong；对于文本消息，根据消息类型调用相应的处理函数。

5.1 客户端消息确认方法：
  • 消息格式为 CLIENT_ACK,type,msgid,did，例如前缀 "CLIENT_ACK," 后跟消息类型、消息唯一 ID 和设备 ID。
  • 检查缓存系统中是否有相关消息的计时器引用，如果有，取消计时器并删除缓存。
  • 根据消息类型清理离线消息。

相关代码如下：

% 客户端确认消息
% 格式：CLIENT_ACK,type,msgid,did
websocket_handle({text, <<"CLIENT_ACK,", Tail/binary>>}, State) ->CurrentUid = maps:get(current_uid, State),try binary:split(Tail, <<",">>, [global]) of[Type, MsgId, DID] ->Key = {CurrentUid, DID, MsgId},% 缓存设置在 message_ds:send_next/5 中case imboy_cache:get(Key) ofundefined ->ok;{ok, TimerRef} ->erlang:cancel_timer(TimerRef),imboy_cache:flush(Key)end,% ... 根据消息类型处理
end.
5.2 处理 WebSocket 消息：

根据接收到的文本消息类型，调用不同的逻辑处理函数。

websocket_handle({text, Msg}, State) ->% ... 解码消息、获取当前用户 UID% 根据消息类型分发处理逻辑case cowboy_bstr:to_lower(Type) of<<"c2c">> ->  % 单聊消息websocket_logic:c2c(MsgId, CurrentUid, Data);% ... 其他消息类型处理end;
% ... 其他处理分支

6. 信息处理 (websocket_info/2)：

处理从 Erlang 系统发送到 WebSocket 进程的消息，例如超时消息或关闭连接请求。

  • 处理超时消息：
websocket_info({timeout, _Ref, Msg}, State) ->{reply, {text, Msg}, State, hibernate};

当超时发生时，回复文本消息，并保持挂起状态以节省资源。

  • 服务端主动关闭连接处理：
websocket_info({close, CloseCode, Reason}, State) ->{reply, {close, CloseCode, Reason}, State};
websocket_info(stop, State) ->{stop, State};

7. 连接终止 (terminate/3)：

在连接终止时，根据关闭原因执行清理操作，如记录用户下线。

terminate(Reason, _Req, State) ->% ... 执行清理操作
end;

WebSocket vs AMQP vs MQTT

在选择适合 IM 应用的协议时，需考虑以下因素：

  • 实时性：WebSocket 提供最低延迟和最高实时性。
  • 复杂性：AMQP 提供丰富消息模式，但配置和实现较复杂。
  • 轻量级：MQTT 适合资源受限环境，但全双工通信受限。

结论

Cowboy WebSocket 提供了高效、简洁的方法来实现实时 Web 通信，特别适合需要快速交互的 IM 应用。通过深入理解其实现原理和生命周期管理，开发者可以构建高性能的实时通信系统。

希望通过本文的分析和代码示例，能帮助不同经验水平的开发者更好地理解和使用 Cowboy WebSocket，从而在项目中实现高效、稳定的实时通信功能。

欢迎关注 IMBoy 开源项目 https://gitee.com/imboy-pub。

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

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

相关文章

2024QS世界大学学科排名（各学科详细）

2024QS世界大学学科排名（各学科详细）

2024QS全球高校学科排名附榜单&#xff1a; 人文与艺术相关学科全球Top10 社会科学与管理相关学科全球Top10 自然科学相关学科全球Top10 工程与技术相关学科全球Top10 生命科学与医学相关学科全球Top10
阅读更多...
Flutter 是如何实现的 ？

Flutter 是如何实现的 ？

Flutter 是由 Google 开发的一个开源 UI 软件开发工具包&#xff0c;用于构建跨平台的应用程序。Flutter 的核心理念是提供一个高度可定制、快速和现代的 UI 框架&#xff0c;它允许开发者使用一套代码库构建 Android、iOS、Web 和桌面应用程序。以下是 Flutter 的一些关键实现…
阅读更多...
【基于R语言群体遗传学】-14-种群起源的相对似然

【基于R语言群体遗传学】-14-种群起源的相对似然

我们可以将预测的基因型比例视为在种群中看到一组特定等位基因的概率。如果种群在等位基因频率上存在差异&#xff0c;我们可以使用基因型来推断个体起源于每个种群的相对可能性。大家可以先看一下之前的博客&#xff1a;群体遗传学_tRNA做科研的博客-CSDN博客 种群起源的相对似…
阅读更多...
Python OpenCV 教学取得视频资讯

Python OpenCV 教学取得视频资讯

这篇教学会介绍使用OpenCV&#xff0c;取得影像的长宽尺寸、以及读取影像中某些像素的颜色数值。 因为程式中的OpenCV 会需要使用镜头或GPU&#xff0c;所以请使用本机环境( 参考&#xff1a;使用Python 虚拟环境) 或使用Anaconda Jupyter 进行实作( 参考&#xff1a;使用Anaco…
阅读更多...
基于Python的51job招聘数据采集与可视化项目实践

基于Python的51job招聘数据采集与可视化项目实践

项目背景与目标 在当今竞争激烈的就业市场中&#xff0c;深入分析招聘信息对于求职者和企业都具有重要意义。基于Python的51job招聘数据采集与可视化项目旨在通过自动化手段高效获取大量招聘信息&#xff0c;并对这些数据进行深度分析和展示。 51job作为中国领先的招聘网站&…
阅读更多...
RockyLinux9上安装Nacos2.3.0（非Docker安装）

RockyLinux9上安装Nacos2.3.0（非Docker安装）

RockyLinux9上安装Nacos2.3.0 说明什么是Nacos下载并安装创建一个nacos-conf数据库修改application.properties文件 启动访问网址查看是否成功 开启访问鉴权 说明 本文采用的是&#xff1a;安装包安装&#xff0c;非Docker安装&#xff0c;系统采用的Rocky Linux9.4。   当前…
阅读更多...
C++ 【 Open3D 】 读取、可视化并保存点云

C++ 【 Open3D 】 读取、可视化并保存点云

一、读取常见点云 #include <iostream> #include <Open3D/Open3D.h>int main(int argc, char* argv[]) {std::string fileName("hand.pcd");auto cloud_ptr std::make_shared<open3d::geometry::PointCloud>();if (open3d::io::ReadPointCloud(f…
阅读更多...
警钟！电池储能安全事故频发！物联网技术如何加强储能安全排查？

警钟！电池储能安全事故频发！物联网技术如何加强储能安全排查？

在新能源时代背景下&#xff0c;储能系统作为能源转型的关键支撑技术&#xff0c;其安全问题日益凸显&#xff0c;尤其是近期海外电池项目连续发生的事故&#xff0c;为全球储能行业敲响了警钟。面对这一挑战&#xff0c;物联网技术以其强大的数据采集、智能分析与远程监控能力…
阅读更多...
Python基础知识——（002）

Python基础知识——（002）

文章目录 P8——7. input函数的使用 基本的输入函数input P9——8. Python中的注释 P10——9. Python中的缩进与本章总结 本章总结 P11——10. 章节习题 P8——7. input函数的使用 基本的输入函数input 语法结构&#xff1a; x input(提示文字) 注意事项&#xff1a;无论输…
阅读更多...
PMON的解读和开发

PMON的解读和开发

提示&#xff1a;龙芯2K1000PMON相关记录 文章目录 1 PMON的发展和编译环境PMONPMON2000 2 PMON2000的目录结构3 Targets目录的组成4 PMON编译环境的建立5 PMON2000的框架6 异常向量表7 Pmon的空间分配8 PMON的汇编部分(starto.S或sbdreset.S)的解读Start.SC代码部分dbginit 9 …
阅读更多...
【Adobe】Adobe Dimension 3D渲染和设计软件

【Adobe】Adobe Dimension 3D渲染和设计软件

一、Adobe Dimension软件介绍 1. 软件背景与功能 Adobe Dimension最初于1994年推出&#xff0c;最初称为“QuarkXPress 3D”&#xff0c;后逐渐发展为现在的Adobe Dimension。作为Adobe Creative Suite的一部分&#xff0c;Dimension与其他Adobe创意软件&#xff08;如Photos…
阅读更多...
点云曲面提取

点云曲面提取

csdn是不是有有什么大bing&#xff1f;gif只能上传5m我吐了在线GIF动图压缩 - docsmall 在线GIF动图压缩工具,在线GIF动图压缩软件 代码整理中
阅读更多...
单元测试Spring 上下文加载过程中遇到的阻塞或死锁问题

单元测试Spring 上下文加载过程中遇到的阻塞或死锁问题

IDEA单元测试一直转圈&#xff0c;阻塞&#xff0c;前置后置的方法都不执行&#xff0c;无任何输出 1.单元测试类 SpringBootTest(classes {BareMetalApplication.class}) RunWith(SpringRunner.class) public class K8sUserNfsStoreInitServiceImplTest {BeforeEachpublic…
阅读更多...
全域数据处理

全域数据处理

#!/usr/bin/env python # coding: utf-8# In[6]:# encoding=utf-8 # encoding=utf-8 import pandas as pd import numpy as np import re import time import subprocess,sys #import logging from operator import itemgetter import os import logging定义一个类，用于下文…
阅读更多...
【结构性型模式-适配器模式】

【结构性型模式-适配器模式】

定义 将一个类的接口转换成客户希望的另外一个接口&#xff0c;使得原本由于接口不兼容而不能一起工作的那些类能一起工作。 适配器模式分为类适配器模式和对象适配器模式&#xff0c;前者类之间的耦合度比后者高&#xff0c;且要求程序员了解现有组件库中的相关组件的内部结…
阅读更多...
基于Java+SpringMvc+Vue技术的图书管理系统的设计与实现(60页论文参考)

基于Java+SpringMvc+Vue技术的图书管理系统的设计与实现(60页论文参考)

博主介绍&#xff1a;硕士研究生&#xff0c;专注于Java技术领域开发与管理&#xff0c;以及毕业项目实战✌ 从事基于java BS架构、CS架构、c/c 编程工作近16年&#xff0c;拥有近12年的管理工作经验&#xff0c;拥有较丰富的技术架构思想、较扎实的技术功底和资深的项目管理经…
阅读更多...
RISC-V 指令系统

RISC-V 指令系统

指令系统 指令集 指令集从本质上可以分为复杂指令集&#xff08;Complex Instruction Set Computing&#xff0c;CISC&#xff09;和精简指令集&#xff08;Reduced Instruction Set Computing&#xff0c;RISC&#xff09;两种。复杂指令集的特点是能够在一条指令内完成很多…
阅读更多...
贪心算法合集一

贪心算法合集一

1005.K次取反后最大化的数组和 给定一个整数数组 A&#xff0c;我们只能用以下方法修改该数组&#xff1a;我们选择某个索引 i 并将 A[i] 替换为 -A[i]&#xff0c;然后总共重复这个过程 K 次。&#xff08;我们可以多次选择同一个索引 i。&#xff09; 以这种方式修改数组后…
阅读更多...
如何理解数据模型？颗粒度、维度及指标？

如何理解数据模型？颗粒度、维度及指标？

问题1 什么是数据模型&#xff1f; 数据模型反映在数据库中就是一张表&#xff0c;该表把他分开来看有以下关注的点。 &#xff08;1&#xff09;主键&#xff1a;表明该表主要的分析对象&#xff0c;比如我们的分析对象是订单、是商品、是门店&#xff0c;那么主键就是订单id,…
阅读更多...
Qt 线程 QThread类详解

Qt 线程 QThread类详解

Qt 线程中QThread的使用 在进行桌面应用程序开发的时候&#xff0c; 假设应用程序在某些情况下需要处理比较复杂的逻辑&#xff0c; 如果只有一个线程去处理&#xff0c;就会导致窗口卡顿&#xff0c;无法处理用户的相关操作。这种情况下就需要使用多线程&#xff0c;其中一个…
阅读更多...
最新文章

Copyright @ 2022~2023