在处理流后(应用过滤器等),处理后的流中的每个剩余项目是否可以直接触发事件而不是写入接收器?
我有一堆设备不断向 hazelcast 喷射流服务器报告状态。服务器对流执行一些过滤,只保留真正状况不佳的设备。我希望这些设备直接触发一些维护事件,而不是被写入接收器(例如 IMAP)。目前,我正在做的是将流接收到 IMAP 并在地图上注册侦听器。但是,我不确定这是否是我用例的最佳实践。我主要有两个担心:
- 我不一定需要存储这些设备。我需要的只是告诉其他服务该设备需要维护。
- Doc 说不应该把沉重的逻辑放在听众身上。事件触发的任务比较全面怎么办?