Apache Storm - 用另一个螺栓组合螺栓

Question

我正在使用 Apache Storm，我想知道是否可以像这样用另一个螺栓组合螺栓：

public class MyNewBolt extends BaseRichBolt {
    private MyOldBolt bolt; // MyOldBolt also extends BaseRichBolt

    public MyNewBolt(MyOldBolt bolt) {
        this.bolt = bolt;
    }

    @Override 
    public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector) {
        bolt.prepare(map, topologyContext, outputCollector);
        //Prepare other stuff
    }

    @Override
    public void execute(Tuple tuple) {
        bolt.execute(tuple);
        bolt.someOtherMethod();
        //Do some other stuff
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        bolt.declareOutputFields(outputFieldsDeclarer);
    }
}

在此之后我会提交螺栓：

public static void main(String[] args) throws Exception {
                         .
                         .
                         .
    TopologyBuilder builder = new TopologyBuilder();
    BaseRichBolt bolt = new MyNewBolt(new MyOldBolt());
    builder.setBolt("bolt-id", bolt).someGrouping(....);
                         .
                         .
                         .
}

这在我以本地模式运行时有效，但它实际上可以在远程模式下工作吗？ Storm在这种情况下是如何处理bolt序列化-反序列化的呢？现在创建了多少任务？

Answer 1

我建议您采用另一种方法（巧合的是，我使用的是这种方法）。与其将 Bolt 视为可重用类，不如将 Bolt 的业务逻辑分解为纯 Java 类。然后，如果您想在另一个螺栓中重用该逻辑，这样做会容易得多。

我还建议您将与特定流相关的所有行为（元组中的名称、类型和值顺序等知识）分解到另一个类中。螺栓类的实现应该是相当少的。