关于eMQTT的部署架构
一：emqtt的架构设计为：
Topic tree每台机器有副本，down机不影响数据
连接、订阅是单节点，一台down机客户端必须重连其他节点，并重新订阅相关主题。
二：官方推荐部署架构为：
你好 MQTT 5.0!
文章翻译自 Jens Deters 11/30/17 的 Hello MQTT Version 5.0!
2017年8月9日，OASIS MQTT技术委员会宣布MQTT 5.0版现已公开发布，并将于9月8日前发表评论。并且预计在17年年底发布下一版本的Message Queue Telemetry Transport（MQTT），MQTT v5.0是MQTT 3.1.1的后续版本。
MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和制动器（比如通过Twitter让房屋联网）的通信协议。
1、为什么不是4.0 ？
根本原因在与协议规范说明中， MQTT CONNECT Control Packet （响应头的）第7个字节处，需要指定协议的级别，因为mqtt 3.1.1时 定义协议级别时使用了 0x04 （占用了4的版本号），所以下一代协议的级别只能是 0x05 （5）。
最重要的是： mqtt v5.0是不向后兼容的，显然有太多的新东西要被引入，所有现有的实现要重新实现。…
MQTT v5.0新特性总结（非规范）
最近翻译了MQTT v5.0协议的公开审阅版，已经传到GitHub上了，可以参见：MQTT v5.0 协议草案中文翻译
MQTT v5.0添加了以下特性
- 会话过期
把清理会话标志拆分成新开始标志（指示会话应该在不使用现有会话的情况下开始）和会话过期间隔标志（指示连接断开之后会话保留的时间）。会话过期间隔时间可以在断开时修改。把新开始标志设置为1且会话过期间隔标志设置为0，等同于在MQTT v3.1.1中把清理会话（CleanSession）设置为1。 - 消息过期
允许消息在发布时设置一个过期间隔。 - 所有确认报文原因码
更改所有响应报文以包含原因码，包括CONNACK，PUBACK，PUBREC，PUBREL，PUBCOMP，SUBACK，UNSUBACK，DISCONNECT和AUTH，以使得调用方确定请求的函数是否成功。 - 所有确认报文原因字符串
更改大部分报文以包含原因码同时也允许一个可选的原因字符串。这是为问题定位而设计的，并且不应由接收端所解析。 - 服务端断开
允许服务端发送DISCONNECT报文，以指示连接被关闭的原因。 - 载荷格式和内容类型
允许在消息发布时指定载荷格式（二进制、文本）和MIME样式内容类型。这些信息被转发到消息的接收端。 - 请求/响应
规定MQTT请求/响应模式，提供响应主题和对比数据属性，以使得响应消息被路由回请求的发布者。此外，为客户端添加从服务端获取获取关于构造响应主题的配置信息的能力。 - 共享订阅
添加对共享订阅的支持，以允许多个订阅消费者进行负载均衡。 - 订阅标识符
允许在SUBSCRIBE报文中指定一个数字订阅标识符，并在消息分发时返回此标识符。这使得客户端收到分发的消息时确定此消息是由哪个或哪些订阅导致的。 - 主题别名
通过将主题名缩写为小整数来减小MQTT报文的开销大小。客户端和服务端分别指定它们允许的主题别名的数量。 - 流量控制
允许客户端和服务端分别指定未完成的可靠消息（QoS>0）的数量。发送端可以暂停发送此类消息以保持消息数量低于配额。这被用于限制可靠消息的速率和某一时刻的传输中（in-flight）消息数量。 - 用户属性
为大多数报文添加用户属性。PUBLISH报文的用户属性由客户端应用程序定义。PUBLISH报文和遗嘱报文的用户属性由服务端转发给应用消息的接收端。CONNECT，SUBSCRIBE和UNSUBSCRIBE报文的用户属性由服务端实现定义。CONNACK，PUBACK，PUBREC，PUBREL，PUBCOMP，SUBACK，UNSUBACK和AUTH报文的用户属性由发送端定义，且对发送端具有唯一性。MQTT规范不定义用户属性的意义。 - 最大报文长度
允许客户端和服务端各自指定它们支持的最大报文长度。会话参与方发送更大的报文将造成错误。 - 可选的服务端功能可用性
提供定义一组服务端不允许的功能，并告知客户端的机制。可以使用这种方式指定的功能包括：最大QoS等级，保留可用，通配符订阅可用，订阅标识符可用和共享订阅可用。客户端使用服务端通知了（不可用）的功能将造成错误。
在早期版本的MQTT协议中，服务端没有实现的功能通过未授权告知客户端。当客户端使用其中一种（不可用的）功能时，此功能允许服务端告知客户端，并添加特定的原因码。 - 增强的认证
提供一种机制来启用包括互相认证在内的质询/响应风格的认证。这允许在客户端和服务端都支持的情况下使用SASL风格的认证，包括客户端在连接中重新认证的功能。 - 订阅选项
你的MQTT应用具备足够弹性吗？
Introduction
Let’s face it: Despite the best intentions and hard work of engineers, software developers and quality assurance folks, software fails. Although it’s an accepted best practice to test software thoroughly in dedicated test and integration environments, failures that are …
MQTT 协议 3.1.0 和 3.1.1的区别
Differences between versions 3.1.0 and 3.1.1 of the MQTT specification:
3.1.0 specification: http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/mqtt-v3r1.html
3.1.1 specification: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html…
原关于 emqtt 推送问题，mqtt有时收不到消息疑难解答
一、客户端 连接冲突会发现以下报错 （开启 debug日志：把配置文件 的log.console.level 改为= debug)
11:20:55.849 [info] Session(060010100000868936): resumed by <0.21232.18>^M^M
11:20:55.849 [warning] Session(060010100000868936): <0.21232.18> kickout <0.31200.17>^M^M
11:20:55.849 [warning] Client(27.187.80.148:9093): clientid '060010100000868936' conflict with <0.21232.18>^M^M…
原MQTT协议流程图
MQTT协议流程图
转载请注明来自lenix 的博客，地址 http://blog.p2hp.com/archives/4100…
基于Jmeter的MQTT测试插件-上
1. Jmeter插件简介
Apache JMeter是Apache组织开发的基于Java的压力测试工具。下载
用于对软件做压力测试，它最初被设计用于Web应用测试，但后来扩展到其他测试领域。
这里我们主要使用的基于Jmeter开发的，测试MQTT协议的插件工具，从github上找到了几个歪果人写的插件，主要有以下几个：
这3个插件都很像，
第1个下载的最多，但是我在使用发现存在bug，弃之。
第2个功能比较简单，只能满足简单的单主题发送。
第3个是作者基于第1个来改的，并且把连接MQTT的客户端换成了最常用的paho java客户端，正好是我项目中使用的，熟悉，功能上虽然没有第1个丰富，但是有源码，改改还是可以适用的。
2. mqttws源码打包
下载解压之后，导入到eclipse中，项目是通过maven构建，如图：
插件的效果图：
下面是具体的构建方法：
在项目上点击右键，Run As->Maven clean->Maven install，在target目录下，将生产一个名为mqttws-jmeter.jar的jar包。
将mqttws-jmeter.jar复制到Jmeter的\lib\ext
MQTT压力测试之Tsung的使用
现在做物联网，MQTT协议被广泛应用。因此如何对MQTT Broker服务器进行压力测试也是测试人员、开发人员面临的问题。笔者经过多方选择，选择了Tsung这款工具。
简介
Tsung 是一个压力测试工具，可以测试包括HTTP, WebDAV, PostgreSQL, MySQL, LDAP, and XMPP/Jabber等服务器。针对 HTTP 测试，Tsung 支持
HTTP 1.0/1.1 ，包含一个代理模式的会话记录、支持 GET、POST 和 PUT 以及 DELETE 方法，支持 Cookie 和基本的WWW 认证，同时还支持 SSL。…
原emqtt 系统参数调优
emqtt 系统方面参数调优
----------------------------------------
（一）执行如下命令
echo 2097152 > /proc/sys/fs/nr_open
ulimit -n 1048576
（二）编辑 /etc/sysctl.conf ，加入如下项…
近期评论