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

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

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

相关内容

热门资讯

记者揭秘!智星菠萝辅助(透视辅... 记者揭秘!智星菠萝辅助(透视辅助)拱趴大菠萝辅助神器,扑克教程(有挂细节);模式供您选择,了解更新找...
一分钟揭秘!约局吧能能开挂(透... 一分钟揭秘!约局吧能能开挂(透视辅助)hhpoker辅助靠谱,2024新版教程(有挂教学);约局吧能...
透视辅助!wepoker模拟器... 透视辅助!wepoker模拟器哪个好用(脚本)hhpoker辅助挂是真的,科技教程(有挂技巧);囊括...
透视代打!hhpkoer辅助器... 透视代打!hhpkoer辅助器视频(辅助挂)pokemmo脚本辅助,2024新版教程(有挂教程);风...
透视了解!约局吧德州真的有透视... 透视了解!约局吧德州真的有透视挂(透视脚本)德州局HHpoker透视脚本,必胜教程(有挂分析);亲,...
六分钟了解!wepoker挂底... 六分钟了解!wepoker挂底牌(透视)德普之星开辅助,详细教程(有挂解密);德普之星开辅助是一种具...
9分钟了解!wpk私人辅助(透... 9分钟了解!wpk私人辅助(透视)hhpoker德州透视,插件教程(有挂教学);风靡全球的特色经典游...
推荐一款!wepoker究竟有... 推荐一款!wepoker究竟有透视(脚本)哈糖大菠萝开挂,介绍教程(有挂技术);囊括全国各种wepo...
每日必备!wepoker有人用... 每日必备!wepoker有人用过(脚本)wpk有那种辅助,线上教程(有挂规律);wepoker有人用...
玩家必备教程!wejoker私... 玩家必备教程!wejoker私人辅助软件(脚本)哈糖大菠萝可以开挂,可靠技巧(有挂神器)申哈糖大菠萝...