公开(公告)号：CN116302578B

公开(公告)日：2023-08-08

申请号：CN202310595972.9

申请日：2023-05-25

Applicant: 中国地质大学(北京)

Inventor： 孙大为 ,  管程钧

IPC: G06F9/50 ,  G06F9/48

Abstract: 本发明提供一种QoS约束的流应用延迟确保方法及系统，涉及分流式计算技术领域，包括：通过将拓扑建模为排队网络，构建延迟约束模型；通过延迟约束模型对系统延迟进行评估，为系统中具有优先级的组件分配执行器，在线调整拓扑任务中组件的并行度，对不同QoS约束情况下的处理延迟进行优化；构建通信开销模型；基于贪心算法，对调整并行度后的组件进行任务调度，获得最小化通信开销的任务调度。实现了Lg‑Stream的数据监测模块以及性能优化模块，并集成到典型的分布式流计算系统Apache Storm中，从系统延迟、吞吐量、资源利用率和资源使用量的角度对系统指标进行全面评估。与现有的Apache Storm框架相比，提出的Lg‑Stream在系统性能上具有明显的提升。

公开(公告)号：CN116302578A

公开(公告)日：2023-06-23

申请号：CN202310595972.9

申请日：2023-05-25

Applicant: 中国地质大学(北京)

Inventor： 孙大为 ,  管程钧

IPC: G06F9/50 ,  G06F9/48

Abstract: 本发明提供一种QoS约束的流应用延迟确保方法及系统，涉及分流式计算技术领域，包括：通过将拓扑建模为排队网络，构建延迟约束模型；通过延迟约束模型对系统延迟进行评估，为系统中具有优先级的组件分配执行器，在线调整拓扑任务中组件的并行度，对不同QoS约束情况下的处理延迟进行优化；构建通信开销模型；基于贪心算法，对调整并行度后的组件进行任务调度，获得最小化通信开销的任务调度。实现了Lg‑Stream的数据监测模块以及性能优化模块，并集成到典型的分布式流计算系统Apache Storm中，从系统延迟、吞吐量、资源利用率和资源使用量的角度对系统指标进行全面评估。与现有的Apache Storm框架相比，提出的Lg‑Stream在系统性能上具有明显的提升。