一种电信实时系统长链接接口交互超时处理装置和方法

摘要

一种电信实时系统长链接接口交互超时处理装置和方法，用以解决在电信实时系统之间交互信息高稳定性和高可靠性的问题，也能够满足对交互信息自动记录和自动分析的要求，其特征在于，包括内部业务接口和实时消息交互适配接口，所述内部业务接口通过交互请求消息处理队列模块连接实时消息交互适配接口，所述实时消息交互适配接口通过交互回复消息处理队列模块连接内部业务接口，交互信息会话池分别连接交互请求消息处理队列模块、交互回复消息处理队列模块和超时交互扫描模块，所述超时交互扫描模块分别连接交互请求消息处理队列模块和交互信息记录模块，所述交互信息记录模块分别连接交互回复消息处理队列模块和交互信息分析模块。

权利要求

1.一种电信实时系统长链接接口交互超时处理装置，其特征在于，包括内部业务接口和实时消息交互适配接口，所述内部业务接口通过交互请求消息处理队列模块连接实时消息交互适配接口，所述实时消息交互适配接口通过交互回复消息处理队列模块连接内部业务接口，交互信息会话池分别连接交互请求消息处理队列模块、交互回复消息处理队列模块和超时交互扫描模块，所述超时交互扫描模块分别连接交互请求消息处理队列模块和交互信息记录模块，所述交互信息记录模块分别连接交互回复消息处理队列模块和交互信息分析模块；

所述内部业务接口，用于接收内部业务处理模块提交的交互请求消息，将交互请求消息传递给交互请求消息处理队列模块；所述交互请求消息处理队列模块，用于向实时消息交互适配接口提交交互请求消息，并存储交互请求消息到交互信息会话池；所述交互信息会话池，用于保存交互请求消息；所述实时消息交互适配接口，用于当交互正常时则回复信息给交互回复消息处理队列模块，当交互不正常时则通知超时交互扫描模块；所述超时交互扫描模块，用于从交互信息会话池中扫描出超时的交互请求消息，根据不同的业务需求做不同的处理；所述交互信息记录模块，用于记录所有的交互信息；所述交互信息分析模块，用于分析所记录的交互信息；所述根据不同的业务需求做不同的处理，是指删除并记录超时交互信息，或者重新提交交互请求消息，实现异步重发机制。

2.一种电信实时系统长链接接口交互超时处理方法，其特征在于包括以下步骤：①将电信实时系统长链接接口交互超时处理装置一端通过其内部业务接口连接各业务处理组件，另一端连接通过其实时消息交互适配接口连接外围实时系统；②当内部业务接口接收到业务处理组件提交的交互请求消息后，将交互请求消息传递给交互请求消息处理队列模块；③交互请求消息处理队列模块将交互请求消息保存到交互信息会话池并发送给实时消息交互适配接口；④如果交互正常，则回复信息给交互回复消息处理队列模块，如果交互不正常，则通过超时交互扫描模块从交互信息会话池中提取该交互请求消息，重新计算优先级并提交到交互请求消息处理队列模块，实现异步重发机制。

说明书

一种电信实时系统长链接接口交互超时处理装置和方法

技术领域

[0001] 本发明涉及电信实时系统的信息交互管理技术，特别是一种电信实时系统长链接接口交互超时处理装置和方法，用以解决在电信实时系统之间交互信息高稳定性和高可靠性的问题，也能够满足对交互信息自动记录和自动分析的要求。

背景技术

[0002] 现有电信网络中存在各种OSS/BSS系统(OSS：Operation support system运营支撑系统/BSS：Business support system业务支撑系统)，所有这类系统均需要与多个外围系统交互业务信息。由电信业务自身特点决定，接收、处理请求的时间集中，强度大。在高并发，长时间的压力下，实时系统不可避免的会出现短暂的断链，丢包，超时的异常情况。而电信级系统要求，实时系统间交互成功率必须达到99.9999％(无断链，无丢包，无超时即为交互成功)。旦出现系统交互异常，只能依赖信息交互客户端接口，在异常发生时记录并抛弃该次交互，由事后人工方式上报超时数据，定位故障位置，排查故障原因，以避免下次同类异常发生(而实际上此类稳定性问题很难完全避免)。通常这些交互数据由于实时性强，事后已经无法补充处理。现有的技术，在故障发生时无法自动重试，只能通过事后人工方式定位处理超时故障。

[0003] 图1是现有技术中的实时信息交互技术的系统架构示意图。图1中业务系统与外围实时系统连接，业务系统中的实时消息交互适配接口分别与各业务处理组件和超时信息日志记录直接连接。

[0004] 当实时系统之间在高并发，长时间的信息交互压力下，实时系统不可避免的会出现短暂的断链，丢包，超时的异常情况。从可靠性、稳定性、可维护的角度看，存在的问题及缺陷，有以下几点：1、交互可靠性存在问题。在系统交互超时发生时，现有系统要么记录并抛弃掉本次交互，要么以同步方式重试若干次，若仍然无法正常交互，也只能记录并抛弃掉本次交互。处理手段简单粗暴。2、记录的故障信息不全面，格式不合理，对故障信息无事后统计分析的手段。由于电信级实时接口通常都是并行处理接口，在记录接口交互时通常请求与回复不在同一线程中，在日志中请求消息与回复消息通常不在同一条记录中，这给超时统计，故障分析定位带来问题，处理效率低下。

发明内容

[0005] 本发明针对现有技术中存在的缺陷或不足，提供一种电信实时系统长链接接口交互超时处理装置和方法，用以解决在电信实时系统之间交互信息高稳定性和高可靠性的问题，也能够满足对交互信息自动记录和自动分析的要求。

[0006] 本发明的技术方案如下：

[0007] 一种电信实时系统长链接接口交互超时处理装置，其特征在于，包括内部业务接口和实时消息交互适配接口，所述内部业务接口通过交互请求消息处理队列模块连接实时消息交互适配接口，所述实时消息交互适配接口通过交互回复消息处理队列模块连接内部业务接口，交互信息会话池分别连接交互请求消息处理队列模块、交互回复消息处理队列模块和超时交互扫描模块，所述超时交互扫描模块分别连接交互请求消息处理队列模块和交互信息记录模块，所述交互信息记录模块分别连接交互回复消息处理队列模块和交互信息分析模块。

[0008] 所述内部业务接口，用于接收内部业务处理模块提交的交互消息；所述交互请求消息处理队列模块，用于向实时消息交互适配接口提交请求消息，并存储消息到交互消息会话池；所述交互消息会话池，用于保存交互请求消息，以供收到回复消息后和/或超时以后，取出消息做后续处理；所述超时交互扫描模块，用于从交互信息会话池中扫描出超时交互信息会话，根据不同的业务需求做不同的处理；所述交互信息记录模块，用于记录所有的交互信息，以供后续环节使用；所述交互信息分析模块，用于分析所记录的交互信息，以定位故障类型，故障原因，判断该次故障影响业务及大小。

[0009] 所述根据不同的业务需求做不同的处理，是指删除并记录超时交互信息，或者重新提交交互请求消息。

[0010] 一种电信实时系统长链接接口交互超时处理方法，其特征在于包括以下步骤：①将电信实时系统长链接接口交互超时处理装置一端通过其内部业务接口连接各业务处理组件，另一端连接通过其实时消息交互适配接口连接外围实时系统；②当内部业务接口接收到业务处理组件提交的交互请求消息后，将交互请求消息传递给交互请求消息处理队列模块；③交互请求消息处理队列模块将交互请求消息保存到交互消息会话池并发送给实时消息交互适配接口；④如果交互正常，则回复信息给交互回复消息处理队列模块，如果交互不正常，则通过超时交互扫描模块从交互消息会话池中提取该交互请求消息，重新计算优先级并提交到交互请求消息处理队列模块，实现异步重发机制。

[0011] 本发明的技术效果如下：

[0012] 电信BSS系统消息交互，接口协议需要基于长链接通信协议，在业务上能够支持重复请求。以交互消息处理队列，实现异步重发机制；以对交互信息记录，实现多维度故障分析。

[0013] 本发明通过对电信实时系统信息交互的管理，记录，实现了对交互超时消息异步重试机制，提高了信息交互的稳定性、可靠性。对交互超时信息记录的自动多维度分析处理，为故障定位提供了经过分析整理的数据，系统维护人员不用在做重复简单的初级数据整理分析工作，可能更快速的定位交互超时原因，为排除故障提供时间保障。

附图说明

[0014] 图1是现有技术中的实时信息交互技术的系统架构示意图。

[0015] 图2是电信实时系统长链接接口交互超时处理装置在BSS系统与实时扣费系统交互中所处的位置示意图。

[0016] 图3是电信实时系统长链接接口交互超时处理装置结构示意图。

[0017] 图4是电信实时系统长链接接口交互超时处理方法流程图。

具体实施方式

[0018] 下面结合附图(图1-图4)对本发明进行说明。

[0019] 图1是现有技术中的实时信息交互技术的系统架构示意图。图1中业务系统与外围实时系统连接，业务系统中的实时消息交互适配接口分别与各业务处理组件和超时信息日志记录直接连接。

[0020] 图2是电信实时系统长链接接口交互超时处理装置在BSS系统与实时扣费系统交互中所处的位置示意图。如图2所示，电信实时系统长链接接口交互超时处理装置一端连接BSS系统中的各种计费扣费组件，另一端通过实时消息交互适配接口连接外围实时系统(实时扣费系统)。

[0021] 图3是电信实时系统长链接接口交互超时处理装置结构示意图。如图3所示，装置分为以下几个部分：①内部业务接口：接收内部业务处理模块提交的交互消息。②交互消息处理队列：向适配接口提交请求消息，并存储消息到交互消息会话池。③交互信息会话池：保存交互请求消息，以供收到回复消息后和超时以后，取出消息做后续处理。④超时交互扫描：从交互信息会话池中扫描出超时交互信息会话。根据不同的业务需求做不同的处理(删除并记录超时交互信息，或者重新提交交互请求消息)。⑤交互信息记录模块：负责记录所有的交互信息，以供后续环节使用。⑥交互信息分析模块：负责分析所记录的交互信息，以定位故障类型，故障原因，判断该次故障影响业务及大小。

[0022] 图4是电信实时系统长链接接口交互超时处理方法流程图。如图4所示，交互消息的处理过程如下：①将电信实时系统长链接接口交互超时处理装置一端通过其内部业务接口连接各业务处理组件，另一端连接通过其实时消息交互适配接口连接外围实时系统；②当内部业务接口接收到业务处理组件提交的交互请求消息后，将交互请求消息传递给交互请求消息处理队列模块；③交互请求消息处理队列模块将交互请求消息保存到交互消息会话池并发送给实时消息交互适配接口；④如果交互正常，则回复信息给交互回复消息处理队列模块，如果交互不正常，则通过超时交互扫描模块从交互消息会话池中提取该交互请求消息，重新计算优先级并提交到交互请求消息处理队列模块，实现异步重发机制。

[0023] 对交互超时记录做多维度的分析包括：超时业务类型分析；超时时间点分析；单位时间超时数量分析。

[0024] 一种电信实时系统长链接接口交互超时处理装置，其特征在于，包括内部业务接口和实时消息交互适配接口，所述内部业务接口通过交互请求消息处理队列模块连接实时消息交互适配接口，所述实时消息交互适配接口通过交互回复消息处理队列模块连接内部业务接口，交互信息会话池分别连接交互请求消息处理队列模块、交互回复消息处理队列模块和超时交互扫描模块，所述超时交互扫描模块分别连接交互请求消息处理队列模块和交互信息记录模块，所述交互信息记录模块分别连接交互回复消息处理队列模块和交互信息分析模块。所述内部业务接口，用于接收内部业务处理模块提交的交互消息；所述交互请求消息处理队列模块，用于向实时消息交互适配接口提交请求消息，并存储消息到交互消息会话池；所述交互消息会话池，用于保存交互请求消息，以供收到回复消息后和/或超时以后，取出消息做后续处理；所述超时交互扫描模块，用于从交互信息会话池中扫描出超时交互信息会话，根据不同的业务需求做不同的处理；所述交互信息记录模块，用于记录所有的交互信息，以供后续环节使用；所述交互信息分析模块，用于分析所记录的交互信息，以定位故障类型，故障原因，判断该次故障影响业务及大小。所述根据不同的业务需求做不同的处理，是指删除并记录超时交互信息，或者重新提交交互请求消息，实现异步重发机制。

[0025] 在此指明，以上叙述有助于本领域技术人员理解本发明创造，但并非限制本发明创造的保护范围。任何没有脱离本发明创造实质内容的对以上叙述的等同替换、修饰改进和/或删繁从简而进行的实施，均落入本发明创造的保护范围。