流计算是对实时数据流处理的研究,其理念是基于数据隐含价值随着时间的流逝而降低,所以数据出现后需要尽快处理。而在各种解决方案中,分布式流计算框架因其具有很好的扩展性,易用性和灵活性而受到业界的普遍欢迎,本文即着手设计和实现分布式流计算框架中最为关键的容错功能。首先,本文立足于分布式流计算框架的研究背景和目前的研究走向,阐述容错功能对分布式流计算框架的重要意义,并提出了设计和实现容错功能的设想,介绍了实现分布式流计算框架容错功能所需要的关键技术。接下来,本文以开源的分布式流计算框架S4(Simple Scalable Stream System)为依托,详细阐述分布式流计算框架的容错功能需求分析,主要包含三大部分：处理节点容错功能、处理节点间网络通信容错功能和处理节点计算容错功能。处理节点容错功能实现节点本身的可靠性,处理节点间网络通常容错功能实现网络通信的可靠性,处理节点计算容错功能实现应用程序处理结果的可靠性。最后,本文对分布式流计算框架各容错功能进行详细设计和实现。处理节点容错功能采用的是温备份复制技术,定时的保存处理节点的状态信息到第三方的数据库MongoDB中,恢复处理节点时从MongoDB中获取节点最近保存的状态信息并初始化新创建的节点；处理节点间网络通信容错功能采用开源的网络通信库ZeroMQ实现,ZeroMQ对消息差错处理和网络连接故障处理均具有较好的容错能力；处理节点计算容错功能采用多版本的软件容错技术屏蔽系统运行中可能发生的各种故障。论文末尾对主要的容错功能模块进行了相应测试和分析,指出容错功能使分布式流计算系统具有较好的可靠性和健壮性,同时,简要概括论文有待改进的方面以及下一步的工作。