java一个风暴拓扑可以通过喷口或螺栓来停用和重新激活吗？

Question

当满足某些条件时，比如遇到特殊类型的元组，我想停用拓扑。这可以在喷口/螺栓中完成吗？ 如果是的话，有没有办法从喷口/螺栓重新激活拓扑

Answer 1

我在bolow代码中添加了所有三个动作来激活/停用/杀死。这可以从独立的java代码中调用（在spout/bolt之外）

从喷口或螺栓停用是直接的，但重新激活将是棘手的，因为您的喷口/螺栓在停用后不会主动运行java程序

import backtype.storm.generated.KillOptions;
import backtype.storm.generated.Nimbus.Client;
import backtype.storm.utils.NimbusClient;
import backtype.storm.utils.Utils;

Client client = NimbusClient.getConfiguredClient(Utils.readStormConfig()).getClient();

client.activate(topologyName);
client.deactivate(topologyName);

KillOptions killOpts = new KillOptions();
killOpts.set_wait_secs(30);
client.killTopologyWithOpts(topologyName, killOpts);