在局域网中,CEP引擎和流数据生成器之间传输数据的最佳方式是什么



我是复杂事件处理(CEP)系统的新手,使用一个名为Esper的CEP引擎来检测智能建筑中的事件模式。不同的传感器为它们假设并实现了数据生成器。我想衡量一下我的系统的性能。整个实现都是用java实现的,那么在局域网中将流数据从不同的数据生成器传输到我的CEP系统的最佳方式是什么。

我应该使用UDP还是TCP??是否需要线程?因为假设了许多传感器。

你几个月前问过你的问题,但我还是会做一些评论的。从我读到的内容来看,在我看来(截至2015年3月…)

  • 要使用的摄取协议是AMQP
  • 数据流和扩展应由Apache Storm或Spark管理
  • 对于弹性,请使用某种消息队列,例如RabbitMQ、Kafka、Azure EventHubs、AWS Kinesis

我确信您可以使用Java生态系统中的所有这些技术。

最新更新