高吞吐量的物联网消息中间件实现方案

场景：
智能家居设备数量超过千万。使用移动设备比如Android手机、IOS手机等远程控制这些智能家居系统。这个是典型的物联网应用场景。

原理：
通过物联网标准协议MQTT，使用消息中间件服务器集群。发布/订阅模式，手机通过发送MQTT消息到服务器，智能家电上面的芯片定时向服务器发送心跳，并主动从服务器上面pull订阅的主题消息指令来达到控制效果。

性能指标：
1000万台设备同时连接，每秒100万消息请求。

初步方案是通过使用Kafka分布式消息系统作为消息服务器。但是Kafaka并没有实现MQTT协议。

对于协议的本质，应该就是定义了一种规范，发送方根据这个规范发送指定格式的数据，接收方接到数据后可以正确的解析出来，提取所需的信息。是这么理解吧。

现在有一个MQTT协议，是物联网的标准协议，专门为低宽带、不可信网络设计的高效传输协议。
大体架构是 Producer ------push------> Broker  <------pull--------Consumer。
生产者给Broker发送MQTT格式的消息，Consumer从Broker中拉取消息。感觉中间那个Broker应该只需要转发消息就行了，不用去实现MQTT协议吧。

目前暂时只是个设想，还没去试验，如果有相关中间件设计经验的，希望不吝赐教。

这个和我朋友的需求很像，mqtt我之前也研究过，但是不熟悉，kafak/jafka还可以，我对这样的事情比较感兴趣，有时间可以一块聊聊

嗯，我给你发了私信。