雨水口和螺栓不使用Spring自动接线

Question

我建立了一套喷口和螺栓的Storm拓扑，也使用Spring进行依赖注入。

不幸的是，尽管我已经将所有的喷口和螺栓声明为@Components，但没有一个字段自动连接。

然而，在我声明拓扑的地方，Spring运行良好，所有依赖项都被正确注入。

是因为集群吗。submitTopology（“test”，conf，builder.createTopology（））将拓扑提交到自动布线不起作用的集群（在本地为喷嘴和螺栓生成不同的线程）？

请建议。

PS-

Answer 1

我问了这个问题，但没有人指示我正确的答案。发布它以便对某人有用：

喷口和螺栓无法解析依赖关系，因为它们是由ToplogyBuilder作为新对象创建的

例如：

TopologyBuilder builder = new TopologyBuilder();
    builder.setSpout("rabbitMqSpout", new RabbitListnerSpout(), 1);
    builder.setBolt("mapBolt", new GroupingBolt(), 1).shuffleGrouping("rabbitMqSpout");
    builder.setBolt("reduceBolt", new PublishingBolt(), 1).shuffleGrouping("mapBolt");

使用new创建它们的那一刻，它们就超出了Spring上下文的范围。可以通过将applicationContext作为构造函数发送来解决这个问题。

所以你可以把它当做，

TopologyBuilder builder = new TopologyBuilder();
    builder.setSpout("rabbitMqSpout", new RabbitListnerSpout(appContext), 1);
    builder.setBolt("mapBolt", new GroupingBolt(appContext), 1).shuffleGrouping("rabbitMqSpout");
    builder.setBolt("reduceBolt", new PublishingBolt(appContext), 1).shuffleGrouping("mapBolt");

通过这种方式，可以使用喷嘴和螺栓。因此，当你启动集群时，它们仍然可用。

P. S-

更新后，由于无法序列化appContext，上述操作将无法在远程群集上运行。要使spring在远程集群上工作，必须在open中定义和初始化上下文，并准备喷口和螺栓的方法。