本发明提出一种基于大数据的流处理预警的方法，构建Storm分布式集群作为数据处理模块，数据处理模块从数据收集端口接收待处理数据，通过Drool构建规则引擎，数据处理模块和规则引擎共同将待处理数据处理为待预警数据，预警模块根据待预警数据发出警报，将规则引擎与Storm分布式集群结合，规则引擎拉取分布式集群中的待处理数据进行数据关联分析得到待预警数据后进行预警，提升了海量数据实时分析处理能力，并且能够及时获取危险预警信息并及时发出预警。