基于Web会话流的分布式实时异常定位方法

摘要

本发明涉及一种基于Web会话流的分布式实时异常定位方法，包括以下步骤：利用Flume与Kafka联合收集Web流量数据，将收集到的Web流量一方面发送到HDFS存储为离线日志，并通过DPS_DRB规则库构建算法动态建立和更新动态规则库DRB，另一方面发送到Spark Streaming，发送到Spark Streaming中的Web流量作为实时日志，Spark Streaming对持续不断的实时日志流式数据以滑动窗口的方式处理；AL_HBGSA算法基于动态规则库，将会话序列与动态规则库中的规则序列进行比对，从而进行异常定位。该方法有利于对Web会话流的异常进行高效、准确的定位。