实时引擎面向D0即时分账场景,交易完成后消息即刻推送,调度器优先抢占低延迟计算资源,快速执行分账试算、借贷平衡核验、原子事务落库,满足分销商秒级回款、前台实时展示分账明细的诉求。实时引擎队列优先级更高,调度逻辑追求低时延,单任务处理链路短,不做等待休眠;仅瞬时通道超时的任务,才会转入独立的指数退避重试队列,不占用实时主线程资源。实时引擎主打吞吐响应速度,承接绝大多数常规收单分账请求。
调度层是双引擎协同的核心。统一调度中心负责任务分流,根据任务标签判定归属:标记为实时分账的推送实时引擎;带有触发时间、延后标识的分配至延迟引擎。两套引擎各自维护独立的任务状态机,实时引擎状态为处理中、成功、即时失败、转重试;延迟引擎包含待唤醒、唤醒中、执行成功、执行失败。任务执行时,都会拉取同一份合约版本快照,遵循相同的阶梯累进、渠道路由、并行规则、时序裁定逻辑,核算标准一致。
隔离机制保证互不干扰。计算资源池分开部署,数据库读写连接池隔离,延时队列和实时队列分分区存储。极端场景下,比如月底大量冻结保证金集中到期,延迟引擎批量唤醒任务,压力被限制在专属集群,实时分账链路依旧稳定提供秒到能力,不会出现分销商实时回款排队延迟。任意一个引擎内部出现堆积、异常,故障熔断范围被框定在自身链路,不会向上蔓延影响另一套引擎。
业务落地时,商户需要做好业务归类,即时佣金、货款走实时引擎;质保金到期释放、月度返利、周期对账分润交给延迟引擎。不建议把延后结算需求压到实时链路,容易造成大量人工工单。调度日志分开留存,分别记录实时触发时间、延迟计划唤醒时间、实际执行时间,方便排查不同类型分账的时效问题。
这套双引擎调度方案,把即时性任务和定时延后任务解耦隔离,资源互不抢占,兼顾业务多样化分账(http://www.xianzhitech.com/)时序诉求,同时守住统一的账务核算标准,在复杂平台分账场景下兼顾时效与稳定性。
