一种基于消息驱动的分布式日志处理方法及系统

本申请提出了一种基于消息驱动的分布式日志处理方法及系统，涉及医疗信息化领域。其包括：对多源原始日志数据进行异步采集，并封装为日志事件消息后通过无阻塞接口投递至分布式消息队列。根据日志事件消息的元数据特征，利用预设路由规则将日志事件消息分配至对应的消息队列。利用Actor模型集群对各消息队列中的日志事件消息进行并行消费处理；其中，在进行并行消费处理时，通过监测消息队列的分区积压量和Actor模型集群负载率，按阈值动态调整Actor集群的实例数量，并通过监督者层级结构监测Actor模型集群运行状态，对故障的Actor模型进行重启或消息重路由处理，以及结合死信队列处理失败消息。该方案能够匹配医疗日志高敏感、强合规和高实时的核心需求。