一种双报文匹配方法、装置、设备、介质及产品与流程

摘要: 本发明涉及电通信,尤其涉及一种双报文匹配方法、装置、设备、介质及产品。背景技术:1、在分布式业务系统中,一笔完整的交易常由两种相互关联的报文共同构成,例如支付请...
一种双报文匹配方法、装置、设备、介质及产品与流程

本发明涉及电通信,尤其涉及一种双报文匹配方法、装置、设备、介质及产品。

背景技术:

1、在分布式业务系统中,一笔完整的交易常由两种相互关联的报文共同构成,例如支付请求报文与支付确认报文、物联网设备的上行指令与下行响应。由于网络延迟、队列调度、传输路径差异等因素,这两种报文可能乱序到达。若无法高效、准确地完成报文关联,将导致业务处理延迟、状态不一致甚至交易失败。

2、目前业界已有一些针对报文乱序处理的技术方案,但均存在各自的局限性,无法很好地解决业务层面两种不同类型报文乱序到达时的精确关联问题。

技术实现思路

1、本发明提供了一种双报文匹配方法、装置、设备、介质及产品,以提高报文的实时精准匹配。

2、根据本发明的一方面,提供了一种双报文匹配方法,该方法包括:

3、接收目标报文,并提取所述目标报文的业务标识和报文类型;根据所述业务标识和所述报文类型从报文热池的待匹配报文中查找是否存在所述目标报文对应的关联报文;其中,所述报文热池位于内存中高速存储区域,用于暂存先接收的报文;

4、若存在,则将所述目标报文和所述关联报文进行合并,并删除报文冷池中所述目标报文和所述关联报文;其中,所述报文冷池为持久化存储区域,用于备份所有待匹配报文;

5、若不存在,则将所述目标报文以所述业务标识为键、以所述目标报文的报文内容为值,写入所述报文热池,并异步将所述目标报文写入所述报文冷池。

6、根据本发明的另一方面,提供了一种双报文匹配装置,该装置包括:

7、目标报文获取模块,用于接收目标报文,并提取所述目标报文的业务标识和报文类型;

8、报文匹配模块,用于根据所述业务标识和所述报文类型从报文热池的待匹配报文中查找是否存在所述目标报文对应的关联报文;其中,所述报文热池位于内存中高速存储区域,用于暂存先接收的报文;

9、报文处理模块,用于若存在,则将所述目标报文和所述关联报文进行合并,并删除报文冷池中所述目标报文和所述关联报文;其中,所述报文冷池为持久化存储区域,用于备份所有待匹配报文;

10、所述报文处理模块,还用于若不存在,则将所述目标报文以所述业务标识为键、以所述目标报文的报文内容为值,写入所述报文热池,并异步将所述目标报文写入所述报文冷池。

11、根据本发明的另一方面,提供了一种电子设备,所述电子设备包括:

12、至少一个处理器;以及

13、与所述至少一个处理器通信连接的存储器;其中,

14、所述存储器存储有可被所述至少一个处理器执行的计算机程序,所述计算机程序被所述至少一个处理器执行,以使所述至少一个处理器能够执行本发明任一实施例所述的双报文匹配方法。

15、根据本发明的另一方面,提供了一种计算机可读存储介质,所述计算机可读存储介质存储有计算机指令,所述计算机指令用于使处理器执行时实现本发明任一实施例所述的双报文匹配方法。

16、根据本发明的另一方面,提供了一种计算机程序产品,所述计算机程序产品包括计算机程序,所述计算机程序在被处理器执行时实现根据本发明任一实施例所述的双报文匹配方法。

17、本发明实施例的技术方案,通过接收目标报文,并提取所述目标报文的业务标识和报文类型;根据所述业务标识和所述报文类型从报文热池的待匹配报文中查找是否存在所述目标报文对应的关联报文;其中,所述报文热池位于内存中高速存储区域,用于暂存先接收的报文;若存在,则将所述目标报文和所述关联报文进行合并,并删除报文冷池中所述目标报文和所述关联报文;其中,所述报文冷池为持久化存储区域,用于备份所有待匹配报文;若不存在,则将所述目标报文以所述业务标识为键、以所述目标报文的报文内容为值,写入所述报文热池,并异步将所述目标报文写入所述报文冷池。上述技术方案,通过报文热池进行报文实时匹配,以及报文冷池进行报文备份,通过两级存储模式进行报文处理的方式,在确保报文匹配精度的同时还能够保证数据不丢失。

18、应当理解,本部分所描述的内容并非旨在标识本发明的实施例的关键或重要特征,也不用于限制本发明的范围。本发明的其它特征将通过以下的说明书而变得容易理解。

1.一种双报文匹配方法,其特征在于,包括:

2.根据权利要求1所述的方法,其特征在于,所述报文热池按照报文优先级划分为多个优先级区域;

3.根据权利要求1所述的方法,其特征在于,还包括:

4.根据权利要求3所述的方法,其特征在于,根据所述等待时间对所述待匹配报文的报文优先级进行调整,并对所述待匹配报文的优先存储区域进行调整,包括:

5.根据权利要求3所述的方法,其特征在于,根据所述等待时间对所述待匹配报文的报文优先级进行调整,并对所述待匹配报文的优先存储区域进行调整的同时,还包括:

6.根据权利要求5所述的方法,其特征在于,对所述异常检测包括下述至少一项操作:

7.一种双报文匹配装置,其特征在于,包括:

8.一种电子设备,其特征在于,所述电子设备包括:

9.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机指令,所述计算机指令用于使处理器执行时实现权利要求1-6中任一项所述的双报文匹配方法。

10.一种计算机程序产品,其特征在于,所述计算机程序产品包括计算机程序,所述计算机程序在被处理器执行时实现根据权利要求1-6中任一项所述的双报文匹配方法。