一种控制消息分发的方法及装置
Abstract:
本发明公开一种控制消息分发的方法及装置,该方法包括:针对实时流式计算系统中的每个计算单元,获取所述每个计算单元在设定周期内处理消息的执行状态;针对一个计算单元,若所述计算单元的执行状态满足设定的工作效率指标,则确定所述计算单元对应的上游计算单元;向所述上游计算单元发送与所述设定的工作效率指标相应的调整指令,以使所述上游计算单元调整对所述计算单元的消息分发状态,用以解决现有技术中存在数据流堵塞、消息处理的吞吐量低的问题。
Public/Granted literature
Patent Agency Ranking
0/0