我的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:/....
我的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我们以插件的形式来实现，我的插件路径....
我的mqtt协议和emqttd开源项目个人理解（11） - EMQ 一个客户链接的资源消耗
Erlang进程消耗EMQ对客户端链接使用链接进程(emqtt_client)和session进程(emqtt_session)分开的策略。 当一个mqtt的客户端连接到EMQ的服务器上的时候，首先会建立一个负责管理连接的进程(emqtt_client)，当验证客户端有效后会建立另一个进程(emqtt_session)，负责该客户端的会话。在EMQ中，每一个clientID只能登录一次，因此后登....
我的mqtt协议和emqttd开源项目个人理解（10） - 建立高可用集群，负载均衡haproxy
方案1：Nginx+Keepalived+emq+MySQL双机热备，MySQL用于数据持久化方案2（推荐）：HAProxy+Keepalived+emq+MySQL双机热备方案3：HAProxy+confd+emq+etcd问：我还有一个疑问，使用了nginx或者haproxy真的能提升性能吗？那nginx或haproxy本身服务器岂不是压力山大，所有数据都要经过它转发。答：它不需要处理，仅仅....
我的mqtt协议和emqttd开源项目个人理解（9） - 集群和Mnesia源码分析
学习mqtt协议和emqttd开源项目http://emqtt.com/emqttd源码版本号是v1.1.3。http://emqtt.com/downloads/1113一、先来看EMQ的文档定义：http://emqtt.com/docs/v1/cluster.htmlemqttd集群设置管理¶假设部署两台服务器s1.emqtt.io, s2.emqtt.io上部署集群:节点名 主机名(FQ....
我的mqtt协议和emqttd开源项目个人理解（8） - 客户端subscribe消息的源码分析
学习mqtt协议和emqttd开源项目http://emqtt.com/emqttd源码版本号是v1.1.3。http://emqtt.com/downloads/1113源码写得比较绕，需要经过以下模块的调用，入口是emqttd_client模块，handle_info函数负责接收socket的数据：（注意：gen_server:call是同步调用，cast是异步。call对应的是handle....
我的mqtt协议和emqttd开源项目个人理解（7） - Qos==2是如何保证消息只收到一次的
只有QoS==1,2时候，才有Store(Msg)之说；QoS==0时没有。我们以第一种action为例（注意这里第一种action存储的是message，第二种action存储的是message ID）：1 若client没收到来自sever的pubcomp：那么client将重发pubrel，意思是sever将收到两次pubrel；但是sever并不会将消息发送两次，因为在第一次将消息发送给....
我的mqtt协议和emqttd开源项目个人理解（6） - 使用Wireshark分析mqtt协议
固定报头(Fixed header)可变报头(Variable header)报文有效载荷(Payload)固定报头Bit 7 6 5 4 3 2 1 0byte1 MQTT Packet type Flagsbyte2… Remaining Length报文类型类型名称 类型值 报文说明CONNECT 1 发起连接CONNACK 2 连接回执PUBLISH 3 发布消息PUBACK 4 发布回....
我的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....
我的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...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
云消息队列 MQ您可能感兴趣
- 云消息队列 MQ客户端
- 云消息队列 MQ物联网
- 云消息队列 MQ http
- 云消息队列 MQ console
- 云消息队列 MQ acl2.0
- 云消息队列 MQ报错
- 云消息队列 MQ acl
- 云消息队列 MQ升级
- 云消息队列 MQ共探
- 云消息队列 MQ议题
- 云消息队列 MQ消息队列
- 云消息队列 MQ apache
- 云消息队列 MQ队列
- 云消息队列 MQ版本
- 云消息队列 MQ模式
- 云消息队列 MQ安装
- 云消息队列 MQ集群
- 云消息队列 MQ topic
- 云消息队列 MQ协议
- 云消息队列 MQ配置
- 云消息队列 MQ消费者
- 云消息队列 MQ broker
- 云消息队列 MQ spring
- 云消息队列 MQ数据
- 云消息队列 MQ springboot
- 云消息队列 MQ rocketmq
- 云消息队列 MQ部署
- 云消息队列 MQ java
- 云消息队列 MQ kafka
- 云消息队列 MQ实战
中间件
为企业提供高效、稳定、易扩展的中间件产品。
+关注