CN109388434A - 交互数据的获取方法及装置 - Google Patents
交互数据的获取方法及装置 Download PDFInfo
- Publication number
- CN109388434A CN109388434A CN201710652700.2A CN201710652700A CN109388434A CN 109388434 A CN109388434 A CN 109388434A CN 201710652700 A CN201710652700 A CN 201710652700A CN 109388434 A CN109388434 A CN 109388434A
- Authority
- CN
- China
- Prior art keywords
- service
- monitored
- parameter
- monitoring
- requester
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/445—Program loading or initiating
- G06F9/44505—Configuring for program initiating, e.g. using registry, configuration files
- G06F9/4451—User profiles; Roaming
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/2866—Architectures; Arrangements
- H04L67/30—Profiles
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/34—Network arrangements or protocols for supporting network services or applications involving the movement of software or configuration parameters
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/51—Discovery or management thereof, e.g. service location protocol [SLP] or web services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
本发明实施方式涉及一种交互数据的获取方法及装置,其中所述获取方法包括:当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;基于所述请求参数和响应参数确定所述被监听服务的调用参数;通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及将所述交互数据发送给第三方。本发明的交互数据的获取方法及装置,能够实现在服务提供方和服务请求方之间进行数据交换时将交互数据发送给第三方。
Description
技术领域
本发明涉及计算机通信领域,并且更具体地,涉及交互数据的获取方法及装置。
背景技术
随着计算机通信技术的快速发展,区域信息网络内多个设备之间进行信息共享是当今各个行业面临的主要挑战之一。现有的应用系统由于采用了不同标准、数据模型或者实现平台,在需要数据共享时候,常常根据某些特定需求实现了特定方式的连接。由于系统的异构性以及集成需求的变化和增加,这种点对点的信息交换模式越来越复杂而且难以维护,逐渐不能满足日益复杂的数据共享和交换要求。
然而,传统的行业服务总线只支持服务提供方和服务请求方之间的数据交换。交互数据无法被第三方获取。在实际应用中,行业服务总线在实际的项目中,用户经常提出让运行在总线上的服务产生的交互数据同时发送给第三方的需求。
发明内容
根据本发明的一个方面,提供一种交互数据的获取方法,其特征在于,所述获取方法包括:
当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;
当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
基于所述请求参数和响应参数确定所述被监听服务的调用参数;
通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
将所述交互数据发送给第三方。
其中,所述请求参数包括服务请求方ID、服务请求方地址、被监听服务ID以及服务内容的参数;以及所述响应参数包括服务请求方地址、被监听服务ID、交换结构地址以及服务内容的参数。
其中,由所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。
其中,所述配置文件包括多个三元组,每个三元组为<服务内容、服务请求方ID、监听服务>。
其中,所述通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据包括:
基于调用参数中的服务内容和服务请求方ID在所述配置文件的多个三元组中进行搜索,从而确定匹配的三元组,所述匹配的三元组中的监听服务能够获取交互数据。
其中,所述方法还包括:
将所述交互数据发送给历史服务器,并且由所述历史服务器对所述交互数据进行保存。
根据本发明的另一方面,提供一种交互数据的获取装置,其特征在于,所述获取装置包括:
监测单元,当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;以及当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
参数生成单元,基于所述请求参数和响应参数确定所述被监听服务的调用参数;
处理单元,通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
接口单元,将所述交互数据发送给第三方。
其中,所述请求参数包括服务请求方ID、服务请求方地址、被监听服务ID以及服务内容的参数;所述响应参数包括服务请求方地址、被监听服务ID、交换结构地址以及服务内容的参数。
其中,所述参数生成单元将所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。
其中,所述配置文件包括多个三元组,每个三元组为<服务内容、服务请求方ID、监听服务>。
其中,所述处理单元通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据包括:所述处理单元基于调用参数中的服务内容和服务请求方ID在所述配置文件的多个三元组中进行搜索,从而确定匹配的三元组,所述匹配的三元组中的监听服务能够获取交互数据。
其中,所述接口单元还用于将所述交互数据发送给历史服务器,以由所述历史服务器对所述交互数据进行保存。
根据本发明的再一方面,提供一种计算机程序产品,其包括处理器可执行的程序,其特征在于,该程序被处理器执行时实现以下步骤:
当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;
当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
基于所述请求参数和响应参数确定所述被监听服务的调用参数;
通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
将所述交互数据发送给第三方。
根据本发明的再一方面,提供一种交互数据的获取系统,其特征在于,所述获取系统包括:
处理器;
用于存储处理器可执行指令的存储器;
其中,所述处理器被配置为:执行如上所述的方法。
通过本发明的交互数据的获取方法及装置,能够实现服务提供方和服务请求方之间的数据交换并且能够将交互数据发送给第三方。为此,本方面通过监听服务将交互数据发送给第三方来解决交互数据不能向第三方发送的问题。由于本发明在监测到请求参数和响应参数后,实时地通过请求参数和响应参数构建调用参数,并且基于调用参数和配置文件来选择监听服务,从而保证向多个第三方发送数据的实时有效性。此外,本发明通过历史服务器对交互数据进行保存,从而能够在后期需要获取交互数据时提供查询服务。最后,本发明通过监听机制来获取与监听服务相关的参数,对被监听服务的运行无任何影响。
附图说明
通过参考下面的附图,可以更为完整地理解本发明的示例性实施方式:
图1为现有技术中的传统卫生服务系统的结构示意图;
图2为根据本发明实施方式的与卫生服务相关的交互数据的获取方法的流程图;
图3为根据本发明实施方式的交互数据的获取方法的流程图;
图4为根据本发明实施方式的卫生服务系统的结构示意图;以及
图5为根据本发明实施方式的交互数据的获取装置的结构示意图。
具体实施方式
现在参考附图介绍本发明的示例性实施方式,然而,本发明可以用许多不同的形式来实施,并且不局限于此处描述的实施方式,提供这些实施方式是为了详尽地且完全地公开本发明,并且向所属技术领域的技术人员充分传达本发明的范围。对于表示在附图中的示例性实施方式中的术语并不是对本发明的限定。在附图中,相同的单元/元件使用相同的附图标记。
除非另有说明,此处使用的术语(包括科技术语)对所属技术领域的技术人员具有通常的理解含义。另外,可以理解的是,以通常使用的词典限定的术语,应当被理解为与其相关领域的语境具有一致的含义,而不应该被理解为理想化的或过于正式的意义。
图1为现有技术中的传统卫生服务系统100的结构示意图。卫生服务系统100将现有的卫生服务整合和集成以形成统一的应用架构,从而形成互联互通的医疗卫生业务协作网络。卫生服务系统100是企业服务总线在医疗行业的实现,并且以医疗行业标准为基础,将医疗卫生机构的业务流程、应用系统和相关数据整合起来,从而提供统一的访问总线。如图1所示,卫生服务系统100包括:服务请求方101-1、101-2、…、101-N,卫生服务总线102以及服务提供方103-1、103-2、…、103-N。应当了解的是,服务请求方和服务提供方是针对于服务的相对概念。通常,部分实体既可以是服务请求方,也可以是服务提供方。例如,在社区中心为普通用户提供服务的情况下,普通用户是服务请求方,并且社区中心为服务提供方。在医院为社区中心提供服务的情况下,社区中心是服务请求方,并且医院为服务提供方。此外,当医院A为医院B提供服务时,医院B是服务请求方,并且医院A为服务提供方。
然而,卫生服务总线102只支持服务请求方101-1、101-2、…、101-N和服务提供方103-1、103-2、…、103-N之间的数据交换。交互数据无法保存也无法发送给第三方。其中,第三方例如是服务监督方、业务监控方、社会公众等。在实际应用中,卫生服务总线在实际的项目中,客户经常提出让运行在总线上的服务产生的交互数据同时发送给第三方的需求。
图2为根据本发明实施方式的与卫生服务相关的交互数据的获取方法200的流程图。本申请通过对被监听服务进行监测,从交换结构中获取与被监听服务相关的请求参数,并且通过对服务响应进行监测,从交换结构中获取与服务响应相关的响应参数。本申请基于请求参数和响应参数来构建与被监听服务相关的调用参数,并且基于调用参数和被监听服务的配置文件选择能够获取交互数据的监听服务,以使得监听服务能够将交互数据发送给第三方。
如图2所示,获取方法200从步骤201处开始。在步骤201,对请求参数进行解析及保存。当被监听的服务被调用的时候,将调用的请求参数从交换结构中解析出来,并以文件方式保存到文件服务器中。在步骤201之前,本申请可以确定需要经由网络设备进行数据转发的多个服务,并且基于多个服务中每个服务的交互类型将服务分为需要进行监听的服务和不需要进行监听的服务。其中交互类型包括:第三方无关型和第三方相关型,其中当服务的交互类型为第三方无关型,则确定这个服务为不需要进行监听的服务,并且当服务的交互类型为第三方相关型,则确定这个服务为需要进行监听的服务。本申请对经由服务网络内的网络设备进行转发的数据进行监测。如上所述。服务请求方能够通过网络设备向服务提供方(例如,被监听服务)发送服务请求并且能够通过网络设备从服务提供方接收服务响应。
当服务请求方通过网络设备向服务提供方发送服务请求以及通过网络设备从服务提供方接收服务响应时,网络设备会将上述服务请求和服务响应存储在交换结构中。为此,本申请能够在交换结构中获取与所述服务请求相关的请求参数和响应参数。
此外,系统管理员可以预先设置需要进行监听的服务。通常,通过网络设备进行数据传输的服务可以是各种类型的服务,并且可以是多个服务请求方中任意服务请求方和多个服务提供方中任意服务提供方之间的服务。对于不需要进行监听或者不存在服务监听方的服务,方法通常不进行监听处理。请求参数可以包括:服务请求方ID、服务请求方地址、被监听服务ID以及服务内容。其中,服务请求方ID是服务请求方的标识,其用于标识服务请求方。服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤202,对响应参数进行解析及保存。当被监听的服务响应调用的时候,将响应参数从交换结构中解析出来,并以文件方式保存到文件服务器中。响应参数可以包括:服务请求方地址、被监听服务ID、交换结构地址以及服务内容。其中,服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。在被监听服务针对服务请求向服务请求方发送服务响应后,服务请求方和被监听服务通过网络设备进行数据交互并且将交互数据保存在网络设备的交换结构中。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤203,对参数进行转换。根据监听服务的属性,将截获的请求参数和响应参数转换为监听服务对应的调用参数。其中调用参数包括:服务请求方ID、被监听服务ID、交换结构地址以及服务内容。服务请求方ID是服务请求方的标识,其用于标识服务请求方。被监听服务ID是用于识别被监听服务的标识。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤204,调用监听服务。根据监听服务的配置,使用转换后的参数,调用监听服务。本申请基于调用参数和被监听服务的配置文件确定监听服务。被监听服务的配置文件包括多个三元组,并且每个三元组为<服务内容、服务请求方ID、监听服务>。其中,服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。服务请求方ID是服务请求方的标识,其用于标识服务请求方。监听服务用于将交互数据发送给第三方。本申请基于调用参数中的服务内容和服务请求方在被监听服务的配置文件的多个三元组中进行搜索,从而确定匹配的三元组,将所述匹配的三元组中的监听服务作为发送交互数据的主体。
在步骤205,对结果进行保存,即对监听的结果进行保存。此外,本申请还包括利用历史服务器的存储单元将每个服务监听方将通过监听得到的数据进行保存,或者由历史服务器的存储单元将所接收的相关的监听控制数据、监听过程参数等数据以进行存储。基于结果,本申请可追溯监听过程中每一步的状态。如果监听过程中发生错误,根据结果的状态,可以进行重发操作。
下面以实际例子进行说明:
(一)传染病报卡
传染病报卡要求相关责任报告人需要在2小时以内以最快的方式及时向疾控中心、疫情监测中心上报病人信息,并且需要明确得知是否上报成功,上报不成功时要采取其他应急措施继续上报,确保疫情信息及时发布。
其他相关单位如病人所在社区、数据中心或其他业务上有需要的机构也要受到相应的通知,但是实时性要求不那么强,仅需要在一定时间范围内成功通知到即可。如果失败能够有相应重发的流程就能满足要求。
可以将病人所在社区、数据中心或其他业务上有需要的机构设置为传染病报卡服务的数据监听方,即可满足上述场景的业务需求。
(二)数据中心数据监听
以往数据中心存储医疗机构交易数据都是调用医疗机构提供的接口,在特定时间进行数据采集。采集流程复杂且很难保证数据的完整性。
通过使用数据监听功能,数据中心可以针对特定服务进行监听配置,实时的采集交易数据,并且可以同时保存请求数据和相应数据。
图3为根据本发明实施方式的交互数据的获取方法300的流程图。本申请通过对被监听服务进行监测,从交换结构中获取与被监听服务相关的请求参数,并且通过对服务响应进行监测,从交换结构中获取与被监听服务相关的响应参数。本申请基于请求参数和响应参数来构建与被监听服务相关的调用参数,并且基于调用参数和被监听服务的配置文件选择能够获取交互数据的监听服务,以使得监听服务能够将交互数据发送给第三方。
如图3所示,方法300从步骤301处开始。在步骤301,当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数。当服务请求方通过网络设备向服务提供方(例如,被监听服务)发送服务请求以及通过网络设备从服务提供方接收服务响应时,网络设备会将上述服务请求和服务响应存储在交换结构中。为此,本申请能够在交换结构中获取与所述服务请求相关的请求参数。请求参数可以包括:服务请求方ID、服务请求方地址、被监听服务ID以及服务内容。其中,服务请求方ID是服务请求方的标识,其用于标识服务请求方。服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤301之前,本申请还可以确定需要经由网络设备进行数据转发的多个服务,并且基于所述多个服务中每个服务的交互类型将服务分为需要进行监听的服务和不需要进行监听的服务。其中交互类型包括:第三方无关型和第三方相关型,其中当服务的交互类型为第三方无关型,则确定这个服务为不需要进行监听的服务,并且当服务的交互类型为第三方相关型,则确定这个服务为需要进行监听的服务。本申请对经由服务网络内的网络设备进行转发的数据进行监测。如上所述。服务请求方能够通过网络设备向服务提供方发送服务请求并且能够通过网络设备从服务提供方接收服务响应。
在步骤302,当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数。当服务请求方通过网络设备向服务提供方发送服务请求以及通过网络设备从服务提供方接收服务响应时,网络设备会将上述服务请求和服务响应存储在交换结构中。为此,本申请能够在交换结构中获取与针对于被监听服务的服务请求相关的响应参数。
响应参数可以包括:服务请求方地址、被监听服务ID、交换结构地址、服务等级以及服务内容。其中,服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。在被监听服务针对服务请求向服务请求方发送服务响应后,服务请求方和被监听服务通过网络设备进行数据交互并且将交互数据保存在网络设备的交换结构中。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在数据缓存中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤303,基于所述请求参数和响应参数确定所述被监听服务的调用参数。本申请基于所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。因此,调用参数包括:服务请求方ID、被监听服务ID、交换结构地址以及服务内容。服务请求方ID是服务请求方的标识,其用于标识服务请求方。被监听服务ID是用于识别被监听服务的标识。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在数据缓存中的地址。服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
在步骤304,通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据。被监听服务的配置文件包括多个三元组,并且每个三元组为<服务内容、服务请求方ID、监听服务>。其中,服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。服务请求方ID是服务请求方的标识,其用于标识服务请求方。监听服务用于将交互数据发送给第三方。本申请基于调用参数中的服务内容和服务请求方在被监听服务的配置文件的多个三元组中进行搜索,从而确定匹配的三元组,将所述匹配的三元组中的监听服务作为发送交互数据的主体。
在步骤305,将所述交互数据发送给第三方。此外,本申请还包括利用存储单元将每个服务监听方(即,第三方)将通过监听得到的数据进行保存,或者存储单元将所接收的相关的监听控制数据、监听过程参数等数据以进行存储。基于所保存的结果,本申请可追溯监听过程中每一步的状态。如果监听过程中发生错误,根据结果的状态,可以进行重发操作。
图4为根据本发明实施方式的卫生服务系统400的结构示意图。为了简化地进行说明,图4中仅示出了一个服务请求方和一个服务提供方。如图4所示,卫生服务系统400包括:服务请求方401、卫生服务总线402、服务提供方403、服务监听方404-1,404-2,…,404-N、历史服务器405以及控制单元406。服务请求方401能够通过卫生服务总线402向服务提供方403发送服务请求并且能够通过卫生服务总线402从服务提供方403接收服务响应。服务提供方403可以针对服务请求方401的服务请求进行处理,从而提供服务。为了使第三方能够在服务请求方401和服务提供方403之间进行信息交互时进行数据获取或数据监控,本发明允许服务监听方404-1,404-2,…,404-N接入卫生服务总线402。服务监听方404-1,404-2,…,404-N能够对同一个服务会话或服务进程进行监听。为此,服务监听方404-1,404-2,…,404-N能够可以同时对服务请求和服务响应进行监听。此外,控制单元406对于所监听的数据可以采用实时发送和延时发送的数据发送方式。基于这种监听,当服务监听方404-1,404-2,…,404-N确定服务出现错误时可触发错误追溯和服务重发。
控制单元406对经由卫生服务网络内的卫生服务总线402进行转发的数据进行监测。如上所述。服务请求方401能够通过卫生服务总线402向服务提供方403发送服务请求并且能够通过卫生服务总线402从服务提供方403接收服务响应。为此,控制单元406对经由卫生服务总线402进行转发的数据进行数据识别并且在确定数据中存在与服务请求和服务响应相关的内容时确定监测到服务请求和服务响应。
当监测到被监听服务被调用时,控制单元406从卫生服务总线402的交换结构中获取与调用所述被监听服务的请求参数,并且当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数。当服务请求方401通过卫生服务总线402向服务提供方403发送服务请求以及通过卫生服务总线402从服务提供方403接收服务响应时,卫生服务总线402会将上述服务请求和服务响应存储在交换结构中。为此,控制单元406能够在交换结构中获取与所述服务请求相关的请求参数和响应参数。
此外,通过对控制单元406进行配置,系统管理员可以预先设置需要进行监听的服务。通常,通过卫生服务总线402进行数据传输的服务可以是各种类型的服务,并且可以是多个服务请求方中任意服务请求方和多个服务提供方中任意服务提供方之间的服务。对于不需要进行监听或者不存在服务监听方的服务,控制单元406通常不进行监听处理。
请求参数可以包括:服务请求方ID、服务请求方地址、被监听服务的ID以及服务内容。其中,服务请求方ID是服务请求方的标识,其用于标识服务请求方。服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务的ID是用于识别被监听服务的标识。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
响应参数可以包括:服务请求方地址、被监听服务ID、交换结构地址以及服务内容。其中,服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。在被监听服务针对服务请求向服务请求方发送服务响应后,服务请求方和被监听服务通过卫生服务总线402进行数据交互并且将交互数据保存在卫生服务总线402的交换结构中。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
控制单元406基于所述请求参数和响应参数确定所述被监听服务的调用参数。本申请基于所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。因此,调用参数包括:服务请求方ID、被监听服务ID、交换结构地址以及服务内容。服务请求方ID是服务请求方的标识,其用于标识服务请求方。被监听服务ID是用于识别被监听服务的标识。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
控制单元406通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据。被监听服务的配置文件包括多个三元组,并且每个三元组为<服务内容、服务请求方ID、监听服务>。其中,服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。服务请求方ID是服务请求方的标识,其用于标识服务请求方。监听服务用于将交互数据发送给第三方。本申请基于调用参数中的服务内容和服务请求方在被监听服务的配置文件的多个三元组进行搜索,从而确定匹配的三元组,将所述匹配的三元组中的监听服务作为发送交互数据的主体。
控制单元406促使,例如,监听服务,将所述交互数据发送给第三方。控制单元406还可以确定需要经由所述网络设备进行数据转发的多个服务,并且基于所述多个服务中每个服务的交互类型将服务分为需要进行监听的服务和不需要进行监听的服务。其中交互类型包括:第三方无关型和第三方相关型,其中当服务的交互类型为第三方无关型,则确定所述第二服务为不需要进行监听的服务,并且当第三服务的交互类型为第三方相关型,则确定所述第三服务为需要进行监听的服务。
历史服务器405用于将每个服务监听方将通过监听得到的数据进行保存,或者历史服务器405从控制单元406接收相关的监听控制数据、监听过程参数等数据以进行存储。
图5为根据本发明优选实施方式的交互数据的获取装置500的结构示意图。本申请通过对被监听服务进行监测,从交换结构中获取与被监听服务相关的请求参数,并且通过对服务响应进行监测,从交换结构中获取与被监听服务相关的响应参数。本申请基于请求参数和响应参数来构建与被监听服务相关的调用参数,并且基于调用参数和被监听服务的配置文件选择能够获取交互数据的监听服务,以使得监听服务能够将交互数据发送给第三方。
如图5所示,系统500包括:初始化单元501、监测单元502、参数生成单元503、处理单元504以及接口单元305。初始化单元501可以确定需要经由网络设备进行数据转发的多个服务,并且基于所述多个服务中每个服务的交互类型将服务分为需要进行监听的服务和不需要进行监听的服务。其中交互类型包括:第三方无关型和第三方相关型,其中当服务的交互类型为第三方无关型,则确定这个服务为不需要进行监听的服务,并且当服务的交互类型为第三方相关型,则确定这个服务为需要进行监听的服务。
监测单元502对经由服务网络内的网络设备进行转发的数据进行监测。如上所述。服务请求方能够通过网络设备向服务提供方(例如,被监听服务)发送服务请求并且能够通过网络设备从服务提供方接收服务响应。为此,监测单元502对经由网络设备进行转发的服务请求和服务响应进行监测。
当监测到被监听服务被调用时,监测单元302从交换结构中获取调用所述被监听服务的请求参数,并且当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数。当服务请求方通过网络设备向服务提供方发送服务请求以及通过网络设备从服务提供方接收服务响应时,网络设备会将上述服务请求和服务响应存储在交换结构中。为此,监测单元502能够在交换结构中获取与针对于被监听服务的服务请求相关的请求参数和响应参数。
此外,通过对初始化单元501进行配置,系统管理员可以预先设置需要进行监听的服务。通常,通过网络设备进行数据传输的服务可以是各种类型的服务,并且可以是多个服务请求方中任意服务请求方和多个服务提供方中任意服务提供方之间的服务。对于不需要进行监听或者不存在服务监听方的服务,监测单元502通常不进行监听处理。请求参数可以包括:服务请求方ID、服务请求方地址、被监听服务ID以及服务内容。其中,服务请求方ID是服务请求方的标识,其用于标识服务请求方。服务请求方地址是服务请求方的IP地址或MAC地址。被监听服务ID是用于识别被监听服务的标识。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
响应参数可以包括:服务请求方地址、被监听服务ID、交换结构地址以及服务内容。其中,服务请求方的地址是服务请求方的IP地址或MAC地址。被监听服务的ID是用于识别被监听服务的标识。在被监听服务针对服务请求向服务请求方发送服务响应后,服务请求方和被监听服务通过网络设备进行数据交互并且将交互数据保存在网络设备的交换结构中。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
参数生成单元503基于所述请求参数和响应参数确定所述被监听服务的调用参数。本申请基于所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。因此,调用参数包括:服务请求方ID、被监听服务ID、交换结构地址以及服务内容。服务请求方ID是服务请求方的标识,其用于标识服务请求方。被监听服务ID是用于识别被监听服务的标识。交换结构地址用于指示在服务请求方和服务提供方建立服务连接后,所提供的服务内容在交换结构中的地址。以及服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。
处理单元504通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据。被监听服务的配置文件包括多个三元组,并且每个三元组为<服务内容、服务请求方ID、监听服务>。其中,服务内容是服务请求方请求服务提供方提供服务的内容,例如可以是语音数据、视频数据等。服务请求方ID是服务请求方的标识,其用于标识服务请求方。监听服务用于将交互数据发送给第三方。本申请基于调用参数中的服务内容和服务请求方在被监听服务的配置文件的多个三元组中进行搜索,从而确定匹配的三元组,将所述匹配的三元组中的监听服务作为发送交互数据的主体。
接口单元505响应于监听服务的请求,将所述交互数据发送给第三方。此外,装置500还包括存储单元(图5中未示出)用于将每个服务监听方将通过监听得到的数据进行保存,或者存储单元将所接收的相关的监听控制数据、监听过程参数等数据以进行存储。
已经通过参考少量实施方式描述了本发明。然而,本领域技术人员所公知的,正如附带的专利权利要求所限定的,除了本发明以上公开的其他的实施方式等同地落在本发明的范围内。
通常地,在权利要求中使用的所有术语都根据他们在技术领域的通常含义被解释,除非在其中被另外明确地定义。所有的参考“一个/所述/该[装置、组件等]”都被开放地解释为所述装置、组件等中的至少一个实例,除非另外明确地说明。这里公开的任何方法的步骤都没必要以公开的准确的顺序运行,除非明确地说明。
Claims (10)
1.一种交互数据的获取方法,其特征在于,所述获取方法包括:
当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;
当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
基于所述请求参数和响应参数确定所述被监听服务的调用参数;
通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
将所述交互数据发送给第三方。
2.根据权利要求1所述的获取方法,其特征在于,所述请求参数包括服务请求方ID、服务请求方地址、被监听服务ID以及服务内容的参数;以及所述响应参数包括服务请求方地址、被监听服务ID、交换结构地址以及服务内容的参数。
3.根据权利要求2所述的获取方法,其特征在于,由所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。
4.根据权利要求1-3任一项所述的获取方法,所述配置文件包括多个三元组,每个三元组为<服务内容、服务请求方ID、监听服务>。
5.一种交互数据的获取装置,其特征在于,所述获取装置包括:
监测单元,当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;以及当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
参数生成单元,基于所述请求参数和响应参数确定所述被监听服务的调用参数;
处理单元,通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
接口单元,将所述交互数据发送给第三方。
6.根据权利要求5所述的获取装置,其特征在于,所述请求参数包括服务请求方ID、服务请求方地址、被监听服务ID以及服务内容的参数;所述响应参数包括服务请求方地址、被监听服务ID、交换结构地址以及服务内容的参数。
7.根据权利要求6所述的获取装置,所述参数生成单元将所述请求参数中的服务请求方ID和被监听服务ID,以及所述响应参数中的交换结构地址和服务内容构成所述调用参数。
8.根据权利要求5-7任一项所述的获取装置,所述配置文件包括多个三元组,每个三元组为<服务内容、服务请求方ID、监听服务>。
9.一种计算机程序产品,其包括处理器可执行的程序,其特征在于,该程序被处理器执行时实现以下步骤:
当监测到被监听服务被调用时,从交换结构中获取调用所述被监听服务的请求参数;
当监测到所述被监听服务的服务响应时,从所述交换结构中获取响应所述被监听服务的响应参数;
基于所述请求参数和响应参数确定所述被监听服务的调用参数;
通过调用配置文件中所述调用参数对应的监听服务获取被监听服务的交互数据;以及
将所述交互数据发送给第三方。
10.一种交互数据的获取系统,其特征在于,所述获取系统包括:
处理器;
用于存储处理器可执行指令的存储器;
其中,所述处理器被配置为:执行权利要求1至4任意一项所述的获取方法。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201710652700.2A CN109388434B (zh) | 2017-08-02 | 2017-08-02 | 交互数据的获取方法及装置 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201710652700.2A CN109388434B (zh) | 2017-08-02 | 2017-08-02 | 交互数据的获取方法及装置 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN109388434A true CN109388434A (zh) | 2019-02-26 |
CN109388434B CN109388434B (zh) | 2022-02-11 |
Family
ID=65412005
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201710652700.2A Active CN109388434B (zh) | 2017-08-02 | 2017-08-02 | 交互数据的获取方法及装置 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN109388434B (zh) |
Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN105516266A (zh) * | 2015-11-30 | 2016-04-20 | 华为技术有限公司 | 一种业务监控方法、系统及相关设备 |
CN105553920A (zh) * | 2014-10-29 | 2016-05-04 | 腾讯科技(深圳)有限公司 | 数据交互方法及装置、系统 |
CN106331156A (zh) * | 2016-09-26 | 2017-01-11 | 广东小天才科技有限公司 | 一种终端信息交互方法及装置 |
-
2017
- 2017-08-02 CN CN201710652700.2A patent/CN109388434B/zh active Active
Patent Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN105553920A (zh) * | 2014-10-29 | 2016-05-04 | 腾讯科技(深圳)有限公司 | 数据交互方法及装置、系统 |
CN105516266A (zh) * | 2015-11-30 | 2016-04-20 | 华为技术有限公司 | 一种业务监控方法、系统及相关设备 |
CN106331156A (zh) * | 2016-09-26 | 2017-01-11 | 广东小天才科技有限公司 | 一种终端信息交互方法及装置 |
Also Published As
Publication number | Publication date |
---|---|
CN109388434B (zh) | 2022-02-11 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US10129073B2 (en) | System and method for addition and removal of servers in server cluster | |
US9635067B2 (en) | Tracing and asynchronous communication network and routing method | |
US9641684B1 (en) | Tracing and asynchronous communication network and routing method | |
EP1562132B1 (en) | Dynamic contact list management system and method | |
US10171661B2 (en) | System and method of distributed maintenance of contact center state | |
CN105075229B (zh) | 用于建立回叫远程通信连接的方法 | |
EP1551162A2 (en) | Call treatment in a communications system based on instant messaging | |
US12095875B2 (en) | Dynamic user profiles based on interactions between users | |
US20120124137A1 (en) | System, Method and Apparatus for Enhanced Processing of Communication In a Peer-To-Peer Network | |
US20230075903A1 (en) | Initiating a response action from a persistent graphical user interface panel | |
CN109388434A (zh) | 交互数据的获取方法及装置 | |
US12058287B2 (en) | Reconnecting a calling device to a stage of an interactive voice response service | |
US11991313B2 (en) | Limiting query distribution within an agent group based on skip criteria | |
US20190342234A1 (en) | Message Integrator | |
EP3143756A1 (en) | Systems and methods for handling and routing incoming communication requests | |
US20210058361A1 (en) | System and method for collecting and storing electronic messages of different types based on subject matter | |
US8929527B2 (en) | Method allowing an exchange of context information within a group of users sharing one and the same identifier | |
JP2007013353A (ja) | 文字/データ送受信システム、端末管理装置及びそれらに用いる文字/データ送受信方法並びにそのプログラム | |
US11556880B1 (en) | Sentiment-based prioritization of contact center engagements | |
US12022030B2 (en) | Limiting query distribution within an agent group | |
CN107925586A (zh) | 用于计算机集成电信环境中的监视对象的监视的启动的方法、用于方法的装置和系统 | |
JP2017529614A (ja) | サービス内容処理方法及び装置 | |
BR112015006024B1 (pt) | Método de processamento de informação, e sistema de comunicação |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |