apache-storm - Storm 程序的执行流程

我是新手，试图了解从spout到bolt的不同方法的执行流程。
像喷口一样有不同的方法



和 bolt 有类似的方法



有人能告诉我这些方法的执行顺序吗？

最佳答案

首先，当您启动拓扑时...

创建喷嘴和 bolt

declareOutputFields

喷嘴/ bolt 已序列化并分配给 worker

其次，在集群中某个位置的每个工作人员中...

喷出open和 bolt prepare(发生一次)

循环中...

Spouts调用ack，fail和nextTuple

bolt 调用execute

如果您的拓扑已停用...

您的喷口deactivate方法将被调用。当您再次激活拓扑时，将调用activate。

如果您的拓扑被杀死...

喷口可能具有称为

的close

bolt 可能具有称为

的cleanup
笔记:

关于apache-storm - Storm 程序的执行流程，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/28981197/