基于事件属性和资源节点状态约束的事件过滤系统及方法

    公开(公告)号:CN115220934A

    公开(公告)日:2022-10-21

    申请号:CN202210866671.0

    申请日:2022-07-22

    Abstract: 本发明提供了一种基于事件属性和资源节点状态约束的事件过滤系统及方法,其特征在于,包括:事件发布者、事件订阅者、事件处理模块、策略处理模块与节点信息点;事件发布者、事件订阅者和事件处理模块是发布/订阅模型中基本的三个组成部分;事件发布者生成事件,事件订阅者消费事件,事件处理模块进行事件的路由转发,策略处理模块解析用EFPL定义的过滤策略和生成每个事件订阅者的选择器,节点信息点存储资源节点状态信息。本发明能够针对接受事件订阅者的状态确定是否要将事件发给这些订阅者,从而极大地避免了事件的无效分发;本发明能够对资源的状态和事件属性的复杂过滤条件进行定义;本发明能够与目前的发布订阅系统进行有机集成。

    轻量级异构分布式并行任务的协同处理方法、系统、介质

    公开(公告)号:CN118075261A

    公开(公告)日:2024-05-24

    申请号:CN202311754580.9

    申请日:2023-12-19

    Abstract: 本发明涉及轻量级异构分布式并行任务的协同处理方法、系统、介质,包括如下步骤:接收数据处理任务请求,生成组播地址并广播至各计算节点,基于各计算节点的反馈生成参与组播的计算节点列表;基于待处理数据中相邻两关键帧之间的帧数量以及参与组播的计算节点数量,为所述计算节点列表中的计算节点分配需要处理的相对于关键帧的偏移帧号,建立计算节点‑偏移帧号的映射关系;接收待处理数据,并组播至所述计算节点列表中的计算节点;从计算节点接收数据处理结果,基于所述映射关系合并得到最终处理结果。与现有技术相比,本发明具有优化突发需求的实时处理能力等优点。

Patent Agency Ranking