apache-storm是否像akka一样提供优先级邮箱

Question

正如在docs中解释的那样，akka提供了优先邮箱，如果您想要在处理某种类型的消息之前处理其他类型的消息，它会有所帮助。我没有在storm文档中找到类似的功能，apache-storm中有类似的支持吗?或者如何实现类似的行为？

Answer 1

不，据我所知，Storm没有这样的东西。消息按照到达螺栓的顺序进行处理。

如果您确实需要此功能，获得此效果的最好方法可能是在两个配置中提交拓扑两次；一个读取低优先级消息，另一个仅读取高优先级消息。虽然您可以在一个拓扑中将元组流划分为低优先级消息和高优先级消息，但您可能仍然会看到来自低优先级消息的一些干扰，例如topology.max.spout.pending。