CN113285997B - Data processing method, device, medium and product based on heterogeneous system - Google Patents
Data processing method, device, medium and product based on heterogeneous system Download PDFInfo
- Publication number
- CN113285997B CN113285997B CN202110545610.XA CN202110545610A CN113285997B CN 113285997 B CN113285997 B CN 113285997B CN 202110545610 A CN202110545610 A CN 202110545610A CN 113285997 B CN113285997 B CN 113285997B
- Authority
- CN
- China
- Prior art keywords
- application service
- data processing
- service system
- request message
- processing request
- 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.)
- Active
Links
Images
Classifications
-
- 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
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/60—Software deployment
- G06F8/65—Updates
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; 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
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/06—Management of faults, events, alarms or notifications
- H04L41/0654—Management of faults, events, alarms or notifications using network fault recovery
- H04L41/0659—Management of faults, events, alarms or notifications using network fault recovery by isolating or reconfiguring faulty entities
- H04L41/0661—Management of faults, events, alarms or notifications using network fault recovery by isolating or reconfiguring faulty entities by reconfiguring faulty entities
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/74—Address processing for routing
-
- 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
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Theoretical Computer Science (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer Security & Cryptography (AREA)
- Stored Programmes (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The embodiment of the invention provides a data processing method, equipment, medium and product based on a heterogeneous system, wherein the method comprises the following steps: the access layer receives a data processing request message sent by the terminal equipment, wherein the data processing request message comprises a function type; acquiring system configuration information in an access layer; transmitting the data processing request message to a corresponding application service system according to the system configuration information; if the updated application service system section layer is determined to receive the data processing request message, a route configuration table is obtained, and whether the updated application service system processes the data processing request message or not is determined according to the route configuration table and the function type. The flexibility of configuration is effectively provided, errors in data processing performed by the updated application service system are effectively reduced, and the accuracy of data processing is improved.
Description
Technical Field
The embodiment of the invention relates to the technical field of data processing, in particular to a data processing method, device, medium and product based on a heterogeneous system.
Background
With the continuous development of big data technology, various application service systems are also continuously upgraded. In the process of upgrading an application service system, it is necessary to provide the application service to a user continuously and stably.
In the prior art, the terminal device is generally configured with access domain names of different requests to determine whether the terminal device accesses the updated application service system or the original application service system. The configuration mode needs to be configured for each terminal device, the configuration flexibility is low, and when the updated application service system fails, the accessed application service system cannot be switched in time, so that the accuracy of data processing is low.
Disclosure of Invention
The embodiment of the invention provides a data processing method, equipment, medium and product based on a heterogeneous system, which are used for solving the technical problems that the configuration flexibility of an accessed application service system is low in the prior art, and when an updated application service system fails, the accessed application service system cannot be switched in time, so that the accuracy of data processing is low.
In a first aspect, an embodiment of the present invention provides a data processing method based on a heterogeneous system, where the method is applied to an upgraded application service system, and the upgraded application service system includes an access layer and a tangential layer, and the method includes:
Receiving a data processing request message sent by terminal equipment through an access layer, wherein the data processing request message comprises a function type;
acquiring system configuration information in an access layer;
transmitting the data processing request message to a corresponding application service system according to the system configuration information;
if the updated application service system section layer is determined to receive the data processing request message, a route configuration table is obtained, and whether the data processing request message is processed by the updated application service system is determined according to the route configuration table and the function type.
In a second aspect, an embodiment of the present invention provides a heterogeneous system-based data processing device, where the device is located in an upgraded application service system, where the upgraded application service system includes an access layer and a tangential layer, and the device includes:
the receiving module is used for receiving a data processing request message sent by the terminal equipment through the access layer, wherein the data processing request message comprises a function type;
the acquisition module is used for acquiring system configuration information in the access layer;
the sending module is used for sending the data processing request message to a corresponding application service system according to the system configuration information;
And the determining module is used for acquiring a route configuration table if the updated application service system section layer is determined to receive the data processing request message, and determining whether the updated application service system processes the data processing request message according to the route configuration table and the function type.
In a third aspect, an embodiment of the present invention provides a data processing apparatus based on a heterogeneous system, including: at least one processor, memory, and transceiver;
the processor, the memory and the transceiver are interconnected by a circuit;
the memory stores computer-executable instructions; the transceiver is used for receiving and transmitting data with the original application service system, the terminal equipment and the updated database;
the at least one processor executing computer-executable instructions stored in the memory causes the at least one processor to perform the method of any one of the first aspects.
In a fourth aspect, embodiments of the present invention provide a computer-readable storage medium having stored therein computer-executable instructions for performing the method according to any of the first aspects when executed by a processor.
In a fifth aspect, an embodiment of the invention provides a computer program product comprising a computer program which, when executed by a processor, implements the method according to any of the first aspects.
The data processing method, the device, the medium and the product based on the heterogeneous system provided by the embodiment of the invention receive the data processing request message sent by the terminal device through the access layer, wherein the data processing request message comprises the function type; acquiring system configuration information in an access layer; transmitting the data processing request message to a corresponding application service system according to the system configuration information; if the updated application service system section layer is determined to receive the data processing request message, a route configuration table is obtained, and whether the updated application service system processes the data processing request message or not is determined according to the route configuration table and the function type. Since the configuration information of whether the terminal equipment accesses the updated application service system or the original application service system is placed in the updated application service system, each terminal equipment does not need to be configured again. When the configuration information is modified, only the application service system after upgrading is required to be modified, so that the flexibility of configuration is effectively provided. When the updated application service system fails, the corresponding configuration information in the updated application service system can be timely modified, so that errors in data processing performed by the updated application service system are effectively reduced, and the accuracy of data processing is improved.
Drawings
The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the disclosure and together with the description, serve to explain the principles of the disclosure.
FIG. 1 is a network architecture diagram of a heterogeneous system based data processing method in which embodiments of the present invention may be implemented;
FIG. 2 is a flow chart of a data processing method based on a heterogeneous system according to an embodiment of the present invention;
FIG. 3 is a flow chart of a data processing method based on a heterogeneous system according to another embodiment of the present invention;
FIG. 4 is a schematic flow chart of a corresponding heterogeneous system in a heterogeneous system-based data processing method according to another embodiment of the present invention;
FIG. 5 is another flow chart of a corresponding heterogeneous system in a heterogeneous system-based data processing method according to another embodiment of the present invention;
FIG. 6 is a schematic diagram of a heterogeneous system based data processing apparatus according to an embodiment of the present invention;
fig. 7 is a block diagram of a heterogeneous system-based data processing apparatus for implementing a heterogeneous system-based data processing method according to an embodiment of the present invention.
Specific embodiments of the present disclosure have been shown by way of the above drawings and will be described in more detail below. These drawings and the written description are not intended to limit the scope of the disclosed concepts in any way, but rather to illustrate the disclosed concepts to those skilled in the art by reference to specific embodiments.
Detailed Description
Reference will now be made in detail to exemplary embodiments, examples of which are illustrated in the accompanying drawings. When the following description refers to the accompanying drawings, the same numbers in different drawings refer to the same or similar elements, unless otherwise indicated. The implementations described in the following exemplary examples are not representative of all implementations consistent with the present disclosure. Rather, they are merely examples of apparatus and methods consistent with some aspects of the present disclosure as detailed in the accompanying claims.
For a clear understanding of the technical solutions of the present application, the prior art solutions will be described in detail first.
In the prior art, in order to ensure that a continuous and stable application service is provided for a user in an application service system upgrading process, an original application service system and an upgraded application service system are both participated in the application service provided for the user. Specifically, the terminal equipment of the user configures access domain names of different requests to determine whether the terminal equipment accesses the updated application service system or the original application service system. The configuration mode needs to be configured for each terminal device, and the configuration flexibility is low. The updated application service system has an unstable problem, so that the risk of failure exists, and after the updated application service system fails, the accessed application service system cannot be quickly adjusted by modifying the accessed domain name for each terminal device. And then the accessed application service system cannot be switched in time, so that after the application service system fails, the data processing performed by the application service system is wrong, and the accuracy of the data processing is lower.
Therefore, when facing the technical problems in the prior art, the inventor finds that the configuration information of whether the terminal equipment accesses the updated application service system or the original application service system can be placed at the back end after creative research, and can be particularly placed in an access layer of the updated application service system. After the access layer receives the data processing request sent by the front-end terminal equipment, determining whether the data processing request is sent to the original application service system or to the tangent plane layer of the updated application service system according to the system configuration information pre-configured in the access layer. If the updated application service system section layer is determined to receive the data processing request message, a route configuration table storing mapping relations between a plurality of preset function types and the application service system is obtained, and whether the data processing request message is processed by the updated application service system is determined according to the route configuration table and the function type corresponding to the data processing request. Since the configuration information of whether the terminal equipment accesses the updated application service system or the original application service system is placed in the updated application service system, each terminal equipment does not need to be configured again. When the configuration information is modified, only the application service system after upgrading is required to be modified, so that the flexibility of configuration is effectively provided. When the updated application service system fails, the corresponding configuration information in the updated application service system can be timely modified, so that errors in data processing performed by the updated application service system are effectively reduced, and the accuracy of data processing is improved.
The inventor proposes the technical scheme of the embodiment of the invention based on the creative discovery. The network architecture of the data acquisition method based on the distributed system provided by the embodiment of the invention is described below.
Fig. 1 is a network architecture diagram of a heterogeneous system-based data processing method, where the heterogeneous system-based data processing method according to an embodiment of the present invention may be implemented, as shown in fig. 1, where the network architecture of the heterogeneous system-based data processing method provided in the embodiment includes: terminal equipment 1, an updated application service system 2 and an original application service system 3. The updated application service system 2 includes: access layer 21, tangential layer 22. The upgraded application service system 2 is in communication connection with the terminal device 1 through the access layer 21 and is in communication connection with the original application service system 3 through the cut-away layer 22. The upgraded application service system 2 may access the upgraded database 23. The legacy application service system 3 may access the legacy database 31.
The data processing method based on the heterogeneous system provided by the embodiment of the invention can be applied to application scenes of various industries with original application service systems and updated application service systems for providing application services for users.
The following describes the technical scheme of the present invention and how the technical scheme of the present application solves the above technical problems in detail with specific embodiments. The following embodiments may be combined with each other, and the same or similar concepts or processes may not be described in detail in some embodiments. Embodiments of the present invention will be described below with reference to the accompanying drawings.
Example 1
Fig. 2 is a flow chart of a heterogeneous system-based data processing method according to an embodiment of the present invention, and as shown in fig. 2, an execution body of the heterogeneous system-based data processing method according to the embodiment is a heterogeneous system-based data processing device, where the heterogeneous system-based data processing device is located in an upgraded application service system, and the upgraded application service system includes an access layer and a tangential layer. The heterogeneous system-based data processing method provided in the embodiment includes the following steps:
step 101, receiving a data processing request message sent by a terminal device through an access layer, wherein the data processing request message comprises a function type.
In this embodiment, the original application service system may be an application service system built based on a mainframe. The upgraded application service system may be an application service system built by an operating system such as Windows, linux and Unix. The upgraded application service system comprises an access layer and a tangential layer.
The access layer is a proxy layer for receiving the data processing request, and the data processing request can be processed and forwarded by adopting technologies such as F5, nginx and the like.
In this embodiment, when the terminal device has a data processing requirement, the data processing request packet may be triggered by the corresponding application service client or the web page. When the user triggers the data processing request message, the access layer of the updated application service system receives the data processing request message by default.
Wherein the data processing request message comprises a function type. As in the transaction processing request message, the function types may be represented by transaction codes, each representing a different function type.
Step 102, system configuration information in an access layer is obtained.
In this embodiment, system configuration information is pre-stored in the access layer, where the system configuration information is identification information of the upgraded application service system or identification information of the original application service system. If the default system configuration information is the identification information of the updated application service system.
The identification information of the updated application service system may be an access domain name of the updated application service system, or other information uniquely representing the updated application service system. The representation information of the original application service system is the access domain name of the original application service system or other information uniquely representing the original application service system.
And step 103, sending the data processing request message to the corresponding application service system according to the system configuration information.
In this embodiment, if the system configuration information is the identification information of the upgraded application service system, the access domain name and the address of the tangent plane layer of the upgraded application service system are obtained, and the data processing request message is sent to the tangent plane layer of the upgraded application service system. If the system configuration information is determined to be the original application service system identification information, the access domain name of the original application service system is acquired, and the data processing request message is sent to the original application service system.
The message format of the data processing request message is a message format meeting the requirements of the updated application service system. Such as in json format. If the system configuration information is determined to be the original application service system identification information, before the data processing request message is sent to the original application service system, the conversion of the message format of the data processing request message is needed. Optionally, the message format meeting the requirement of the original application service system is a streaming message format, then the json format data processing request message is converted into the streaming message format, and then the data processing request message is sent to the original application service system.
Step 104, if it is determined that the upgraded application service system section layer receives the data processing request message, the routing configuration table is obtained, and whether the upgraded application service system processes the data processing request message or not is determined according to the routing configuration table and the function type.
In this embodiment, after the access layer sends the data processing request packet to the corresponding application service system according to the system configuration information, it is determined whether the upgraded application service system cut-surface layer receives the data processing request packet. If yes, the route configuration table is obtained. The mapping relation between a plurality of preset function types and the application service system is stored in the routing configuration table, so that whether the application service system with the function type corresponding to the data processing request message is an upgraded application service system or an original application service system is determined according to the routing configuration table. And if the application service system is determined to be the updated application service system, determining that the updated application service system processes the data processing request message. Otherwise, if the original application service system is determined, the original application service system is determined to process the data processing request message.
According to the heterogeneous system-based data processing method provided by the embodiment, a data processing request message sent by a terminal device is received through an access layer, wherein the data processing request message comprises a function type; acquiring system configuration information in an access layer; transmitting the data processing request message to a corresponding application service system according to the system configuration information; if the updated application service system section layer is determined to receive the data processing request message, a route configuration table is obtained, and whether the updated application service system processes the data processing request message or not is determined according to the route configuration table and the function type. Since the configuration information of whether the terminal equipment accesses the updated application service system or the original application service system is placed in the updated application service system, each terminal equipment does not need to be configured again. When the configuration information is modified, only the application service system after upgrading is required to be modified, so that the flexibility of configuration is effectively provided. When the updated application service system fails, the corresponding configuration information in the updated application service system can be timely modified, so that errors in data processing performed by the updated application service system are effectively reduced, and the accuracy of data processing is improved.
Example two
Fig. 3 is a flow chart of a data processing method based on a heterogeneous system according to another embodiment of the present invention, and as shown in fig. 3, the data processing method based on a heterogeneous system according to the present invention further refines steps 102 and 103 and further includes other steps based on the data processing method based on a heterogeneous system according to the first embodiment of the present invention, and the data processing method based on a heterogeneous system according to the present invention includes the following steps.
Step 201, receiving, by an access layer, a data processing request message sent by a terminal device, where the data processing request message includes a function type.
In this embodiment, the message format of the data processing request message received by the access layer is json format.
In this embodiment, the implementation manner of step 201 is similar to that of step 101 in the first embodiment of the present invention, and will not be described in detail here.
Optionally, in this embodiment, as shown in fig. 4, the default system configuration information is identification information of the upgraded application service system.
And 203, sending the data processing request message to a corresponding application service system according to the system configuration information.
Optionally, in this embodiment, step 203 includes the following steps:
step 2031, if it is determined that the system configuration information is the updated application service system identification information, sending the data processing request packet to the slice layer of the updated application service system.
In this embodiment, as shown in fig. 4, if the system configuration information is the identification information of the upgraded application service system, the access domain name and the address of the section layer of the upgraded application service system are obtained, and the data processing request message is sent to the section layer of the upgraded application service system.
The section layer of the updated application service system can comprise a plurality of clusters, each cluster can comprise a plurality of servers, so after the section layer receives the data processing request message, if the updated application service system determines to process the data processing request message according to the configuration table and the function type corresponding to the data processing request message, the data processing request message is distributed to the servers in a certain cluster, and one server in the cluster processes the data processing request message correspondingly.
Step 2032, if it is determined that the system configuration information is the original application service system identification information, sending the data processing request packet to the original application service system.
In this embodiment, if it is determined that the system configuration information is the original application service system identification information, the data processing request packet is first subjected to a first format conversion, where the first format conversion is a format conversion that meets the packet requirements in the original application service system. If the format meeting the message requirement in the original application service system is a streaming message, converting the data processing request message from json format to streaming message format. Then, as shown in fig. 5, the access domain name of the original application service system is obtained, and the data processing request message in the streaming message format is sent to the original application service system. The original application service system analyzes the data processing request message, determines the data processing type as the writing data type or the reading data type, and further performs corresponding data processing by accessing the original database.
Step 204, if it is determined that the upgraded application service system section layer receives the data processing request message, the routing configuration table is obtained.
The routing configuration table stores mapping relations between a plurality of preset function types and the application service system. For example, for each preset function type, there is a corresponding configuration state. If the value of the configuration state is 1, the mapping relation between the preset function type and the updated application service system is determined, and if the value of the configuration state is 0, the mapping relation between the preset function type and the original application service system is determined.
Optionally, in this embodiment, step 205 includes the steps of:
step 2051, judging whether the application service system having the mapping relation with the function type is the updated application service system according to the routing configuration table.
Step 2052, if it is determined that the updated application service system is an updated application service system, determining that the updated application service system processes the data processing request message.
Step 2053, if the original application service system is determined, determining that the original application service system processes the data processing request message.
In this embodiment, a function type corresponding to a data processing request message is queried in a routing configuration table, after the function type is queried in the routing configuration table, a value of a corresponding configuration state is determined, if the value of the configuration state is 1, it is determined that an application service system having a mapping relationship with the function type is an updated application service system, and the updated application service system processes the data processing request message. Otherwise, if the value of the configuration state is 0, determining that the application service system with the mapping relation with the function type is the original application service system, and determining that the original application service system processes the data processing request message.
Step 206, analyzing the data processing request message; accessing the updated database according to the analysis result to perform reading operation or writing operation of corresponding data; generating a data processing response message, and sending the data processing response message to the terminal equipment through the access layer.
In this embodiment, the data processing request packet is parsed to obtain a parsing result, where the parsing result includes a data processing type of the data processing request packet. The data processing type is a write data type or a read data type. As shown in fig. 4, if the type of data is written, the corresponding data is written into the updated database. And if the data type is the read data type, reading the corresponding data from the updated database. After the data processing is executed, a data response message is generated, the format of the data response message can be json format, and then the data response message is sent to the terminal equipment through the access layer.
In this embodiment, if it is determined that the original application service system processes the data processing request packet, the data processing request packet is first subjected to the first format conversion in the slice layer. Such as converting json format data processing request message into stream format data processing request message. The data processing request message in the streaming format meets the message requirements in the original application service system.
Step 208, the data processing request message after format conversion is sent to the original application service system, so that the original application service system analyzes the data processing request message after format conversion, and accesses the original database according to the analysis result to perform the reading operation or the writing operation of the corresponding data.
In this embodiment, the original application service system analyzes the data processing request packet to obtain an analysis result, where the analysis result includes a data processing type of the data processing request packet. As shown in fig. 5, if the type of data is written, the corresponding data is written into the original database. If the data type is the read data type, the corresponding data is read from the original database. After the data processing is performed, a data response message is generated, and the format of the data response message can be a streaming format.
Step 209, receiving a data processing response message sent by the original application service system.
Step 210, performing a second format conversion on the data processing response message, where the second format conversion is a format conversion that meets the requirements of the message in the upgraded application service system.
Step 211. And sending the data processing response message after format conversion to the terminal equipment through the access layer.
In this embodiment, the second format conversion is performed on the data processing response message in the slice layer. Such as converting a streaming format data processing response message into a json format data processing response message. The json format data processing response message meets the message requirement in the updated application service system, and then the data processing response message is sent to the terminal equipment through the access layer, so that the terminal equipment can identify the data processing response message.
According to the heterogeneous system-based data processing method provided by the embodiment, after the original application service system is determined to process the data processing request message, the data processing request message is subjected to first format conversion in a section layer; the first format conversion is the format conversion meeting the message requirement in the original application service system; the data processing request message after format conversion is sent to an original application service system, so that the original application service system analyzes the data processing request message after format conversion, and accesses an original database according to the analysis result to perform reading operation or writing operation of corresponding data; receiving a data processing response message sent by an original application service system; performing second format conversion on the data processing response message, wherein the second format conversion is performed to meet the message requirement in the updated application service system; and sending the data processing response message after format conversion to the terminal equipment through the access layer. When the updated application service system interacts data with the original application service system, the data format is converted, so that the smooth interaction can be ensured.
As an optional implementation manner, in this embodiment, on the basis of the heterogeneous system-based data processing method provided in the first embodiment or the second embodiment, the method further includes the following steps:
step 301, receiving, at a tangent plane layer, update information of a routing configuration table sent by a monitoring system, where the update information includes: the updated function type and the corresponding updated identification information of the application service system.
The updated information of the routing configuration table is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to a certain function type in the updated application service system is larger than a corresponding threshold value.
As shown in fig. 4, in this embodiment, the monitoring system monitors the data processing process of the upgraded application service system, and monitors the error rate and response time of the data processing corresponding to each function type. And comparing the error rate of data processing corresponding to each function type with a preset error rate threshold. And comparing the response time of the data processing corresponding to each function with a preset response time threshold. And if the monitoring system determines that the error rate of data processing corresponding to a certain function type is greater than a preset error rate threshold value or the response time corresponding to the certain function type is greater than a preset response time threshold value, sending updated information of the routing configuration table to the section layer of the upgraded application service system.
Wherein, the update information includes: the updated function type and the corresponding updated identification information of the application service system. The updated identification information of the application service system is the identification information of the original application service system.
And 302, correspondingly updating the routing configuration table according to the updating information of the routing configuration table.
Specifically, in this embodiment, the updated application service system updates the application service system corresponding to the function type in the routing configuration table. Specifically, the original configuration state value with the mapping relation with the function type is updated from 1 to 0, that is, the application service system with the mapping relation with the function type is updated from the updated application service system to the original application service system. When the updated application service system fails to process the data processing request message corresponding to the function type, the corresponding routing information can be updated in time, so that the original application service system processes the data processing request message of the function type again after the data processing request message of the function type is received, and the accuracy of the data processing of the function type is ensured.
As an optional implementation manner, in this embodiment, on the basis of the heterogeneous system-based data processing method provided in the first embodiment or the second embodiment, the method further includes the following steps:
Step 401, receiving, at the access layer, update information of system configuration information sent by the monitoring system, where the update information includes identification information of the updated application service system.
The system configuration information updating information is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to more than half of function types in the updated application service system is greater than a corresponding threshold value.
The updated identification information of the application service system is the identification information of the original application service system.
As shown in fig. 4, in this embodiment, the monitoring system continuously monitors the data processing process of the upgraded application service system, and monitors the error rate and response time of the data processing corresponding to each function type. And if the error rate of the data processing corresponding to more than half of the function types in the upgraded application service system is monitored to be greater than a preset error rate threshold, or the response time of the data processing corresponding to more than half of the function types in the upgraded application service system is monitored to be greater than a preset response time threshold, sending the updating information of the system configuration information to an access layer of the upgraded application service system.
Step 402, updating the system configuration information according to the update information of the system configuration information.
Specifically, in this embodiment, the updated application service system updates the system configuration information. And updating the system configuration information into the identification information of the original application service system. When the updated application service system fails to process data processing request messages corresponding to more than half of the function types, the system configuration information can be updated in time, so that the data processing request messages are directly processed by the original application service system after being received again, and the accuracy of data processing is ensured.
If the failure of the updated application service system is removed, the system configuration information in the access layer is updated to the identification information of the updated application service system.
Example III
Fig. 6 is a schematic structural diagram of a heterogeneous system-based data processing device according to an embodiment of the present invention, as shown in fig. 6, where the heterogeneous system-based data processing device according to the embodiment is located in an upgraded application service system. The upgraded application service system comprises an access layer and a tangential layer. The heterogeneous system-based data processing apparatus 50 provided in the present embodiment includes: the device comprises a receiving module 51, an acquiring module 52, a transmitting module 53 and a determining module 54.
The receiving module 51 is configured to receive, through an access layer, a data processing request packet sent by a terminal device, where the data processing request packet includes a function type. An obtaining module 52, configured to obtain system configuration information in the access stratum. And the sending module 53 is configured to send the data processing request message to the corresponding application service system according to the system configuration information. And the determining module 54 is configured to obtain the routing configuration table if it is determined that the upgraded application service system section layer receives the data processing request message, and determine whether to process the data processing request message by the upgraded application service system according to the routing configuration table and the function type.
Optionally, the routing configuration table stores mapping relations between a plurality of preset function types and the application service system.
Accordingly, the determining module 54 is specifically configured to, when determining, according to the routing configuration table, whether the application service system having the mapping relationship with the function type is an upgraded application service system:
judging whether the application service system with the mapping relation with the function type is an updated application service system or not according to the routing configuration table; if the application service system is determined to be the updated application service system, the updated application service system is determined to process the data processing request message; if the data processing request message is determined to be the original application service system, the original application service system is determined to process the data processing request message.
Optionally, the heterogeneous system-based data processing apparatus provided in this embodiment further includes: and a format conversion module.
The format conversion module is also used for carrying out first format conversion on the data processing request message at the section layer; the first format conversion is the format conversion meeting the message requirement in the original application service system. The sending module 53 is further configured to send the format-converted data processing request packet to an original application service system, so that the original application service system analyzes the format-converted data processing request packet, and accesses an original database according to the analysis result, so as to perform a read operation or a write operation of corresponding data. The receiving module 51 is further configured to receive a data processing response message sent by the original application service system. The format conversion module is further used for sending the data processing response message after format conversion to the terminal equipment through the access layer.
Optionally, the heterogeneous system-based data processing apparatus provided in this embodiment further includes: the system comprises an analysis module, an access module and a generation module.
The analysis module is used for analyzing the data processing request message. And the access module is used for accessing the updated database according to the analysis result so as to perform reading operation or writing operation of corresponding data. The generating module is used for generating a data processing response message and sending the data processing response message to the terminal equipment through the access layer.
Optionally, the sending module 53 is specifically configured to, when sending the data processing request packet to the corresponding application service system according to the system configuration information: if the system configuration information is determined to be the updated application service system identification information, a data processing request message is sent to a tangent plane layer of the updated application service system; if the system configuration information is determined to be the original application service system identification information, the data processing request message is sent to the original application service system.
Optionally, the heterogeneous system-based data processing apparatus provided in this embodiment further includes: and updating the module.
The sending module 53 is further configured to receive, at the tangent plane layer, update information of the routing configuration table sent by the monitoring system, where the update information includes: the updated function type and the corresponding updated identification information of the application service system. And the updating module is used for correspondingly updating the routing configuration table according to the updating information of the routing configuration table. The updated information of the routing configuration table is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to a certain function type in the updated application service system is larger than a corresponding threshold value.
Optionally, the sending module 53 is further configured to receive, at the access layer, update information of system configuration information sent by the monitoring system, where the update information includes identification information of the updated application service system. And the updating module is also used for updating the system configuration information according to the updating information of the system configuration information. The system configuration information updating information is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to more than half of function types in the updated application service system is greater than a corresponding threshold value.
The heterogeneous system-based data processing device provided in this embodiment may execute the technical solutions of the method embodiments shown in fig. 2 and fig. 3, and its implementation principle and technical effects are similar to those of the method embodiments shown in fig. 2 and fig. 3, and are not described in detail herein.
Example IV
Fig. 7 is a block diagram of a heterogeneous system-based data processing apparatus for implementing a heterogeneous system-based data processing method according to an embodiment of the present invention, and as shown in fig. 7, a heterogeneous system-based data processing apparatus 60 according to the present embodiment includes: at least one processor 61, a memory 62 and a transceiver 63.
Wherein the processor 61, the memory 62 and the transceiver 63 are interconnected by a circuit.
In this embodiment, the memory 62 stores computer-executable instructions; and the transceiver 62 is used for transceiving data with the original application service system, the terminal equipment and the updated database.
The at least one processor 61 executes computer-executable instructions stored in the memory 62, such that the at least one processor 61 performs the method of the first or second embodiment described above.
Example five
A fifth embodiment of the present invention provides a computer-readable storage medium, in which computer-executable instructions are stored, where the computer-executable instructions are configured to implement the method provided in the first or second embodiment when executed by a processor.
In an exemplary embodiment, a computer program product is also provided, comprising a computer program for executing the method provided in the above embodiment one or embodiment two by a processor.
Other embodiments of the disclosure will be apparent to those skilled in the art from consideration of the specification and practice of the disclosure disclosed herein. This application is intended to cover any adaptations, uses, or adaptations of the disclosure following, in general, the principles of the disclosure and including such departures from the present disclosure as come within known or customary practice within the art to which the disclosure pertains. It is intended that the specification and examples be considered as exemplary only, with a true scope and spirit of the disclosure being indicated by the following claims.
It is to be understood that the present disclosure is not limited to the precise arrangements and instrumentalities shown in the drawings, and that various modifications and changes may be effected without departing from the scope thereof. The scope of the present disclosure is limited only by the appended claims.
Claims (7)
1. A heterogeneous system-based data processing method, wherein the method is applied to an upgraded application service system, the upgraded application service system comprising an access layer and a tangential layer, the method comprising:
receiving a data processing request message sent by terminal equipment through an access layer, wherein the data processing request message comprises a function type;
acquiring system configuration information in an access layer;
transmitting the data processing request message to a corresponding application service system according to the system configuration information;
if the updated application service system section layer is determined to receive the data processing request message, acquiring a routing configuration table, and determining whether the updated application service system processes the data processing request message according to the routing configuration table and the function type;
the routing configuration table stores mapping relations between a plurality of preset function types and an application service system;
The step of determining whether the data processing request message is processed by the upgraded application service system according to the routing configuration table and the function type comprises the following steps:
judging whether the application service system with the mapping relation with the function type is an updated application service system or not according to the routing configuration table;
if the application service system is determined to be the updated application service system, the updated application service system is determined to process the data processing request message;
if the original application service system is determined, the original application service system is determined to process the data processing request message;
further comprises:
and receiving update information of a route configuration table sent by a monitoring system at a section layer, wherein the update information comprises the following components: the updated function type and the corresponding updated identification information of the application service system;
correspondingly updating the route configuration table according to the update information of the route configuration table;
the updated information of the routing configuration table is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to a certain function type in the updated application service system is larger than a corresponding threshold value;
Further comprises:
receiving update information of system configuration information sent by a monitoring system at an access layer, wherein the update information comprises identification information of an updated application service system;
updating the system configuration information according to the updating information of the system configuration information;
the updating information of the system configuration information is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to more than half of the function types in the updated application service system is greater than a corresponding threshold value.
2. The method of claim 1, wherein the determining, after the processing of the data processing request message by the legacy application service system, further comprises:
performing first format conversion on the data processing request message at the tangential layer; the first format conversion is performed to meet the format conversion of the message in the original application service system;
the method comprises the steps of sending a data processing request message after format conversion to an original application service system, so that the original application service system analyzes the data processing request message after format conversion, and accessing an original database according to an analysis result to perform reading operation or writing operation of corresponding data;
Receiving a data processing response message sent by an original application service system;
performing second format conversion on the data processing response message, wherein the second format conversion is performed to meet the message requirements in the updated application service system;
and sending the data processing response message after format conversion to the terminal equipment through the access layer.
3. The method of claim 1, wherein the determining that the data processing request message is processed by the upgraded application service system further comprises:
analyzing the data processing request message;
accessing the updated database according to the analysis result to perform reading operation or writing operation of corresponding data;
generating a data processing response message, and sending the data processing response message to the terminal equipment through the access layer.
4. The method according to claim 1, wherein the sending the data processing request message to the corresponding application service system according to the system configuration information includes:
if the system configuration information is determined to be the updated application service system identification information, the data processing request message is sent to a tangent plane layer of the updated application service system;
And if the system configuration information is the original application service system identification information, the data processing request message is sent to the original application service system.
5. A heterogeneous system-based data processing device, wherein the device is located in an upgraded application service system, the upgraded application service system including an access layer and a tangential layer, the device comprising:
the receiving module is used for receiving a data processing request message sent by the terminal equipment through the access layer, wherein the data processing request message comprises a function type;
the acquisition module is used for acquiring system configuration information in the access layer;
the sending module is used for sending the data processing request message to a corresponding application service system according to the system configuration information;
the determining module is used for acquiring a route configuration table if the updated application service system section layer is determined to receive the data processing request message, and determining whether the updated application service system processes the data processing request message according to the route configuration table and the function type;
the routing configuration table stores mapping relations between a plurality of preset function types and an application service system;
The determining module is specifically configured to determine, according to the routing configuration table, whether an application service system having a mapping relationship with the function type is an upgraded application service system; if the application service system is determined to be the updated application service system, the updated application service system is determined to process the data processing request message; if the original application service system is determined, the original application service system is determined to process the data processing request message;
the heterogeneous system-based data processing device further comprises an updating module;
the sending module is further configured to receive, at the tangent plane layer, update information of the routing configuration table sent by the monitoring system, where the update information includes: the updated function type and the corresponding updated identification information of the application service system; the updating module is used for correspondingly updating the route configuration table according to the updating information of the route configuration table; the updated information of the routing configuration table is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to a certain function type in the updated application service system is larger than a corresponding threshold value;
the sending module is further used for receiving update information of system configuration information sent by the monitoring system at the access layer, wherein the update information comprises the updated identification information of the application service system; the updating module is used for updating the system configuration information according to the updating information of the system configuration information; the updating information of the system configuration information is generated after the monitoring system monitors that the error rate or response time of data processing corresponding to more than half of the function types in the updated application service system is greater than a corresponding threshold value.
6. A heterogeneous system-based data processing apparatus, comprising: at least one processor, memory, and transceiver;
the processor, the memory and the transceiver are interconnected by a circuit;
the memory stores computer-executable instructions; the transceiver is used for receiving and transmitting data with the original application service system, the terminal equipment and the updated database;
the at least one processor executing computer-executable instructions stored in the memory causes the at least one processor to perform the method of any one of claims 1-4.
7. A computer readable storage medium having stored therein computer executable instructions which when executed by a processor are adapted to carry out the method of any one of claims 1-4.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110545610.XA CN113285997B (en) | 2021-05-19 | 2021-05-19 | Data processing method, device, medium and product based on heterogeneous system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110545610.XA CN113285997B (en) | 2021-05-19 | 2021-05-19 | Data processing method, device, medium and product based on heterogeneous system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113285997A CN113285997A (en) | 2021-08-20 |
| CN113285997B true CN113285997B (en) | 2023-05-12 |
Family
ID=77279812
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110545610.XA Active CN113285997B (en) | 2021-05-19 | 2021-05-19 | Data processing method, device, medium and product based on heterogeneous system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113285997B (en) |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104426947A (en) * | 2013-08-27 | 2015-03-18 | 中兴通讯股份有限公司 | Terminal intelligent updating method and system, terminal and data updating server |
Family Cites Families (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7558843B2 (en) * | 2004-07-12 | 2009-07-07 | Netsuite, Inc. | Phased rollout of version upgrades in web-based business information systems |
| CN101222374B (en) * | 2008-01-30 | 2010-09-22 | 华为技术有限公司 | A system, device and method for realizing service upgrade |
| US9213728B2 (en) * | 2011-12-14 | 2015-12-15 | Sap Se | Change data capturing during an upgrade |
| US9106700B2 (en) * | 2012-09-06 | 2015-08-11 | Amazon Technologies, Inc. | Risk aware domain name service |
| US20140379767A1 (en) * | 2013-06-25 | 2014-12-25 | Tonian Inc. | Out of band methods and system of acquiring access data in a parallel access network file system and methods of using such access data |
| CN106331203B (en) * | 2015-07-01 | 2021-01-01 | 中兴通讯股份有限公司 | User access control method and device, relay equipment and server |
| US9954777B2 (en) * | 2016-01-14 | 2018-04-24 | International Business Machines Corporation | Data processing |
| US10642860B2 (en) * | 2016-06-03 | 2020-05-05 | Electronic Arts Inc. | Live migration of distributed databases |
| CN109672698B (en) * | 2017-10-13 | 2021-02-09 | 华为技术有限公司 | Content distribution method, device and system |
| CN109104368B (en) * | 2018-09-12 | 2021-07-16 | 网宿科技股份有限公司 | A method, device, server and computer-readable storage medium for requesting connection |
| CN111917825A (en) * | 2020-06-23 | 2020-11-10 | 中国建设银行股份有限公司 | Heterogeneous system data interaction method and device |
| CN112055078B (en) * | 2020-09-02 | 2023-10-03 | 数字广东网络建设有限公司 | Data transmission method, device, computer equipment and storage medium |
-
2021
- 2021-05-19 CN CN202110545610.XA patent/CN113285997B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104426947A (en) * | 2013-08-27 | 2015-03-18 | 中兴通讯股份有限公司 | Terminal intelligent updating method and system, terminal and data updating server |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113285997A (en) | 2021-08-20 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110351283B (en) | Data transmission method, device, equipment and storage medium | |
| CN110119292B (en) | System operation parameter query method, matching method, device and node equipment | |
| US20080222617A1 (en) | Server side application integration framework | |
| JP6859340B2 (en) | Equipment, systems and methods for retrieving, processing and updating global information | |
| CN111580884A (en) | Configuration updating method and device, server and electronic equipment | |
| CN112702441B (en) | Container-based access data processing method, device, system and storage medium | |
| US7509422B2 (en) | System and method for locating web services | |
| US7734723B2 (en) | Deferred handling of a message | |
| CN109151025B (en) | Load balancing method and device based on URL, computer storage medium and equipment | |
| CN109104368B (en) | A method, device, server and computer-readable storage medium for requesting connection | |
| CN112363845A (en) | Data synchronization method of system integration middling station and integration middling station system | |
| CN102779071A (en) | Method, device and system for calling software interface | |
| CN114244654A (en) | URL forwarding method, device, equipment and computer storage medium | |
| CN109787789B (en) | Compatibility management method, device and equipment for software upgrading and storage medium | |
| CN110798358A (en) | Distributed service identification method and device, computer readable medium and electronic equipment | |
| CN113285997B (en) | Data processing method, device, medium and product based on heterogeneous system | |
| CN111338717B (en) | Interface calling method, application program upgrading method, server and client | |
| US8549090B2 (en) | Messaging tracking system and method | |
| CN112988385A (en) | Request processing method, device, system, storage medium and electronic equipment | |
| US8645544B2 (en) | Cross product/service management | |
| US7912922B2 (en) | Globally unique instance identification | |
| CN103380593A (en) | Method, apparatus, a device for processing business in system updating process | |
| CN115562714A (en) | Medical data interface service processing method based on micro-service | |
| CN111949472B (en) | A method and device for recording application logs | |
| CN116033015B (en) | Flow segmentation method and device |
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 |