随着移动互联网的普及和网络支付技术的不断发展,网络内容提供平台不断涌现,网络消费的规模越来越大,订单的产生量也越来越多。为更好地维护网络平台的秩序和确保平台交易数据的质量,需要一个可用于实时反刷单监控的系统。咪咕数媒手机阅读平台原有的反刷单系统存在一些问题,需要基于Spark Streaming重新实现一个反刷单系统。本文通过将复杂事件处理系统的设计思路与分布式流计算框架Spark Streaming结合在一起,设计和实现了一个在数据流处理方面具有一定通用性的反刷单系统。本系统通过解析基于SQL配置的监控任务实现了对刷单行为的灵活监控。在本系统实现过程中尝试将Spark Streaming和MySQL两种系统的数据处理能力融合在一起,既增强了系统的处理能力,又简化了数据的处理逻辑。系统在流控和数据容错方面的改进增强了系统的稳定性和容错性。系统对数据流信息和规则信息的独立管理,实现了信息的复用,同时也简化了监控任务的配置过程。在最后的系统测试过程中,系统表现出了很好的稳定性和可扩展性。