一种面向高并发场景的轻量级异步消息处理方法及系统
本申请涉及一种面向高并发场景的轻量级异步消息处理方法及系统,该方法包括接收客户端的消息请求,并对消息请求进行预处理,生成待处理消息;基于优先级调度机制将待处理消息分配至多级优先级队列中;根据资源状态数据动态调整线程池的核心线程数量与最大线程数量,形成当前调度周期的线程池资源配置方案;基于各级优先级队列的消息堆积数量、线程池资源配置方案、资源状态数据中的CPU使用率和JVM堆内存使用率,动态计算当前调度批次的消息处理数量;基于堆外内存缓冲区引用,将待处理消息对象分派至对应的处理线程中执行业务处理逻辑,直至完成所有调度单元中消息的处理操作。本申请具有提升异步消息处理架构的资源适应性的效果。