java - 如何消费物联网设备产生的数据?

标签 java spring

我必须创建一个基于 Spring Boot/Java 8 的小型物联网平台。

上下文:设备向平台发送一些各种信息。我必须保存它们,然后在分析算法中使用它们。

约束:我希望一切都是异步的,并且平台必须基于 Java8/Spring 技术,或者必须轻松集成到 Spring Boot 应用程序中。

我想象的是什么?我想将设备的信息发送到异步 Spring REST Controller 并将它们异步保存在 Mongodb 中。 我已经有了基于Google Guava Event Bus的分析算法。

继续,我有 Mongodb 数据库中的设备数据和基于 Java POJO 的算法,最后缺少的部分是将数据从设备转换为 Java POJO。

我可以使用哪些技术来做到这一点? Spring react 堆? RxJava?还有别的事吗?我怎样才能把它落实到位?

我搜索了一些易于安装的东西,例如可以通过实例复制轻松扩展。目前,我认为 Spring Cloud 技术对于我的目的来说有点太大了。

最佳答案

您应该看看Spring XD引擎。

Spring XD 支持不同的源(HTTP、FTP、MQTT、文件等)、转换器、过滤器、接收器(HTTP、FTP、MQTT、文件等)。

请查看this关于基于 Spring XD 和 Twitter API 的小型 IoT 项目的帖子。

关于java - 如何消费物联网设备产生的数据?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34633929/

相关文章:

java - Play Framework 2.5 表单对象 bean 中的依赖注入(inject) (Java)

java - JPA 与 "where"子句不同

java - 如何增加 hadoop 中 map 任务的数量以及如何获取 hadoop mapreduce 作业所花费的总时间

spring - Grails + RESTful URL映射+过滤器+路由

java - Tomcat 8.5中部署的Spring Boot如何使用外部配置文件

java - 用于开发和生产的不同 URL。 (重新加载静态内容)

java - java.util.Properties 字段的 Spring JavaConfig

java - 与java的Set Collection相关的查询

java - java.io.File 的静态最终字段的命名不标准

spring - 使用 Spring Boot 和 JPA 进行批处理 - 将内存中数据源用于批处理相关的表