推荐算法在数据挖掘中广泛应用,但当前主要针对静态数据,缺乏对动态数据的适应性。提出基于数据流的推荐算法,通过点对点网络替代传统参数服务器,解决了分布式平台中滞后梯度和掉队者问题。算法引入了遗忘策略和异常评分检测,基于Flink框架设计实现,并在MovieLens-1m数据集上验证。实验结果显示,该算法保持推荐准确率的同时,显著降低了通讯开销。