关于高并发下的数据处理

架构总是在不断修正演变的过程中得到完善！！！需求背景：接到了一个判断报文中规则来触发告警的需求，本以为需求很简单，具体的告警逻辑就不赘述了，大体的流程是：接收到报文，报文中有定义规则和对应的当前值，判断当前值是否需要触发告警，如果需要则触发告警，存储告警，通过mqtt推送告警信息给前端。实现