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

摘要

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

主权项

一种计算机实现的方法，用于生成用于在信息分发环境中控制消息流量的传播策略，该计算机实现的方法包括：识别具有每个数据陈旧度值的一个状态的马尔可夫模型，其中该马尔可夫模型包括：(a)定义作为当前陈旧度的函数的陈旧度值的参数、(b)在当前时间单位期间新消息将到达的概率、和(c)决定是否在当前时间单位期间发送最新消息或停止发送最新消息的每个值的变换的成本，并且其中陈旧度表示订户侧的数据与及时发送更新的理想情况相比较陈旧的程度；确定在马尔可夫模型中状态变换概率，以决定使用期望的消息速率从信息提供商向信息订户发送包括数据更新的新消息以及从信息提供商决定停止向信息订户发送新消息；使用成本函数为马尔可夫模型中的每个状态变换注释状态变换成本，以决定发送新消息和决定停止发送新消息，其中使用朝向该信息订户传播该新消息的传播成本和针对数据的陈旧度的函数的损失，来计算该状态变换成本；为每个状态确定传播策略，其中该传播策略指定是否向信息订户发送新消息或者停止为信息订户发送新消息；以及部署该传播策略。