报文保序方法及其装置

摘要

本发明公开了一种报文保序方法及其装置，该装置包括：流分类标识单元：按照给定规则，将接收到的报文划分为不同的业务流中，为流中每个报文分配一个连续递增的序列号；同时完成报文在多核/多线程上的负载均衡分发；报文处理单元：对接收到的报文进行处理；流状态监控单元：用来维护流状态队列，标记报文的处理状态；保持流状态队列和业务流队列一一对应；保序和调度发送单元：根据流状态队列中的报文状态向量和对应的处理策略，实现对报文调度、发送的同步。本发明通过可变粒度流发送序列号，可同时解决业务流正常报文、异常报文的保序功能；保序策略更为完善、保序功能更为稳定有效。

主权项

1.一种报文保序方法，包括如下的步骤：11)流分类标识单元对接收到的报文首先进行流分类和标识操作，将报文按给定规则划分为不同的业务流，同时为流中每个报文分配一个报文序列号，同一流中序列号连续递增分配；然后将报文均衡分发到并行的多个核/线程中；12)报文处理单元对报文进行处理时，流状态监控单元为每个业务流队列维护一个相应的流状态队列，实时监控报文状态，设置每个报文的状态向量，对于不同的报文状态向量，指定不同的处理策略；13)保序调度发送单元获取业务流当前发送序列号、报文序列号、业务流报文状态向量和对应的处理策略；锁定业务流当前发送序列号、相应状态向量；根据不同报文状态向量对应的处理策略，实现对报文调度、发送的同步；同时更新当前发送序列号，解锁发送序列号和报文状态向量。