我计划开始实施以下物联网用例。
用例
物联网设备将通过中继器向网关发送 10 万条消息/分钟,网关将消息传输到云端。我想跟踪组织中的员工。传感器将固定在他们的身份证上。传感器通过中继器将位置相关数据(大约 15KB/消息)发送到网关。这是为了分析目的。将数据传递到云端后,我将进行一些分析并存储到数据库中并显示在网页上。基于此分析数据,我将显示用户的当前位置以及用户在特定时间跨度(过去 1 小时或 2 小时或 1 天)内的移动位置。
我将对数据进行一些处理并将其发送到前端/数据库。
我已经了解了 IoT 基础知识及其架构。然后我决定使用“SMACK”堆栈(Spark、Mesos、Akka、Cassandra、Kafka)架构。
我决定在网关中使用“Kafka native client”将消息发布到云端。
我应该使用 MQTT 协议将消息传输到 Kafka 吗?或者上面的用例不需要MQTT?
如果是,将 MQTT 与“SMACK”架构一起使用有什么好处?