摘要
本发明涉及一种铁路物资采购异步任务处理方法、装置及系统,该方法包括:构建采购业务流程的六层消息通道架构,并基于Kafka集群的核心消息中间件,执行对每个通道部署双活模式的消息代理节点的指令;指令前端网关将采购事件封装为带事务ID与时间戳的二进制消息体,并根据任务类型标签进行优先级标注后写入持久化队列;采用多级反馈队列调度算法处理并发任务,并基于线程池动态分配计算资源;根据指数退避重试策略设置最大重试阈值,以使失败任务自动转入死信队列;基于供应商画像和物资分类模型,动态计算最优消息路由路径,并根据消息队列的Topic动态切换,将订单提取至最优供应商的专属处理队列。本发明降低了耦合度,提高了系统性能,增强容错性。
技术关键词
多级反馈队列
Kafka集群
事件驱动型服务
消息
双活模式
分布式锁服务
调度算法
铁路
订单
时间片轮转调度
网关
动态
服务组件
画像
指数
微服务实例
调度器
通道
系统为您推荐了相关专利信息
分布式配置
软件配置方法
更新消息
项目
机器学习分类器
网络套接字
异常检测方法
身份验证信息
算法模型
格式
控制策略
数据访问请求
角色访问控制方法
数据访问方法
访问控制列表