文件名称：storm-demo:风暴示威
文件大小：19KB
文件格式：ZIP
更新时间：2024-06-05 02:22:59
Java
风暴示威 介绍 该存储库包含四种风暴拓扑，用于演示两件事：至少一次处理语义和无状态处理Storm。 我希望通过在本地创建的多节点群集中运行这些拓扑来演示这些功能。 在拓扑运行时，我们将选择性地杀死一些工作节点，并得出结论，通过查看工作节点中打印的日志，风暴可以至少提供一次语义和无状态处理。 演示场景 演示1：消息重播 从枪口到枪栓，我们播放n条消息，并确认除枪栓中的一条消息以外的所有消息。 观察：我们可以看到没有确认的消息将永远被重播。 结论：Storm通过重播消息直到成功处理消息（如果我们使用锚定拓扑结构）来保证至少处理一次。 演示2：消息重播到所有螺栓 从一个喷口到两个直接连接到喷口的螺栓，我们播放n条消息（不一定是不同的消息）。 一个螺栓（例如Bolt1 ）对收到的所有消息进行应答，而另一个（ Bolt2 ）对其中一条消息进行应答。 观察：我们可以看到，即使Bolt1 ACK
【文件预览】：
storm-demo-master
----pom.xml(3KB)
----src()
--------main()
----README.md(6KB)