正如docs中所解释的那样，akka提供了优先邮箱，如果您想在处理其他类型的消息之前先处理某些类型的消息，这将很有帮助。我在storm文档中没有发现类似的特性，ApacheStorm中是否有类似的支持，或者如何实现类似的行为？
anauzrmj1#
不，据我所知，斯托姆没有这样的事。消息按到达螺栓的顺序进行处理。如果您真的需要此功能，那么获得此效果的最佳方法可能是在两种配置中提交两次拓扑；一个读取低优先级消息，另一个只读取高优先级消息。虽然您可以在一个拓扑中将元组流划分为低优先级和高优先级消息，但是您可能仍然会看到来自低优先级消息的一些干扰，例如。 topology.max.spout.pending .
topology.max.spout.pending
1条答案
按热度按时间anauzrmj1#
不，据我所知，斯托姆没有这样的事。消息按到达螺栓的顺序进行处理。
如果您真的需要此功能，那么获得此效果的最佳方法可能是在两种配置中提交两次拓扑；一个读取低优先级消息，另一个只读取高优先级消息。虽然您可以在一个拓扑中将元组流划分为低优先级和高优先级消息，但是您可能仍然会看到来自低优先级消息的一些干扰，例如。
topology.max.spout.pending.