云消息队列 MQ协议emqttd 的相关内容

文章 2021-11-14 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（17） - [error] Dependency luerl is specified as a dependency but is not...

编译源码出错：===> No entry for profile default in config. ===> Verifying dependencies... ===> Compiling jwerl make[2]: Leaving directory `/home/emq2.3.10/deps/jwerl' make[1]: Leaving directory...

文章 2021-11-14 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（13） - Hook使用和连接Kafka发送消息，使用brod库

一、工作环境准备erlang kafka客户端库使用的是brod，https://github.com/klarna/brodemq使用的是v2.3.5版本，https://github.com/emqtt/emq-relxkafka的运行环境准备，http://blog.csdn.net/libaineu2004/article/details/79202408我们以插件的形式来实现，我的插件....

文章 2021-11-14 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（14） - 使用redis插件来实现访问控制

一、工作环境准备准备好redis server，http://blog.csdn.net/libaineu2004/article/details/76267836erlang redis客户端使用开源项目，https://github.com/wooga/erediserlang连接池，https://github.com/emqtt/ecpoolemq使用的是v2.3.5版本，https:/....

文章 2021-11-14 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（12） - Hook使用和连接Kafka发送消息，使用ekaf库

一、工作环境准备erlang kafka客户端库使用的是https://github.com/helpshift/ekafemq使用的是v2.3.5版本，https://github.com/emqtt/emq-relxkafka的运行环境准备，http://blog.csdn.net/libaineu2004/article/details/79202408我们以插件的形式来实现，我的插件路径....

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（11） - EMQ 一个客户链接的资源消耗

Erlang进程消耗EMQ对客户端链接使用链接进程(emqtt_client)和session进程(emqtt_session)分开的策略。当一个mqtt的客户端连接到EMQ的服务器上的时候，首先会建立一个负责管理连接的进程(emqtt_client)，当验证客户端有效后会建立另一个进程(emqtt_session)，负责该客户端的会话。在EMQ中，每一个clientID只能登录一次，因此后登....

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（10） - 建立高可用集群，负载均衡haproxy

方案1：Nginx+Keepalived+emq+MySQL双机热备，MySQL用于数据持久化方案2（推荐）：HAProxy+Keepalived+emq+MySQL双机热备方案3：HAProxy+confd+emq+etcd问：我还有一个疑问，使用了nginx或者haproxy真的能提升性能吗？那nginx或haproxy本身服务器岂不是压力山大，所有数据都要经过它转发。答：它不需要处理，仅仅....

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（5） - hook的使用，源码分析

学习mqtt协议和emqttd开源项目http://emqtt.com/emqttd源码版本号是v1.1.3。http://emqtt.com/downloads/11131、-module(emqttd_app).start(_StartType, _StartArgs) -> load_all_mods(), 2、读取emqttd.config文件，modules字段%% Module....

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（4） - 客户端CleanSession=0时，上线接收离线消息，源码分析

学习mqtt协议和emqttd开源项目http://emqtt.com/emqttd源码版本号是v1.1.3。http://emqtt.com/downloads/11131、-module(emqttd_client).[html] view plain copy handle_info({inet_async, _Sock, _Ref, {ok, Data}}, State) -> &a...

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（2） - 订阅$SYS主题，捕获客户端上下线消息

1、acl.config文件定义了可订阅$SYS主题的权限。{allow, {user, "dashboard"}, subscribe, ["$SYS/#"]}. {allow, {ipaddr, "127.0.0.1"}, pubsub, ["$SYS/#", "#"]}. %%%{deny, all, subscribe, ["$SYS/#", {eq, "#"}]}. {allow, a....

文章 2021-11-13 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（1） - Clean Session和Retained Message

学习mqtt协议和emqttd开源项目http://emqtt.com/emqttd源码版本号是v1.1.3。http://emqtt.com/downloads/1113官方文档有定义：MQTT会话(Clean Session)MQTT客户端向服务器发起CONNECT请求时，可以通过’Clean Session’标志设置会话。‘Clean Session’设置为0，表示创建一个持久会话，在客户....