CN113055470B - Service request distribution method and system - Google Patents
Service request distribution method and system Download PDFInfo
- Publication number
- CN113055470B CN113055470B CN202110266612.5A CN202110266612A CN113055470B CN 113055470 B CN113055470 B CN 113055470B CN 202110266612 A CN202110266612 A CN 202110266612A CN 113055470 B CN113055470 B CN 113055470B
- Authority
- CN
- China
- Prior art keywords
- service
- request
- determining
- service request
- architecture
- 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
- 238000000034 method Methods 0.000 title claims abstract description 59
- 238000012545 processing Methods 0.000 claims description 25
- 230000010354 integration Effects 0.000 claims description 20
- 238000004590 computer program Methods 0.000 claims description 9
- 238000012544 monitoring process Methods 0.000 claims description 9
- 230000005856 abnormality Effects 0.000 claims description 5
- 230000036541 health Effects 0.000 claims description 5
- 238000010586 diagram Methods 0.000 description 18
- 230000006870 function Effects 0.000 description 17
- 238000013461 design Methods 0.000 description 16
- 239000003795 chemical substances by application Substances 0.000 description 10
- 230000009466 transformation Effects 0.000 description 10
- 230000008569 process Effects 0.000 description 7
- 230000004048 modification Effects 0.000 description 6
- 238000012986 modification Methods 0.000 description 6
- 238000011161 development Methods 0.000 description 5
- 238000004891 communication Methods 0.000 description 4
- 230000003287 optical effect Effects 0.000 description 4
- 230000007704 transition Effects 0.000 description 4
- 230000008901 benefit Effects 0.000 description 3
- 230000000694 effects Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 230000001965 increasing effect Effects 0.000 description 3
- 238000002955 isolation Methods 0.000 description 3
- 230000003044 adaptive effect Effects 0.000 description 2
- 230000005540 biological transmission Effects 0.000 description 2
- 238000010276 construction Methods 0.000 description 2
- 238000000354 decomposition reaction Methods 0.000 description 2
- 235000019580 granularity Nutrition 0.000 description 2
- 230000007246 mechanism Effects 0.000 description 2
- 230000000750 progressive effect Effects 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 238000011084 recovery Methods 0.000 description 2
- 230000002441 reversible effect Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 230000001960 triggered effect Effects 0.000 description 2
- 230000002159 abnormal effect Effects 0.000 description 1
- 230000009471 action Effects 0.000 description 1
- 230000002411 adverse Effects 0.000 description 1
- 238000013459 approach Methods 0.000 description 1
- 230000015556 catabolic process Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000006731 degradation reaction Methods 0.000 description 1
- 238000012938 design process Methods 0.000 description 1
- 230000002708 enhancing effect Effects 0.000 description 1
- 230000007613 environmental effect Effects 0.000 description 1
- 239000000835 fiber Substances 0.000 description 1
- 230000004927 fusion Effects 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 239000003999 initiator Substances 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000011835 investigation Methods 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000012360 testing method Methods 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/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
-
- 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
-
- 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
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer And Data Communications (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a service request distribution method and a service request distribution system, and relates to the technical field of computers. One embodiment of the method comprises the following steps: receiving a service request sent by a channel side; determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture; and distributing the service request according to the target business service. The embodiment can better support the centralized service architecture and the distributed micro-service architecture at the same time.
Description
Technical Field
The present invention relates to the field of computer technologies, and in particular, to a service request distribution method and system.
Background
Along with the development of technology and business, the application system construction of each enterprise successively goes through several design modes such as a host centralized mode, an open distributed mode and the like. The granularity of the corresponding service implementation also evolves from a jumbo service, a mini service to a micro service. At present, in the process of evolving from a centralized service architecture to a distributed micro service architecture, a design method capable of simultaneously and well supporting the centralized service architecture and the distributed micro service architecture is not available.
Disclosure of Invention
In view of this, the embodiments of the present invention provide a service request distribution method and system, which can better support both a centralized service architecture and a distributed micro-service architecture.
In a first aspect, an embodiment of the present invention provides a service request distribution method, including:
receiving a service request sent by a channel side;
determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture;
and distributing the service request according to the target business service.
Optionally, the determining the target business service according to the service request includes:
determining request parameters of the service request, the request parameters including at least one of: path parameters, identity information, current domain name and service parameters;
and determining the target business service according to the request parameters.
Optionally, the method further comprises:
determining and storing the corresponding relation between the business service and the request parameter;
the determining the target business service according to the request parameter comprises the following steps:
acquiring the corresponding relation;
and determining the target business service according to the request parameters and the corresponding relation.
Optionally, the method further comprises:
determining at least one service component corresponding to a business service, wherein the business service is a service based on a centralized architecture or a service based on a micro-service architecture;
the at least one service component is programmed to generate a sub-model of the business service, the sub-model being for responding to service requests.
Optionally, the method further comprises:
acquiring and saving registration information of the service component, wherein the registration information comprises at least one of the following components: ip address, port number, service proxy, service identification;
the determining at least one service component corresponding to the business service comprises:
and determining the at least one service component corresponding to the business service according to the registration information.
Optionally, the method further comprises:
judging whether the message of the service request needs decryption processing or not;
if yes, the message of the service request is decrypted.
Optionally, the decrypting the message of the service request includes:
acquiring safety processing parameter information from a configuration file of a configuration center;
and decrypting the message of the service request according to the safety processing parameter information.
Optionally, the method further comprises:
judging whether the message of the service request needs encryption processing or not;
if yes, the message of the service request is encrypted.
Optionally, the method further comprises:
determining identity information of the channel side according to the service request;
judging whether the identity information meets a preset authentication requirement or not;
if yes, executing the step of distributing the service request;
if not, a prompt for prohibiting access is sent out.
Optionally, the method further comprises:
judging whether each business service is in a health state;
if not, a prompt of service abnormality is sent out.
Optionally, the method further comprises:
judging whether the monitoring service is in an unavailable state;
if yes, fusing the monitoring service.
Optionally, the method further comprises:
determining the maximum concurrency and the current access number of the target business service;
judging whether the current access number is larger than the maximum concurrency amount or not;
if yes, discarding the service request.
In a second aspect, an embodiment of the present invention provides a service request distribution system, including: channel side, service side, application route, configuration center and service integration agent;
the application route is used for receiving a service request sent by a channel side; determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture or services based on a micro-service architecture; distributing the service request to the service side according to the target business service;
the service integration agent is used for determining at least one service component corresponding to a business service, wherein the business service is a micro-service architecture service; orchestrating the at least one service component to generate a sub-model of the business service;
the configuration center is used for determining and storing the corresponding relation between the business service or the sub-model and the request parameters.
In a third aspect, an embodiment of the present invention provides an electronic device, including:
one or more processors;
storage means for storing one or more programs,
the one or more programs, when executed by the one or more processors, cause the one or more processors to implement the methods of any of the embodiments described above.
In a fourth aspect, embodiments of the present invention provide a computer readable medium having stored thereon a computer program which, when executed by a processor, implements a method as described in any of the above embodiments.
One embodiment of the above invention has the following advantages or benefits: and determining a target business service according to the service request sent by the channel side, wherein the target business service can be a service based on a centralized architecture or a service based on a micro-service architecture, and distributing the service request according to the target business service. Therefore, the method of the embodiment of the invention can better support the centralized service architecture and the distributed micro-service architecture at the same time.
Further effects of the above-described non-conventional alternatives are described below in connection with the embodiments.
Drawings
The drawings are included to provide a better understanding of the invention and are not to be construed as unduly limiting the invention. Wherein:
FIG. 1 is a schematic diagram of the architecture of a service request distribution system of the prior art;
FIG. 2 is a schematic diagram of the architecture of another service request distribution system in the prior art;
fig. 3 is a schematic diagram of an application scenario of a service request distribution method according to an embodiment of the present invention;
FIG. 4 is a schematic diagram of a service request distribution method according to an embodiment of the present invention;
FIG. 5 is a schematic diagram of a flow of another service request distribution method provided by an embodiment of the present invention;
FIG. 6 is a schematic diagram of a service request distribution system according to an embodiment of the present invention;
fig. 7 is a schematic diagram of a computer system suitable for use in implementing an embodiment of the invention.
Detailed Description
Exemplary embodiments of the present invention will now be described with reference to the accompanying drawings, in which various details of the embodiments of the present invention are included to facilitate understanding, and are to be considered merely exemplary. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the invention. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
In the process of evolving from a centralized service architecture to a distributed micro service architecture, the centralized service architecture and the distributed micro service architecture can be supported simultaneously in the following two ways.
The first mode, the channel side service, performs distributed modification based on the current situation. Fig. 1 is a schematic diagram of an architecture of a service request distribution system in the prior art. As shown in fig. 1, in the IT practice of each enterprise, when performing distributed micro-service architecture transformation, application transformation of channel invoker is generally involved to meet the requirements of the distributed micro-service architecture of the server. Under the original centralized architecture, from a transaction initiator, according to the processing flow of a service, a plurality of services of different service systems on a transaction line are sequentially called on the basis of the design of the whole transaction line through service call of a chained mechanism, and when one service call at the tail end is successful and a response is returned according to the reverse order of the transaction line, the whole service flow is completed.
In the whole process of the distributed transformation of the business flow, the distributed service transformation and deployment change of the service side application can influence the channel calling mode. At this time, the design purpose can be achieved by the channel side performing distributed modification based on the current situation synchronization.
In the mode, the channel side and the service side are required to meet the requirements of the distributed micro-service architecture on the basis of meeting the requirements of the current centralized architecture, and the complexity of cooperation of the channel side and the service side is increased, so that the complexity of distributed transformation is increased; in the presence of objective constraints such as manpower, time, cost, etc., adverse effects may be exerted on the usability and stability of the external services affecting the enterprise.
And secondly, the channel side service independently adds a distributed unit. Fig. 2 is a schematic diagram of the architecture of another service request distribution system in the prior art. As shown in fig. 2, in the second mode, on the basis of the distributed transformation of the first mode, according to the distributed transformation progress of the service side, in the period of coexistence of the enterprise centralized architecture and the distributed micro-service architecture, the channel side adds a distributed unit to independently adapt to the distributed service.
In the mode, the channel side service side is independently and newly added with a deployment unit, so that the requirement of coexistence of a centralized architecture and a distributed micro-service architecture can be met, and compared with the mode, the service range of the distributed micro-service architecture and the service range of the original centralized architecture can be isolated, but the problem that the channel side needs to be synchronously matched with the modification of the distributed service side is still existed, and meanwhile, the problems of complexity of service selection and the like generated and stored by users of the existing service flow are solved.
In view of the problems with both of the above approaches. The embodiment of the invention combines some new requirements existing after the implementation of an enterprise SOA (Service-Oriented Architecture Service oriented application architecture) architecture, and needs to consider that part of application components are modified by adopting new technologies such as distributed micro-services and the like, so that the existing SOA architecture is inherited and optimized. On the basis of meeting the requirements of the distributed micro-service architecture, the related requirements are analyzed, the scheme of the distributed platform is selected and designed by combining the actual situation of the existing application components of the enterprise, and conditions and references are provided for the implementation of the follow-up service side under the condition that the constraint of noninductivity of the channel side is met.
Fig. 3 is a schematic diagram of an application scenario of a service request distribution method according to an embodiment of the present invention. As shown in fig. 3, the service request distribution method according to the embodiment of the present invention may be applied to the gateway device 304. Gateway device 304 may be a gateway, router, switch, firewall, or the like.
The channel side 301, 302, 303 sends a service request message to the gateway device 304, and the gateway device 304 determines a target business service according to the service request, where the target business service includes: services based on a centralized architecture and services based on a micro-service architecture; and distributing the service request to the service parties 305, 306, 307 according to the target business service.
The channel parties 301, 302, 303 may be cell phones, notebooks, tablets, laptop portable computers, servers, etc. The servers 305, 306, 307 may be servers deployed based on a centralized architecture or servers deployed based on a distributed micro-service architecture.
It should be noted that, the service request distribution method provided in the embodiment of the present invention is generally executed by the gateway device 304, and accordingly, the service request distribution system is generally disposed in the gateway device 304.
Fig. 4 is a schematic diagram of a flow of a service request distribution method according to an embodiment of the present invention, as shown in fig. 4, where the method includes:
step 401: a service request sent by a channel side is received.
Step 402: determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture.
A centralized architecture-based service is deployed in a centralized architecture mode for a server or cluster of servers that provide the service. A service based on a micro-service architecture employs a schema deployment of a distributed micro-service architecture for a server or cluster of servers providing the service.
In one embodiment of the present invention, step 402 may include:
determining request parameters of the service request, the request parameters including at least one of: path parameters, identity information, current domain name and service parameters;
and determining the target business service according to the request parameters.
The path parameters may include: protocol type, access address, etc. The identity information may include one or a combination of any of a user name, password, fingerprint authentication information, voiceprint authentication information, iris authentication information, etc. of the user to which the client corresponds. The current domain name is the network domain to which the IP address of the current client maps. The traffic parameters may be used to characterize the current environmental parameters on which the service request depends.
The target business service may be determined by: determining and storing the corresponding relation between the business service and the request parameter by using a configuration center; and determining the target business service according to the request parameters and the corresponding relation.
The correspondence between the business service and the request parameter may be set in the configuration center in advance. Specifically, the corresponding relation between the service request address and the service link address may be stored in the configuration center, and when the service request is received, the service corresponding to the request parameter is searched in the corresponding relation, and the service is determined as the target service.
Step 403: and distributing the service request according to the target business service.
And distributing the service request to a service party corresponding to the target business service. The service party can be a service party for providing services based on a centralized architecture or a service party for providing services based on a micro-service architecture. Distributing service requests may be implemented using the components of ngix or spring cloud gateway, etc.
In the embodiment of the invention, the target business service is determined according to the service request sent by the channel side, and the target business service can be the service based on the centralized architecture or the service based on the micro-service architecture and distributes the service request according to the target business service. Therefore, the problem that the centralized service architecture and the distributed micro-service architecture cannot be well supported simultaneously in the prior art can be solved.
In one embodiment of the present invention, further comprising:
judging whether the message of the service request needs decryption processing or not;
if yes, the message of the service request is decrypted.
An encryption flag bit can be set in the header of the request message, and whether the received request message needs decryption processing or not is determined according to the encryption flag bit. If the request message needs to be decrypted, the security parameter information can be obtained from the configuration file of the configuration center, and the decryption algorithm, the secret key and the like corresponding to the security parameter information are utilized to decrypt the message of the service request. The gateway is utilized to realize encryption and decryption of the message, so that the security of the message information in the network transmission process can be improved.
In one embodiment of the present invention, further comprising:
judging whether the message of the service request needs encryption processing or not;
if yes, the message of the service request is encrypted.
Whether the message of the service request needs to be encrypted or not can be judged by various methods, for example, whether the message needs to be encrypted or not can be determined by an encryption flag bit in a message header; or judging whether the sensitive field exists in the message, and if so, encrypting the message. The sensitive fields may include: user name, password, amount, etc.
If the request message needs to be encrypted, the security parameter information can be obtained from the configuration information of the configuration center, and the service request message is encrypted by utilizing an encryption algorithm, a secret key and the like corresponding to the security parameter information. The gateway is utilized to realize encryption and decryption of the message, so that the security of the message information in the network transmission process can be improved.
In one embodiment of the present invention, further comprising:
determining identity information of a channel side according to the service request;
judging whether the identity information meets the preset authentication requirement or not;
if yes, executing the step of distributing the service request;
if not, a prompt for prohibiting access is sent out.
The identity information may include one or a combination of any of a user name, password, fingerprint authentication information, voiceprint authentication information, iris authentication information, etc. of the user to which the client corresponds. According to the authentication credential information related to safety, such as a user name and a password, whether the current user name in the service request is in a legal user list can be judged, if yes, whether the current user name is matched with the password is continuously judged, and if yes, the current identity information can be judged to meet the preset authentication requirement. If the current identity information is judged not to meet the preset authentication requirement, prompt information for prohibiting access can be sent to the channel side.
In one embodiment of the present invention, further comprising:
judging whether each business service is in a health state;
if not, a prompt of service abnormality is sent out.
The state information of the server where each business service is located, such as CPU utilization rate, process number and physical memory occupancy rate, can be obtained first. And judging whether each business service is in a health state according to the state information. If the service in the unhealthy state is found, a prompt of service abnormality is sent out to prompt related technicians to conduct investigation so as to ensure the overall stable operation of the system.
In one embodiment of the present invention, further comprising:
judging whether the monitoring service is in an unavailable state;
if yes, fusing the monitoring service.
When a request is sent to a service side, the fuse is used for proxy, the overtime time and retry times of the fuse can be set, failure logic is triggered or retry is carried out when the request of the fuse proxy is not responded for a period of time, the number of times of request failure for a service instance is counted in a sliding window, the fuse is triggered when the call failure proportion in the window is higher than a threshold value, and the corresponding service instance is identified as unavailable.
In one embodiment of the present invention, further comprising:
determining the maximum concurrency and the current access number of the target business service;
judging whether the current access number is larger than the maximum concurrency;
if so, the service request is discarded.
If the current number of accesses to the business service is greater than the maximum concurrency of the business service, the service party of the business service may not be able to access or even crash due to excessive accesses that need to be handled. Therefore, in order to ensure the normal operation of the business service, under the condition of a large number of current accesses, part of the service requests can be discarded.
Fig. 5 is a schematic diagram of a flow of a service request distribution method according to an embodiment of the present invention, as shown in fig. 5, where the method includes:
step 501: a service request sent by a channel side is received.
Step 502: determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture.
Step 503: and distributing the service request according to the target business service.
Step 504: and determining at least one service component corresponding to the business service, wherein the business service is a service based on a micro-service architecture.
Step 505: at least one service component is orchestrated to generate a sub-model of the business service.
In one embodiment of the present invention, step 505 comprises:
acquiring and saving registration information of the service component, wherein the registration information comprises at least one of the following components: ip address, port number, service proxy, service identification;
and determining at least one service component corresponding to the business service according to the registration information.
By component orchestration, a single application can be split into many loosely coupled and independently deployable smaller components or services. The arrangement of the components can enhance the reusability of codes, reduce the development cost and the testing cost of software, improve the maintainability of the software and reduce the maintenance cost.
Step 506: according to the sub-model, the service request is responded to.
In the embodiment of the invention, the target business service is determined according to the service request sent by the channel side, and the target business service can be the service based on the centralized architecture or the service based on the micro-service architecture. The sub-model can be arranged for the service based on the micro-service architecture in a stream arrangement mode, and the service request is responded according to the sub-model. Therefore, the method of the embodiment of the invention can better and flexibly support the problems of the centralized service architecture and the distributed micro-service architecture.
In addition, the embodiment of the invention also provides a distributed platform integration scheme. The integration scheme combines the existing component application SOA architecture to integrate the distributed platform scheme, and introduces new technical architectures such as enterprise-level gateway, micro-service and the like; supporting the interaction capability of north-south and east-west, and adding the adaptive support to new messages and protocols on the adaptive capability; the newly added service integration proxy function supports the integration capability of the cross-distributed component application service and the existing application component service according to the business elements; the application routing function is newly added, the interactive capability of the north-south direction and the east-west direction is supported, and the request can be forwarded according to the business elements in different scenes, so that the distributed application service is transparent to the channel position; the service addressing of the existing centralized architecture service addressing and the service addressing of the distributed micro-service architecture are supported simultaneously by enhancing the configuration center addressing function so as to support the smooth and effective floor implementation of the distributed micro-service architecture based on the existing SOA architecture. The integration scheme comprises the following steps: application routing, service integration agent and configuration center.
Fig. 6 is a schematic structural diagram of a service request distribution system according to an embodiment of the present invention. As shown in fig. 6, the system includes: channel side, service side, application route, configuration center and service integration agent.
An application route for receiving a service request sent by a channel side; determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture or services based on a micro-service architecture; distributing the service request to a service side according to the target business service;
the service integration agent is used for determining at least one service component corresponding to the service, and the service is a centralized architecture service or a micro-service architecture service; arranging at least one service component to generate a sub-model of a business service;
and the configuration center is used for determining and storing the corresponding relation between the business service or the sub-model and the request parameters.
Optionally, the application routing is specifically for:
determining request parameters of the service request, the request parameters including at least one of: path parameters, identity information, current domain name and service parameters;
and determining the target business service according to the request parameters.
Optionally, the application routing is specifically for:
obtaining a corresponding relation;
and determining the target business service according to the request parameters and the corresponding relation.
Optionally, the service integration agent is specifically configured to:
determining at least one service component corresponding to a business service, wherein the business service is a service based on a centralized architecture or a service based on a micro-service architecture;
at least one service component is orchestrated to generate a sub-model of the business service for responding to the service request.
Optionally, the service integration agent is specifically configured to:
acquiring and saving registration information of the service component, wherein the registration information comprises at least one of the following components: ip address, port number, service proxy, service identification;
and determining at least one service component corresponding to the business service according to the registration information.
Optionally, the application routing is further configured to:
judging whether the message of the service request needs decryption processing or not;
if yes, the message of the service request is decrypted.
Optionally, the application routing is further configured to:
acquiring preset safety parameter information from a configuration file of a configuration center;
and decrypting the message of the service request according to the security parameter information.
Optionally, the application routing is further configured to:
judging whether the message of the service request needs encryption processing or not;
if yes, the message of the service request is encrypted.
Optionally, the application routing is further configured to:
determining identity information of a channel side according to the service request;
judging whether the identity information meets the preset authentication requirement or not;
if yes, executing the step of distributing the service request;
if not, a prompt for prohibiting access is sent out.
Optionally, the application routing is further configured to:
judging whether each business service is in a health state;
if not, a prompt of service abnormality is sent out.
Optionally, the application routing is further configured to: :
judging whether the monitoring service is in an unavailable state;
if yes, fusing processing is carried out on the monitoring service.
Optionally, the application routing is further configured to:
determining the maximum concurrency and the current access number of the target business service;
judging whether the current access number is larger than the maximum concurrency;
if yes, discarding the service request.
Under the distributed micro-service architecture, the application route is used as a unified entry for the channel side to access the service side application, addresses and forwards the message of the channel side to different physical positions of the service side application instance, has self-protection capability and downstream service protection capability, is decoupled from specific service logic, adopts a 'stateless' design, and simultaneously realizes transaction-level current limiting, degradation, fusing, link tracking and the like. The specific roles of application routing are as follows:
(1) The unified access specification is provided, and the channel side is supported to access the back-end component by adopting different agreements, so that the iterative updating of the subsequent channel side application is facilitated.
(2) The distributed service side application is provided with corresponding hosting service capability, a unified forwarding mode is provided according to request message characteristics and the physical deployment of the back-end distributed application instance, and the distributed application selects a specific mode according to configuration.
(3) Increasing flow control capability, and controlling the inlet flow in a loadable range by defining various elements such as a distributed service timeout threshold value and the like; current limiting and fusing are carried out on downstream distributed application; and controlling the flow of the downstream distributed application by expanding various factors such as the maximum transaction concurrency number, the service baseline current limiting rule/fusing rule and the like.
(4) The system provides the online/offline management capability for service integration agent examples and distributed application examples, and supports service processing and calling (giant service, small service and micro service) with different granularities.
(5) The system has the advantages of measuring and tracking capability, opening or closing in a switching mode, collecting logs, monitoring system performance, transaction time consumption, transaction amount and transaction success rate in real time, and generating the dynamic topology of the managed service in real time by defining various tracking conditions (such as time, transaction ID, employee number and the like) and preset buried points.
(6) The method comprises the steps of providing encryption and decryption service, authentication and tamper-proof service for a message, providing point-to-point conversion encryption and decryption service for sensitive data, and enabling a channel side application to specify a specific encryption and decryption algorithm through the message; inherits the original element processing modes such as the security of the centralized back-end service side.
(7) The service logic minimization design is adopted, the 'stateless' is realized in design, the unified access, the transaction forwarding, the message encryption and decryption are focused, the service related logic is not processed, and the peak access flow is handled through the transverse expansion.
(8) The system has multi-place multi-center multi-activity capability, is deployed according to center unitization, and has service isolation between internal modules, so that a centralized point is avoided during physical deployment.
The service integration agent design functions as follows: according to the distributed transformation and deployment conditions of the service side, a service integration proxy cluster is newly added, an enterprise-level service integration proxy mode is realized, a service arrangement and combination function is provided, and processing such as service consistency is completed; fully considering the functions and development of the current service, establishing a sub-model of various service arrangements, completing the realization of the service functions through the assembly of the sub-model, and simplifying the complexity of development design and the like; the consistency of the abnormal scene is not required to be considered when the distributed business logic is processed, and only the normal business logic is required to be considered.
The configuration center is designed for integrating distributed platform schemes by combining the existing SOA architecture, and provides unified service information registration and management functions for the enterprise system. The specific function of the configuration center is as follows:
(1) According to the distributed transformation and deployment conditions of the service side, distributed cluster expansion is performed in multiple centers, and data of the distributed cluster expansion are globally shared in an enterprise, so that the requirements of high availability and disaster recovery are met; any single-room configuration center fault does not affect the external service capacity of the same-city machine room and different-place machine rooms.
(2) The system provides public basic capabilities of enterprise-level service configuration management, service discovery and management, service load balancing, service fault isolation and recovery and the like so as to support the floor implementation of distributed micro-services based on the existing SOA architecture.
(3) And according to the design requirement of the distributed micro-service architecture, improving the unitized positioning capability.
(4) And carrying out diversified capability design, and providing customized and free service management capability implementation based on the existing standard service management capability.
The technical scheme of the embodiment of the invention carries out complete inheritance on the design of the existing SOA architecture of the enterprise. Support design and floor practice of distributed microservice architecture on the basis of maintaining existing enterprise service capabilities. Under the condition that the centralized architecture and the distributed micro-service architecture coexist, smooth transition is realized through incremental progressive switching; in the design process of the distributed micro-service architecture, there is a transition process from a transition state to a target state, in the transition state, the centralized-to-distributed switching can support the switching according to the mechanism or the custom dimension such as the application, and the normal development of the service of a switching object is not influenced. The distributed micro-service transformation is insensitive to the application of the channel side service, and supports the flexibility of the channel side service; reducing the risk of external system dependency.
The method of the embodiment of the invention can meet the design requirements of various customized businesses of enterprises, provide a distributed fusion design with rich functions and robust performance, and realize the decomposition of a large functional module into different micro-services in a functional decomposition mode according to business functions, thereby realizing functional focusing and fault isolation and being applicable to various scenes with complex businesses; and an incremental and progressive switching mode is supported, and manageability is ensured.
The embodiment of the invention provides electronic equipment, which comprises:
one or more processors;
storage means for storing one or more programs,
when the one or more programs are executed by the one or more processors, the one or more processors are caused to implement the methods of any of the embodiments described above.
Referring now to FIG. 7, there is illustrated a schematic diagram of a computer system 700 suitable for use in implementing an embodiment of the present invention. The terminal device shown in fig. 7 is only an example, and should not impose any limitation on the functions and the scope of use of the embodiment of the present invention.
As shown in fig. 7, the computer system 700 includes a Central Processing Unit (CPU) 701, which can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 702 or a program loaded from a storage section 708 into a Random Access Memory (RAM) 703. In the RAM 703, various programs and data required for the operation of the system 700 are also stored. The CPU 701, ROM 702, and RAM 703 are connected to each other through a bus 704. An input/output (I/O) interface 705 is also connected to bus 704.
The following components are connected to the I/O interface 705: an input section 706 including a keyboard, a mouse, and the like; an output portion 707 including a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, a speaker, and the like; a storage section 708 including a hard disk or the like; and a communication section 709 including a network interface card such as a LAN card, a modem, or the like. The communication section 709 performs communication processing via a network such as the internet. The drive 710 is also connected to the I/O interface 705 as needed. A removable medium 711 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is mounted on the drive 710 as necessary, so that a computer program read therefrom is mounted into the storage section 708 as necessary.
In particular, according to embodiments of the present disclosure, the processes described above with reference to flowcharts may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable medium, the computer program comprising program code for performing the method shown in the flow chart. In such an embodiment, the computer program may be downloaded and installed from a network via the communication portion 709, and/or installed from the removable medium 711. The above-described functions defined in the system of the present invention are performed when the computer program is executed by a Central Processing Unit (CPU) 701.
The computer readable medium shown in the present invention may be a computer readable signal medium or a computer readable storage medium, or any combination of the two. The computer readable storage medium can be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples of the computer-readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present invention, however, the computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, with the computer-readable program code embodied therein. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.
The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present invention. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The modules involved in the embodiments of the present invention may be implemented in software or in hardware. The described modules may also be provided in a processor, for example, as: application routing, configuration center and service integration agent. Wherein the names of the modules do not constitute a limitation of the module itself in some cases, e.g. application routing may also be described as "receiving a service request sent by a channel side; determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture or services based on a micro-service architecture; and distributing the service request to a module of the service party according to the target business service.
As another aspect, the present invention also provides a computer-readable medium that may be contained in the apparatus described in the above embodiments; or may be present alone without being fitted into the device. The computer readable medium carries one or more programs which, when executed by a device, cause the device to include:
receiving a service request sent by a channel side;
determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture;
and distributing the service request according to the target business service.
According to the technical scheme of the embodiment of the invention, the target business service is determined based on the service request sent by the channel side, and can be the service based on the centralized architecture or the service based on the micro-service architecture, and the service request is distributed according to the target business service. Therefore, the method of the embodiment of the invention can better support the centralized service architecture and the distributed micro-service architecture at the same time.
The above embodiments do not limit the scope of the present invention. It will be apparent to those skilled in the art that various modifications, combinations, sub-combinations and alternatives can occur depending upon design requirements and other factors. Any modifications, equivalent substitutions and improvements made within the spirit and principles of the present invention should be included in the scope of the present invention.
Claims (13)
1. A service request distribution method, applied to a gateway device, comprising:
receiving a service request sent by a channel side;
determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture and services based on a micro-service architecture;
distributing the service request according to the target business service;
the determining the target business service according to the service request comprises the following steps:
determining request parameters of the service request, the request parameters including: path parameters and identity information; determining the target business service according to the request parameters;
the method further comprises the steps of:
determining at least one service component corresponding to a business service, wherein the business service is a service based on a centralized architecture or a service based on a micro-service architecture; orchestrating the at least one service component to generate a sub-model of the business service, the sub-model for responding to service requests;
judging whether a sensitive field exists in the message of the service request, and if so, acquiring safety processing parameter information from configuration information of a configuration center; encrypting the message of the service request by utilizing the safety processing parameter information; the encryption algorithm for encrypting the message of the service request is specified by the channel side through the message;
before determining the at least one service component corresponding to the business service, the method further comprises: acquiring and storing registration information of the service component; and determining the at least one service component corresponding to the business service according to the registration information.
2. The method as recited in claim 1, further comprising:
determining and storing the corresponding relation between the business service and the request parameter;
the determining the target business service according to the request parameter comprises the following steps:
acquiring the corresponding relation;
and determining the target business service according to the request parameters and the corresponding relation.
3. The method of claim 1, wherein the registration information comprises at least one of: ip address, port number, service proxy, service identification.
4. The method as recited in claim 1, further comprising:
judging whether the message of the service request needs decryption processing or not;
if yes, the message of the service request is decrypted.
5. The method of claim 4, wherein decrypting the message of the service request comprises:
acquiring safety processing parameter information from configuration information of a configuration center;
and decrypting the message of the service request according to the safety processing parameter information.
6. The method as recited in claim 1, further comprising:
judging whether the message of the service request needs encryption processing or not;
if yes, the message of the service request is encrypted.
7. The method as recited in claim 1, further comprising:
determining identity information of the channel side according to the service request;
judging whether the identity information meets a preset authentication requirement or not;
if yes, executing the step of distributing the service request;
if not, a prompt for prohibiting access is sent out.
8. The method as recited in claim 1, further comprising:
judging whether each business service is in a health state;
if not, a prompt of service abnormality is sent out.
9. The method as recited in claim 1, further comprising:
judging whether the monitoring service is in an unavailable state;
if yes, fusing the monitoring service.
10. The method as recited in claim 1, further comprising:
determining the maximum concurrency and the current access number of the target business service;
judging whether the current access number is larger than the maximum concurrency amount or not;
if yes, discarding the service request.
11. A service request distribution system, comprising: channel side, service side, application route, configuration center and service integration agent;
the application route is used for receiving a service request sent by a channel side; determining a target business service according to the service request, wherein the target business service comprises: services based on a centralized architecture or services based on a micro-service architecture; distributing the service request to the service side according to the target business service;
the service integration agent is used for determining at least one service component corresponding to a business service, wherein the business service is a service based on a centralized architecture or a service based on a micro-service architecture; orchestrating the at least one service component to generate a sub-model of the business service;
the configuration center is used for determining and storing the corresponding relation between the business service and the request parameter;
the application route is also for:
determining request parameters of the service request, the request parameters including: path parameters and identity information; determining the target business service according to the request parameters;
judging whether a sensitive field exists in the message of the service request, and if so, acquiring safety processing parameter information from configuration information of a configuration center; encrypting the message of the service request by utilizing the safety processing parameter information; the encryption algorithm for encrypting the message of the service request is specified by the channel side through the message;
the service integration agent is further configured to: acquiring and storing registration information of the service component; and determining the at least one service component corresponding to the business service according to the registration information.
12. An electronic device, comprising:
one or more processors;
storage means for storing one or more programs,
when executed by the one or more processors, causes the one or more processors to implement the method of any of claims 1-10.
13. A computer readable medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to any of claims 1-10.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110266612.5A CN113055470B (en) | 2021-03-10 | 2021-03-10 | Service request distribution method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110266612.5A CN113055470B (en) | 2021-03-10 | 2021-03-10 | Service request distribution method and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113055470A CN113055470A (en) | 2021-06-29 |
| CN113055470B true CN113055470B (en) | 2023-04-28 |
Family
ID=76511699
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110266612.5A Active CN113055470B (en) | 2021-03-10 | 2021-03-10 | Service request distribution method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113055470B (en) |
Families Citing this family (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113900941A (en) * | 2021-09-30 | 2022-01-07 | 深圳市金蝶天燕云计算股份有限公司 | Micro-service processing method, micro-service system, electronic device and storage medium |
| CN113988873B (en) * | 2021-11-25 | 2024-11-22 | 中国银行股份有限公司 | Method and device for analyzing microservice association relationship of distributed system |
| CN114363378B (en) * | 2022-01-14 | 2022-10-11 | 上海交通大学 | A microservice system architecture and management method for industrial heterogeneous network management |
| CN114827228B (en) * | 2022-04-21 | 2024-04-09 | 马上消费金融股份有限公司 | Link processing method and device |
| CN115001956B (en) * | 2022-05-24 | 2023-06-16 | 中国平安财产保险股份有限公司 | Method, device, equipment and storage medium for running server cluster |
| CN119276779A (en) * | 2023-07-07 | 2025-01-07 | 中国电信股份有限公司技术创新中心 | Distributed microservice architecture traffic diversion method, system, device and medium |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107438101A (en) * | 2017-07-26 | 2017-12-05 | 北京中电普华信息技术有限公司 | A kind of service extension method and device of monomer-type application |
Family Cites Families (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110310034B (en) * | 2019-06-28 | 2022-06-07 | 京东科技控股股份有限公司 | Service arrangement and business flow processing method and device applied to SaaS |
| CN110519379A (en) * | 2019-08-29 | 2019-11-29 | 泰康保险集团股份有限公司 | Request processing method and equipment based on micro services |
| CN110928709B (en) * | 2019-11-21 | 2023-08-29 | 中国民航信息网络股份有限公司 | Service calling method and device under micro-service framework and server |
| CN111163166B (en) * | 2019-12-30 | 2022-03-22 | 广州银行股份有限公司 | Enterprise service bus system |
| CN112165507B (en) * | 2020-08-27 | 2023-07-21 | 摩尔元数(福建)科技有限公司 | Method, device, equipment and medium for supporting multi-service architecture by single Web project |
-
2021
- 2021-03-10 CN CN202110266612.5A patent/CN113055470B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107438101A (en) * | 2017-07-26 | 2017-12-05 | 北京中电普华信息技术有限公司 | A kind of service extension method and device of monomer-type application |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113055470A (en) | 2021-06-29 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113055470B (en) | Service request distribution method and system | |
| Bierzynski et al. | Cloud, fog and edge: Cooperation for the future? | |
| CN112187491B (en) | Management method, device and equipment of server | |
| US10135763B2 (en) | System and method for secure and efficient communication within an organization | |
| US12225132B2 (en) | Cybersecurity guard for core network elements | |
| US8825735B2 (en) | Public BOT management in private networks | |
| US20180013729A1 (en) | Secure Application Communication System | |
| CN118802549A (en) | Optimization method and device of authentication and authorization system | |
| JP2023551382A (en) | Inter-service communication and authentication via central network mesh | |
| US12267421B2 (en) | Post quantum secure ingress/egress network communication | |
| CN112929453B (en) | Method and device for sharing session data | |
| US20240364505A1 (en) | Intelligent and secure packet captures for cloud solutions | |
| US20240078132A1 (en) | Systems and methods for multi cloud task orchestration | |
| US11595471B1 (en) | Method and system for electing a master in a cloud based distributed system using a serverless framework | |
| CN116208544B (en) | Message sending method, system, device, equipment and storage medium | |
| CN114297309B (en) | Automated operation and maintenance method and device, computer-readable storage medium, and electronic device | |
| US11637819B2 (en) | Establishing connectivity between user devices | |
| CN111783044B (en) | Method and device for sharing login state | |
| CN115550322B (en) | User registration method and device based on network security protocol, electronic equipment and medium | |
| US12363029B2 (en) | Systems and methods for contextual messaging and information routing in a distributed ledger network | |
| US12010112B2 (en) | Remote secured console over a secured connection for inoperable virtual machine | |
| US20180115553A1 (en) | Transparent asynchronous network flow information exchange | |
| US20250023858A1 (en) | Systems and methods for authentication brokering | |
| CN113419878B (en) | Data operation method and device | |
| US20250078631A1 (en) | Systems and methods for atm session caching |
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 |