基于发送方的流量控制的随机控制优化

摘要

一种在分布式流处理中控制消息流量的方法和系统。确定在每个数据陈旧度值具有一个状态的马尔可夫模型中的状态变换概率，以使用期望的消息速率从信息提供商向订户发送或停止发送数据更新。成本函数利用每个决定“发送”或“停止发送”的状态变换成本来注释在模型中的每个状态变换。为每个状态确定指定是否发送或停止发送消息的传播策略。然后，部署传播策略。如果在流失的时间单位期间接收到包括数据更新的新消息，则由订户保留的数据的陈旧度值被增加。使用传播策略来确定是否发送或停止发送消息。如果应当发送消息，则消息得以传播并且数据的陈旧度值被复位。