一种面向计费采集数据转发的高性能队列方法及系统

摘要文本

本发明提出一种面向计费采集数据转发的高性能队列方法及系统，包括：步骤S1：启动管理进程，创建共享内存，拉起核心进程，并注册生产者和消费者；步骤S2：生产者通过API发送消息，工作进程负责消息格式化和入队；步骤S3：持久化进程处理队列中的消息并创建文件，分发进程根据组ID分配消息；步骤S4：消费者通过API拉取消息，工作进程管理消息提取和确认。本发明通过其先进的架构和技术实现，展现了卓越的性能、低I/O依赖和高稳定性，使其成为处理大规模、高频率消息传递场景的理想选择，实现组内消息的严格有序性，确保消息的幂等性。支持积压消息的动态重分配，保障计费业务消息的有序性和安全性。