Apache Storm:监督程序终止并重新启动工作进程
创始人
2024-09-05 00:00:32
0

以下是一个使用Apache Storm监控和重新启动工作进程的示例代码:

import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.generated.StormTopology;
import org.apache.storm.topology.TopologyBuilder;

public class StormSupervisorRestartExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建TopologyBuilder对象
        TopologyBuilder builder = new TopologyBuilder();
        
        // 添加spout和bolt到TopologyBuilder中
        builder.setSpout("spout", new MySpout());
        builder.setBolt("bolt", new MyBolt()).shuffleGrouping("spout");
        
        // 创建Storm配置对象
        Config config = new Config();
        config.setDebug(true);
        
        // 创建本地集群对象并提交Topology
        LocalCluster cluster = new LocalCluster();
        cluster.submitTopology("my-topology", config, builder.createTopology());
        
        // 监听Supervisor是否终止
        while (!cluster.isSupervisorDaemonAlive()) {
            Thread.sleep(1000);
        }
        
        // 停止Topology
        cluster.killTopology("my-topology");
        
        // 等待一段时间后重新启动Topology
        Thread.sleep(5000);
        cluster.submitTopology("my-topology", config, builder.createTopology());
        
        // 关闭本地集群
        cluster.shutdown();
    }
}

在上面的示例代码中,我们首先创建了一个TopologyBuilder对象,并添加了一个spout和一个bolt。然后,我们创建了一个Storm配置对象,并设置了调试模式。接下来,我们创建了一个本地集群对象并提交了Topology。

然后,我们使用cluster.isSupervisorDaemonAlive()方法来监控Supervisor是否终止。一旦Supervisor终止,我们使用cluster.killTopology()方法停止Topology。然后,我们等待一段时间后重新启动Topology,再次使用cluster.submitTopology()方法。

最后,我们关闭本地集群对象。

请注意,这只是一个示例代码,具体的实现可能因环境和需求而有所不同。

相关内容

热门资讯

透视辅助!微扑克中牌率(wep... 透视辅助!微扑克中牌率(wepoker)外挂透明挂辅助挂(透视)透牌教程(有挂方式)-哔哩哔哩1、很...
一分钟教会你!云扑克(WepO... 一分钟教会你!云扑克(WepOke)外挂透明挂辅助APP(辅助挂)细节方法(有挂详细)-哔哩哔哩;1...
科普常识!欢乐棋牌(wepOk... WePoker透视辅助版本稳定性对比与推荐‌:科普常识!欢乐棋牌(wepOkE)外挂透明挂辅助工具(...
今日焦点!鱼扑克辅助(wePO... 今日焦点!鱼扑克辅助(wePOKE)外挂透明挂辅助脚本(辅助挂)详细教程(有挂教学)-哔哩哔哩;鱼扑...
大家学习交流(轰趴大菠萝)外挂... 《大家学习交流(轰趴大菠萝)外挂透明挂辅助神器(透视)软件透明挂(2025已更新)(哔哩哔哩)》 轰...
一分钟快速了解!cloudpo... 1、一分钟快速了解!cloudpoker云扑克(WEpoke)外挂透明挂辅助挂(透视)解密教程(有挂...
重大通报(wpk插件)外挂透明... 重大通报(wpk插件)外挂透明挂辅助软件(透视)透视辅助(2021已更新)(哔哩哔哩);(需添加指定...
透视辅助!wepoke数据(w... 透视辅助!wepoke数据(wepoker)外挂透明挂辅助工具(透视)必胜教程(有挂方法)-哔哩哔哩...
重大发现(wepokeai)外... 重大发现(wepokeai)外挂透明挂辅助工具(透视)德州ai机器人(有人有挂)-哔哩哔哩1、很好的...
透明神器(微扑克钻石)外挂透明... 透明神器(微扑克钻石)外挂透明挂辅助脚本(透视)透视辅助(2022已更新)(哔哩哔哩);玩家在微扑克...