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

摘要

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

说明书

技术领域

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

背景技术

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

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

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

发明内容

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

本发明的技术方案如下：

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

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

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

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

本发明的技术效果如下：

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

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

附图说明

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

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

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

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

具体实施方式

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

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

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

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

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

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

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

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