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()方法。

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

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

相关内容

热门资讯

实测发现!wpk系统是否存在作... wpk系统是否存在作弊行为AI 游戏攻略黑科技上线本地缓存功能,离线查阅能力开挂。提前下载对应游戏攻...
终于清楚!德扑圈透视挂,WPK... 一款 AI 游戏攻略黑科技工具上线,查攻略效率直接开挂。它整合版本更新、装备搭配、BOSS 打法、牌...
今日焦点!wepoker游戏的... 今日焦点!wepoker游戏的安装教程,德普之星透视挂件教程(本来真的是有辅助器)AI 是一款可以让...
2024教程!德普之星有辅助软... 2024教程!德普之星有辅助软件吗,wepoker有挂么辅助工具(固有真的有透视挂)AI 智能体黑科...
1.9分钟了解!wepoker... 『标题:当前标题』主打赛后复盘的 AI 游戏攻略黑科技走红,对局总结能力开挂。上传对局回放或者战绩截...
大神推荐!wpk软件是正规的吗... 大神推荐!wpk软件是正规的吗,微扑克透视软件平台(确实有辅助器)主打本地运行的 AI 黑科技工具迎...
重大来袭!wepoker开脚本... 重大来袭!wepoker开脚本视频,德普之星真的有透视吗平台(最初存在有辅助)主打本地运行的 AI ...
分享一款!德普之星的辅助工具介... 很多人使用云端 AI 时,都担心德普之星的辅助工具介绍、内部资料上传带来隐私风险。这款本地运行的 A...
一分钟了解!we-poker正... 『标题:当前标题』主打赛后复盘的 AI 游戏攻略黑科技走红,对局总结能力开挂。上传对局回放或者战绩截...
攻略讲解!德扑圈有透视吗,we... 您好:德扑圈有透视吗这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特...