java - 在本地模式下运行多个 Storm 拓扑

我的main（）方法中有两个单独的拓扑。我正在使用“ for loop”来设置其相应的喷嘴和螺栓，并同时提交该拓扑。
每个拓扑结构都有各自不同的喷口和螺栓组，逻辑不同。

现在，我想动态调用不同的喷嘴和螺栓。我怎样才能做到这一点 ？？

主要方法中的代码：

    public static void main(String[] args) throws InterruptedException,Exception
    {
    LocalCluster cluster = new LocalCluster();



    try{
        BufferedReader in=new BufferedReader(new FileReader("/home/praveen /workspace/OfferEngine/OfferListJSON.json"));
        //ArrayList<String> content = new ArrayList<String>();
        String str="";
        String str1="";
        while((str1=in.readLine())!=null)
        {
            str = str + str1;
        }

         JsonParser parser = new JsonParser();
         JsonObject o = (JsonObject)parser.parse(str);
         JsonObject o2 = (JsonObject)o.get("OfferData");

         ArrayList<String> ol = new ArrayList<String>();
         ol.add(o2.get("strOfferId").toString().replaceAll("^\"|\"$", ""));
         ol.add(o2.get("strOfferId1").toString().replaceAll("^\"|\"$", ""));

         TopologyBuilder bu = null;
         Config config = new Config();
         config.setDebug(false);

         for(String x : ol) {
                System.out.println(x); //prints element x
                String y="", z="";
                bu = new TopologyBuilder();
                bu.setSpout(x, new Off1Spout(x).ks(), 2);
                y = x+"2";
                bu.setBolt(y, new main.java.bolts.Off1Bolt()).shuffleGrouping(x);
                z = x+"offerlimit";
                bu.setBolt(z, new OfferLimit()).shuffleGrouping(y);
cluster.submitTopology(x,config,bu.createTopology());
              }
    }

    catch (IOException e)
    {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

任何形式的建议都会更有帮助。

最佳答案

您可以在for循环中尝试if（）条件以获取不同的优惠...请参阅以下代码以供参考

for(String x : ol) {
     System.out.println(x);
//  Offer 1 related Topology
    if(x.equalsIgnoreCase("offer1")){
       String y="", z="";
       bu = new TopologyBuilder();
       bu.setSpout();
       y = x+"start";
       cluster.submitTopology(x,config,bu.createTopology());
    }

//      Offer 2 related Topology

 if(x.equalsIgnoreCase("off2")){

       String y="", z="";
       bu = new TopologyBuilder();
       bu.setSpout(x, new Off1Spout(x).ks(), 2);
       y = x+"start";
       bu.setBolt(y, new off2Bolt()).shuffleGrouping(x);
       cluster.submitTopology(x,config,bu.createTopology());
  }
}

有多少拓扑会创建那么多if条件。

关于java - 在本地模式下运行多个 Storm 拓扑，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/19090610/