云消息队列 MQ项目的相关内容

文章 2022-02-17 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（21） - 关于emq的payload的使用和加密

问：payload传输过程中会不会拆包，粘包？业务层拿到payload还需要自己组包吗？答：不需要，mqtt协议有约定，emq会帮忙处理tcp的粘包拆包。总之，直接拿出来用即可。问：payload怎么加密？答：安全，如果考虑商业用...

文章 2022-02-17 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（20） - 如果客户端clientid为空，emq会随机帮忙生成

mqtt v3.1.1协议有规定clientid可以为空，所以当客户端clientid为空，emq会随机帮忙生成。一、源码emq 1.1.3 -- emqttd_protocol.erl客户端经过TCP三次握手建立连接之后，会发起mqtt connect packet，服务器接收到后开始处理这个数据包，入口函数就是如下的源文件...

文章 2022-02-17 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（19） - emq软件版本升级之后，因插件版本不对而引发的问题

本人把emq2.3.7版本写的插件copy到新版本emq2.3.11之后，编译可以通过，但是运行报错。经过反复调试发现，是版本号有区别造成：/home/emqx-rel-2.3.?/deps/emq_auth_clientid/Makefileemq v2.3.7PROJECT = emq_auth_clientid PROJECT...

文章 2022-02-17 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（18） - 一个客户端sub很多主题和数据，出现宕机？使用本地共享订阅解决！

EMQ中CPU是公平分配给MQTT会话，大量pub消息到一个订阅，订阅不会拿到更多cpu，最终导致消息累积，内存溢出宕机。最好的解决办法是分组订阅，把消息打散，多个客户端订阅。问：请问一下，我现在的业务就是只使用一个sub，主题是\hello\#，去订阅数万...

文章 2022-02-17 来自：开发者社区

我的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/em...

文章 2022-02-17 来自：开发者社区

我的mqtt协议和emqttd开源项目个人理解（16） - [error] Autocluster exception: {badmatch,undefined}

emq2.3.X会出现这个错误，怎么破？出现这个错误，emq程序无法正常启动，1883端口没有在监听。emqttd broker is starting...[ok]emqttd alarm is starting...[ok]emqttd mod supervisor is starting...[ok]emqttd bridge sup...

文章 2022-02-17 来自：开发者社区

我的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/792...

文章 2022-02-17 来自：开发者社区

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

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

文章 2022-02-17 来自：开发者社区

我的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我们以插...

文章 2022-02-17 来自：开发者社区