[go: up one dir, main page]

CN116055355A - Method and system for interface monitoring based on enterprise service bus - Google Patents

Method and system for interface monitoring based on enterprise service bus Download PDF

Info

Publication number
CN116055355A
CN116055355A CN202211455006.9A CN202211455006A CN116055355A CN 116055355 A CN116055355 A CN 116055355A CN 202211455006 A CN202211455006 A CN 202211455006A CN 116055355 A CN116055355 A CN 116055355A
Authority
CN
China
Prior art keywords
interface
request
service
monitoring
information
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.)
Pending
Application number
CN202211455006.9A
Other languages
Chinese (zh)
Inventor
唐德华
张国辉
令狐昌辉
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Industrial Bank Co Ltd
CIB Fintech Services Shanghai Co Ltd
Original Assignee
Industrial Bank Co Ltd
CIB Fintech Services Shanghai Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Industrial Bank Co Ltd, CIB Fintech Services Shanghai Co Ltd filed Critical Industrial Bank Co Ltd
Priority to CN202211455006.9A priority Critical patent/CN116055355A/en
Publication of CN116055355A publication Critical patent/CN116055355A/en
Pending legal-status Critical Current

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/08Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0805Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
    • H04L43/0811Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking connectivity
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/06Management of faults, events, alarms or notifications
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/08Configuration management of networks or network elements
    • H04L41/0893Assignment of logical groups to network elements
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/16Threshold monitoring
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02PCLIMATE CHANGE MITIGATION TECHNOLOGIES IN THE PRODUCTION OR PROCESSING OF GOODS
    • Y02P90/00Enabling technologies with a potential contribution to greenhouse gas [GHG] emissions mitigation
    • Y02P90/02Total factory control, e.g. smart factories, flexible manufacturing systems [FMS] or integrated manufacturing systems [IMS]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Environmental & Geological Engineering (AREA)
  • Debugging And Monitoring (AREA)

Abstract

本发明提供了一种基于企业服务总线的接口监测方法和系统,包括:步骤1:配置应用系统接口参数,并根据参数信息对接口进行连通性探测;步骤2:对接口交易报文和业务量进行监控;步骤3:对客户发起的交易请求进行报文分析和路由转发。本发明可在总体的应用系统接口调用或者集成方式不变的前提下,提供应用系统接口监测、监控和接口路由的可配置方案,可根据实际业务的需要,配置适合于业务特征的监测、监控策略,确保应用系统提供的接口及各系统间的相互调用平稳运行。

Figure 202211455006

The present invention provides an interface monitoring method and system based on an enterprise service bus, comprising: step 1: configuring application system interface parameters, and performing connectivity detection on the interface according to the parameter information; step 2: detecting interface transaction messages and business volume Monitor; Step 3: Analyze the message and route and forward the transaction request initiated by the customer. The present invention can provide a configurable solution for application system interface monitoring, monitoring and interface routing under the premise that the overall application system interface call or integration mode remains unchanged, and can configure monitoring and monitoring suitable for business characteristics according to actual business needs Strategies to ensure that the interfaces provided by the application system and the mutual calls between systems run smoothly.

Figure 202211455006

Description

基于企业服务总线的接口监测方法和系统Method and system for interface monitoring based on enterprise service bus

技术领域technical field

本发明涉及接口监测技术领域,具体地,涉及一种基于企业服务总线的接口监测方法和系统。The invention relates to the technical field of interface monitoring, in particular to an interface monitoring method and system based on an enterprise service bus.

背景技术Background technique

基于企业服务总线(ESB)集成的应用系统间对接,需要根据需求,定义接口、设计接口、开发接口,并在ESB治理和发布,然后对接系统之间做验证。系统之间的调用变得安全有序。同时,也面临如下问题:The docking between application systems based on enterprise service bus (ESB) integration needs to define, design, and develop interfaces according to requirements, and manage and publish them in ESB, and then verify between docking systems. Calls between systems become safe and orderly. At the same time, it also faces the following problems:

(1)随着对接系统的规模增大和分布式应用系统的部署,ESB治理过程和发布、验证过程的耗时也在增长,接口的治理、发布和部署直接影响到系统上线的周期;(1) With the increase in the scale of the docking system and the deployment of distributed application systems, the time-consuming process of ESB governance, release, and verification is also increasing, and the governance, release, and deployment of interfaces directly affect the cycle of system launch;

(2)应用系统的规模增大,对外提供的接口增多,接口的可用性和接口业务量的实时监控至关重要,应用系统运营过程中,需要根据监控指标提前做好扩容或者流控准备,并对告警做出即时响应;(2) The scale of the application system increases, and the number of external interfaces increases. The availability of the interface and the real-time monitoring of the interface business volume are very important. During the operation of the application system, it is necessary to make preparations for expansion or flow control in advance according to the monitoring indicators, and Respond immediately to alerts;

(3)微服务架构下的分布式应用系统的部署,对外提供服务的接口不再由一台或者两台服务器提供,而是以多集群的方式提供,如何在传统的ESB集成环境下,不增加接口数量的前提下满足分布式应用部署的要求是需要考虑的问题。(3) For the deployment of distributed application systems under the microservice architecture, the interface for providing external services is no longer provided by one or two servers, but in the form of multiple clusters. On the premise of increasing the number of interfaces, meeting the requirements of distributed application deployment is a problem that needs to be considered.

专利文献CN112071408A(申请号:CN201910501547.2)公开了一种应用于企业服务总线的业务数据监测构件,该构件包括医院信息集成平台的企业服务总线,企业服务总线包括服务接入口和服务执行机构,服务接入口与服务执行机构相连接,企业服务总线中还包括业务数据监测与处置接口,业务数据监测与处置接口与服务接入口相连接。然而该专利无法解决上述技术问题。Patent document CN112071408A (application number: CN201910501547.2) discloses a business data monitoring component applied to an enterprise service bus, which includes an enterprise service bus of a hospital information integration platform. The service access port is connected to the service execution agency, and the enterprise service bus also includes a service data monitoring and disposal interface, which is connected to the service access port. Yet this patent can't solve above-mentioned technical problem.

发明内容Contents of the invention

针对现有技术中的缺陷,本发明的目的是提供一种基于企业服务总线的接口监测方法和系统。Aiming at the defects in the prior art, the object of the present invention is to provide an interface monitoring method and system based on enterprise service bus.

根据本发明提供的基于企业服务总线的接口监测方法,包括:The interface monitoring method based on the enterprise service bus provided by the present invention includes:

步骤1:配置应用系统接口参数,并根据参数信息对接口进行连通性探测;Step 1: Configure the interface parameters of the application system, and perform connectivity detection on the interface according to the parameter information;

步骤2:对接口交易报文和业务量进行监控;Step 2: Monitor the interface transaction messages and business volume;

步骤3:对客户发起的交易请求进行报文分析和路由转发。Step 3: Carry out message analysis and route forwarding for the transaction request initiated by the client.

优选的,所述步骤1包括:Preferably, said step 1 includes:

初始化接口配置,根据目标接口定义配置接口的服务集代码、子服务码、接口版本号和接口输入参数,在完成初始化接口配置后,将配置信息写入持久化层保存,查看和修改已保存的接口配置信息;Initialize the interface configuration, configure the service set code, sub-service code, interface version number and interface input parameters according to the target interface definition, after completing the initial interface configuration, write the configuration information into the persistence layer for storage, view and modify the saved Interface configuration information;

选择待探测的接口并发起探测,根据应用系统接口的配置信息自动生成接口请求报文,并向目标系统接口发送请求,通过解析应用系统的返回报文,判断应用系统接口的可用性;或配置定时任务,按照预置的频率监测应用系统接口的可用性。Select the interface to be detected and initiate a detection, automatically generate an interface request message according to the configuration information of the application system interface, and send a request to the target system interface, and judge the availability of the application system interface by analyzing the return message of the application system; or configure a timing The task monitors the availability of the application system interface according to the preset frequency.

优选的,所述步骤2包括:Preferably, said step 2 includes:

通过解析交易报文,记录交易流水号、接口服务码集、服务子码、请求接入时间、响应时间和请求返回码,并保存到持久化层;By parsing the transaction message, record the transaction serial number, interface service code set, service subcode, request access time, response time and request return code, and save it to the persistence layer;

通过分析请求报文,提供数据格式或进行参数转换,以满足多应用系统对接中存在自定义请求参数的需求;By analyzing the request message, provide data format or perform parameter conversion to meet the needs of custom request parameters in multi-application system docking;

通过统计交易请求、响应信息、单位时间内的业务情况量信息,实时呈现监控信息;Real-time presentation of monitoring information by counting transaction requests, response information, and business volume information per unit time;

通过配置告警规则,将监控信息转换为告警信息,在前端展示或者对外发布;支持黑名单配置,对于黑名单内的交易将直接拦截。By configuring alarm rules, the monitoring information is converted into alarm information, displayed on the front end or released to the outside world; blacklist configuration is supported, and transactions in the blacklist will be directly blocked.

优选的,所述步骤3包括:通过接口服务集代码和子服务码确定服务处理集群,若请求报文中的接口服务集代码和子服务码不在配置列表内,则直接将请求返回给客户端;若请求报文中的接口服务集代码和子服务码在配置列表内,则将请求转发给对应的后端服务处理。Preferably, the step 3 includes: determining the service processing cluster through the interface service set code and sub-service code, if the interface service set code and sub-service code in the request message are not in the configuration list, then directly return the request to the client; if If the interface service set code and sub-service code in the request message are in the configuration list, the request will be forwarded to the corresponding backend service for processing.

优选的,对在客户端发起的接口调用申请进行请求报文分析,根据不同的报文格式和请求体参数将请求报文转换为应用服务端要求的格式,同时拦击非法请求;Preferably, the request message is analyzed for the interface call application initiated by the client, and the request message is converted into the format required by the application server according to different message formats and request body parameters, and illegal requests are blocked at the same time;

根据请求报文中的服务集代码和子服务码,将请求信息转发给后端应用服务端处理,在后端应用服务端完成处理后,根据交易流水号将响应码记录到持久层;According to the service set code and sub-service code in the request message, the request information is forwarded to the back-end application server for processing. After the back-end application server completes the processing, the response code is recorded in the persistence layer according to the transaction serial number;

分析接口请求、响应信息,统计并展示同一接口的请求成功率和失败率,如果请求失败率超过设定阈值,则触发告警。Analyze interface request and response information, count and display the request success rate and failure rate of the same interface, and trigger an alarm if the request failure rate exceeds the set threshold.

根据本发明提供的基于企业服务总线的接口监测系统,包括:The interface monitoring system based on the enterprise service bus provided by the present invention includes:

应用接口监测模块:配置应用系统接口参数,并根据参数信息对接口进行连通性探测;Application interface monitoring module: configure the interface parameters of the application system, and detect the connectivity of the interface according to the parameter information;

接口业务量监控模块:对接口交易报文和业务量进行监控;Interface business volume monitoring module: monitor interface transaction messages and business volume;

交易报文转发模块:对客户发起的交易请求进行报文分析和路由转发。Transaction message forwarding module: perform message analysis and route forwarding for transaction requests initiated by customers.

优选的,所述应用接口监测模块包括:Preferably, the application interface monitoring module includes:

初始化接口配置,根据目标接口定义配置接口的服务集代码、子服务码、接口版本号和接口输入参数,在完成初始化接口配置后,将配置信息写入持久化层保存,查看和修改已保存的接口配置信息;Initialize the interface configuration, configure the service set code, sub-service code, interface version number and interface input parameters according to the target interface definition, after completing the initial interface configuration, write the configuration information into the persistence layer for storage, view and modify the saved Interface configuration information;

选择待探测的接口并发起探测,根据应用系统接口的配置信息自动生成接口请求报文,并向目标系统接口发送请求,通过解析应用系统的返回报文,判断应用系统接口的可用性;或配置定时任务,按照预置的频率监测应用系统接口的可用性。Select the interface to be detected and initiate a detection, automatically generate an interface request message according to the configuration information of the application system interface, and send a request to the target system interface, and judge the availability of the application system interface by analyzing the return message of the application system; or configure a timing The task monitors the availability of the application system interface according to the preset frequency.

优选的,所述接口业务量监控模块包括:Preferably, the interface traffic monitoring module includes:

通过解析交易报文,记录交易流水号、接口服务码集、服务子码、请求接入时间、响应时间和请求返回码,并保存到持久化层;By parsing the transaction message, record the transaction serial number, interface service code set, service subcode, request access time, response time and request return code, and save it to the persistence layer;

通过分析请求报文,提供数据格式或进行参数转换,以满足多应用系统对接中存在自定义请求参数的需求;By analyzing the request message, provide data format or perform parameter conversion to meet the needs of custom request parameters in multi-application system docking;

通过统计交易请求、响应信息、单位时间内的业务情况量信息,实时呈现监控信息;Real-time presentation of monitoring information by counting transaction requests, response information, and business volume information per unit time;

通过配置告警规则,将监控信息转换为告警信息,在前端展示或者对外发布;支持黑名单配置,对于黑名单内的交易将直接拦截。By configuring alarm rules, the monitoring information is converted into alarm information, displayed on the front end or released to the outside world; blacklist configuration is supported, and transactions in the blacklist will be directly blocked.

优选的,所述交易报文转发模块包括:通过接口服务集代码和子服务码确定服务处理集群,若请求报文中的接口服务集代码和子服务码不在配置列表内,则直接将请求返回给客户端;若请求报文中的接口服务集代码和子服务码在配置列表内,则将请求转发给对应的后端服务处理。Preferably, the transaction message forwarding module includes: determining the service processing cluster through the interface service set code and sub-service code, if the interface service set code and sub-service code in the request message are not in the configuration list, then directly return the request to the client If the interface service set code and sub-service code in the request message are in the configuration list, the request will be forwarded to the corresponding back-end service for processing.

优选的,客户端发起的接口调用申请,经企业服务总线到达接口业务量监控模块,经请求报文分析,根据不同的报文格式和请求体参数将请求报文转换为应用服务端要求的格式,同时拦击非法请求,然后将合法的请求转发给交易报文转发模块,并保存请求信息;Preferably, the interface call application initiated by the client reaches the interface traffic monitoring module through the enterprise service bus, and after analyzing the request message, the request message is converted into the format required by the application server according to different message formats and request body parameters , and block illegal requests at the same time, and then forward legal requests to the transaction message forwarding module, and save the request information;

所述交易报文转发模块根据请求报文中的服务集代码和子服务码,将请求信息转发给后端应用服务端处理,后端应用服务端完成处理后,根据交易流水号将响应码记录到持久层;The transaction message forwarding module forwards the request information to the back-end application server for processing according to the service set code and sub-service code in the request message, and after the back-end application server completes the processing, it records the response code in the persistence layer;

所述接口业务量监控模块分析接口请求、响应信息,统计并展示同一接口的请求成功率和失败率,如果请求失败率超过设定阈值,则触发告警。The interface traffic monitoring module analyzes interface request and response information, counts and displays the request success rate and failure rate of the same interface, and triggers an alarm if the request failure rate exceeds a set threshold.

与现有技术相比,本发明具有如下的有益效果:Compared with the prior art, the present invention has the following beneficial effects:

(1)本发明在接口初次部署上生产环境前或者修订后生产环境上线前,提前验证接口的可用性和连通性,确保了后端应用服务上线时接口在ESB已就绪;(1) The present invention verifies the usability and connectivity of the interface in advance before the interface is deployed on the production environment for the first time or before the revised production environment goes online, so as to ensure that the interface is ready in the ESB when the back-end application service goes online;

(2)本发明可实时监控应用系统在生产环境的发布的接口运行情况,确保了服务质量;(2) The present invention can real-time monitor the running situation of the interface issued by the application system in the production environment, ensuring the quality of service;

(3)本发明可根据应用系统的维护需要,灵活配置后台提供接口的服务端,在灰度升级等日常运维中,提供安全可控的路由方案。(3) According to the maintenance needs of the application system, the present invention can flexibly configure the server end that provides the interface in the background, and provide a safe and controllable routing scheme in daily operation and maintenance such as gray scale upgrade.

(4)本发明可在总体的应用系统接口调用或者集成方式不变的前提下,提供应用系统接口监测、监控和接口路由的可配置方案,可根据实际业务的需要,配置适合于业务特征的监测、监控策略,确保应用系统提供的接口及各系统间的相互调用平稳运行,此外,本发明的运用不需要与应用系统强耦合,具有可以根据应用系统的需要灵活配置,扩展性较强的特点。(4) The present invention can provide a configurable solution for application system interface monitoring, monitoring and interface routing under the premise that the overall application system interface call or integration mode remains unchanged, and can be configured according to the actual business needs. Monitoring and monitoring strategies to ensure the smooth operation of the interface provided by the application system and the mutual calls between the systems. In addition, the application of the present invention does not need to be strongly coupled with the application system, and it can be flexibly configured according to the needs of the application system and has strong scalability. features.

附图说明Description of drawings

通过阅读参照以下附图对非限制性实施例所作的详细描述,本发明的其它特征、目的和优点将会变得更明显:Other characteristics, objects and advantages of the present invention will become more apparent by reading the detailed description of non-limiting embodiments made with reference to the following drawings:

图1为本发明方法流程图;Fig. 1 is a flow chart of the method of the present invention;

图2为本发明系统结构示意图。Fig. 2 is a schematic structural diagram of the system of the present invention.

具体实施方式Detailed ways

下面结合具体实施例对本发明进行详细说明。以下实施例将有助于本领域的技术人员进一步理解本发明,但不以任何形式限制本发明。应当指出的是,对本领域的普通技术人员来说,在不脱离本发明构思的前提下,还可以做出若干变化和改进。这些都属于本发明的保护范围。The present invention will be described in detail below in conjunction with specific embodiments. The following examples will help those skilled in the art to further understand the present invention, but do not limit the present invention in any form. It should be noted that those skilled in the art can make several changes and improvements without departing from the concept of the present invention. These all belong to the protection scope of the present invention.

实施例1:Example 1:

如图1,本发明提供了一种基于企业服务总线的接口监测方法,包括:步骤1:配置应用系统接口参数,并根据参数信息对接口进行连通性探测;步骤2:对接口交易报文和业务量进行监控;步骤3:对客户发起的交易请求进行报文分析和路由转发。As shown in Fig. 1, the present invention provides a kind of interface monitoring method based on enterprise service bus, comprising: step 1: configure application system interface parameters, and carry out connectivity detection to interface according to parameter information; Step 2: interface transaction message and The business volume is monitored; Step 3: Carry out message analysis and routing and forwarding of the transaction request initiated by the customer.

所述步骤1包括:初始化接口配置,根据目标接口定义配置接口的服务集代码、子服务码、接口版本号和接口输入参数,在完成初始化接口配置后,将配置信息写入持久化层保存,查看和修改已保存的接口配置信息;选择待探测的接口并发起探测,根据应用系统接口的配置信息自动生成接口请求报文,并向目标系统接口发送请求,通过解析应用系统的返回报文,判断应用系统接口的可用性;或配置定时任务,按照预置的频率监测应用系统接口的可用性。The step 1 includes: initializing the interface configuration, configuring the service set code, sub-service code, interface version number and interface input parameters according to the target interface definition, and writing the configuration information into the persistence layer for storage after completing the initializing interface configuration. View and modify the saved interface configuration information; select the interface to be detected and initiate detection, automatically generate an interface request message according to the configuration information of the application system interface, and send a request to the target system interface, and analyze the return message of the application system. Judge the availability of the application system interface; or configure a scheduled task to monitor the availability of the application system interface according to the preset frequency.

所述步骤2包括:通过解析交易报文,记录交易流水号、接口服务码集、服务子码、请求接入时间、响应时间和请求返回码,并保存到持久化层;通过分析请求报文,提供数据格式或进行参数转换,以满足多应用系统对接中存在自定义请求参数的需求;通过统计交易请求、响应信息、单位时间内的业务情况量信息,实时呈现监控信息;通过配置告警规则,将监控信息转换为告警信息,在前端展示或者对外发布;支持黑名单配置,对于黑名单内的交易将直接拦截。Said step 2 includes: by parsing the transaction message, recording the transaction serial number, interface service code set, service subcode, request access time, response time and request return code, and saving it to the persistence layer; by analyzing the request message , to provide data format or parameter conversion to meet the needs of custom request parameters in multi-application system docking; to present monitoring information in real time by counting transaction requests, response information, and business situation information per unit time; by configuring alarm rules , convert the monitoring information into alarm information, display it on the front end or release it to the outside world; support blacklist configuration, and directly block transactions in the blacklist.

所述步骤3包括:通过接口服务集代码和子服务码确定服务处理集群,若请求报文中的接口服务集代码和子服务码不在配置列表内,则直接将请求返回给客户端;若请求报文中的接口服务集代码和子服务码在配置列表内,则将请求转发给对应的后端服务处理。The step 3 includes: determining the service processing cluster through the interface service set code and the sub-service code, if the interface service set code and the sub-service code in the request message are not in the configuration list, then directly return the request to the client; if the request message If the interface service set code and sub-service code in the configuration list are in the configuration list, the request will be forwarded to the corresponding backend service for processing.

对在客户端发起的接口调用申请进行请求报文分析,根据不同的报文格式和请求体参数将请求报文转换为应用服务端要求的格式,同时拦击非法请求;根据请求报文中的服务集代码和子服务码,将请求信息转发给后端应用服务端处理,在后端应用服务端完成处理后,根据交易流水号将响应码记录到持久层;分析接口请求、响应信息,统计并展示同一接口的请求成功率和失败率,如果请求失败率超过设定阈值,则触发告警。Analyze the request message for the interface call application initiated by the client, convert the request message into the format required by the application server according to different message formats and request body parameters, and block illegal requests at the same time; according to the service in the request message Set the code and sub-service code, forward the request information to the back-end application server for processing, after the back-end application server completes the processing, record the response code to the persistence layer according to the transaction serial number; analyze the interface request and response information, make statistics and display The request success rate and failure rate of the same interface, if the request failure rate exceeds the set threshold, an alarm will be triggered.

实施例2:Example 2:

本发明还提供一种基于企业服务总线的接口监测系统,所述基于企业服务总线的接口监测系统可以通过执行所述基于企业服务总线的接口监测方法的流程步骤予以实现,即本领域技术人员可以将所述基于企业服务总线的接口监测方法理解为所述基于企业服务总线的接口监测系统的优选实施方式。The present invention also provides an interface monitoring system based on the enterprise service bus, the interface monitoring system based on the enterprise service bus can be realized by executing the process steps of the interface monitoring method based on the enterprise service bus, that is, those skilled in the art can The enterprise service bus-based interface monitoring method is understood as a preferred implementation of the enterprise service bus-based interface monitoring system.

本发明系统提供了接口监测、接口业务监控和接口报文转发功能,部署在ESB和客户端或者目标应用服务之间,部署形态及业务流程如图1所示。所述系统具体包括:应用接口监测模块ESB-TEST、接口业务量监控模块ESB-MONITORING和交易报文转发模块ESB-GATEWAY。The system of the present invention provides interface monitoring, interface service monitoring and interface message forwarding functions, and is deployed between the ESB and the client or target application service. The deployment form and business process are shown in FIG. 1 . The system specifically includes: an application interface monitoring module ESB-TEST, an interface traffic monitoring module ESB-MONITORING and a transaction message forwarding module ESB-GATEWAY.

所述应用接口监测模块提供配置应用系统接口参数的功能并根据参数信息对接口发起连通性探测。首先,初始化接口配置,根据目标接口定义,配置接口的服务集代码、子服务码和接口版本号、接口输入参数等。完成初始化配置后,配置信息被写入持久化层保存。支持查看和修改已保存的接口配置参数。其次,选择待探测的接口并发起探测,应用接口监测模块根据系统接口的配置参数,自动生成接口请求报文,并向目标系统接口发送请求。应用接口监测模块通过解析应用系统的返回报文,判断应用系统接口的可用性。应用接口监测模块还支持配置定时任务,按照预置的频率监测应用系统接口的可用性。The application interface monitoring module provides the function of configuring the interface parameters of the application system and initiates connectivity detection on the interface according to the parameter information. First, initialize the interface configuration, and configure the service set code, sub-service code, interface version number, interface input parameters, etc. of the interface according to the definition of the target interface. After the initial configuration is completed, the configuration information is written to the persistence layer for storage. Supports viewing and modifying saved interface configuration parameters. Secondly, select the interface to be detected and initiate the detection, and the application interface monitoring module automatically generates an interface request message according to the configuration parameters of the system interface, and sends the request to the target system interface. The application interface monitoring module judges the usability of the application system interface by analyzing the return message of the application system. The application interface monitoring module also supports the configuration of timing tasks to monitor the availability of the application system interface according to the preset frequency.

所述接口业务量监控模块提供接口交易报文监控和业务量监控能力。接口业务量监控模块通过解析交易报文,记录该交易流水号、接口服务码集、服务子码、请求接入时间、响应时间、请求返回码等,并保存到持久化层。同时,接口业务量监控模块通过分析请求报文,提供数据格式或者参数转换的能力,解决多系统对接中存在自定义请求参数的需求。接口业务量监控模块通过统计交易请求、响应信息、单位时间内的业务情况量信息等,实时呈现监控信息。接口业务量监控模块支持通过配置告警规则,将监控信息转换为告警信息。告警信息支持直接在接口业务量监控模块前端展示或者对外发布,用于集中监控。此外,接口业务量监控模块支持黑名单配置,对于黑名单内的交易,将直接拦截。The interface traffic monitoring module provides interface transaction message monitoring and traffic monitoring capabilities. The interface traffic monitoring module records the transaction serial number, interface service code set, service subcode, request access time, response time, request return code, etc. by analyzing the transaction message, and saves it in the persistence layer. At the same time, the interface traffic monitoring module provides the ability to convert data formats or parameters by analyzing request messages, so as to solve the need for custom request parameters in multi-system docking. The interface business volume monitoring module presents monitoring information in real time by counting transaction requests, response information, business situation volume information per unit time, etc. The interface traffic monitoring module supports converting monitoring information into alarm information by configuring alarm rules. The alarm information can be directly displayed on the front end of the interface traffic monitoring module or released externally for centralized monitoring. In addition, the interface traffic monitoring module supports blacklist configuration, and will directly intercept transactions in the blacklist.

所述交易报文转发模块提供交易请求路由转发能力,基于配置化的方法实现。交易报文转发模块支持接口服务类型、接口服务集代码、子服务码和服务处理集群地址。交易报文转发模块通过接口服务集代码和子服务码唯一确定服务处理集群,若请求报文中的服务集代码和子服务码不在配置列表内,则交易报文转发模块直接将请求返回给客户端;若请求报文中的服务集代码和子服务码在配置列表内,则交易报文转发模块将请求转发给对应的后端服务处理。The transaction message forwarding module provides transaction request routing and forwarding capabilities, and is implemented based on a configuration method. The transaction message forwarding module supports interface service type, interface service set code, sub-service code and service processing cluster address. The transaction message forwarding module uniquely determines the service processing cluster through the interface service set code and sub-service code. If the service set code and sub-service code in the request message are not in the configuration list, the transaction message forwarding module directly returns the request to the client; If the service set code and sub-service code in the request message are in the configuration list, the transaction message forwarding module forwards the request to the corresponding backend service for processing.

所述应用接口监测模块用于测试目标应用系统在ESB上发布的接口,如果测试结果发现调用目标应用系统接口失败,可以帮助相关系统维护人员定位问题。The application interface monitoring module is used to test the interface published by the target application system on the ESB. If the test result finds that the call to the target application system interface fails, it can help the relevant system maintenance personnel to locate the problem.

所述接口业务量监控模块和交易报文转发模块适用于于应用系统作为服务端通过ESB提供接口供其他系统或客户端调用的场景。客户端发起的接口调用申请,经ESB到达接口监测工具的接口业务量监控模块,接口业务量监控模块分析请求报文,根据不同的报文格式和请求体参数将请求报文转换为应用服务端要求的格式,提高接口的适配灵活性。同时,拦击非法请求,然后将合法的请求转发给交易报文转发模块,并保存请求信息。The interface traffic monitoring module and the transaction message forwarding module are applicable to the scenario where the application system serves as the server and provides an interface through the ESB for other systems or clients to call. The interface call application initiated by the client reaches the interface traffic monitoring module of the interface monitoring tool through the ESB. The interface traffic monitoring module analyzes the request message and converts the request message into the application server according to different message formats and request body parameters. The required format improves the adaptability of the interface. At the same time, intercept illegal requests, then forward legal requests to the transaction message forwarding module, and save the request information.

所述交易报文转发模块根据请求报文中的服务集代码和子服务码,将请求转发给后端应用服务端处理。后端应用完成处理后,根据交易流水号将该响应码记录到持久层。The transaction message forwarding module forwards the request to the back-end application server for processing according to the service set code and sub-service code in the request message. After the backend application completes the processing, it records the response code to the persistence layer according to the transaction serial number.

所述接口业务量监控模块分析接口请求、响应信息,支持统计并展示同一接口的请求成功率和失败率,如果请求失败率超过了设定的阈值,将触发告警。The interface traffic monitoring module analyzes interface request and response information, supports statistics and displays the request success rate and failure rate of the same interface, and will trigger an alarm if the request failure rate exceeds a set threshold.

本领域技术人员知道,除了以纯计算机可读程序代码方式实现本发明提供的系统、装置及其各个模块以外,完全可以通过将方法步骤进行逻辑编程来使得本发明提供的系统、装置及其各个模块以逻辑门、开关、专用集成电路、可编程逻辑控制器以及嵌入式微控制器等的形式来实现相同程序。所以,本发明提供的系统、装置及其各个模块可以被认为是一种硬件部件,而对其内包括的用于实现各种程序的模块也可以视为硬件部件内的结构;也可以将用于实现各种功能的模块视为既可以是实现方法的软件程序又可以是硬件部件内的结构。Those skilled in the art know that, in addition to realizing the system, device and each module thereof provided by the present invention in a purely computer-readable program code mode, the system, device and each module thereof provided by the present invention can be completely programmed by logically programming the method steps. The same program is implemented in the form of logic gates, switches, application specific integrated circuits, programmable logic controllers, and embedded microcontrollers, among others. Therefore, the system, device and each module provided by the present invention can be regarded as a hardware component, and the modules included in it for realizing various programs can also be regarded as the structure in the hardware component; A module for realizing various functions can be regarded as either a software program realizing a method or a structure within a hardware component.

以上对本发明的具体实施例进行了描述。需要理解的是,本发明并不局限于上述特定实施方式,本领域技术人员可以在权利要求的范围内做出各种变化或修改,这并不影响本发明的实质内容。在不冲突的情况下,本申请的实施例和实施例中的特征可以任意相互组合。Specific embodiments of the present invention have been described above. It should be understood that the present invention is not limited to the specific embodiments described above, and those skilled in the art may make various changes or modifications within the scope of the claims, which do not affect the essence of the present invention. In the case of no conflict, the embodiments of the present application and the features in the embodiments can be combined with each other arbitrarily.

Claims (10)

1. An interface monitoring method based on an enterprise service bus, comprising the following steps:
step 1: configuring interface parameters of an application system, and detecting connectivity of the interface according to parameter information;
step 2: monitoring interface transaction messages and traffic;
step 3: and carrying out message analysis and route forwarding on the transaction request initiated by the client.
2. The method for monitoring an interface based on an enterprise service bus according to claim 1, wherein the step 1 comprises:
initializing interface configuration, namely writing configuration information into a persistence layer for storage after completing the initialization interface configuration according to service set codes, sub-service codes, interface version numbers and interface input parameters of a target interface definition configuration interface, and checking and modifying the stored interface configuration information;
selecting an interface to be detected, initiating detection, automatically generating an interface request message according to configuration information of an application system interface, sending a request to a target system interface, and judging the availability of the application system interface by analyzing a returned message of an application system; or configuring a timing task, and monitoring the availability of the application system interface according to a preset frequency.
3. The method for monitoring an interface based on an enterprise service bus according to claim 1, wherein the step 2 comprises:
recording a transaction serial number, an interface service code set, a service subcode, a request access time, a response time and a request return code by analyzing the transaction message, and storing the transaction serial number, the interface service code set, the service subcode, the request access time, the response time and the request return code in a persistence layer;
the request message is analyzed to provide a data format or perform parameter conversion so as to meet the requirement of the user-defined request parameters in the multi-application system docking;
the monitoring information is presented in real time by counting transaction requests, response information and business condition information in unit time;
the monitoring information is converted into alarm information through configuration of alarm rules, and the alarm information is displayed at the front end or is released outwards; the blacklist configuration is supported and transactions within the blacklist will be intercepted directly.
4. The method for monitoring an interface based on an enterprise service bus according to claim 1, wherein the step 3 comprises: determining a service processing cluster through the interface service set codes and the sub-service codes, and if the interface service set codes and the sub-service codes in the request message are not in the configuration list, directly returning the request to the client; if the interface service set code and the sub-service code in the request message are in the configuration list, the request is forwarded to the corresponding back-end service processing.
5. The interface monitoring method based on the enterprise service bus according to claim 1, wherein the interface calling application initiated at the client is analyzed to convert the request message into a format required by the application server according to different message formats and request body parameters, and an illegal request is blocked;
according to the service set codes and the sub-service codes in the request message, forwarding the request information to a back-end application server for processing, and after the back-end application server finishes processing, recording a response code to a persistence layer according to the transaction serial number;
analyzing interface request and response information, counting and displaying the request success rate and failure rate of the same interface, and triggering an alarm if the request failure rate exceeds a set threshold value.
6. An interface monitoring system based on an enterprise service bus, comprising:
an application interface monitoring module: configuring interface parameters of an application system, and detecting connectivity of the interface according to parameter information;
interface traffic monitoring module: monitoring interface transaction messages and traffic;
a transaction message forwarding module: and carrying out message analysis and route forwarding on the transaction request initiated by the client.
7. The enterprise service bus-based interface monitoring system of claim 6, wherein the application interface monitoring module comprises:
initializing interface configuration, namely writing configuration information into a persistence layer for storage after completing the initialization interface configuration according to service set codes, sub-service codes, interface version numbers and interface input parameters of a target interface definition configuration interface, and checking and modifying the stored interface configuration information;
selecting an interface to be detected, initiating detection, automatically generating an interface request message according to configuration information of an application system interface, sending a request to a target system interface, and judging the availability of the application system interface by analyzing a returned message of an application system; or configuring a timing task, and monitoring the availability of the application system interface according to a preset frequency.
8. The enterprise service bus-based interface monitoring system of claim 6, wherein the interface traffic monitoring module comprises:
recording a transaction serial number, an interface service code set, a service subcode, a request access time, a response time and a request return code by analyzing the transaction message, and storing the transaction serial number, the interface service code set, the service subcode, the request access time, the response time and the request return code in a persistence layer;
the request message is analyzed to provide a data format or perform parameter conversion so as to meet the requirement of the user-defined request parameters in the multi-application system docking;
the monitoring information is presented in real time by counting transaction requests, response information and business condition information in unit time;
the monitoring information is converted into alarm information through configuration of alarm rules, and the alarm information is displayed at the front end or is released outwards; the blacklist configuration is supported and transactions within the blacklist will be intercepted directly.
9. The enterprise service bus-based interface monitoring system of claim 6, wherein the transaction message forwarding module comprises: determining a service processing cluster through the interface service set codes and the sub-service codes, and if the interface service set codes and the sub-service codes in the request message are not in the configuration list, directly returning the request to the client; if the interface service set code and the sub-service code in the request message are in the configuration list, the request is forwarded to the corresponding back-end service processing.
10. The interface monitoring system based on the enterprise service bus according to claim 6, wherein the interface call application initiated by the client arrives at the interface traffic monitoring module through the enterprise service bus, the request message is converted into the format required by the application server according to different message formats and request body parameters through request message analysis, illegal requests are blocked at the same time, and then legal requests are forwarded to the transaction message forwarding module, and request information is stored;
the transaction message forwarding module forwards the request information to a back-end application server for processing according to the service set codes and the sub-service codes in the request message, and the back-end application server records the response code to the persistence layer according to the transaction serial number after finishing processing;
the interface traffic monitoring module analyzes interface request and response information, counts and displays the request success rate and failure rate of the same interface, and triggers an alarm if the request failure rate exceeds a set threshold.
CN202211455006.9A 2022-11-21 2022-11-21 Method and system for interface monitoring based on enterprise service bus Pending CN116055355A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202211455006.9A CN116055355A (en) 2022-11-21 2022-11-21 Method and system for interface monitoring based on enterprise service bus

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202211455006.9A CN116055355A (en) 2022-11-21 2022-11-21 Method and system for interface monitoring based on enterprise service bus

Publications (1)

Publication Number Publication Date
CN116055355A true CN116055355A (en) 2023-05-02

Family

ID=86124955

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202211455006.9A Pending CN116055355A (en) 2022-11-21 2022-11-21 Method and system for interface monitoring based on enterprise service bus

Country Status (1)

Country Link
CN (1) CN116055355A (en)

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20110125821A1 (en) * 2009-11-24 2011-05-26 International Business Machines Corporation Service Oriented Architecture Enterprise Service Bus With Universal Ports
CN113676509A (en) * 2021-07-06 2021-11-19 北京思特奇信息技术股份有限公司 Method and system for active detection of HTTP interface health status
CN115086311A (en) * 2022-04-28 2022-09-20 上海浦东发展银行股份有限公司 Management system of enterprise cross-system service based on cloud service bus

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20110125821A1 (en) * 2009-11-24 2011-05-26 International Business Machines Corporation Service Oriented Architecture Enterprise Service Bus With Universal Ports
CN113676509A (en) * 2021-07-06 2021-11-19 北京思特奇信息技术股份有限公司 Method and system for active detection of HTTP interface health status
CN115086311A (en) * 2022-04-28 2022-09-20 上海浦东发展银行股份有限公司 Management system of enterprise cross-system service based on cloud service bus

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
赵佳峰;: "基于Mule ESB的企业应用集成与实现", 智能计算机与应用, no. 03, 26 June 2018 (2018-06-26) *

Similar Documents

Publication Publication Date Title
CN111831420B (en) Method for task scheduling, related device and computer program product
US6279124B1 (en) Method and system for testing hardware and/or software applications
KR101683321B1 (en) Monitoring of distributed applications
US20170329659A1 (en) Linux system-based cen/xfs standard architecture and implementation method
CN109714192A (en) Monitoring method and system for monitoring cloud platform
CN113760500B (en) Business processing method, device, server and medium
WO2022016847A1 (en) Automatic test method and device applied to cloud platform
CN114884838B (en) Monitoring method and server of Kubernetes component
US20150236799A1 (en) Method and system for quick testing and detecting mobile devices
CN110555019B (en) Data cleaning method based on service end
CN114490063A (en) Business management method, platform and service delivery system, computer storage medium
CN110262955B (en) Application performance monitoring tool based on pinpoint
CN119883773A (en) BIOS operation and maintenance method, system and storage medium
CN114519477B (en) Big data platform tenant management system, method, storage medium and electronic equipment
CN112445860A (en) Method and device for processing distributed transaction
CN112463338A (en) Accumulation fund service processing method and device, electronic equipment and medium
CN103699485A (en) Application program debugging method and device
CN116055355A (en) Method and system for interface monitoring based on enterprise service bus
US10430582B2 (en) Management apparatus and management method
CN113067722A (en) Data management platform and working method thereof
CN109274533B (en) Web service fault positioning device and method based on rule engine
CN114510352B (en) Method and system for automatically permeating project scheduling tasks
CN112905428A (en) Test method, test device, electronic equipment and storage medium
CN112306862B (en) Front-end automated testing system and method, storage medium, and computing device
CN115756888A (en) Data processing method, processor, device and storage medium

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