java - 如何对 Storm 拓扑进行单元测试？

Question

我一直在开发 Storm 拓扑，但是我仍然发现我缺乏一种正确的方法来对已创建的 bolt 和喷口进行单元测试，而无需启动拓扑并向自己发送流量。拓扑中使用的服务是分离的并经过单元测试，但它们的使用或拓扑内容仍然可能存在错误(元组不正确等)。为了解决这个问题，在我的项目中创建单元测试的方法是什么？谢谢。

Answer 1

为 Bolt 创建单元测试有点复杂，但是无需部署拓扑也是可以的。您可以创建一个实现 IOutputCollector 的测试类和另一个实现元组的测试类。您应该实现您使用的方法并可能存储发出的元组。

之后您可以使用以下代码创建 Bolt 的单元测试。

MockOutputCollector c = new MockOutputCollector();
Bolt b = new Bolt();
b.prepare(c,null,null);
MockTuple tuple = new MockTuple(fields,Arrays.aslist({"a,b,c"}));
b.execute(tuple);
List result = c.getEmittedTuples().get(0);