一种消息排序方法、装置、电子设备及程序产品

本申请提出一种消息排序方法、装置、电子设备及程序产品，通过分发线程池获取原始消息并将同一业务流程消息分配至同一待排序队列，排序线程池工作线程读取消息存入线程本地缓存集合，基于业务流程内消息依赖关系判定可发送性，满足条件的消息发送至订阅队列，不满足的保留在缓存中。该机制有效解决了消息中间件因多交换机、网络延迟导致的同一业务消息乱序问题，避免数据不一致与业务异常；统一的排序逻辑替代订阅方重复开发，降低系统复杂度；通过线程池分工、本地缓存存储及未满足条件消息的缓存策略，减少交互开销，在高频交易场景下兼顾消息有序性与低延迟要求，提升高并发下处理吞吐量、实时性与资源利用率。