CN114845183B 可自定义工程租赁车辆运行指标异常的监控系统及方法 （西安交通大学）

可自定义工程租赁车辆运行指标异常的监本发明公开一种可自定义工程租赁车辆运通过MQTT协议经Nginx负载均衡后发送到EMQX网过身份验证后被发送到消息队列Kafka。大数据实时处理引擎Flink实时消费Kafka的数据，将Redis中的各种指标阈值和Drools的规则配置文指标的异常阈值，该值会分别存到Redis和关系租方可以查询报警数据实现对车辆异常的实时2所述数据采集层用于实现车辆运行数据的采集，在每一台工程租赁车载物联网智能盒子采集到的车辆运行数据通过MQTT消息协议传输到系统的Nginx负载均衡网关层用于对经Nginx负载均衡处理过的MQTT数据进行认证鉴权，并将MQTT数据发送务之间的解耦；计算引擎层使用大数据实时计算引擎Flink订阅消息队列中的数据实现对时序数据库Opentsdb以及关系型数据库PostgreSQL以及内存数据库Redis多种数据库来存2.根据权利要求1所述的可自定义工程租赁车辆运行指标异常的监控系统，其特征在3.根据权利要求1所述的可自定义工程租赁车辆运行指标异常的监控系统，其特征在4.根据权利要求1所述的可自定义工程租赁车辆运行指标异常的监控系统，其特征在5.根据权利要求1所述的可自定义工程租赁车辆运行指标异常的监控系统，其特征在3在使用自定义的聚合处理类进行对聚合后数据进行处理时，将存储在Redis中的异常子围栏的范围信息保存到关系型数据库PostgreSQL和内存数据步骤15，使用大数据实时计算引擎Flink实时利用工程车辆的位置数据并进行开窗聚的位置数据写入到关系型数据库Postgre4步骤5，获取当前所有配置的报警规则，并将步骤4获步骤6，使用大数据实时计算引擎Flink实时消费Kafka中的工程车辆指标数据并进行5[0006]1)工程车辆在被租赁后，车辆的出租方和租赁方无法实6工作时间等运行指标，数据将按照MQTT协议的格式经Nginx负载均衡后发送到EMQX网关集群。EMQX通过内置数据库与MQTT协议中的Clinetid/Username与密码进行对比完成认证鉴合，实现对异常数据筛选报警。最终将车辆位置数据写入到HBase，指标数据写入到标异常阈值，经过网站后端的业务逻辑处理该值会分别存到Redis和关系数据库载物联网智能盒子，基于车载物联网智能盒子对工程车辆的运行状态信息进行实时采集，将车载物联网智能盒子采集到的车辆运行数据通过MQTT消息协议传输到系统的Nginx负载[0016]网关层用于对经Nginx负载均衡处理过的MQTT数据进行认证鉴权，并将MQTT数据算服务之间的解耦；引擎层使用大数据实时计算引擎Flink订阅消息队列中的数据实现对数据库Opentsdb以及关系型数据库PostgreSQL以及内存数据库Redis多种数据库来存储引PostgreSQL存储自定义的车辆异常检测规则信息；业务逻辑层针对业务人员的车辆管理、7进行传输时，在MQTT协议报文中指定客户端Clientid/Username与密码，通过所述客户端Clientid/Username与密码完成对工程租赁车辆身份的绑定，同时为实现系统对于车辆身[0018]负载均衡层包括Nginx集群，负载均衡层承接车载物联网智能盒子发送的实时车[0019]网关层实现对MQTT消息进行认证/访问控制，在EMQX的内置Mnesia数据库或者外部关系型数据库存储客户端Clientid/Username与密码，客户端连接EMQX时，EMQX会获取[0026]在使用自定义的聚合处理类进行对聚合后数据进行处理时，将存储在Redis中的在车辆发生异常时及时的通知车辆出租方，也要将异常数据写回Kafka，系统后端会订阅[0028]在表现层绘制车辆电子围栏，实现用户自定义的绘制工8[0033]步骤15，使用大数据实时计算引擎Flink实时利用工程车辆的位置数据并进行开车辆的位置数据写入到关系型数据库Postgr[0036]步骤2，在resources目录下为每一个需要预警的数据指标创建后缀为.drl的[0043]步骤6，使用大数据实时计算引擎Flink实时消费Kafka中的工程车辆指标数据并EMQX通过内置数据库与MQTT协议中的Clinetid/Username与密码进行对比完成认证鉴权。Kafka中的数据，并获取存储在Redis中的各种指标阈值和Drools的规则配置文件进行整9通过Nginx将请求根据相应的规则分发到相应的服务器，解决了单个服务器硬件性能瓶颈[0049]本发明使用大数据流式计算框架Flink对工程租赁车辆发送的实时数据进行处数据将按照MQTT协议的格式经Nginx负载均衡后发送到EMQX网关集群。EMQX通过内置数据取存储在Redis中的各种指标阈值和Drools的规则配置文件进行整合，实现对异常数据筛标异常阈值，经过网站后端的业务逻辑处理该值会分别存到Redis和关系数据库采集到车辆运行数据之后通过MQTT消息协议传输，并在MQTT协议报文中指定客户端[0055]为了承接车载物联网智能盒子发送的海量实时的车辆运行数据，当Nginx负载均证/访问控制，可以在EMQX的内置Mnesia数据库或者外部关系型数据库(例如PostgreSQL)的密码进行匹配，若匹配成功则认证成功，则将车辆实时运行指标数据发送至消息队列[0058]利用消息队列Kafka构建消息队列集群实现身份认证服务与数据计算服务之间的[0059]利用开源规则引擎Drools构建规则配置文件解