java - 在 Apache Storm 中运行时编辑 Bolt 进程

Question

我的项目通过 Storm 将对象数据流式传输到图形应用程序。这些对象的外观取决于 Storm 拓扑中 bolt 分配的变量。

我的问题是是否可以通过向 Bolt 进程发送一条消息来更新它，该消息会更改它附加到对象数据的变量。例如，在向 Bolt 发送消息后声明我希望参数 x 高于特定数字的任何对象显示为红色而不是蓝色。然后，bolt 进程会将红色 rgb 变量附加到对象数据，而不是蓝色。

我认为这可以通过使用 Bolt 用来应用外观的 displayConfig 类来实现，并且可以通过具有特定 header 的消息来编辑谁的内容。

这可能吗？

Answer 1

这是可能的，但您需要手动执行此操作并在启动之前准备好拓扑。

有两种方法可以做到这一点:

1. 使用您放入工作计算机中的 Bolt 本地配置文件(可能通过 NFS)。 Bolt 会定期检查文件是否有更新，并在您更改文件时读取更新的配置。

2. 您再使用一个 spout 来生成配置流。您想要在运行时发送配置的所有 bolt ，都需要通过“allGrouping”从此配置喷口使用。处理输入元组时，您检查它是否是常规数据元组或配置元组(并相应地更新您的配置)。