本发明公开了一种基于流计算和RETE算法的实时决策引擎实现方法，涉及大数据技术领域，通过把分布式流计算处理框架FLINK和RETE模式匹配算法结合起来，形成一个实时分布式流计算决策引擎，极大提高了大数据量且业务规则复杂场景下决策处理的吞吐量、处理速度和系统的高可用性，从而大大提高了业务实时决策的能力，解决了现有技术中数据处理吞吐量偏小，当需要处理的数据量庞大且需匹配的规则数多的情况下，系统处理时间大大增加，内存和CPU等计算资源消耗很大，数据处理严重延迟，系统性能严重下降等问题。