简介： 本发明公开了一种新能源车辆故障实时报警方法及系统，该方法包括采集原始车辆数据，并发送至前置机；前置机对原始车辆数据进行数据解析和过滤，并将解析后的车辆数据缓存入第一Kafka消息队列中；利用实时计算框架消费第一Kafka消息队列中的车辆数据，检测车辆是否发生故障，当车辆发生故障时，将报警数据缓存入第二Kafka消息队列中；利用KafkaService组件将第二Kafka消息队列中的报警数据写入数据库中；Web服务器读取数据库中的报警数据并展示到显示页面上，同时进行报警。本发明实现了高实时性、高效率的车辆故障实时报警。