网站拦截数据上报

处理传过来的数据，将数据进行封装，保存到kafka消息队列中参数格式：topic、group、key、value

传入参数datas

处理消息

>10000

ip写入黑名单ad_guard_ip_balck表，刷新黑名单缓存数据ad_guard_ip_black_list

开始

数据库是否存在

网站拦截数据上报

刷新缓存

判断同一个ip当日请求记录数是否大于10000

>500

不存在

空

存在

直接抛弃

结束

<=500

if(datas==null)

返回不为空校验

每条记录的counts>500

<10000

不为空

消息存入数据库，刷新缓存数据

返回状态status=200

缓存数据是否存在