测试风暴螺栓

Testing a storm Bolt

我是 apache 风暴的新手,我一直在寻找无需实际构建完整拓扑即可测试螺栓的方法。只是想避免模拟测试。相反,我尝试调用 bolt 的方法来发出 OutputCollector 对象中的输出。但是我试图找到一种方法来从 OutputCollector 对象获取数据,但没有找到这样的方法。有什么方法可以简单地访问 OutputCollector 对象中发出的值?

如果您仅从风暴角度进行测试,那么

junit

会做的。但是,如果您尝试从分布式计算的角度进行测试

mrunit

测试工具应该会有帮助。

测试螺栓逻辑的一种方法是编写 FakeDataGeneratorSpout 它模仿拓扑的实际来源。 Build Test Main Topology Builder Class 可以使用 FakeDataGeneratorSpout 进行测试。

其次,您可以保持简单的螺栓逻辑 Java class 并为它们编写 junit,然后从实际的螺栓中调用该测试方法。