CN113037831B - Service gateway message processing method and device - Google Patents
Service gateway message processing method and device Download PDFInfo
- Publication number
- CN113037831B CN113037831B CN202110238619.6A CN202110238619A CN113037831B CN 113037831 B CN113037831 B CN 113037831B CN 202110238619 A CN202110238619 A CN 202110238619A CN 113037831 B CN113037831 B CN 113037831B
- Authority
- CN
- China
- Prior art keywords
- service
- calling
- channel
- information
- control flow
- 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
- 238000003672 processing method Methods 0.000 title claims abstract description 17
- 238000012545 processing Methods 0.000 claims abstract description 52
- 238000000034 method Methods 0.000 claims abstract description 24
- 238000012795 verification Methods 0.000 claims description 16
- 238000013475 authorization Methods 0.000 claims description 9
- 238000004891 communication Methods 0.000 claims description 3
- 230000008878 coupling Effects 0.000 abstract description 4
- 238000010168 coupling process Methods 0.000 abstract description 4
- 238000005859 coupling reaction Methods 0.000 abstract description 4
- 210000001503 joint Anatomy 0.000 abstract description 4
- 238000010586 diagram Methods 0.000 description 9
- 238000004590 computer program Methods 0.000 description 6
- 230000008569 process Effects 0.000 description 6
- 230000005540 biological transmission Effects 0.000 description 2
- 238000005538 encapsulation Methods 0.000 description 2
- 238000005516 engineering process Methods 0.000 description 2
- 230000006870 function Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 238000004458 analytical method Methods 0.000 description 1
- 230000008901 benefit Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 239000000284 extract Substances 0.000 description 1
- 238000003032 molecular docking Methods 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
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/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/02—Banking, e.g. interest calculation or account maintenance
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/66—Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/2866—Architectures; Arrangements
- H04L67/30—Profiles
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
- H04L67/63—Routing a service request depending on the request content or context
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/22—Parsing or analysis of headers
-
- Y—GENERAL 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
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02P—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN THE PRODUCTION OR PROCESSING OF GOODS
- Y02P90/00—Enabling technologies with a potential contribution to greenhouse gas [GHG] emissions mitigation
- Y02P90/02—Total 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)
- Business, Economics & Management (AREA)
- Finance (AREA)
- Accounting & Taxation (AREA)
- Economics (AREA)
- Development Economics (AREA)
- Computer Security & Cryptography (AREA)
- Marketing (AREA)
- Strategic Management (AREA)
- Technology Law (AREA)
- Physics & Mathematics (AREA)
- General Business, Economics & Management (AREA)
- General Physics & Mathematics (AREA)
- Theoretical Computer Science (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
According to the service gateway message processing method and device, the corresponding service number, system number and channel number are obtained by identifying the coding format in the service gateway message and analyzing the service gateway message; inquiring control flows corresponding to the service numbers, the system numbers and the channel numbers from a control flow database; respectively controlling and processing three dimensions of channels, systems and services according to a control flow; and after the control flow is normally finished, the corresponding service is called by using the Dubbo generalization so as to finish the business flow. According to the method and the system, the judgment conditions in the calling logic are configured in the database, hard coding conditions are reduced, code reusability is improved, abstract objects are used for replacing specific objects by using Dubbo generalized calling, dependence of a gateway on input parameter object classes is eliminated, and coupling is reduced, so that the requirement of butt joint of a banking system and various external platform servers is met.
Description
Technical Field
The present invention relates to the field of banking and insurance services, and in particular, to a method and apparatus for processing a service gateway message
Background
In a banking system, according to the existing inter-platform server deployment technical scheme, as shown in the architecture shown in fig. 1, each service which is in butt joint with each external platform server is subjected to service processing by a single dubbo service, as shown in fig. 1, each external platform server sends a message meeting a certain format specification to a gateway, the gateway analyzes the message, calls a server cluster to register to a service on a corresponding zookeeper server according to the content of the message, and then decides whether to wait for the service to finish according to the service, particularly synchronous or asynchronous, and returns a result to the external platform server. The server cluster is a provider of business layer service, completes respective business data processing and returns results outwards; the Zookeeper server cluster is responsible for coordinating the services distributed on each server; the gateway is responsible for receiving the message from the external platform server, authenticating the identity information of the sender, analyzing the message and invoking the corresponding service on the corresponding zookeeper server according to the message information.
With more and more external platform servers interfacing with the bank insurance service, there are multiplexing parts and unique parts between interfaces of different external platform servers, and interfaces of each external platform server in the existing gateway architecture are managed independently, so that customized transaction interfaces needing to be maintained are more and more, and therefore, the existing gateway architecture cannot meet the requirements of interfacing a bank system with various external platform servers.
Disclosure of Invention
The application provides a service gateway message processing method and device, which are used for meeting the requirement of butting a banking system with various external platform servers.
In order to achieve the above object, the present application provides the following technical solutions:
a service gateway message processing method includes:
acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number;
identifying the coding format in the service gateway message and analyzing the service gateway message to obtain a corresponding service number, a corresponding system number and a corresponding channel number;
inquiring a control flow corresponding to the service number, the system number and the channel number from a control flow database, wherein the control flow at least comprises one of concurrency number control, verification signature, message decryption and authorization verification, and the control flow database comprises: a service information table, a system information table and a channel information table;
respectively controlling and processing three dimensions of channels, systems and services according to the control flow;
and after the control flow is normally ended, calling the corresponding service by using the Dubbo generalization to finish the business flow.
Preferably, the service information table, the system information table and the channel information table respectively use a service number, a system number and a channel number as primary keys, and the channel number is an external key of the system information table.
Preferably, whether each control flow is enabled, the order of invocation, and the control value are adjusted by modifying the value of each configuration item.
Preferably, if the invoked service is a single service, the service corresponding to the Dubbo generalized invocation is used, specifically:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
Preferably, if the invoked service is an orchestration service, the service corresponding to the Dubbo generalization call is used, specifically:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
A service gateway message processing apparatus, comprising:
the first processing unit is used for acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number;
the second processing unit is used for identifying the coding format in the service gateway message and analyzing the service gateway message to obtain a corresponding service number, a corresponding system number and a corresponding channel number;
the third processing unit is configured to query a control flow corresponding to the service number, the system number and the channel number from a control flow database, where the control flow database includes: a service information table, a system information table and a channel information table;
the fourth processing unit is used for respectively controlling and processing three dimensions of the channel, the system and the service according to the control flow;
and the fifth processing unit is used for calling the corresponding service by using the Dubbo generalization after the control flow is normally ended so as to finish the business flow.
Preferably, if the invoked service is a single service, the fifth processing unit is specifically configured to:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
Preferably, if the invoked service is an orchestration service, the fifth processing unit is specifically configured to:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
A storage medium comprising a stored program, wherein the program, when run, controls a device in which the storage medium resides to perform a service gateway message processing method as described above.
An electronic device comprising at least one processor, and at least one memory, bus connected to the processor; the processor and the memory complete communication with each other through the bus; the processor is configured to call the program instructions in the memory to execute the service gateway message processing method as described above.
According to the service gateway message processing method and device, the corresponding service number, system number and channel number are obtained by identifying the coding format in the service gateway message and analyzing the service gateway message; inquiring control flows corresponding to the service numbers, the system numbers and the channel numbers from a control flow database; respectively controlling and processing three dimensions of channels, systems and services according to a control flow; and after the control flow is normally finished, the corresponding service is called by using the Dubbo generalization so as to finish the business flow. According to the method and the system, the judgment conditions in the calling logic are configured in the database, hard coding conditions are reduced, code reusability is improved, abstract objects are used for replacing specific objects by using Dubbo generalized calling, dependence of a gateway on input parameter object classes is eliminated, and coupling is reduced, so that the requirement of butt joint of a banking system and various external platform servers is met.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings that are required in the embodiments or the description of the prior art will be briefly described below, it being obvious that the drawings in the following description are only some embodiments of the present application, and that other drawings may be obtained according to these drawings without inventive effort for a person skilled in the art.
FIG. 1 is a schematic diagram of an external platform server deployment architecture in the prior art;
fig. 2 is a schematic diagram of an external platform server deployment architecture according to an embodiment of the present application;
fig. 3 is a flow chart of a service gateway message processing method provided in an embodiment of the present application;
fig. 4 is a schematic diagram of a service gateway message processing flow provided in an embodiment of the present application;
FIG. 5 is a schematic view of orchestration service invocation provided in an embodiment of the present application;
fig. 6 is a schematic structural diagram of a service gateway message processing apparatus according to an embodiment of the present application;
fig. 7 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
The existing inter-platform server deployment technical scheme is as the architecture given in fig. 1, and when an external platform server sends a call request, the processing flow of a service gateway message is as follows: firstly, judging a butted external platform server according to information such as service codes in the message; then, according to the format of the message agreed with the external platform server, calling the external platform server of the service interface to realize subclasses, and carrying out processing such as decryption, signature verification, object analysis and the like on the message through the external platform server; and finally, calling the corresponding service to complete the business process by using the Dubbo non-generalization call.
The applicant finds that the existing service gateway message processing flow has the following problems:
1) Employing non-generalized calls
The input parameters are encapsulation classes defined by each service interface in the bank insurance service scene, and are mainly used for encapsulating service data, the encapsulation classes are various, and new interfaces can be generated along with the access of a new external platform server, so that the gateway part has high coupling with other parts and is difficult to maintain.
2) Configuration management of services using unused databases
The existing gateway does not depend on a database, and the information of the fixed external platform server for judging the received message is directly written in the code or the configuration file, and the logic of the judging parts becomes more and more complex along with the access of the external platform server, so that the code is difficult to manage and maintain.
In summary, the existing gateway architecture cannot meet the requirement of the banking system for interfacing with various external platform servers.
For this reason, the present application provides a method and apparatus for processing a service gateway message, which are applied to an external platform server deployment architecture as shown in fig. 2, where the architecture includes: the channel is a direct source channel of the message with the gateway, can be an external platform server which is in butt joint, and can also be a corresponding branch for transmitting service information; the system is a third party system from which the message is sourced; the service provides the gateway with the service called by each system to fulfill the requirement of the business interface. In the application context, it is constrained that one channel can interface with multiple systems, but one system can only access the gateway through one channel.
The following description of the embodiments of the present application will be made clearly and fully with reference to the accompanying drawings, in which it is evident that the embodiments described are only some, but not all, of the embodiments of the present application. All other embodiments, which can be made by one of ordinary skill in the art without undue burden from the present disclosure, are within the scope of the present disclosure.
Referring to fig. 3, a flow chart of a service gateway message processing method provided in an embodiment of the present application is shown. As shown in fig. 3, the method for processing a service gateway message provided in the embodiment of the present application specifically includes the following steps:
s31: and acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number.
S32: identifying the coding format in the service gateway message and analyzing the service gateway message to obtain the corresponding service number, system number and channel number.
S33: and inquiring control flows respectively corresponding to the service numbers, the system numbers and the channel numbers from a control flow database.
The control flow at least comprises one of concurrency control, verification signature, message decryption and authorization verification, and the control flow database comprises: a service information table, a system information table, and a channel information table.
It should be noted that the relationship between channels and systems is one-to-many; the relation between the system and the service is many-to-many, and in the channel information table, the system information table and the service information table, the corresponding channel number, the system number and the service number are the main keys respectively; and the channel number is an external key of the system information table, so that the one-to-many constraint effect between the channel and the system is achieved. The relation between the system and the service is realized by a service authorization table, the main key of the table is (system number and service number), and the service can be called by the system through the authorization relation and authorization code between the system and the service.
S34: and respectively controlling and processing the three dimensions of the channel, the system and the service according to the control flow.
And respectively controlling and processing three dimensions of the channel, the system and the service according to the control flow determined in the step S33, wherein the control flow comprises concurrency control, signature verification, message decryption, authorization verification and the like as shown in fig. 4. Whether each control flow is enabled, the calling sequence, the control value (such as concurrency quantity, signature verification public key, decryption private key and the like) can be adjusted by modifying the value of each configuration item, and the control value is not needed or is not configured.
S35: and after the control flow is normally ended, calling the corresponding service by using the Dubbo generalization to finish the business flow.
In the embodiment of the application, the service can only call a single service, and a plurality of services can be organized together to schedule the call. The following description is made for a single service and an orchestration service, respectively:
in practical application, if the called service is a single service, the service corresponding to the Dubbo generalized call is used, specifically:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
In practical application, the name of each input and output corresponding to the service and the class name for instantiation by the application are recorded in the service input and output table of the association table of the service information table, and the consumer extracts the json (which is essentially a map) of each input and output from the service gateway message through fastjson (an open source component for implementing the inter-conversion among json, character strings and objects) according to the name in the input and output table, and meanwhile, the class names for instantiation of the objects are transmitted to the service provider as call parameters. After receiving json and class names, the service provider converts json into objects through fastjson to call services, so that generalization call is realized.
It should be noted that, the advantage of the generalized call is that the gateway does not need to define the type of the input/output object, and only needs to add the corresponding class name in the input/output information of the service, so that the code of the gateway is not changed when a new service is added.
In practical application, if the called service is an orchestration service, the service corresponding to the Dubbo generalization call is used, specifically:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
In practical application, if the service code in the message is the arrangement service, the service code in the message is an abstract service, as shown in fig. 5, the configuration information of the arrangement main service records the service codes of a plurality of arrangement sub-services participating in arrangement and the calling sequence thereof, and then the arrangement sub-services are sequentially called according to the information, and finally the whole arrangement service is completed. It should be noted that, the orchestration sub-service in the embodiments of the present application may be provided by different external platform servers and registered on the zookeeper server cluster.
It should be noted that, when a service is called, some judgment needs to be made to determine whether the call is legal, for example: authorization code verification, IP verification, MAC address verification, signature verification and the like; still other processes for service gateway messages need to be completed before the background service is invoked, such as decryption of service gateway messages, and judgment conditions or key values needed by these processes need to be preconfigured in a database.
According to the service gateway message processing method, the corresponding service number, system number and channel number are obtained by identifying the coding format in the service gateway message and analyzing the service gateway message; inquiring control flows corresponding to the service numbers, the system numbers and the channel numbers from a control flow database; respectively controlling and processing three dimensions of channels, systems and services according to a control flow; and after the control flow is normally finished, the corresponding service is called by using the Dubbo generalization so as to finish the business flow. According to the embodiment of the application, the judging conditions in the calling logic are configured in the database, the hard coding condition is reduced, the code reusability is improved, the abstract object is used for replacing a specific object by using the Dubbo generalized calling, the dependence of the gateway on the input parameter object class is canceled, and the coupling is reduced, so that the requirement of butting of a banking system with various external platform servers is met.
Referring to fig. 6, based on the method for processing a service gateway message disclosed in the foregoing embodiment, this embodiment correspondingly discloses a service gateway message processing apparatus, which specifically includes:
a first processing unit 61, configured to obtain a service gateway packet sent by an external platform server, where the service gateway packet includes a service number, a system number, and a channel number;
a second processing unit 62, configured to identify a coding format in the service gateway packet and parse the service gateway packet to obtain a corresponding service number, a system number and a channel number;
a third processing unit 63, configured to query a control flow database for control flows corresponding to the service number, the system number, and the channel number, where the control flow database includes: a service information table, a system information table and a channel information table;
a fourth processing unit 64, configured to control three dimensions of a channel, a system, and a service according to the control flow;
and the fifth processing unit 65 is configured to call the corresponding service by using the Dubbo generalization after the control flow is normally ended, so as to complete the business flow.
Optionally, if the invoked service is a single service, the fifth processing unit 65 is specifically configured to:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
Optionally, if the invoked service is an orchestration service, the fifth processing unit 65 is specifically configured to:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
The service gateway message processing device comprises a processor and a memory, wherein the first processing unit, the second processing unit, the third processing unit, the fourth processing unit, the fifth processing unit and the like are all stored in the memory as program units, and the processor executes the program units stored in the memory to realize corresponding functions.
The processor includes a kernel, and the kernel fetches the corresponding program unit from the memory. The kernel can be provided with one or more than one, and the requirement of the bank system for docking with various external platform servers is met by adjusting kernel parameters.
The embodiment of the application provides a storage medium, on which a program is stored, which when executed by a processor, implements the service gateway message processing method.
The embodiment of the application provides a processor, which is used for running a program, wherein the service gateway message processing method is executed when the program runs.
An embodiment of the present application provides an electronic device, as shown in fig. 7, where the electronic device 70 includes at least one processor 701, and at least one memory 702 and a bus 703 connected to the processor; wherein, the processor 701 and the memory 702 complete communication with each other through the bus 703; the processor 701 is configured to call the program instructions in the memory 702 to execute the service gateway message processing method described above.
The electronic device herein may be a server, a PC, a PAD, a mobile phone, etc.
The present application also provides a computer program product adapted to perform, when executed on a data processing device, a program initialized with the method steps of:
acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number;
identifying the coding format in the service gateway message and analyzing the service gateway message to obtain a corresponding service number, a corresponding system number and a corresponding channel number;
inquiring a control flow corresponding to the service number, the system number and the channel number from a control flow database, wherein the control flow at least comprises one of concurrency number control, verification signature, message decryption and authorization verification, and the control flow database comprises: a service information table, a system information table and a channel information table;
respectively controlling and processing three dimensions of channels, systems and services according to the control flow;
and after the control flow is normally ended, calling the corresponding service by using the Dubbo generalization to finish the business flow.
Optionally, the service information table, the system information table and the channel information table respectively use a service number, a system number and a channel number as primary keys, and the channel number is an external key of the system information table.
Optionally, the values of the configuration items are modified to adjust whether the control flows are enabled, the calling order, and the control values.
Optionally, if the invoked service is a single service, the service corresponding to the Dubbo generalized invocation is used, specifically:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
Optionally, if the invoked service is an orchestration service, the Dubbo generalizing is used to invoke the corresponding service, specifically:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to embodiments of the application. It will be understood that each flow and/or block of the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
In one typical configuration, the device includes one or more processors (CPUs), memory, and a bus. The device may also include input/output interfaces, network interfaces, and the like.
The memory may include volatile memory, random Access Memory (RAM), and/or nonvolatile memory, such as Read Only Memory (ROM) or flash memory (flash RAM), among other forms in computer readable media, the memory including at least one memory chip. Memory is an example of a computer-readable medium.
Computer readable media, including both non-transitory and non-transitory, removable and non-removable media, may implement information storage by any method or technology. The information may be computer readable instructions, data structures, modules of a program, or other data. Examples of storage media for a computer include, but are not limited to, phase change memory (PRAM), static Random Access Memory (SRAM), dynamic Random Access Memory (DRAM), other types of Random Access Memory (RAM), read Only Memory (ROM), electrically Erasable Programmable Read Only Memory (EEPROM), flash memory or other memory technology, compact disc read only memory (CD-ROM), digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic tape magnetic disk storage or other magnetic storage devices, or any other non-transmission medium, which can be used to store information that can be accessed by a computing device. Computer-readable media, as defined herein, does not include transitory computer-readable media (transmission media), such as modulated data signals and carrier waves.
It should also be noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising one … …" does not exclude the presence of other like elements in a process, method, article or apparatus that comprises an element.
It will be appreciated by those skilled in the art that embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The foregoing is merely exemplary of the present application and is not intended to limit the present application. Various modifications and changes may be made to the present application by those skilled in the art. Any modifications, equivalent substitutions, improvements, etc. which are within the spirit and principles of the present application are intended to be included within the scope of the claims of the present application.
Claims (10)
1. The service gateway message processing method is characterized by comprising the following steps:
acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number;
identifying the coding format in the service gateway message and analyzing the service gateway message to obtain a corresponding service number, a corresponding system number and a corresponding channel number;
inquiring a control flow corresponding to the service number, the system number and the channel number from a control flow database, wherein the control flow at least comprises one of concurrency number control, verification signature, message decryption and authorization verification, and the control flow database comprises: a service information table, a system information table and a channel information table;
the method comprises the steps that three dimensions of a channel, a system and a service are respectively controlled and processed according to the control flow, the relation between the channel and the system is one-to-many, the relation between the system and the service is one-to-many, wherein the channel is any one of a direct source channel from which a gateway receives a message, a butted external platform server and a corresponding branch for transmitting service information, the system is a third party system from which the message is sourced, and the service is provided for the system to call;
and after the control flow is normally ended, calling the corresponding service by using the Dubbo generalization to finish the business flow.
2. The method of claim 1, wherein the service information table, the system information table, and the channel information table have a service number, a system number, and a channel number as primary keys, respectively, and the channel number is a foreign key of the system information table.
3. The method of claim 1, wherein the respective control flow is enabled, the order of invocation, and the control value are adjusted by modifying the value of the respective configuration item.
4. The method according to claim 1, wherein if the invoked service is a single service, the corresponding service is invoked using Dubbo generalization, in particular:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
5. The method according to claim 1, wherein if the invoked service is an orchestration service, the corresponding service is invoked using Dubbo generalization, in particular:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
6. A service gateway message processing apparatus, comprising:
the first processing unit is used for acquiring a service gateway message sent by an external platform server, wherein the service gateway message comprises a service number, a system number and a channel number;
the second processing unit is used for identifying the coding format in the service gateway message and analyzing the service gateway message to obtain a corresponding service number, a corresponding system number and a corresponding channel number;
the third processing unit is configured to query a control flow corresponding to the service number, the system number and the channel number from a control flow database, where the control flow database includes: a service information table, a system information table and a channel information table;
a fourth processing unit, configured to control three dimensions of a channel, a system, and a service according to the control flow, where a relationship between the channel and the system is one-to-many, and a relationship between the system and the service is many-to-many, where the channel is any one of a direct source channel from which a gateway receives a message, a docked external platform server, and a corresponding branch for transmitting service information, and the system is a third party system from which the message is derived, and the service is a service provided by the gateway to the system for invoking;
and the fifth processing unit is used for calling the corresponding service by using the Dubbo generalization after the control flow is normally ended so as to finish the business flow.
7. The apparatus of claim 6, wherein if the invoked service is a single service, the fifth processing unit is specifically configured to:
inquiring service information corresponding to the service number from a service configuration table, and determining service calling information corresponding to the service information;
and converting the service input parameters in the service gateway message from character strings into generalized objects according to the service calling information so as to realize the calling of the service.
8. The apparatus of claim 7, wherein if the invoked service is an orchestration service, the fifth processing unit is configured to:
inquiring arrangement service information corresponding to the service number from a service configuration table, wherein the configuration information of the arrangement service information comprises service codes of at least two arrangement sub-services and calling sequences of the arrangement sub-services;
and calling the arrangement sub-service in turn according to the service codes of the arrangement sub-service and the calling sequence of the arrangement sub-service so as to realize the calling of the service.
9. A storage medium comprising a stored program, wherein the program, when run, controls a device in which the storage medium is located to perform the service gateway message processing method according to any one of claims 1 to 5.
10. An electronic device comprising at least one processor, and at least one memory, bus coupled to the processor; the processor and the memory complete communication with each other through the bus; the processor is configured to invoke program instructions in the memory to perform the service gateway message processing method according to any of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110238619.6A CN113037831B (en) | 2021-03-04 | 2021-03-04 | Service gateway message processing method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110238619.6A CN113037831B (en) | 2021-03-04 | 2021-03-04 | Service gateway message processing method and device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113037831A CN113037831A (en) | 2021-06-25 |
| CN113037831B true CN113037831B (en) | 2023-04-28 |
Family
ID=76466196
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110238619.6A Active CN113037831B (en) | 2021-03-04 | 2021-03-04 | Service gateway message processing method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113037831B (en) |
Families Citing this family (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113472880B (en) * | 2021-06-30 | 2023-06-27 | 中国银行股份有限公司 | Gateway processing method and system based on database configuration in micro-service architecture |
| CN113596164B (en) * | 2021-07-30 | 2024-10-18 | 工银科技有限公司 | Data access method, device, system, equipment and medium |
| CN113973139B (en) * | 2021-10-20 | 2024-09-20 | 北京沃东天骏信息技术有限公司 | Message processing method and device |
| CN114448920B (en) * | 2022-01-27 | 2023-12-12 | 浙江惠瀜网络科技有限公司 | Encryption communication method, device, terminal and storage medium based on gateway route forwarding |
| CN114584525B (en) * | 2022-01-28 | 2023-12-05 | 深圳市梦网科技发展有限公司 | Message processing method, system, terminal equipment and storage medium |
| CN114448754B (en) * | 2022-02-25 | 2025-07-04 | 支付宝(杭州)信息技术有限公司 | A method, device and equipment for accessing external services |
| CN114553873B (en) * | 2022-02-27 | 2023-06-09 | 重庆长安汽车股份有限公司 | SOA-based vehicle-cloud cooperative control system, method and readable storage medium |
| CN114697131B (en) * | 2022-04-27 | 2024-08-16 | 京东科技控股股份有限公司 | Data calling method and device, storage medium and electronic equipment |
| CN114827311A (en) * | 2022-04-28 | 2022-07-29 | 中国农业银行股份有限公司 | Data processing method and device, electronic equipment and computer storage medium |
| CN119094588A (en) * | 2024-11-07 | 2024-12-06 | 天津金城银行股份有限公司 | Information access system, computer device and readable storage medium |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| EP3121998A1 (en) * | 2015-06-15 | 2017-01-25 | Opencode Systems O.O.D. | Generic multichannel center for network applications and services |
| CN108768727A (en) * | 2018-05-31 | 2018-11-06 | 康键信息技术（深圳）有限公司 | Access method, electronic device and the readable storage medium storing program for executing of third party's service |
| CN111553652A (en) * | 2020-04-23 | 2020-08-18 | 中国银行股份有限公司 | Service processing method and device |
| CN111585880A (en) * | 2020-05-13 | 2020-08-25 | 腾讯科技（深圳）有限公司 | Gateway control method and device in service system and electronic equipment |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10015267B2 (en) * | 2008-09-02 | 2018-07-03 | Constantin Staykoff | Generic multichannel center for network applications and services |
| CN110830280B (en) * | 2018-08-10 | 2023-05-30 | 深圳市鸿合创新信息技术有限责任公司 | Micro-service gateway device and method and electronic equipment |
| CN109151091B (en) * | 2018-09-21 | 2022-01-21 | 福建南威软件有限公司 | API gateway service supporting dubbo protocol calling |
| CN111045648B (en) * | 2019-12-11 | 2024-03-15 | 盈佳云创科技(深圳)有限公司 | Micro-service development device |
-
2021
- 2021-03-04 CN CN202110238619.6A patent/CN113037831B/en active Active
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| EP3121998A1 (en) * | 2015-06-15 | 2017-01-25 | Opencode Systems O.O.D. | Generic multichannel center for network applications and services |
| CN108768727A (en) * | 2018-05-31 | 2018-11-06 | 康键信息技术（深圳）有限公司 | Access method, electronic device and the readable storage medium storing program for executing of third party's service |
| CN111553652A (en) * | 2020-04-23 | 2020-08-18 | 中国银行股份有限公司 | Service processing method and device |
| CN111585880A (en) * | 2020-05-13 | 2020-08-25 | 腾讯科技（深圳）有限公司 | Gateway control method and device in service system and electronic equipment |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113037831A (en) | 2021-06-25 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113037831B (en) | Service gateway message processing method and device | |
| CN111163129B (en) | A resource processing method and device based on a cross-chain network | |
| US7526547B2 (en) | Intelligent network charging edge | |
| US8291077B2 (en) | Provision of services over a common delivery platform such as a mobile telephony network | |
| CN112182096A (en) | Cross-chain data subscription method and device | |
| CN106375458B (en) | Service calling system, method and device | |
| US8904000B2 (en) | Provision of services over a common delivery platform such as a mobile telephony network | |
| CN110798490B (en) | Method and device for accessing third-party system based on data center and data center | |
| CN108053088A (en) | A kind of Subscriber Management System, method and apparatus | |
| US5615351A (en) | Method and system for correlating usage data in a distributed architecture | |
| CN112346717A (en) | Micro service system creating method, device, equipment, medium and micro service system | |
| CN110989984B (en) | Data processing method, device and system | |
| CN108696864B (en) | Virtual number request and transmission method, device and storage medium | |
| CN112738139A (en) | Cross-link access control method and device | |
| CN115964743A (en) | User identification and user information processing method, device, equipment and medium | |
| US10397342B2 (en) | Web service contract selection | |
| CN115756399B (en) | A scenario-based assembleable middle-end business integration method and system | |
| US20060190539A1 (en) | Provision of services over a common delivery platform such as a mobile telephony network | |
| CN116594613A (en) | Application development method and device | |
| CN111241173A (en) | Method and system for data interaction among multiple systems | |
| CN111127039A (en) | Block chain-based computer accessory fidelity method, equipment and storage medium | |
| CN110535957B (en) | Data calling method of service application platform and service application platform system | |
| CN114499759B (en) | Message generation method and device, electronic equipment and storage medium | |
| CN114153488B (en) | Application request processing method, device, system and medium | |
| CN119629258A (en) | User data access method, device, computer equipment and readable 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 | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |