前言
在前一篇中，我们基于KeyedProcessFunction 实现了一个恶意登录检测的简单案例，但是在具体实现过程中我们发现，过程还是比较繁琐的，有没有更好的实现呢，就可以考虑使用CEP的方式；
我们知道，CEP提供了非常丰富而灵活的事件匹配模式，借助这一点，比如要实现检测特定时间窗口内连续2次登录失败时间，使用CEP就非常方便，而不需要注册定时器那样来的麻烦一些；
下面直接上代码，
import org.apache.flink.cep.CEP;
import org.apache.flink.cep.PatternSelectFunction;
import org.apache.flink.cep.PatternStream;
import org.apache.flink.cep.pattern.Pattern;
import org.apache.flink.cep.pattern.conditions.SimpleCondition;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
import o版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143268.html
