我正在开发一个处理包含序列化消息片段的事务的应用程序。它读取、分组和连接,并在反序列化它们之后将它们推送到订阅的读者。不同的任务(读取、分组、反序列化)作为专用组件实现,这些组件通过 BlockingQueue .应用程序是多线程的,但没有分布式体系结构。问题是apachestorm是否也部署在这样的非分布式系统中?
BlockingQueue
qnzebej01#
没有什么能阻止你运行单节点风暴集群,但我不明白你为什么要这么做。storm的大部分复杂性(如调度、心跳、确认)来自于希望能够在许多物理机器上分配工作。如果你不需要运行一台以上的机器,我不认为你得到任何东西使用风暴。
1条答案
按热度按时间qnzebej01#
没有什么能阻止你运行单节点风暴集群,但我不明白你为什么要这么做。storm的大部分复杂性(如调度、心跳、确认)来自于希望能够在许多物理机器上分配工作。如果你不需要运行一台以上的机器,我不认为你得到任何东西使用风暴。