在java中为ApacheStorm拓扑编写集成测试的推荐方法是什么？感谢您的建议/链接。
ui7jx7zq1#
您可以使用localcluster进行集成测试。看看这个班https://github.com/apache/storm/blob/822a4685c0278aba9d4e0f43104bc4f86a462222/storm-server/src/main/java/org/apache/storm/localcluster.java#l119你可以看看storm自己的一些集成测试来获得灵感。https://github.com/apache/storm/blob/e0feb6cf04107029d4b24420f265495cdfbdb098/storm-server/src/test/java/org/apache/storm/testingtest.java#l38.您可能想要使用的工具是 FeederSpout 以及 FixedTupleSpout . 所有喷口实现 CompletableSpout 可以使用中的工具运行接口直到完成 Testing 班级。storm测试还可以选择“模拟时间”，这意味着storm拓扑将空闲，直到您调用 LocalCluster.advanceClusterTime . 例如，这可以让您在螺栓发射之间执行Assert。
FeederSpout
FixedTupleSpout
CompletableSpout
Testing
LocalCluster.advanceClusterTime
1条答案
按热度按时间ui7jx7zq1#
您可以使用localcluster进行集成测试。看看这个班https://github.com/apache/storm/blob/822a4685c0278aba9d4e0f43104bc4f86a462222/storm-server/src/main/java/org/apache/storm/localcluster.java#l119
你可以看看storm自己的一些集成测试来获得灵感。https://github.com/apache/storm/blob/e0feb6cf04107029d4b24420f265495cdfbdb098/storm-server/src/test/java/org/apache/storm/testingtest.java#l38.
您可能想要使用的工具是
FeederSpout以及FixedTupleSpout. 所有喷口实现CompletableSpout可以使用中的工具运行接口直到完成Testing班级。storm测试还可以选择“模拟时间”，这意味着storm拓扑将空闲，直到您调用
LocalCluster.advanceClusterTime. 例如，这可以让您在螺栓发射之间执行Assert。