风暴信号 Storm-Signals旨在提供一种将消息(“信号”)发送到Apache Storm拓扑中无法寻址的组件(喷口/螺栓)的方法。 风暴拓扑可以认为是静态的,因为对拓扑行为的修改需要重新部署。 Storm-Signals提供了一种在运行时修改拓扑行为的简单方法,而无需重新部署。 项目地点 风暴信号的主要开发将在以下位置进行: : 用于发布的Maven工件将在Maven Central上可用。 用例 典型的风暴喷头会永远运行(直到取消部署),并根据潜在的事件驱动的基础数据源/流发出元组。 一些风暴用户表示有兴趣对这种模式进行更多控制,例如在数据流不是开放式的情况下,或者在这种情况下需要数据流是可控的(例如,启动/停止/暂停/恢复处理)。 Storm-Signals提供了一种非常简单的机制,用于与部署在Storm拓扑中的喷口进行通信。 通信机制位于Storm的基本流处理范式