发布MQTT消息究竟有多快？

 

如今许多的智能硬件应用都须要从传感器得到相应的数据，处理后把这些数据传递到后端。为了可以评估这些应用的性能，首先咱们须要解决如下的问题：

1. 每秒从网关发送到后端的信息数
2. 在反应模块和纯Java环境中建立解决方案的比较
3. 如何在多核的环境下并行收发和处理数据的进程

在本次的测试中咱们使用Raspberry Pi 2 (Model B)，具体的参数以下：

Quad-core Broadcom BCM 2836 CPU

900 MHz

1GB RAM

 

从网关发送消息到后端

 

咱们使用MQTT协议将信息发送到后端，使用在爱尔兰的AWS数据中心做为MQTT的服务器。因为咱们的网关设定在挪威的特隆赫姆，因此传输的距离跨越了整个北海。

下图是测试应用的配置：

 

信息将会以1,2,5…10000的信息组的模式发送，并记录发送的时间。

 

首先，这个实验说明了在qos=0和qos=2时的显著的差别。在MQTT是能够设置qos的（quality of service）。当qos=0时，信息是没有保证送达和认证的，当qos=2时，信息是保证送达而且不会有重复。若是没有以上的配置，qos=2时每秒平都可以送达8到9条认证的消息，而当qos=0时每秒平都可送达1000条，是qos=2时的100多倍。这并非件很稀奇的情形，主要仍是由于后者不须要花大量时间从服务器的到认证。所以，肯定一个应用须要什么样的qos等级是很是重要的。

 

纯Java和反应模块比较

 

咱们一样也要在反应模块和纯Java（使用Paho）环境中建立解决方案进行比较。虽然反应模块一样使用的Paho核心，但和自动生成的code封装成模块。下面是测试的结果：

 

 

从图中咱们能够看到用纯java应用和经过反应模块产生jave code来推送必定数量的MQTT信息，所耗费的时间几乎是同样的。那就意味着generated code和programmed code同样的高效。

 

使用多核心

 

拥有quad-core CPU的Raspberry Pi 2能够并行相关任务。这使得网关应用更方便接收典型的传感器的数据，咱们用单线程的模拟传感数据测试了这一典型的应用，经过不一样的线程来进行多项式计算和经过MQTT发布数据。

 

 

这些任务能够经过划分不一样的线程来在四核的Raspberry Pi上并行。这里咱们选着每秒产生大约18000个传感器事件。模块化的多项式计算解决了每一个事件的多项式方程，并赋予每2000个事件的平均值。这些均值将会经过MQTT发布模块进行发布。也就是说，将会有每秒大约9条qos=2的MQTT消息被发布。不管MQTT发布模块何时报告进程消息，缓冲库里的BES（Buffer Eager Simple）模块将会存储要被发布的生产消息。

经过java能够将这种应用划分红不一样的核。然而反应模块却能使得全部同步的线程更加容易的产生纯净并且可靠的应用。

 

本文翻译至http://www.bitreactive.com/how-fast-can-you-publish-mqtt-messages/?utm_campaign=shareaholic&utm_medium=twitter&utm_source=socialnetwork  （How Fast Can You Publish MQTT Messages?）如转载请请注明出处

 

后记：以后本身也作过相似的实验测试（一样用的相似的板，用的云巴的MQTT）在qos>0时速度比原做者快，可能也和距离有关吧~但基本差很少